Skip to content

Commit 2f3e31a

Browse files
committed
Fixup bug: forgot to break the new if-statement
1 parent b6f0591 commit 2f3e31a

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/workers.jl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,7 @@ function Base.close(w::Worker, from::Symbol=:manual)
121121
end
122122
end
123123
wait(w)
124+
@debug "Worker $(w.pid) has closed successfully."
124125
return
125126
end
126127

@@ -324,12 +325,14 @@ function serve_requests(io)
324325
req = deserialize(io)
325326
@assert req isa Request
326327
if is_shutdown(req)
328+
@debug "Received shutdown request on worker $(getpid())"
327329
resp = Response(nothing, nothing, rand(UInt64), true)
328330
@lock iolock begin
329331
# println("sending response: $(resp)")
330332
serialize(io, resp)
331333
flush(io)
332334
end
335+
break
333336
end
334337
# println("received request: $(req)")
335338
Threads.@spawn begin

0 commit comments

Comments
 (0)