Skip to content

Commit 2fce546

Browse files
rohanmcluresimonbyrne
authored andcommitted
cman.jl fixed incorrect get call (#293)
Add testcase to test/test_cman_mpi.jl
1 parent 597fcaf commit 2fce546

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

src/cman.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -282,7 +282,7 @@ function connect(mgr::MPIManager, pid::Int, config::WorkerConfig)
282282
config.connect_at = to_rank
283283
return start_send_event_loop(mgr, to_rank)
284284
else
285-
return start_send_event_loop(mgr, get(config.connect_at))
285+
return start_send_event_loop(mgr, config.connect_at)
286286
end
287287
end
288288

test/test_cman_mpi.jl

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,4 +30,12 @@ s = @distributed (+) for i in 1:10
3030
end
3131
@test s == 385
3232

33+
# Communication between workers
34+
@fetchfrom 2 begin
35+
@fetchfrom workers()[end] begin
36+
# This call should be allowed to occur
37+
@test true
38+
end
39+
end
40+
3341
MPI.stop_main_loop(mgr)

0 commit comments

Comments
 (0)