*/\r
#pragma once\r
\r
-#include "../format/video_format.h"\r
-#include "../processor/read_frame.h"\r
+#include "../video_format.h"\r
+\r
+#include <common/memory/safe_ptr.h>\r
\r
#include <boost/noncopyable.hpp>\r
\r
-#include <memory>\r
+#include <functional>\r
+#include <string>\r
+#include <vector>\r
\r
namespace caspar { namespace core {\r
\r
+class read_frame;\r
+struct video_format_desc;\r
+\r
+size_t consumer_buffer_depth();\r
+\r
struct frame_consumer : boost::noncopyable\r
{\r
- enum sync_mode\r
- {\r
- ready = 0,\r
- clock \r
- };\r
-\r
virtual ~frame_consumer() {}\r
+ \r
+ virtual bool send(const safe_ptr<read_frame>& frame) = 0;\r
+ virtual void initialize(const video_format_desc& format_desc) = 0;\r
+ virtual std::wstring print() const = 0;\r
+ virtual bool has_synchronization_clock() const {return true;}\r
+ virtual const core::video_format_desc& get_video_format_desc() const = 0; // nothrow\r
\r
- virtual void send(const safe_ptr<const read_frame>& frame) = 0;\r
- virtual sync_mode synchronize() = 0;\r
- virtual size_t buffer_depth() const = 0;\r
+ static const safe_ptr<frame_consumer>& empty()\r
+ {\r
+ struct empty_frame_consumer : public frame_consumer\r
+ {\r
+ core::video_format_desc format_desc;\r
+ virtual bool send(const safe_ptr<read_frame>&){return false;}\r
+ virtual void initialize(const video_format_desc&){}\r
+ virtual std::wstring print() const {return L"empty";}\r
+ virtual bool has_synchronization_clock() const {return false;}\r
+ virtual const core::video_format_desc& get_video_format_desc() const{return format_desc;}; // nothrow\r
+ };\r
+ static safe_ptr<frame_consumer> consumer = make_safe<empty_frame_consumer>();\r
+ return consumer;\r
+ }\r
};\r
-typedef std::shared_ptr<frame_consumer> frame_consumer_ptr;\r
-typedef std::shared_ptr<const frame_consumer> frame_consumer_const_ptr;\r
\r
-typedef std::unique_ptr<frame_consumer> frame_consumer_uptr;\r
-typedef std::unique_ptr<const frame_consumer> frame_consumer_const_uptr;\r
+typedef std::function<safe_ptr<core::frame_consumer>(const std::vector<std::wstring>&)> consumer_factory_t;\r
+\r
+void register_consumer_factory(const consumer_factory_t& factory);\r
+safe_ptr<core::frame_consumer> create_consumer(const std::vector<std::wstring>& params);\r
\r
}}
\ No newline at end of file