x64-exp

[casparcg] / core / consumer / frame_consumer.cpp

diff --git a/core/consumer/frame_consumer.cpp b/core/consumer/frame_consumer.cpp
index 7ebb91818a29a4eb04203b7d4d84b4cf7637f483..4e40c513ec44e756c29170f11290051ed2451306 100644 (file)
--- a/core/consumer/frame_consumer.cpp
+++ b/core/consumer/frame_consumer.cpp
@@ -69,9 +69,8 @@ safe_ptr<core::frame_consumer> create_consumer(const std::vector<std::wstring>&
 class cadence_guard : public frame_consumer\r
 {\r
        safe_ptr<frame_consumer>                consumer_;\r
-       std::vector<size_t>                             audio_cadence_;\r
-       boost::circular_buffer<size_t>  sync_buffer_;\r
-       bool                                                    synced_;\r
+       std::vector<int>                                audio_cadence_;\r
+       boost::circular_buffer<int>     sync_buffer_;\r
 public:\r
        cadence_guard(const safe_ptr<frame_consumer>& consumer)\r
                : consumer_(consumer)\r
@@ -81,30 +80,29 @@ public:
        virtual void initialize(const video_format_desc& format_desc, int channel_index) override\r
        {\r
                audio_cadence_  = format_desc.audio_cadence;\r
-               sync_buffer_    = boost::circular_buffer<size_t>(format_desc.audio_cadence.size());\r
+               sync_buffer_    = boost::circular_buffer<int>(format_desc.audio_cadence.size());\r
                consumer_->initialize(format_desc, channel_index);\r
        }\r
 \r
        virtual bool send(const safe_ptr<read_frame>& frame) override\r
        {               \r
-               sync_buffer_.push_back(static_cast<size_t>(frame->audio_data().size()));\r
+               if(audio_cadence_.size() == 1)\r
+                       return consumer_->send(frame);\r
+\r
+               bool result = true;\r
                \r
-               if(!boost::range::equal(sync_buffer_, audio_cadence_))\r
-               {\r
-                       synced_ = false;\r
-                       CASPAR_LOG(trace) << L"[cadence_guard] Audio cadence unsynced. Skipping frame.";\r
-                       return true;\r
-               }\r
-               else if(!synced_)\r
-               {\r
-                       synced_ = true;\r
+               if(boost::range::equal(sync_buffer_, audio_cadence_) && audio_cadence_.front() == static_cast<int>(frame->audio_data().size())) \r
+               {       \r
+                       // Audio sent so far is in sync, now we can send the next chunk.\r
+                       result = consumer_->send(frame);\r
                        boost::range::rotate(audio_cadence_, std::begin(audio_cadence_)+1);\r
-                       return true;\r
                }\r
+               else\r
+                       CASPAR_LOG(trace) << print() << L" Syncing audio.";\r
 \r
-               boost::range::rotate(audio_cadence_, std::begin(audio_cadence_)+1);\r
-\r
-               return consumer_->send(frame);\r
+               sync_buffer_.push_back(static_cast<int>(frame->audio_data().size()));\r
+               \r
+               return result;\r
        }\r
 \r
        virtual std::wstring print() const override\r
@@ -122,7 +120,7 @@ public:
                return consumer_->has_synchronization_clock();\r
        }\r
 \r
-       virtual size_t buffer_depth() const override\r
+       virtual int buffer_depth() const override\r
        {\r
                return consumer_->buffer_depth();\r
        }\r
@@ -146,7 +144,7 @@ const safe_ptr<frame_consumer>& frame_consumer::empty()
                virtual void initialize(const video_format_desc&, int) override{}\r
                virtual std::wstring print() const override {return L"empty";}\r
                virtual bool has_synchronization_clock() const override {return false;}\r
-               virtual size_t buffer_depth() const override {return 0;};\r
+               virtual int buffer_depth() const override {return 0;};\r
                virtual int index() const{return -1;}\r
                virtual boost::property_tree::wptree info() const override\r
                {\r