fix: 连续收到多帧音频数据时发生崩溃

Author: DawningW

src/AsyncCallback.hpp

@@ -38,6 +38,8 @@ class AsyncCallback
     {
         if (!callback)
             return;
+        if (signal.test()) // Avoid race condition with loop()
+            return;
         next = std::bind(callback, std::forward<T>(args)...);
         signal.test_and_set();
         signal.notify_all();

src/AudioDecoder.cpp

@@ -122,7 +122,6 @@ bool AudioDecoder::processPacket(AVPacket* packet)
                     swrCtx = swr_alloc();
                 }
 #if HAVE_CH_LAYOUT
-
                 AVChannelLayout out_ch_layout;
                 av_channel_layout_default(&out_ch_layout, outFrame.channels);
 

src/StreamPuller.cpp

@@ -111,7 +111,9 @@ StreamPuller::StreamPuller() : exit(1), authenticator(NULL)
                         callback.invokeSync(CRP_EV_AUDIO_EXTRADATA, &eventData, userData);
                     }
                 }
-                callback(CRP_EV_NEW_AUDIO, audioDecoder->getFrame(), userData);
+                // Synchronized calls are required to ensure proper processing
+                // because multiple frames of audio data may be received simultaneously.
+                callback.invokeSync(CRP_EV_NEW_AUDIO, audioDecoder->getFrame(), userData);
             }
         };
 }