Fix subtle bug introduced by debdfa5

Author: shikokuchuo

DESCRIPTION

@@ -1,7 +1,7 @@
 Type: Package
 Package: nanonext
 Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
-Version: 1.5.2.9020
+Version: 1.5.2.9021
 Authors@R: c(
     person("Charlie", "Gao", , "[email protected]", role = c("aut", "cre"),
            comment = c(ORCID = "0000-0002-0750-061X")),

src/aio.c

@@ -20,21 +20,6 @@ static SEXP mk_error_aio(const int xc, SEXP env) {
 
 // aio completion callbacks ----------------------------------------------------
 
-static inline void nano_list_free(nano_node *list) {
-
-  while (list != NULL) {
-    nano_node *current = list;
-    list = list->next;
-    nano_aio *saio = (nano_aio *) current->data;
-    nng_aio_free(saio->aio);
-    if (saio->data != NULL)
-      free(saio->data);
-    free(saio);
-    free(current);
-  }
-
-}
-
 void nano_list_do(nano_list_op listop, nano_aio *saio) {
 
   static nano_node *free_list = NULL;
@@ -47,7 +32,7 @@ void nano_list_do(nano_list_op listop, nano_aio *saio) {
     break;
   case FINALIZE:
     nng_mtx_lock(free_mtx);
-    nano_list_free(free_list);
+    nano_list_do(FREE, NULL);
     if (saio->mode == 0x1) {
       nng_mtx_unlock(free_mtx);
       nng_aio_free(saio->aio);
@@ -75,11 +60,23 @@ void nano_list_do(nano_list_op listop, nano_aio *saio) {
   case SHUTDOWN:
     if (free_mtx == NULL) break;
     nng_mtx_lock(free_mtx);
-    nano_list_free(free_list);
+    nano_list_do(FREE, NULL);
     nng_mtx_unlock(free_mtx);
     nng_mtx_free(free_mtx);
     free_mtx = NULL;
     break;
+  case FREE: // must be entered under lock
+    while (free_list != NULL) {
+      nano_node *current = free_list;
+      free_list = free_list->next;
+      nano_aio *saio = (nano_aio *) current->data;
+      nng_aio_free(saio->aio);
+      if (saio->data != NULL)
+        free(saio->data);
+      free(saio);
+      free(current);
+    }
+    break;
   }
 
 }

src/nanonext.h

@@ -235,6 +235,7 @@ typedef enum nano_list_op {
   INIT,
   FINALIZE,
   COMPLETE,
+  FREE,
   SHUTDOWN
 } nano_list_op;