From 2c2a0508a000973ad9f6177de704412614d578f1 Mon Sep 17 00:00:00 2001 From: shikokuchuo <53399081+shikokuchuo@users.noreply.github.com> Date: Thu, 14 Nov 2024 10:53:29 +0000 Subject: [PATCH] fix tests --- DESCRIPTION | 2 +- NEWS.md | 2 ++ tests/tests.R | 7 ++++--- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/DESCRIPTION b/DESCRIPTION index cf2b4d4ea..b8ee477de 100644 --- a/DESCRIPTION +++ b/DESCRIPTION @@ -1,7 +1,7 @@ Package: nanonext Type: Package Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library -Version: 1.3.1 +Version: 1.3.1.9000 Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is a socket library implementing 'Scalability Protocols', a reliable, high-performance standard for common communications patterns including diff --git a/NEWS.md b/NEWS.md index e17e3b9fa..7b0178aa5 100644 --- a/NEWS.md +++ b/NEWS.md @@ -1,3 +1,5 @@ +# nanonext 1.3.1.9000 (development) + # nanonext 1.3.1 #### Updates diff --git a/tests/tests.R b/tests/tests.R index b762efde1..5beb26b1b 100644 --- a/tests/tests.R +++ b/tests/tests.R @@ -480,7 +480,7 @@ is_nano(s) && { test_type("integer", send(s, c("message1", "test"), block = 500L)) test_notnull(recv(s, block = FALSE)) test_type("integer", send(s, "message2", block = FALSE)) - test_notnull(recv(s, mode = 9L, block = 100)) + test_notnull(suppressWarnings(recv(s, mode = 9L, block = 100))) test_type("integer", send(s, 2L, block = 500)) test_class("recvAio", sr <- recv_aio(s, mode = "i", timeout = 500L, n = 8192L)) test_notnull(suppressWarnings(call_aio(sr)[["data"]])) @@ -539,7 +539,8 @@ test_zero(send(s, TRUE, block = 500L)) test_true(recv(disp, block = 500L)) test_zero(send(disp, NULL, block = 500L)) test_null(recv(s, block = 500L)) -test_zero(close(s)) +test_zero(reap(s)) +Sys.sleep(0.1) test_class("nanoSocket", s <- socket(protocol = "rep")) test_zero(pipe_notify(s, cv, add = TRUE)) test_zero(dial(s, url = "inproc://disp/1")) @@ -550,7 +551,7 @@ test_true(.mark()) test_zero(send(s, NULL, block = 500L)) test_true(!.mark(FALSE)) test_null(recv(disp, block = 500L)) -test_zero(close(s)) +test_zero(reap(s)) rm(disp) test_equal(nanonext:::.DollarNames.ncurlAio(NULL, "sta"), "status")