Add support for callbacks in the dequeue thread.

[bmusb] / bmusb.cpp

diff --git a/bmusb.cpp b/bmusb.cpp
index 16da5f01e467409188f4cb3ab92335631802d401..b2de56f2b2cee588bc4a1c01252ffa2154045a48 100644 (file)
--- a/bmusb.cpp
+++ b/bmusb.cpp
@@ -146,6 +146,9 @@ void dump_audio_block(uint8_t *audio_start, size_t audio_len)
 
 void BMUSBCapture::dequeue_thread()
 {
+       if (has_dequeue_callbacks) {
+               dequeue_init_callback();
+       }
        for ( ;; ) {
                unique_lock<mutex> lock(queue_lock);
                queues_not_empty.wait(lock, [this]{ return !pending_video_frames.empty() && !pending_audio_frames.empty(); });
@@ -181,6 +184,9 @@ void BMUSBCapture::dequeue_thread()
                                       audio_frame.frame, AUDIO_HEADER_SIZE, audio_frame.format);
                }
        }
+       if (has_dequeue_callbacks) {
+               dequeue_cleanup_callback();
+       }
 }
 
 void BMUSBCapture::start_new_frame(const uint8_t *start)