Log when decklink audio buffer level changes.

[mlt] / src / modules / decklink / consumer_decklink.cpp

diff --git a/src/modules/decklink/consumer_decklink.cpp b/src/modules/decklink/consumer_decklink.cpp
index b6b5fa59bbcaf95466be99e0293517425e804a06..956198e56640c450291c620e28f8ed11314fe73a 100644 (file)
--- a/src/modules/decklink/consumer_decklink.cpp
+++ b/src/modules/decklink/consumer_decklink.cpp
@@ -17,6 +17,7 @@
  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  */
 
+#define __STDC_FORMAT_MACROS  /* see inttypes.h */
 #include <framework/mlt.h>
 #include <stdlib.h>
 #include <string.h>
@@ -54,6 +55,8 @@ private:
        int                         m_isKeyer;
        IDeckLinkKeyer*             m_deckLinkKeyer;
        bool                        m_terminate_on_pause;
+       uint32_t                    m_preroll;
+       uint32_t                    m_acnt;
 
        IDeckLinkDisplayMode* getDisplayMode()
        {
@@ -233,6 +236,8 @@ public:
                        return false;
                }
 
+               m_preroll = preroll;
+
                // preroll frames
                for( i = 0; i < preroll; i++ )
                        ScheduleNextFrame( true );
@@ -281,7 +286,12 @@ public:
                {
                        uint32_t written = 0;
                        BMDTimeValue streamTime = m_count * frequency * m_duration / m_timescale;
-
+                       m_deckLinkOutput->GetBufferedAudioSampleFrameCount(&written);
+                       if ( written > (m_preroll + 1) * samples )
+                       {
+                               mlt_log_verbose( getConsumer(), "renderAudio: will flush %d audiosamples\n", written);
+                               m_deckLinkOutput->FlushBufferedAudioSamples();
+                       };
 #ifdef WIN32
                        m_deckLinkOutput->ScheduleAudioSamples( pcm, samples, streamTime, frequency, (unsigned long*) &written );
 #else
@@ -429,6 +439,16 @@ public:
        
        virtual HRESULT STDMETHODCALLTYPE ScheduledFrameCompleted( IDeckLinkVideoFrame* completedFrame, BMDOutputFrameCompletionResult completed )
        {
+               uint32_t cnt;
+               m_deckLinkOutput->GetBufferedAudioSampleFrameCount(&cnt);
+               if(cnt != m_acnt)
+               {
+                       mlt_log_verbose( getConsumer(),
+                               "ScheduledFrameCompleted: GetBufferedAudioSampleFrameCount %u -> %u, m_count=%"PRIu64"\n",
+                               m_acnt, cnt, m_count );
+                       m_acnt = cnt;
+               };
+
                // When a video frame has been released by the API, schedule another video frame to be output
 
                // ignore handler if frame was flushed
@@ -444,6 +464,11 @@ public:
                        mlt_log_verbose( getConsumer(), "ScheduledFrameCompleted: bmdOutputFrameDisplayedLate == completed\n");
                        m_count++;
                }
+               if(bmdOutputFrameDropped == completed)
+               {
+                       mlt_log_verbose( getConsumer(), "ScheduledFrameCompleted: bmdOutputFrameDropped == completed\n");
+                       m_count++;
+               }
 
                return S_OK;
        }