Browse Source

MT#55283 add last_packet time to stats

Change-Id: I040ca6f92ebf2d6847f570e6e6122b2d0fa4d3b0
pull/1826/head
Richard Fuchs 2 years ago
parent
commit
7e90f4db2b
3 changed files with 8 additions and 2 deletions
  1. +2
    -0
      daemon/call_interfaces.c
  2. +4
    -2
      daemon/cli.c
  3. +2
    -0
      kernel-module/xt_RTPENGINE.c

+ 2
- 0
daemon/call_interfaces.c View File

@ -2397,6 +2397,8 @@ static void ng_stats_stream(bencode_item_t *list, const struct packet_stream *ps
bencode_dictionary_add_string(dict, "crypto suite",
ps->crypto.params.crypto_suite->name);
bencode_dictionary_add_integer(dict, "last packet", packet_stream_last_packet(ps));
bencode_dictionary_add_integer(dict, "last kernel packet", atomic64_get_na(&ps->stats_in->last_packet));
bencode_dictionary_add_integer(dict, "last user packet", atomic64_get_na(&ps->last_packet));
flags = bencode_dictionary_add_list(dict, "flags");


+ 4
- 2
daemon/cli.c View File

@ -709,7 +709,8 @@ static void cli_list_tag_info(struct cli_writer *cw, struct call_monologue *ml)
local_addr = sockaddr_print_buf(&local_endpoint->address);
cw->cw_printf(cw, "-------- Port %15s:%-5u <> %15s:%-5u%s, SSRC %" PRIx32 ", "
"" UINT64F " p, " UINT64F " b, " UINT64F " e, " UINT64F " ts",
"" UINT64F " p, " UINT64F " b, " UINT64F " e, " UINT64F " uts "
UINT64F " kts",
local_addr,
(unsigned int) local_endpoint->port,
sockaddr_print_buf(&ps->endpoint.address),
@ -719,7 +720,8 @@ static void cli_list_tag_info(struct cli_writer *cw, struct call_monologue *ml)
atomic64_get_na(&ps->stats_in->packets),
atomic64_get_na(&ps->stats_in->bytes),
atomic64_get_na(&ps->stats_in->errors),
packet_stream_last_packet(ps));
atomic64_get_na(&ps->last_packet),
atomic64_get_na(&ps->stats_in->last_packet));
cw->cw_printf(cw, "\n");
}
}


+ 2
- 0
kernel-module/xt_RTPENGINE.c View File

@ -1556,6 +1556,8 @@ static int proc_list_show(struct seq_file *f, void *v) {
(unsigned long long) atomic64_read(&g->target.pt_stats[i]->packets));
}
seq_printf(f, " last packet: %lli", (long long) atomic64_read(&g->target.stats->last_packet));
seq_printf(f, " SSRC in:");
for (i = 0; i < ARRAY_SIZE(g->target.ssrc); i++) {
if (!g->target.ssrc[i] || !g->target.ssrc_stats[i])


Loading…
Cancel
Save