CRAN release 0.8.2

Author: shikokuchuo

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: nanonext
 Type: Package
 Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
-Version: 0.8.1.9028
+Version: 0.8.2
 Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is 
     a socket library providing high-performance scalability protocols, a
     cross-platform standard for messaging and communications. Serves as a

NEWS.md

@@ -1,4 +1,4 @@
-# nanonext 0.8.1.9028
+# nanonext 0.8.2
 
 #### New Features
 

R/context.R

@@ -24,8 +24,10 @@
 #'
 #' @param socket a Socket.
 #' @param verify [default TRUE] logical value whether to verify there is a
-#'     connection at the socket with the result stored internally (required for
-#'     features of certain functions). Supplying a non-logical value will error.
+#'     connection at the socket with the result stored internally within the
+#'     context (required for features of certain functions). Set to FALSE for
+#'     performance if not using features which explicitly require verification.
+#'     Supplying a non-logical value will error.
 #'
 #' @return A new Context (object of class 'nanoContext' and 'nano').
 #'
@@ -161,8 +163,8 @@ reply <- function(context,
 #' @param data an object (if send_mode = 'raw', a vector).
 #' @param timeout [default NULL] integer value in milliseconds or NULL, which
 #'     applies a socket-specific default, usually the same as no timeout. The
-#'     context must have created with \code{context(verify = TRUE)}, or else
-#'     this value will be ignored.
+#'     context must have been created with \code{context(verify = TRUE)}, or
+#'     else this value will be ignored.
 #'
 #' @return A 'recvAio' (object of class 'recvAio') (invisibly).
 #'

R/ncurl.R

@@ -97,7 +97,7 @@ ncurl <- function(url,
 #'     else an 'errorValue'.
 #'
 #' @examples
-#' s <- ncurl_session("https://httpbin.org/get", response = "date", timeout = 1000L)
+#' s <- ncurl_session("https://httpbin.org/get", response = "date", timeout = 2000L)
 #' s
 #' if (!is_error_value(s)) transact(s)
 #' if (!is_error_value(s)) close(s)

man/context.Rd

@@ -1408,15 +1408,15 @@ SEXP rnng_cv_until(SEXP cvar, SEXP msec) {
     break;
   }
 
-  uint8_t success = 1;
+  uint8_t signalled = 1;
   nng_mtx_lock(mtx);
   while (ncv->condition == 0) {
     if (nng_cv_until(cv, time) == NNG_ETIMEDOUT) {
-      success = 0;
+      signalled = 0;
       break;
     }
   }
-  if (success) ncv->condition--;
+  if (signalled) ncv->condition--;
   nng_mtx_unlock(mtx);
 
   return ncv->flag ? Rf_ScalarLogical(0) : Rf_ScalarLogical(1);

man/ncurl_session.Rd

@@ -467,8 +467,8 @@ SEXP rnng_ctx_close(SEXP context) {
 
   if (R_ExternalPtrTag(context) != nano_ContextSymbol)
     Rf_error("'context' is not a valid Context");
-  nng_ctx *ctxp = (nng_ctx *) R_ExternalPtrAddr(context);
-  const int xc = nng_ctx_close(*ctxp);
+  nano_ctx *nctx = (nano_ctx *) R_ExternalPtrAddr(context);
+  const int xc = nng_ctx_close(nctx->ctx);
 
   if (xc)
     ERROR_RET(xc);

man/request.Rd

@@ -324,10 +324,10 @@ nanotest(is_error_value(ncurl("http", async = TRUE)$data))
 haio <- ncurl("https://i.i", async = TRUE)
 nanotest(is_error_value(call_aio(haio)$raw))
 nanotestp(haio$data)
-sess <- ncurl_session("https://httpbin.org/post", method = "POST", headers = c(`Content-Type` = "text/plain"), data = "test", response = "server", timeout = 1000L)
+sess <- ncurl_session("https://httpbin.org/post", method = "POST", headers = c(`Content-Type` = "text/plain"), data = "test", response = "server", timeout = 2000L)
 nanotestnn(sess)
 nanotest(is_error_value(sess) || length(transact(sess)) == 4L)
-sess <- ncurl_session("https://httpbin.org/post", convert = FALSE, method = "POST", headers = list(`Content-Type` = "text/plain"), response = list("Date", "Server"), timeout = 1000)
+sess <- ncurl_session("https://httpbin.org/post", convert = FALSE, method = "POST", headers = list(`Content-Type` = "text/plain"), response = list("Date", "Server"), timeout = 2000)
 nanotestnn(sess)
 nanotest(is_error_value(sess) || length(transact(sess)) == 4L)
 nanotest(is_error_value(sess) || close(sess) == 0L)