...

Author: decarvalhojunior-fh

src/cluster.jl

@@ -355,7 +355,7 @@ function read_worker_host_port(io::IO)
                 throw(LaunchWorkerError("Unable to read host:port string from worker. Launch command exited with error?"))
             end
 
-            @info "conninfo: $conninfo"
+            #@info "conninfo: $conninfo"
 
             ntries -= 1
             bind_addr, port = parse_connection_info(conninfo)

src/macros.jl

@@ -46,7 +46,7 @@ julia> fetch(f)
 function check_args_2(args...)
     na = length(args)
     if na==1
-        role = :(role = :default)
+        role = Expr(:kw, :role, :(:defaut)) #:(role = :default)
         expr = args[1]
     elseif na==2 
         role = args[1]
@@ -107,7 +107,7 @@ julia> fetch(f)
 function check_args_3a(args...)
     na = length(args)
     if na==2
-        role = :(role = :default)
+        role = Expr(:kw, :role, :(:defaut)) #:(role = :default)
         p = args[1]
         expr = args[2]
     elseif na==3 
@@ -123,7 +123,7 @@ end
 macro spawnat(args...)
    rolearg, p, expr = check_args_3a(args...)
 
-    #@info rolearg, typeof(rolearg)
+   #@info rolearg, typeof(rolearg)
 
    thunk = esc(:(()->($expr)))
    var = esc(Base.sync_varname)
@@ -132,7 +132,7 @@ macro spawnat(args...)
    else
        spawncall = :(spawnat($(esc(p)), $thunk; $(esc(rolearg))))
    end
-    quote
+   quote
         local ref = $spawncall
         if $(Expr(:islocal, var))
             put!($var, ref)
@@ -247,7 +247,7 @@ function check_args_3b(args...)
 
     na = length(args)
     if na==1
-        rolearg = :(role = :default)
+        rolearg = Expr(:kw, :role, :(:defaut)) #:(role = :default)
         reducer = nothing
         loop = args[1]
     elseif na==2
@@ -256,7 +256,7 @@ function check_args_3b(args...)
             reducer = nothing
             loop = args[2]
         else
-            rolearg = :(role = :default)
+            rolearg = Expr(:kw, :role, :(:defaut)) #:(role = :default)
             reducer = args[1]
             loop = args[2]
         end

src/managers.jl

@@ -642,7 +642,8 @@ function connect(manager::ClusterManager, pid::Int, config::WorkerConfig)
             release(sem)
         end
     else
-        (s, bind_addr) = connect_to_worker(#=bind_addr=# pubhost, port)
+#        (s, bind_addr) = connect_to_worker(#=bind_addr=# pubhost, port)
+        (s, bind_addr) = connect_to_worker(bind_addr, port)
     end
 
     config.bind_addr = bind_addr