From 14aa8e53ed6dd92faf840130804e676583b43b7c Mon Sep 17 00:00:00 2001
From: Richard Fuchs <rfuchs@sipwise.com>
Date: Mon, 18 May 2026 09:40:23 -0400
Subject: [PATCH] MT#55283 add missing lock in JB

Closes #2112

Change-Id: Idf691586a74d5ec6c4726cc9b36a2f90e4e61a6b
(cherry picked from commit 7f4657903412b0e8f2731ec61d49e18ed7d56db5)
(cherry picked from commit 7700315a92fbd85ebb6b29e4430597a3299a1098)
---
 daemon/jitter_buffer.c | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/daemon/jitter_buffer.c b/daemon/jitter_buffer.c
index 7d8d9e377..dcff122bd 100644
--- a/daemon/jitter_buffer.c
+++ b/daemon/jitter_buffer.c
@@ -284,7 +284,7 @@ static void check_buffered_packets(struct jitter_buffer *jb) {
 	}
 }
 
-// jb is locked
+// jb is locked and call is locked
 static int queue_packet(struct media_packet *mp, struct jb_packet *p) {
 	struct jitter_buffer *jb = mp->stream->jb;
 	unsigned long ts = ntohl(mp->rtp->timestamp);
@@ -346,6 +346,7 @@ static int queue_packet(struct media_packet *mp, struct jb_packet *p) {
 	return 0;
 }
 
+// jb is locked and call is locked
 static int handle_clock_drift(struct media_packet *mp) {
 	ilog(LOG_DEBUG, "handle_clock_drift");
 	struct jitter_buffer *jb = mp->stream->jb;
@@ -512,6 +513,7 @@ static void decrement_buffer(struct jitter_buffer *jb) {
 		jb->buffer_len--;
 }
 
+// jb and call are unlocked
 static void set_jitter_values(struct media_packet *mp) {
 	struct jitter_buffer *jb = mp->stream->jb;
 	if(!jb || !mp->rtp)
@@ -519,12 +521,16 @@ static void set_jitter_values(struct media_packet *mp) {
 	int curr_seq = ntohs(mp->rtp->seq_num); 
 	int payload_type = (mp->rtp->m_pt & 0x7f);
 	int dtmf = 0;
+
+	call_t *call = mp->call;
+	RWLOCK_R(&call->master_lock);
 	const rtp_payload_type *rtp_pt = codec_rtp_pt(mp, payload_type);
 	if(rtp_pt) {
 		if(rtp_pt->codec_def && rtp_pt->codec_def->dtmf)
 			dtmf = 1;
 	}
-	mutex_lock(&jb->lock);
+
+	LOCK(&jb->lock);
 	if(jb->next_exp_seq && !dtmf) {
 		if(curr_seq > jb->next_exp_seq) {
 			int marker = (mp->rtp->m_pt & 0x80) ? 1 : 0;
@@ -554,7 +560,6 @@ static void set_jitter_values(struct media_packet *mp) {
 	}
 	if(curr_seq >= jb->next_exp_seq)
 		jb->next_exp_seq = curr_seq + 1;
-	mutex_unlock(&jb->lock);
 }
 
 static void __jb_send_later(struct timerthread_queue *ttq, void *p) {