Memleak detected in MQTT over WebSocket module in NanoNNG

[nanomq]

Memleak detected in MQTT over WebSocket module in NanoNNG

[JaylinYu]

Ver nanomq 0.10

==90956==ERROR: LeakSanitizer: detected memory leaks

Direct leak of 14445984 byte(s) in 85988 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7cbe80 in nni_msg_alloc ../nng/src/core/message.c:388
#3 0x55820db0dcad in wstran_pipe_recv_cb ../nng/src/sp/transport/mqttws/nmq_websocket.c:224
#4 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#5 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#6 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#7 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Direct leak of 3360 byte(s) in 20 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7cbe80 in nni_msg_alloc ../nng/src/core/message.c:388
#3 0x55820db0f728 in wstran_pipe_send_start_v4 ../nng/src/sp/transport/mqttws/nmq_websocket.c:453
#4 0x55820db123ce in wstran_pipe_send_start ../nng/src/sp/transport/mqttws/nmq_websocket.c:875
#5 0x55820db12514 in wstran_pipe_send ../nng/src/sp/transport/mqttws/nmq_websocket.c:900
#6 0x55820d7d0519 in nni_pipe_send ../nng/src/core/pipe.c:130
#7 0x55820d801fc2 in nano_ctx_send ../nng/src/sp/protocol/mqtt/nmq_mqtt.c:428
#8 0x55820d7d764d in nni_ctx_send ../nng/src/core/socket.c:1354
#9 0x55820d7b33ce in nng_ctx_send ../nng/src/nng.c:401
#10 0x55820d7aad18 in server_cb ../nanomq/apps/broker.c:484
#11 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#12 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#13 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#14 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Direct leak of 2016 byte(s) in 12 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7cbe80 in nni_msg_alloc ../nng/src/core/message.c:388
#3 0x55820db10d4e in wstran_pipe_send_start_v5 ../nng/src/sp/transport/mqttws/nmq_websocket.c:668
#4 0x55820db12459 in wstran_pipe_send_start ../nng/src/sp/transport/mqttws/nmq_websocket.c:878
#5 0x55820db12514 in wstran_pipe_send ../nng/src/sp/transport/mqttws/nmq_websocket.c:900
#6 0x55820d7d0519 in nni_pipe_send ../nng/src/core/pipe.c:130
#7 0x55820d801fc2 in nano_ctx_send ../nng/src/sp/protocol/mqtt/nmq_mqtt.c:428
#8 0x55820d7d764d in nni_ctx_send ../nng/src/core/socket.c:1354
#9 0x55820d7b33ce in nng_ctx_send ../nng/src/nng.c:401
#10 0x55820d7aad18 in server_cb ../nanomq/apps/broker.c:484
#11 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#12 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#13 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#14 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Direct leak of 504 byte(s) in 3 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7cbe80 in nni_msg_alloc ../nng/src/core/message.c:388
#3 0x55820db0e46c in wstran_pipe_recv_cb ../nng/src/sp/transport/mqttws/nmq_websocket.c:298
#4 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#5 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#6 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#7 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Direct leak of 168 byte(s) in 1 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7cbe80 in nni_msg_alloc ../nng/src/core/message.c:388
#3 0x55820db0f728 in wstran_pipe_send_start_v4 ../nng/src/sp/transport/mqttws/nmq_websocket.c:453
#4 0x55820db123ce in wstran_pipe_send_start ../nng/src/sp/transport/mqttws/nmq_websocket.c:875
#5 0x55820db12514 in wstran_pipe_send ../nng/src/sp/transport/mqttws/nmq_websocket.c:900
#6 0x55820d7d0519 in nni_pipe_send ../nng/src/core/pipe.c:130
#7 0x55820d804974 in nano_pipe_send_cb ../nng/src/sp/protocol/mqtt/nmq_mqtt.c:857
#8 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#9 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#10 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#11 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Indirect leak of 5503232 byte(s) in 85988 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7cac64 in nni_chunk_grow ../nng/src/core/message.c:159
#3 0x55820d7cbed0 in nni_msg_alloc ../nng/src/core/message.c:398
#4 0x55820db0dcad in wstran_pipe_recv_cb ../nng/src/sp/transport/mqttws/nmq_websocket.c:224
#5 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#6 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#7 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#8 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Indirect leak of 1440 byte(s) in 20 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7caa7a in nni_chunk_grow ../nng/src/core/message.c:141
#3 0x55820d7cb33d in nni_chunk_append ../nng/src/core/message.c:245
#4 0x55820d7cc652 in nni_msg_append ../nng/src/core/message.c:525
#5 0x55820db1049f in wstran_pipe_send_start_v4 ../nng/src/sp/transport/mqttws/nmq_websocket.c:574
#6 0x55820db123ce in wstran_pipe_send_start ../nng/src/sp/transport/mqttws/nmq_websocket.c:875
#7 0x55820db12514 in wstran_pipe_send ../nng/src/sp/transport/mqttws/nmq_websocket.c:900
#8 0x55820d7d0519 in nni_pipe_send ../nng/src/core/pipe.c:130
#9 0x55820d801fc2 in nano_ctx_send ../nng/src/sp/protocol/mqtt/nmq_mqtt.c:428
#10 0x55820d7d764d in nni_ctx_send ../nng/src/core/socket.c:1354
#11 0x55820d7b33ce in nng_ctx_send ../nng/src/nng.c:401
#12 0x55820d7aad18 in server_cb ../nanomq/apps/broker.c:484
#13 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#14 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#15 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#16 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Indirect leak of 900 byte(s) in 12 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7caa7a in nni_chunk_grow ../nng/src/core/message.c:141
#3 0x55820d7cb33d in nni_chunk_append ../nng/src/core/message.c:245
#4 0x55820d7cc652 in nni_msg_append ../nng/src/core/message.c:525
#5 0x55820db11e03 in wstran_pipe_send_start_v5 ../nng/src/sp/transport/mqttws/nmq_websocket.c:815
#6 0x55820db12459 in wstran_pipe_send_start ../nng/src/sp/transport/mqttws/nmq_websocket.c:878
#7 0x55820db12514 in wstran_pipe_send ../nng/src/sp/transport/mqttws/nmq_websocket.c:900
#8 0x55820d7d0519 in nni_pipe_send ../nng/src/core/pipe.c:130
#9 0x55820d801fc2 in nano_ctx_send ../nng/src/sp/protocol/mqtt/nmq_mqtt.c:428
#10 0x55820d7d764d in nni_ctx_send ../nng/src/core/socket.c:1354
#11 0x55820d7b33ce in nng_ctx_send ../nng/src/nng.c:401
#12 0x55820d7aad18 in server_cb ../nanomq/apps/broker.c:484
#13 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#14 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#15 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#16 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Indirect leak of 192 byte(s) in 3 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7cac64 in nni_chunk_grow ../nng/src/core/message.c:159
#3 0x55820d7cbed0 in nni_msg_alloc ../nng/src/core/message.c:398
#4 0x55820db0e46c in wstran_pipe_recv_cb ../nng/src/sp/transport/mqttws/nmq_websocket.c:298
#5 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#6 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#7 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#8 0x7f226325f946 in start_thread nptl/pthread_create.c:435

Indirect leak of 72 byte(s) in 1 object(s) allocated from:
#0 0x7f2263582a37 in __interceptor_calloc ../../../../src/libsanitizer/asan/asan_malloc_linux.cpp:154
#1 0x55820d7e1b1b in nni_zalloc ../nng/src/platform/posix/posix_alloc.c:26
#2 0x55820d7caa7a in nni_chunk_grow ../nng/src/core/message.c:141
#3 0x55820d7cb33d in nni_chunk_append ../nng/src/core/message.c:245
#4 0x55820d7cc652 in nni_msg_append ../nng/src/core/message.c:525
#5 0x55820db1049f in wstran_pipe_send_start_v4 ../nng/src/sp/transport/mqttws/nmq_websocket.c:574
#6 0x55820db123ce in wstran_pipe_send_start ../nng/src/sp/transport/mqttws/nmq_websocket.c:875
#7 0x55820db12514 in wstran_pipe_send ../nng/src/sp/transport/mqttws/nmq_websocket.c:900
#8 0x55820d7d0519 in nni_pipe_send ../nng/src/core/pipe.c:130
#9 0x55820d804974 in nano_pipe_send_cb ../nng/src/sp/protocol/mqtt/nmq_mqtt.c:857
#10 0x55820d7dc036 in nni_taskq_thread ../nng/src/core/taskq.c:50
#11 0x55820d7dd318 in nni_thr_wrap ../nng/src/core/thread.c:94
#12 0x55820d7e6220 in nni_plat_thr_main ../nng/src/platform/posix/posix_thread.c:266
#13 0x7f226325f946 in start_thread nptl/pthread_create.c:435

SUMMARY: AddressSanitizer: 19957868 byte(s) leaked in 172048 allocation(s).