Named pipe consumer

src/modules/CMakeLists.txt

@@ -12,7 +12,8 @@ endif ()
 
 if (MSVC)
 	add_subdirectory(flash)
-	add_subdirectory(bluefish)
+	add_subdirectory(bluefish)
+	add_subdirectory(pipe)
 endif()
 
 add_subdirectory(image)

src/modules/pipe/CMakeLists.txt

@@ -0,0 +1,31 @@
+cmake_minimum_required (VERSION 2.6)
+project (pipe)
+
+set(SOURCES
+	consumer/pipe_consumer.cpp
+
+	pipe.cpp
+)
+set(HEADERS
+	consumer/pipe_consumer.h
+
+	pipe.h
+)
+
+add_library(pipe ${SOURCES} ${HEADERS})
+configure_file("${PROJECT_SOURCE_DIR}/packages.config" "${CMAKE_CURRENT_BINARY_DIR}/packages.config")
+
+include_directories(..)
+include_directories(../..)
+include_directories(${BOOST_INCLUDE_PATH})
+include_directories(${TBB_INCLUDE_PATH})
+
+set_target_properties(pipe PROPERTIES FOLDER modules)
+source_group(sources\\consumer consumer/*)
+source_group(sources ./*)
+
+target_link_libraries(pipe common core)
+
+casparcg_add_include_statement("modules/pipe/pipe.h")
+casparcg_add_init_statement("pipe::init" "pipe")
+casparcg_add_module_project("pipe")

src/modules/pipe/consumer/pipe_consumer.h

@@ -0,0 +1,41 @@
+/*
+ * Copyright (c) 2011 Sveriges Television AB <[email protected]>
+ *
+ * This file is part of CasparCG (www.casparcg.com).
+ *
+ * CasparCG is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * CasparCG is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with CasparCG. If not, see <http://www.gnu.org/licenses/>.
+ *
+ * Author: Philip Starkey, https://github.com/philipstarkey
+ * Author: Robert Nagy, [email protected]
+ */
+
+#pragma once
+
+#include <common/memory.h>
+
+#include <core/fwd.h>
+
+#include <boost/property_tree/ptree.hpp>
+#include <vector>
+
+namespace caspar { namespace pipe {
+
+spl::shared_ptr<core::frame_consumer>
+create_consumer(const std::vector<std::wstring>&                         params,
+                const std::vector<spl::shared_ptr<core::video_channel>>& channels);
+spl::shared_ptr<core::frame_consumer>
+create_preconfigured_consumer(const boost::property_tree::wptree&                      ptree,
+                              const std::vector<spl::shared_ptr<core::video_channel>>& channels);
+
+}} // namespace caspar::pipe

src/modules/pipe/packages.config

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="utf-8"?>
+<packages>
+  <package id="boost" version="1.66.0.0" targetFramework="native" />
+</packages>

src/modules/pipe/pipe.cpp

@@ -0,0 +1,37 @@
+/*
+ * Copyright (c) 2011 Sveriges Television AB <[email protected]>
+ *
+ * This file is part of CasparCG (www.casparcg.com).
+ *
+ * CasparCG is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * CasparCG is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with CasparCG. If not, see <http://www.gnu.org/licenses/>.
+ *
+ * Author: Philip Starkey, https://github.com/philipstarkey
+ * Author: Robert Nagy, [email protected]
+ */
+
+#include "pipe.h"
+
+#include "consumer/pipe_consumer.h"
+
+//#include <core/consumer/frame_consumer.h>
+
+namespace caspar { namespace pipe {
+
+void init(core::module_dependencies dependencies)
+{
+    dependencies.consumer_registry->register_consumer_factory(L"Pipe Consumer", create_consumer);
+    dependencies.consumer_registry->register_preconfigured_consumer_factory(L"pipe", create_preconfigured_consumer);
+}
+
+}} // namespace caspar::pipe

src/modules/pipe/pipe.h

@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2011 Sveriges Television AB <[email protected]>
+ *
+ * This file is part of CasparCG (www.casparcg.com).
+ *
+ * CasparCG is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * CasparCG is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with CasparCG. If not, see <http://www.gnu.org/licenses/>.
+ *
+ * Author: Philip Starkey, https://github.com/philipstarkey
+ * Author: Robert Nagy, [email protected]
+ */
+
+#pragma once
+
+#include <core/module_dependencies.h>
+
+namespace caspar { namespace pipe {
+
+void init(core::module_dependencies dependencies);
+
+}} // namespace caspar::pipe

src/modules/pipe/pipe/CMakeLists.txt

@@ -0,0 +1,9 @@
+# CMakeList.txt : CMake project for pipe, include source and define
+# project specific logic here.
+#
+cmake_minimum_required (VERSION 3.8)
+
+# Add source to this project's executable.
+add_executable (pipe "pipe.cpp" "pipe.h")
+
+# TODO: Add tests and install targets if needed.

src/modules/pipe/pipe/pipe.cpp

@@ -0,0 +1,12 @@
+// pipe.cpp : Defines the entry point for the application.
+//
+
+#include "pipe.h"
+
+using namespace std;
+
+int main()
+{
+	cout << "Hello CMake." << endl;
+	return 0;
+}

src/modules/pipe/pipe/pipe.h

@@ -0,0 +1,8 @@
+// pipe.h : Include file for standard system include files,
+// or project specific include files.
+
+#pragma once
+
+#include <iostream>
+
+// TODO: Reference additional headers your program requires here.

src/shell/casparcg.config

@@ -111,6 +111,17 @@
                 <path>[file|url]</path>
                 <args>[most ffmpeg arguments related to filtering and output codecs]</args>
             </ffmpeg>
+            <pipe>
+                <name>[custom name]</name>
+                <index>1 [1...]</index>
+                <video-pipe-name>\\.\pipe\CasparCGVideo [pipe path (optional only if audio pipe name specified)]</video-pipe-name>
+                <audio-pipe-name>\\.\pipe\CasparCGAudio [pipe path (optional only if video pipe name specified)]</audio-pipe-name>
+                <single-pipe>false [true|false] (true = send both audio and video data down a single pipe)</single-pipe>
+                <buffer-size>3.0 (number of seconds to buffer before dropping frames)</buffer-size>
+                <auto-reconnect>false [true|false] (true = recreate/reconnect to pipe(s) if a pipe is closed or writes fail)</auto-reconnect>
+                <realtime>true [true|false] (true = do not buffer frames between pipe reconnection. Only valid if auto-reconnect=true)</realtime>
+                <existing-pipe>false [true|false] (true = connect to an existing pipe. false = explicitly create a named pipe)</existing-pipe>
+            </pipe>
         </consumers>
     </channel>
 </channels>