Skip to content

Commit

Permalink
Merge pull request #9309 from amitmurthy/amitm/cman_rework
Browse files Browse the repository at this point in the history
rework of cluster manager. support additional launches via a worker
  • Loading branch information
amitmurthy committed Dec 19, 2014
2 parents 2841dec + e309b8a commit cc0cbfe
Show file tree
Hide file tree
Showing 6 changed files with 633 additions and 407 deletions.
13 changes: 7 additions & 6 deletions base/client.jl
Original file line number Diff line number Diff line change
Expand Up @@ -189,7 +189,7 @@ function init_bind_addr(args::Vector{UTF8String})
btoidx = findfirst(args, "--bind-to")
if btoidx > 0
bind_to = split(args[btoidx+1], ":")
bind_addr = parseip(bind_to[1])
bind_addr = string(parseip(bind_to[1]))
if length(bind_to) > 1
bind_port = parseint(bind_to[2])
else
Expand All @@ -198,11 +198,11 @@ function init_bind_addr(args::Vector{UTF8String})
else
bind_port = 0
try
bind_addr = getipaddr()
bind_addr = string(getipaddr())
catch
# All networking is unavailable, initialize bind_addr to the loopback address
# Will cause an exception to be raised only when used.
bind_addr = ip"127.0.0.1"
bind_addr = "127.0.0.1"
end
end
global LPROC
Expand Down Expand Up @@ -355,11 +355,12 @@ function load_juliarc()
end

function load_machine_file(path::AbstractString)
machines = AbstractString[]
machines = []
for line in split(readall(path),'\n'; keep=false)
s = split(line,'*'; keep=false)
s = map!(strip, split(line,'*'; keep=false))
if length(s) > 1
append!(machines,fill(s[2],int(s[1])))
cnt = isnumber(s[1]) ? int(s[1]) : symbol(s[1])
push!(machines,(s[2], cnt))
else
push!(machines,line)
end
Expand Down
1 change: 1 addition & 0 deletions base/exports.jl
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,7 @@ export
WeakKeyDict,
WeakRef,
Woodbury,
WorkerConfig,
WString,
Zip,

Expand Down
Loading

0 comments on commit cc0cbfe

Please sign in to comment.