Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
  • Loading branch information
vchuravy committed Sep 14, 2021
1 parent 1dc76ef commit 5f562fd
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions stdlib/Distributed/src/messages.jl
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ function flush_gc_msgs(w::Worker)
end
local add_msgs::Vector{Any}
local del_msgs::Vector{Any}
lock(w.msg_lock) do # TODO: lock_inversion?
lock(w.msg_lock) do
w.gcflag = false
add_msgs = w.add_msgs
w.add_msgs = Any[]
Expand All @@ -140,7 +140,7 @@ function flush_gc_msgs(w::Worker)
remote_do(add_clients, w, msgs)
end
if !isempty(del_msgs)
remote_do(del_clients, w, msgs)
remote_do(del_clients, w, del_msgs)
end
end

Expand Down

0 comments on commit 5f562fd

Please sign in to comment.