@cryptotaxi247 / netdata-1 / commits / b1aea7fc4

Clear packet id when processed from PUBACK (#20808)

Clear packet id when processed

Stelios Fragkakis committed Aug 12, 2025 at 14:05 UTC b1aea7fc457a6f4bbac081310efc97bb227c61b4

1 file changed +2

src/aclk/mqtt_websockets/mqtt_ng.c

@@ -1187,6 +1187,8 @@ static int mark_packet_acked(struct mqtt_ng_client *client, uint16_t packet_id)

1187 spinlock_unlock(&client->pending_packets.spinlock);

1188 return 1;

1189 }

1190 + // Do not reprocess this packet

1191 + frag->packet_id = 0;

1192 usec_t latency = now_monotonic_usec() - frag->sent_monotonic_ut;

1193 pulse_aclk_sent_message_acked(latency, frag->len);

1194 __atomic_store_n(&publish_latency, latency, __ATOMIC_RELEASE);