teste

Author: decarvalhojunior-fh

src/cluster.jl

@@ -1427,7 +1427,7 @@ end
 
 function init_parallel()
     start_gc_msgs_task(role = :master)   # TO CHECK
-    start_gc_msgs_task(role = :worker)    # TO CHECK
+    start_gc_msgs_task(role = :worker)   # TO CHECK
 
     # start in "head node" mode, if worker, will override later.
     #global PGRP

src/managers.jl

@@ -701,7 +701,7 @@ function connect_to_worker(host::AbstractString, port::Integer)
         bind_addr = getaddrinfo(host)
     end
 
-    @info "connect_to_worker: $host $port"
+    @info "connect_to_worker: $host $port $bind_addr"
 
     iptype = typeof(bind_addr)
     sock = socket_reuse_port(iptype)

src/process_messages.jl

@@ -170,7 +170,7 @@ function message_handler_loop(r_stream::IO, w_stream::IO, incoming::Bool; role=
         while true
             reset_state(serializer)
             header = deserialize_hdr_raw(r_stream)
-            println("header: ", header)
+            #println("header: ", header)
 
             try
                 msg = invokelatest(deserialize_msg, serializer)
@@ -207,7 +207,7 @@ function message_handler_loop(r_stream::IO, w_stream::IO, incoming::Bool; role=
             end
             readbytes!(r_stream, boundary, length(MSG_BOUNDARY))
 
-            println("got msg: ", typeof(msg))
+            #println("got msg: ", typeof(msg))
             handle_msg(msg, header, r_stream, w_stream, version; role = role)
         end
     catch e