commit ebaea1edd197fca0d0d9cd41333c40d1ae720edf
author le.han <le.han@amlogic.com> Mon Jul 10 07:26:09 2023 +0000
committer le.han <le.han@amlogic.com> Mon Jul 10 07:26:09 2023 +0000
tree ff1ab9091098413f5c78a7b8751c68bb7b2d0a91
parent 00387eb83230791ed4a08c9e2c8876457b5d1561

avsync: CB2 add mutex for avsync queue [1/1]

PD#SWPL-130877

Problem:
add mutex for avsync queue

Solution:
add mutex for avsync queue

Verify:
t5w

Signed-off-by: le.han <le.han@amlogic.com>
Change-Id: Ic28988acd312c6527ba488aa850aef3cc2323a18

src/avsync.c

diff --git a/src/avsync.c b/src/avsync.c
index dd17d45..fda9951 100644
--- a/src/avsync.c
+++ b/src/avsync.c
@@ -641,11 +641,13 @@
         }
         if (avsync->last_q_pts == frame->pts && avsync->mode == AV_SYNC_MODE_AMASTER) {
             /* TODO: wrong, should remove from back of queue */
+            pthread_mutex_lock(&avsync->lock);
             dqueue_item(avsync->frame_q, (void **)&prev);
             if (prev) {
                 prev->free(prev);
                 log_info ("[%d]drop frame with same pts %u", avsync->session_id, frame->pts);
             }
+            pthread_mutex_unlock(&avsync->lock);
         } else if (avsync->fps_cnt < 100) {
             int32_t interval = frame->pts - avsync->last_q_pts;