We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d415719 commit 542700bCopy full SHA for 542700b
src/aclk/mqtt_websockets/mqtt_ng.c
@@ -2125,7 +2125,8 @@ int handle_incoming_traffic(struct mqtt_ng_client *client)
2125
2126
case MQTT_CPT_PINGRESP:
2127
worker_is_busy(WORKER_ACLK_CPT_PINGRESP);
2128
- pulse_aclk_sent_message_acked(ping_frag.sent_monotonic_ut, ping_frag.len);
+ usec_t latency = now_monotonic_usec() - ping_frag.sent_monotonic_ut;
2129
+ pulse_aclk_sent_message_acked(latency, ping_frag.len);
2130
break;
2131
2132
case MQTT_CPT_SUBACK:
0 commit comments