From e20cc5aa1e817715303244029a9b2193a24c456d Mon Sep 17 00:00:00 2001 From: Jaylin Date: Mon, 14 Feb 2022 15:36:23 +0800 Subject: [PATCH] * FIX [mqtt/tls_transport] init tmaio in pipe_alloc --- src/mqtt/transport/tls/mqtt_tls.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/mqtt/transport/tls/mqtt_tls.c b/src/mqtt/transport/tls/mqtt_tls.c index 313313c8..94e8a26c 100644 --- a/src/mqtt/transport/tls/mqtt_tls.c +++ b/src/mqtt/transport/tls/mqtt_tls.c @@ -192,7 +192,6 @@ mqtts_tcptran_pipe_init(void *arg, nni_pipe *npipe) p->npipe = npipe; nni_lmq_init(&p->rslmq, 16); - nni_aio_init(&p->tmaio, mqtts_pipe_timer_cb, p); p->busy = false; nni_sleep_aio(p->keepalive, &p->tmaio); return (0); @@ -248,6 +247,7 @@ mqtts_tcptran_pipe_alloc(mqtts_tcptran_pipe **pipep) return (NNG_ENOMEM); } nni_mtx_init(&p->mtx); + nni_aio_init(&p->tmaio, mqtts_pipe_timer_cb, p); if (((rv = nni_aio_alloc(&p->txaio, mqtts_tcptran_pipe_send_cb, p)) != 0) || ((rv = nni_aio_alloc(&p->rxaio, mqtts_tcptran_pipe_recv_cb, p)) !=