]> git.sesse.net Git - casparcg/blob - core/consumer/frame_consumer.h
2.0. consumer: Buffer depth (latency) is configurable in xml file.
[casparcg] / core / consumer / frame_consumer.h
1 /*\r
2 * copyright (c) 2010 Sveriges Television AB <info@casparcg.com>\r
3 *\r
4 *  This file is part of CasparCG.\r
5 *\r
6 *    CasparCG is free software: you can redistribute it and/or modify\r
7 *    it under the terms of the GNU General Public License as published by\r
8 *    the Free Software Foundation, either version 3 of the License, or\r
9 *    (at your option) any later version.\r
10 *\r
11 *    CasparCG is distributed in the hope that it will be useful,\r
12 *    but WITHOUT ANY WARRANTY; without even the implied warranty of\r
13 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
14 *    GNU General Public License for more details.\r
15 \r
16 *    You should have received a copy of the GNU General Public License\r
17 *    along with CasparCG.  If not, see <http://www.gnu.org/licenses/>.\r
18 *\r
19 */\r
20 #pragma once\r
21 \r
22 #include "../video_format.h"\r
23 \r
24 #include <common/memory/safe_ptr.h>\r
25 \r
26 #include <boost/noncopyable.hpp>\r
27 \r
28 #include <functional>\r
29 #include <string>\r
30 #include <vector>\r
31 \r
32 namespace caspar { namespace core {\r
33         \r
34 class read_frame;\r
35 struct video_format_desc;\r
36 \r
37 size_t consumer_buffer_depth();\r
38 \r
39 struct frame_consumer : boost::noncopyable\r
40 {\r
41         virtual ~frame_consumer() {}\r
42         \r
43         virtual void send(const safe_ptr<read_frame>& frame) = 0;\r
44         virtual size_t buffer_depth() const {return 1;}\r
45         virtual bool key_only() const{ return false;}\r
46         virtual void initialize(const video_format_desc& format_desc) = 0;\r
47         virtual std::wstring print() const = 0;\r
48         virtual bool has_synchronization_clock() const {return true;}\r
49         virtual const core::video_format_desc& get_video_format_desc() const = 0; // nothrow\r
50 \r
51         static const safe_ptr<frame_consumer>& empty()\r
52         {\r
53                 struct empty_frame_consumer : public frame_consumer\r
54                 {\r
55                         core::video_format_desc format_desc;\r
56                         virtual void send(const safe_ptr<read_frame>&){}\r
57                         virtual size_t buffer_depth() const{return 0;}\r
58                         virtual void initialize(const video_format_desc&){}\r
59                         virtual std::wstring print() const {return L"empty";}\r
60                         virtual bool has_synchronization_clock() const {return false;}\r
61                         virtual const core::video_format_desc& get_video_format_desc() const{return format_desc;}; // nothrow\r
62                 };\r
63                 static safe_ptr<frame_consumer> consumer = make_safe<empty_frame_consumer>();\r
64                 return consumer;\r
65         }\r
66 };\r
67 \r
68 typedef std::function<safe_ptr<core::frame_consumer>(const std::vector<std::wstring>&)> consumer_factory_t;\r
69 \r
70 void register_consumer_factory(const consumer_factory_t& factory);\r
71 safe_ptr<core::frame_consumer> create_consumer(const std::vector<std::wstring>& params);\r
72 \r
73 }}