@@ -294,10 +294,13 @@ test_equal(call_aio(cr)$data, "test")
294
294
test_type(" integer" , cr $ aio )
295
295
test_type(" integer" , send(ctxn , TRUE , mode = 0L , block = FALSE ))
296
296
test_type(" externalptr" , ctxn <- .context(rep ))
297
- test_class(" recvAio" , cs <- request(.context(req $ socket ), data = TRUE , cv = NA , msgid = 12L ))
297
+ test_class(" recvAio" , cs <- request(.context(req $ socket ), data = TRUE , cv = NA ))
298
298
test_notnull(cs $ data )
299
299
test_true(recv(ctxn , block = 500 ))
300
300
test_zero(send(ctxn , TRUE , mode = 1L , block = 500 ))
301
+ test_class(" recvAio" , cs <- request(.context(req $ socket ), data = TRUE , timeout = 5 , msgid = 12L ))
302
+ test_equal(5L , cs [])
303
+ test_identical(c(0L , 12L ), recv(ctxn , mode = 5L , block = 500 ))
301
304
test_zero(reap(ctxn ))
302
305
test_equal(reap(ctxn ), 7L )
303
306
test_zero(pipe_notify(rep , cv , add = TRUE , flag = TRUE ))
@@ -658,7 +661,7 @@ if (!interactive() && Sys.getenv("NOT_CRAN") == "true") {
658
661
659
662
if (Sys.info()[[" sysname" ]] == " Linux" ) {
660
663
rm(list = ls())
661
- gc()
664
+ invisible ( gc() )
662
665
.Call(nanonext ::: rnng_fini_priors )
663
666
Sys.sleep(1L )
664
667
.Call(nanonext ::: rnng_fini )
0 commit comments