Disable QoS resending logic in MQTT Protocol layer

Signed-off-by: jaylin <[email protected]>
emqx · Oct 16, 2023 · 19e601c · 19e601c
1 parent e6f2147
commit 19e601c
Show file tree

Hide file tree

Showing 2 changed files with 58 additions and 58 deletions.
diff --git 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
@@ -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) {