Capture call path traffic alongside aggregate transmission queues

This commit is contained in:
evgeny committed 2026-10-30 21:14:05 +01:00
1 parent 65f0c62a23
commit 490515b7c2
2 files changed
+3

No files matched your search

+2
View File
@@ -1027,6 +1027,8 @@ static void call_audio_batch_tick(void* arg) {
struct etcp_tx_snapshot transport;
if (etcp_tx_get_snapshot(s->ctx->inst, now, &transport) == 0)
snapshot.transport_bytes = transport.queued_bytes + transport.inflight_bytes;
struct ETCP_ROUTER_PATH path = etcp_router_get_path(s->ctx->inst, s->group_id, s->peer_node_id, ETCP_RT_ID_CALL_AUDIO);
snapshot.peer_id = path.next_hop_node_id; snapshot.tx_epoch = path.tx_epoch; snapshot.wire_tx_bytes = path.wire_tx_bytes;
audio->record_tx(s->call_id, &snapshot);
}
if (call_audio_batch_step(&s->audio_batch, now, found ? &net : NULL))
+1
View File
@@ -20,6 +20,7 @@ struct call_history_rx {
};
struct call_history_tx {
uint64_t at_ms, queued_bytes, inflight_bytes, transport_bytes;
uint64_t peer_id, tx_epoch, wire_tx_bytes; /* Текущий путь звонка: разность счётчиков только при одинаковых peer/epoch. */
};
struct call_audio_history {
uint64_t now_ms;