@@ -152,7 +152,7 @@ function _getenv_include_thread_unsafe()
152
152
return b
153
153
end
154
154
const _env_include_thread_unsafe = _getenv_include_thread_unsafe ()
155
- function include_thread_unsafe ()
155
+ function include_thread_unsafe_tests ()
156
156
if Threads. nthreads () > 1
157
157
if _env_include_thread_unsafe
158
158
return true
@@ -260,8 +260,7 @@ remotecall_fetch(f25847, id_other, f)
260
260
261
261
finalize (f)
262
262
yield () # flush gc msgs
263
- @test false == remotecall_fetch (chk_rrid-> (yield (); haskey (Distributed. PGRP. refs, chk_rrid)), id_other, rrid)
264
-
263
+ @test poll_while (() -> remotecall_fetch (chk_rrid-> (yield (); haskey (Distributed. PGRP. refs, chk_rrid)), id_other, rrid))
265
264
266
265
# Distributed GC tests for RemoteChannels
267
266
function test_remoteref_dgc (id)
@@ -288,12 +287,12 @@ let wid1 = workers()[1],
288
287
fstore = RemoteChannel (wid2)
289
288
290
289
put! (fstore, rr)
291
- if include_thread_unsafe ()
290
+ if include_thread_unsafe_tests ()
292
291
@test remotecall_fetch (k -> haskey (Distributed. PGRP. refs, k), wid1, rrid) == true
293
292
end
294
293
finalize (rr) # finalize locally
295
294
yield () # flush gc msgs
296
- if include_thread_unsafe ()
295
+ if include_thread_unsafe_tests ()
297
296
@test remotecall_fetch (k -> haskey (Distributed. PGRP. refs, k), wid1, rrid) == true
298
297
end
299
298
remotecall_fetch (r -> (finalize (take! (r)); yield (); nothing ), wid2, fstore) # finalize remotely
0 commit comments