* FIX [mqtt/tls_transport] init tmaio in pipe_alloc

emqx · Feb 14, 2022 · e20cc5a · e20cc5a
1 parent d187ba1
commit e20cc5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)) !=