Skip to content

Commit 2be833c

Browse files
committed
fixup! Replace a timeout task with timedwait()
1 parent 2874281 commit 2be833c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/cluster.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -194,7 +194,7 @@ function wait_for_conn(w)
194194
timeout = worker_timeout() - (time() - w.ct_time)
195195
timeout <= 0 && error("peer $(w.id) has not connected to $(myid())")
196196

197-
if timedwait(() -> (@atomic w.state) === WorkerState_connected, timeout) === :timed_out
197+
if timedwait(() -> (@atomic w.state) === W_CONNECTED, timeout) === :timed_out
198198
# Notify any waiters on the state and throw
199199
@lock w.c_state notify(w.c_state)
200200
error("peer $(w.id) didn't connect to $(myid()) within $timeout seconds")

0 commit comments

Comments
 (0)