diff --git a/src/mqtt/protocol/mqtt/mqtt_client.c b/src/mqtt/protocol/mqtt/mqtt_client.c index c5811d79..c808866c 100644 --- a/src/mqtt/protocol/mqtt/mqtt_client.c +++ b/src/mqtt/protocol/mqtt/mqtt_client.c @@ -528,35 +528,35 @@ mqtt_timer_cb(void *arg) } } #endif - // start message resending - msg = nni_id_get_min(&p->sent_unack, &pid); - if (msg != NULL) { - uint16_t ptype; - ptype = nni_mqtt_msg_get_packet_type(msg); - if (ptype == NNG_MQTT_PUBLISH) { - nni_mqtt_msg_set_publish_dup(msg, true); - } - if (!p->busy) { - p->busy = true; - nni_msg_clone(msg); - aio = nni_mqtt_msg_get_aio(msg); - if (aio) { - nni_aio_bump_count(aio, - nni_msg_header_len(msg) + - nni_msg_len(msg)); - nni_aio_set_msg(aio, NULL); - } - nni_aio_set_msg(&p->send_aio, msg); - nni_pipe_send(p->pipe, &p->send_aio); - - nni_mtx_unlock(&s->mtx); - nni_sleep_aio(s->retry, &p->time_aio); - return; - } else { - nni_msg_clone(msg); - nni_lmq_put(&p->send_messages, msg); - } - } + // // start message resending + // msg = nni_id_get_min(&p->sent_unack, &pid); + // if (msg != NULL) { + // uint16_t ptype; + // ptype = nni_mqtt_msg_get_packet_type(msg); + // if (ptype == NNG_MQTT_PUBLISH) { + // nni_mqtt_msg_set_publish_dup(msg, true); + // } + // if (!p->busy) { + // p->busy = true; + // nni_msg_clone(msg); + // aio = nni_mqtt_msg_get_aio(msg); + // if (aio) { + // nni_aio_bump_count(aio, + // nni_msg_header_len(msg) + + // nni_msg_len(msg)); + // nni_aio_set_msg(aio, NULL); + // } + // nni_aio_set_msg(&p->send_aio, msg); + // nni_pipe_send(p->pipe, &p->send_aio); + + // nni_mtx_unlock(&s->mtx); + // nni_sleep_aio(s->retry, &p->time_aio); + // return; + // } else { + // nni_msg_clone(msg); + // nni_lmq_put(&p->send_messages, msg); + // } + // } nni_mtx_unlock(&s->mtx); nni_sleep_aio(s->retry, &p->time_aio); diff --git a/src/mqtt/protocol/mqtt/mqttv5_client.c b/src/mqtt/protocol/mqtt/mqttv5_client.c index 26cf247f..d9977dc1 100644 --- a/src/mqtt/protocol/mqtt/mqttv5_client.c +++ b/src/mqtt/protocol/mqtt/mqttv5_client.c @@ -498,35 +498,35 @@ mqtt_timer_cb(void *arg) nni_mtx_unlock(&s->mtx); return; } - // start message resending - msg = nni_id_get_min(&p->sent_unack, &pid); - if (msg != NULL) { - uint16_t ptype; - ptype = nni_mqtt_msg_get_packet_type(msg); - if (ptype == NNG_MQTT_PUBLISH) { - nni_mqtt_msg_set_publish_dup(msg, true); - } - if (!p->busy) { - p->busy = true; - nni_msg_clone(msg); - aio = nni_mqtt_msg_get_aio(msg); - if (aio) { - nni_aio_bump_count(aio, - nni_msg_header_len(msg) + - nni_msg_len(msg)); - nni_aio_set_msg(aio, NULL); - } - nni_aio_set_msg(&p->send_aio, msg); - nni_pipe_send(p->pipe, &p->send_aio); - - nni_mtx_unlock(&s->mtx); - nni_sleep_aio(s->retry, &p->time_aio); - return; - } else { - nni_msg_clone(msg); - nni_lmq_put(&p->send_messages, msg); - } - } + // // start message resending + // msg = nni_id_get_min(&p->sent_unack, &pid); + // if (msg != NULL) { + // uint16_t ptype; + // ptype = nni_mqtt_msg_get_packet_type(msg); + // if (ptype == NNG_MQTT_PUBLISH) { + // nni_mqtt_msg_set_publish_dup(msg, true); + // } + // if (!p->busy) { + // p->busy = true; + // nni_msg_clone(msg); + // aio = nni_mqtt_msg_get_aio(msg); + // if (aio) { + // nni_aio_bump_count(aio, + // nni_msg_header_len(msg) + + // nni_msg_len(msg)); + // nni_aio_set_msg(aio, NULL); + // } + // nni_aio_set_msg(&p->send_aio, msg); + // nni_pipe_send(p->pipe, &p->send_aio); + + // nni_mtx_unlock(&s->mtx); + // nni_sleep_aio(s->retry, &p->time_aio); + // return; + // } else { + // nni_msg_clone(msg); + // nni_lmq_put(&p->send_messages, msg); + // } + // } #if defined(NNG_SUPP_SQLITE) if (!p->busy) {