debug

Author: IanButterworth

src/remotecall.jl

@@ -667,11 +667,13 @@ All asynchronous remote calls return `Future`s and set the
 value to the return value of the call upon completion.
 """
 function put!(r::Future, v)
+    println("put!($(repr(r)), $(repr(v))) on thread $(Threads.threadid()) on worker $(myid())")
     if r.where == myid()
         rid = remoteref_id(r)
         rv = lookup_ref(rid)
         isready(rv) && error("Future can be set only once")
         @lock r.lock begin
+            println("lock acquired on thread $(Threads.threadid()) on worker $(myid())")
             put!(rv, v) # this notifies the tasks waiting on the channel in fetch
             set_future_cache(r, v) # set the cache before leaving the lock, so that the notified tasks already see it cached
         end
@@ -691,6 +693,7 @@ function set_future_cache(r::Future, v)
 end
 
 function put_future(rid, v, caller)
+    println("put_future on thread $(Threads.threadid()) on worker $(myid())")
     rv = lookup_ref(rid)
     isready(rv) && error("Future can be set only once")
     put!(rv, v)

test/distributed_exec.jl

@@ -219,6 +219,7 @@ for i in 1:max_attempts
         @test remotecall_fetch(k->haskey(Distributed.PGRP.refs, k), wid1, fid) == true
 
         testval = remotecall_fetch(wid2, fstore) do x
+            println("remotecall_fetch on worker $(myid()). wid2 = $wid2")
             try
                 put!(fetch(x), :OK)
                 return 0