We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 53cd0d7 commit 0cd901dCopy full SHA for 0cd901d
src/sp/transport/mqttws/nmq_websocket.c
@@ -311,7 +311,6 @@ wstran_pipe_recv_cb(void *arg)
311
goto skip;
312
}
313
p->count++;
314
- log_error("count %d", p->count);
315
// parse fixed header (safe because pkt_len bytes are present)
316
ws_msg_adaptor(baseptr + index, new);
317
nni_msg_set_conn_param(new, p->ws_param);
@@ -321,9 +320,12 @@ wstran_pipe_recv_cb(void *arg)
321
320
if (nni_lmq_put(&p->recvlmq, new) != 0) {
322
log_warn(" WebSocket msg drop due to full lmq");
323
nni_msg_free(new);
+ new = NULL;
324
325
326
- cvector_push_back(msg_vec, new);
+ if (msg_vec != NULL) {
327
+ cvector_push_back(msg_vec, new);
328
+ }
329
index += pkt_len;
330
331
0 commit comments