diff --git a/src/core/aio.h b/src/core/aio.h index 6315e90c9..667098a6a 100644 --- a/src/core/aio.h +++ b/src/core/aio.h @@ -209,6 +209,7 @@ struct nng_aio { nni_aio_expire_q *a_expire_q; nni_list_node a_expire_node; // Expiration node nni_reap_node a_reap_node; + nni_list_node a_finish_node; // Finished node }; #endif // CORE_AIO_H diff --git a/src/sp/protocol/pubsub0/sub.c b/src/sp/protocol/pubsub0/sub.c index 10f42724d..7c1e408e6 100644 --- a/src/sp/protocol/pubsub0/sub.c +++ b/src/sp/protocol/pubsub0/sub.c @@ -326,7 +326,7 @@ sub0_recv_cb(void *arg) return; } - nni_aio_list_init(&finish); + NNI_LIST_INIT(&finish, nng_aio, a_finish_node); msg = nni_aio_get_msg(&p->aio_recv); nni_aio_set_msg(&p->aio_recv, NULL);