fixup! debug

Author: JamesWrigley

src/process_messages.jl

@@ -66,10 +66,7 @@ function showerror(io::IO, re::RemoteException)
     showerror(io, re.captured)
 end
 
-const thunk_counter = Threads.Atomic{Int}(0)
-
 function run_work_thunk(thunk::Function, print_error::Bool)
-    Threads.atomic_add!(thunk_counter, 1)
     local result
     try
         result = thunk()
@@ -78,7 +75,6 @@ function run_work_thunk(thunk::Function, print_error::Bool)
         result = RemoteException(ce)
         print_error && showerror(stderr, ce)
     end
-    Threads.atomic_add!(thunk_counter, -1)
     return result
 end
 function run_work_thunk(rv::RemoteValue, thunk)
@@ -212,7 +208,7 @@ function message_handler_loop(r_stream::IO, w_stream::IO, incoming::Bool)
             end
             readbytes!(r_stream, boundary, length(MSG_BOUNDARY))
 
-            println("$(now()) (thunk counter: $(thunk_counter[])) got msg: ", typeof(msg))
+            println("$(now()) got msg: ", typeof(msg))
             handle_msg(msg, header, r_stream, w_stream, version)
         end
     catch e

src/remotecall.jl

@@ -108,7 +108,7 @@ function finalize_ref(r::AbstractRemoteRef)
                 unlock(client_refs.lock)
             end
         else
-            finalizer(finalize_ref, r)
+            # finalizer(finalize_ref, r)
             return nothing
         end
     end