Skip to content

Commit

Permalink
* SYNC [broker tls/tcp] sync broker_tcp/tls fix #477
Browse files Browse the repository at this point in the history
Signed-off-by: wayne <yukang.wei@emqx.io>
  • Loading branch information
StargazerWayne authored and JaylinYu committed Dec 13, 2023
1 parent 364e8bc commit 067c734
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/sp/transport/mqtts/broker_tls.c
Original file line number Diff line number Diff line change
Expand Up @@ -484,7 +484,7 @@ tlstran_pipe_qos_send_cb(void *arg)
}

if (p->pro_ver == 5) {
(type == CMD_PUBCOMP || type == PUBACK) ? p->qrecv_quota++
(type == CMD_PUBCOMP || type == CMD_PUBACK) ? p->qrecv_quota++
: p->qrecv_quota;
}
nni_msg_free(msg);
Expand All @@ -494,9 +494,9 @@ tlstran_pipe_qos_send_cb(void *arg)
msg, nni_msg_header(msg), nni_msg_header_len(msg));
iov.iov_len = nni_msg_len(msg);
iov.iov_buf = nni_msg_body(msg);
nni_aio_set_msg(p->qsaio, msg);
nni_aio_set_msg(qsaio, msg);
// send it down...
nni_aio_set_iov(p->qsaio, 1, &iov);
nni_aio_set_iov(qsaio, 1, &iov);
nng_stream_send(p->conn, p->qsaio);
p->busy = true;
nni_mtx_unlock(&p->mtx);
Expand Down

0 comments on commit 067c734

Please sign in to comment.