update baseline

Author: shikokuchuo

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: nanonext
 Type: Package
 Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
-Version: 1.2.1.9012
+Version: 1.2.1.9013
 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

NEWS.md

@@ -1,4 +1,4 @@
-# nanonext 1.2.1.9012 (development)
+# nanonext 1.2.1.9013 (development)
 
 #### New Features
 

src/aio.c

@@ -209,13 +209,8 @@ SEXP rnng_aio_get_msg(SEXP env) {
   case RECVAIOS:
   case REQAIOS:
   case IOV_RECVAIOS: ;
-    nano_cv *ncv;
-    if (raio->type == REQAIOS) {
-      nano_rsaio *saio = (nano_rsaio *) raio->next;
-      ncv = (nano_cv *) saio->next;
-    } else {
-      ncv = (nano_cv *) raio->next;
-    }
+    nano_cv *ncv = raio->type == REQAIOS ? (nano_cv *) ((nano_rsaio *) raio->next)->next :
+      (nano_cv *) raio->next;
     nng_mtx *mtx = ncv->mtx;
     nng_mtx_lock(mtx);
     res = raio->result;

src/sync.c

@@ -54,8 +54,7 @@ static void request_complete_dropcon(void *arg) {
 static void request_complete_signal(void *arg) {
 
   nano_aio *raio = (nano_aio *) arg;
-  nano_rsaio *saio = (nano_rsaio *) raio->next;
-  nano_cv *ncv = (nano_cv *) saio->next;
+  nano_cv *ncv = (nano_cv *) ((nano_rsaio *) raio->next)->next;
   nng_cv *cv = ncv->cv;
   nng_mtx *mtx = ncv->mtx;
 
@@ -76,7 +75,7 @@ static void request_complete_signal(void *arg) {
 
 static void sendaio_complete(void *arg) {
 
-  nng_aio *aio = (nng_aio *) arg;
+  nng_aio *aio = ((nano_rsaio *) arg)->aio;
   if (nng_aio_result(aio))
     nng_msg_free(nng_aio_get_msg(aio));
 
@@ -452,7 +451,7 @@ SEXP rnng_request(SEXP con, SEXP data, SEXP sendmode, SEXP recvmode, SEXP timeou
     goto exitlevel1;
 
   if ((xc = nng_msg_append(msg, buf.buf, buf.cur)) ||
-      (xc = nng_aio_alloc(&saio->aio, sendaio_complete, &saio->aio))) {
+      (xc = nng_aio_alloc(&saio->aio, sendaio_complete, saio))) {
     nng_msg_free(msg);
     goto exitlevel1;
   }