From b59ef7d838d46a83137e25f96646a8296c3a6f0a Mon Sep 17 00:00:00 2001
From: Richard Fuchs <rfuchs@sipwise.com>
Date: Mon, 22 Aug 2022 12:55:07 -0400
Subject: [PATCH] TT#188850 add PTs handled by the kernel module to PT tracker

Change-Id: Iec0f6adfd45268070731d0bf6759c2e39969ab8c
---
 daemon/call.c | 18 +++++++++++++++---
 1 file changed, 15 insertions(+), 3 deletions(-)

diff --git a/daemon/call.c b/daemon/call.c
index e3ff42ae4..29c2c663f 100644
--- a/daemon/call.c
+++ b/daemon/call.c
@@ -630,14 +630,21 @@ void call_timer(void *ptr) {
 		atomic64_set(&ps->kernel_stats_in.packets, ke->stats_in.packets);
 		atomic64_set(&ps->kernel_stats_in.errors, ke->stats_in.errors);
 
+		uint64_t max_diff = 0;
+		int max_pt = -1;
 		for (j = 0; j < ke->target.num_payload_types; j++) {
 			pt = ke->target.pt_input[j].pt_num;
 			rs = g_hash_table_lookup(ps->rtp_stats, GINT_TO_POINTER(pt));
 			if (!rs)
 				continue;
-			if (ke->rtp_stats[j].packets > atomic64_get(&rs->packets))
-				atomic64_add(&rs->packets,
-						ke->rtp_stats[j].packets - atomic64_get(&rs->packets));
+			if (ke->rtp_stats[j].packets > atomic64_get(&rs->packets)) {
+				uint64_t diff = ke->rtp_stats[j].packets - atomic64_get(&rs->packets);
+				atomic64_add(&rs->packets, diff);
+				if (diff > max_diff) {
+					max_diff = diff;
+					max_pt = j;
+				}
+			}
 			if (ke->rtp_stats[j].bytes > atomic64_get(&rs->bytes))
 				atomic64_add(&rs->bytes,
 						ke->rtp_stats[j].bytes - atomic64_get(&rs->bytes));
@@ -681,6 +688,8 @@ void call_timer(void *ptr) {
 							sink->ssrc_out, 0);
 					if (!ctx)
 						continue;
+					if (max_pt != -1)
+						payload_tracker_add(&ctx->tracker, max_pt);
 					if (sink->crypto.params.crypto_suite
 							&& o->encrypt.last_index[u] - ctx->srtp_index > 0x4000)
 					{
@@ -707,6 +716,9 @@ void call_timer(void *ptr) {
 				// TODO: add in SSRC stats similar to __stream_update_stats
 				atomic64_set(&ctx->last_seq, ke->target.decrypt.last_index[u]);
 
+				if (max_pt != -1)
+					payload_tracker_add(&ctx->tracker, max_pt);
+
 				if (sfd->crypto.params.crypto_suite
 						&& ke->target.decrypt.last_index[u]
 						- ctx->srtp_index > 0x4000) {