X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=shell%2Fmain.cpp;h=acca06142eb0164c49e82e59c3bc075e2687b2f0;hb=27f42941f074ff9fa2acac82685b3e178c8014dc;hp=53218af8eab10ade58aba2e17927fd2918437fb6;hpb=90ff73db111844f3fe33067afd6c0bfb9d6a936e;p=casparcg

diff --git a/shell/main.cpp b/shell/main.cpp
index 53218af8e..f5499b958 100644
--- a/shell/main.cpp
+++ b/shell/main.cpp
@@ -1,124 +1,367 @@
-/*
-* copyright (c) 2010 Sveriges Television AB <info@casparcg.com>
-*
-*  This file is part of CasparCG.
-*
-*    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/>.
-*
-*/
-
-#include <Windows.h>
-
-#include <tbb/tbbmalloc_proxy.h>
-#include <tbb/task_scheduler_observer.h>
-
-#ifdef _DEBUG
-	#define _CRTDBG_MAP_ALLOC
-	#include <stdlib.h>
-	#include <crtdbg.h>
-#endif
-
-#include <conio.h>
-
-#include <core/config.h>
-#include <core/server.h>
-#include <core/protocol/amcp/AMCPProtocolStrategy.h>
-#include <common/exception/win32_exception.h>
-#include <common/exception/exceptions.h>
-#include <common/log/log.h>
-
-using namespace caspar;
-using namespace caspar::core;
-using namespace caspar::common;
-
-class win32_handler_tbb_installer : public tbb::task_scheduler_observer
-{
-public:
-	win32_handler_tbb_installer()	{observe(true);}
-	void on_scheduler_entry(bool is_worker) 
-	{
-		CASPAR_LOG(debug) << L"Started TBB Worker Thread.";
-		win32_exception::install_handler();
-	} 
-};
- 
-int main(int argc, wchar_t* argv[])
-{
-	std::wstringstream str;
-	str << "CasparCG " << CASPAR_VERSION_STR << " " << CASPAR_VERSION_TAG;
-	SetConsoleTitle(str.str().c_str());
-
-	CASPAR_LOG(info) << L"Starting CasparCG Video Playout Server Ver: " << CASPAR_VERSION_STR << " Tag: " << CASPAR_VERSION_TAG << std::endl;
-	CASPAR_LOG(info) << L"Copyright (c) 2010 Sveriges Television AB <info@casparcg.com>\n\n" << std::endl;
-
-	EnableMenuItem(GetSystemMenu(GetConsoleWindow(), FALSE), SC_CLOSE , MF_GRAYED);
-    DrawMenuBar(GetConsoleWindow());
-	MoveWindow(GetConsoleWindow(), 800, 0, 800, 1000, true);
-
-#ifdef _DEBUG
-	_CrtSetDbgFlag ( _CRTDBG_ALLOC_MEM_DF | _CRTDBG_LEAK_CHECK_DF | _CRTDBG_CHECK_ALWAYS_DF );
-	_CrtSetReportMode( _CRT_ERROR, _CRTDBG_MODE_DEBUG );
-	_CrtSetReportMode( _CRT_WARN, _CRTDBG_MODE_DEBUG );
-	_CrtSetReportMode( _CRT_ASSERT, _CRTDBG_MODE_DEBUG );
-
-	MessageBox(nullptr, TEXT("Now is the time to connect for remote debugging..."), TEXT("Debug"), MB_OK | MB_TOPMOST);
-#endif
-
-	log::add_file_sink(server::log_folder());
-	
-	CASPAR_LOG(debug) << "Started Main Thread";
-
-	win32_handler_tbb_installer win32_handler_tbb_installer;
-	win32_exception::install_handler();
-				
-	try 
-	{
-		server caspar_device;
-				
-		auto dummy = std::make_shared<IO::DummyClientInfo>();
-		amcp::AMCPProtocolStrategy amcp(caspar_device.get_channels());
-		bool is_running = true;
-		while(is_running)
-		{
-			std::wstring wcmd;
-			std::getline(std::wcin, wcmd); // TODO: It's blocking...
-			is_running = wcmd != L"exit" && wcmd != L"q";
-			if(wcmd.substr(0, 1) == L"1")
-				wcmd = L"LOADBG 1-1 " + wcmd.substr(1, wcmd.length()-1) + L" SLIDE 100 LOOP AUTOPLAY";
-			else if(wcmd.substr(0, 1) == L"2")
-				wcmd = L"LOADBG 1-1 " + wcmd.substr(1, wcmd.length()-1) + L" PUSH 100 LOOP AUTOPLAY";
-			else if(wcmd.substr(0, 1) == L"3")
-				wcmd = L"LOADBG 1-1 " + wcmd.substr(1, wcmd.length()-1) + L" MIX 100 LOOP AUTOPLAY";
-			else if(wcmd.substr(0, 1) == L"4")
-				wcmd = L"LOADBG 1-1 " + wcmd.substr(1, wcmd.length()-1) + L" WIPE 100 LOOP AUTOPLAY";
-			else if(wcmd == L"5")
-				wcmd = L"LOADBG 1-1 " + wcmd.substr(1, wcmd.length()-1) + L" CUT 100 LOOP AUTOPLAY";
-			else if(wcmd.substr(0, 1) == L"6")
-				wcmd = L"CG 1-2 ADD 1 BBTELEFONARE 1";
-
-			wcmd += L"\r\n";
-			amcp.Parse(wcmd.c_str(), wcmd.length(), dummy);
-		}
-	}
-	catch(const std::exception&)
-	{
-		CASPAR_LOG(fatal) << "UNHANDLED EXCEPTION in main thread.";
-		CASPAR_LOG_CURRENT_EXCEPTION();
-		std::wcout << L"Press Any Key To Exit";
-		_getwch();
-	}	
-	CASPAR_LOG(debug) << "Ended Main Thread";
-
-	return 0;
-}
+/*
+* Copyright (c) 2011 Sveriges Television AB <info@casparcg.com>
+*
+* 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: Robert Nagy, ronag89@gmail.com
+*/
+
+// tbbmalloc_proxy: 
+// Replace the standard memory allocation routines in Microsoft* C/C++ RTL 
+// (malloc/free, global new/delete, etc.) with the TBB memory allocator. 
+
+#include "stdafx.h"
+
+#include <tbb/task_scheduler_init.h>
+#include <tbb/task_scheduler_observer.h>
+
+#if defined _DEBUG && defined _MSC_VER
+	#define _CRTDBG_MAP_ALLOC
+	#include <stdlib.h>
+	#include <crtdbg.h>
+#else
+	// Reenable when tbb gets official support for vc14
+	//#include <tbb/tbbmalloc_proxy.h>
+#endif
+
+#include "server.h"
+#include "platform_specific.h"
+#include "included_modules.h"
+
+#include <protocol/util/strategy_adapters.h>
+#include <protocol/amcp/AMCPProtocolStrategy.h>
+
+#include <common/env.h>
+#include <common/except.h>
+#include <common/log.h>
+#include <common/gl/gl_check.h>
+#include <common/os/system_info.h>
+#include <common/os/general_protection_fault.h>
+
+#include <core/system_info_provider.h>
+
+#include <boost/property_tree/detail/file_parser_error.hpp>
+#include <boost/property_tree/xml_parser.hpp>
+#include <boost/locale.hpp>
+#include <boost/lexical_cast.hpp>
+#include <boost/algorithm/string/predicate.hpp>
+#include <boost/thread.hpp>
+#include <boost/thread/future.hpp>
+#include <boost/algorithm/string/case_conv.hpp>
+#include <boost/algorithm/string/split.hpp>
+#include <boost/algorithm/string/classification.hpp>
+
+#include <tbb/atomic.h>
+
+#include <future>
+#include <set>
+
+#include <csignal>
+
+using namespace caspar;
+	
+void setup_global_locale()
+{
+	boost::locale::generator gen;
+	gen.categories(boost::locale::codepage_facet);
+
+	std::locale::global(gen(""));
+
+	// sscanf is used in for example FFmpeg where we want decimals to be parsed as .
+	std::setlocale(LC_ALL, "C");
+}
+
+void print_info()
+{
+	CASPAR_LOG(info) << L"############################################################################";
+	CASPAR_LOG(info) << L"CasparCG Server is distributed by the Swedish Broadcasting Corporation (SVT)";
+	CASPAR_LOG(info) << L"under the GNU General Public License GPLv3 or higher.";
+	CASPAR_LOG(info) << L"Please see LICENSE.TXT for details.";
+	CASPAR_LOG(info) << L"http://www.casparcg.com/";
+	CASPAR_LOG(info) << L"############################################################################";
+	CASPAR_LOG(info) << L"Starting CasparCG Video and Graphics Playout Server " << env::version();
+	CASPAR_LOG(info) << L"on " << os_description();
+	CASPAR_LOG(info) << cpu_info();
+	CASPAR_LOG(info) << system_product_name();
+}
+
+
+void print_system_info(const spl::shared_ptr<core::system_info_provider_repository>& repo)
+{
+	boost::property_tree::wptree info;
+	repo->fill_information(info);
+
+	for (auto& elem : info.get_child(L"system"))
+		log::print_child(boost::log::trivial::info, L"", elem.first, elem.second);
+}
+
+void do_run(
+		std::weak_ptr<caspar::IO::protocol_strategy<wchar_t>> amcp,
+		std::promise<bool>& shutdown_server_now,
+		tbb::atomic<bool>& should_wait_for_keypress)
+{
+	std::wstring wcmd;
+	while(true)
+	{
+		std::getline(std::wcin, wcmd); // TODO: It's blocking...
+				
+		//boost::to_upper(wcmd);
+
+		if(boost::iequals(wcmd, L"EXIT") || boost::iequals(wcmd, L"Q") || boost::iequals(wcmd, L"QUIT") || boost::iequals(wcmd, L"BYE"))
+		{
+			CASPAR_LOG(info) << L"Received message from Console: " << wcmd << L"\\r\\n";
+			should_wait_for_keypress = true;
+			shutdown_server_now.set_value(false);	//false to not restart
+			break;
+		}
+
+		try
+		{
+			// This is just dummy code for testing.
+			if(wcmd.substr(0, 1) == L"1")
+				wcmd = L"LOADBG 1-1 " + wcmd.substr(1, wcmd.length()-1) + L" SLIDE 100 LOOP \r\nPLAY 1-1";
+			else if(wcmd.substr(0, 1) == L"2")
+				wcmd = L"MIXER 1-0 VIDEO IS_KEY 1";
+			else if(wcmd.substr(0, 1) == L"3")
+				wcmd = L"CG 1-2 ADD 1 BBTELEFONARE 1";
+			else if(wcmd.substr(0, 1) == L"4")
+				wcmd = L"PLAY 1-1 DV FILTER yadif=1:-1 LOOP";
+			else if(wcmd.substr(0, 1) == L"5")
+			{
+				auto file = wcmd.substr(2, wcmd.length()-1);
+				wcmd = L"PLAY 1-1 " + file + L" LOOP\r\n" 
+						L"PLAY 1-2 " + file + L" LOOP\r\n" 
+						L"PLAY 1-3 " + file + L" LOOP\r\n"
+						L"PLAY 2-1 " + file + L" LOOP\r\n" 
+						L"PLAY 2-2 " + file + L" LOOP\r\n" 
+						L"PLAY 2-3 " + file + L" LOOP\r\n";
+			}
+			else if(wcmd.substr(0, 1) == L"7")
+			{
+				wcmd = L"";
+				wcmd += L"CLEAR 1\r\n";
+				wcmd += L"MIXER 1 CLEAR\r\n";
+				wcmd += L"PLAY 1-0 GREEN\r\n";
+				wcmd += L"PLAY 1-1 BLUE\r\n";
+				wcmd += L"CG 1-2 ADD 1 ECS_TEST 1\r\n";
+				wcmd += L"MIXER 1-2 FILL 0 -1 1 2\r\n";
+			}
+			else if(wcmd.substr(0, 1) == L"8")
+			{
+				wcmd = L"";
+				wcmd += L"MIXER 1-1 FILL 0.0 0.5 1.0 1.0 500 linear DEFER\r\n";
+				wcmd += L"MIXER 1-2 FILL 0.0 0.0 1.0 1.0 500 linear DEFER\r\n";
+				wcmd += L"MIXER 1 COMMIT\r\n";
+			}
+			else if(wcmd.substr(0, 1) == L"X")
+			{
+				int num = 0;
+				std::wstring file;
+				try
+				{
+					num = boost::lexical_cast<int>(wcmd.substr(1, 2));
+					file = wcmd.substr(4, wcmd.length()-1);
+				}
+				catch(...)
+				{
+					num = boost::lexical_cast<int>(wcmd.substr(1, 1));
+					file = wcmd.substr(3, wcmd.length()-1);
+				}
+
+				int n = 0;
+				int num2 = num;
+				while(num2 > 0)
+				{
+					num2 >>= 1;
+					n++;
+				}
+
+				wcmd = L"MIXER 1 GRID " + boost::lexical_cast<std::wstring>(n);
+
+				for(int i = 1; i <= num; ++i)
+					wcmd += L"\r\nPLAY 1-" + boost::lexical_cast<std::wstring>(i) + L" " + file + L" LOOP";// + L" SLIDE 100 LOOP";
+			}
+		}
+		catch (...)
+		{
+			CASPAR_LOG_CURRENT_EXCEPTION();
+			continue;
+		}
+
+		wcmd += L"\r\n";
+		auto strong = amcp.lock();
+		if (strong)
+			strong->parse(wcmd);
+		else
+			break;
+	}
+};
+
+bool run(const std::wstring& config_file_name, tbb::atomic<bool>& should_wait_for_keypress)
+{
+	std::promise<bool> shutdown_server_now;
+	std::future<bool> shutdown_server = shutdown_server_now.get_future();
+
+	print_info();
+
+	// Create server object which initializes channels, protocols and controllers.
+	std::unique_ptr<server> caspar_server(new server(shutdown_server_now));
+
+	// For example CEF resets the global locale, so this is to reset it back to "our" preference.
+	setup_global_locale();
+
+	// Print environment information.
+	print_system_info(caspar_server->get_system_info_provider_repo());
+
+	std::wstringstream str;
+	boost::property_tree::xml_writer_settings<std::wstring> w(' ', 3);
+	boost::property_tree::write_xml(str, env::properties(), w);
+	CASPAR_LOG(info) << config_file_name << L":\n-----------------------------------------\n" << str.str() << L"-----------------------------------------";
+	
+	{
+		CASPAR_SCOPED_CONTEXT_MSG(config_file_name + L": ")
+		caspar_server->start();
+	}
+
+	// Create a dummy client which prints amcp responses to console.
+	auto console_client = spl::make_shared<IO::ConsoleClientInfo>();
+
+	// Create a amcp parser for console commands.
+	std::shared_ptr<IO::protocol_strategy<wchar_t>> amcp = spl::make_shared<caspar::IO::delimiter_based_chunking_strategy_factory<wchar_t>>(
+			L"\r\n",
+			spl::make_shared<caspar::IO::legacy_strategy_adapter_factory>(
+					spl::make_shared<protocol::amcp::AMCPProtocolStrategy>(
+							L"Console",
+							caspar_server->get_amcp_command_repository())))->create(console_client);
+	std::weak_ptr<IO::protocol_strategy<wchar_t>> weak_amcp = amcp;
+
+	// Use separate thread for the blocking console input, will be terminated 
+	// anyway when the main thread terminates.
+	boost::thread stdin_thread(std::bind(do_run, weak_amcp, std::ref(shutdown_server_now), std::ref(should_wait_for_keypress)));	//compiler didn't like lambda here...
+	stdin_thread.detach();
+	bool should_restart = shutdown_server.get();
+	amcp.reset();
+
+	while (weak_amcp.lock());
+
+	return should_restart;
+}
+
+void on_abort(int)
+{
+	CASPAR_THROW_EXCEPTION(invalid_operation() << msg_info("abort called"));
+}
+
+int main(int argc, char** argv)
+{
+	if (intercept_command_line_args(argc, argv))
+		return 0;
+
+	int return_code = 0;
+	setup_prerequisites();
+	//std::signal(SIGABRT, on_abort);
+
+	setup_global_locale();
+
+	std::wcout << L"Type \"q\" to close application." << std::endl;
+	
+	// Set debug mode.
+	auto debugging_environment = setup_debugging_environment();
+
+	// Increase process priotity.
+	increase_process_priority();
+
+	// Install general protection fault handler.
+	ensure_gpf_handler_installed_for_thread("main thread");
+
+	// Install GPF handler into all tbb threads.
+	struct tbb_thread_installer : public tbb::task_scheduler_observer
+	{
+		tbb_thread_installer(){observe(true);}
+		void on_scheduler_entry(bool is_worker) override
+		{
+			ensure_gpf_handler_installed_for_thread("tbb-worker-thread");
+		}
+	} tbb_thread_installer;
+
+	tbb::task_scheduler_init init;
+	std::wstring config_file_name(L"casparcg.config");
+	
+	try 
+	{
+		// Configure environment properties from configuration.
+		if (argc >= 2)
+			config_file_name = caspar::u16(argv[1]);
+
+		env::configure(config_file_name);
+
+		log::set_log_level(env::properties().get(L"configuration.log-level", L"info"));
+		auto log_categories_str = env::properties().get(L"configuration.log-categories", L"communication");
+		std::set<std::wstring> log_categories;
+		boost::split(log_categories, log_categories_str, boost::is_any_of(L", "));
+		for (auto& log_category : { L"calltrace", L"communication" })
+			log::set_log_category(log_category, log_categories.find(log_category) != log_categories.end());
+
+		if (env::properties().get(L"configuration.debugging.remote", false))
+			wait_for_remote_debugging();
+
+		// Start logging to file.
+		log::add_file_sink(env::log_folder() + L"caspar",		caspar::log::category != caspar::log::log_category::calltrace);
+		log::add_file_sink(env::log_folder() + L"calltrace",	caspar::log::category == caspar::log::log_category::calltrace);
+		std::wcout << L"Logging [info] or higher severity to " << env::log_folder() << std::endl << std::endl;
+		
+		// Setup console window.
+		setup_console_window();
+
+		tbb::atomic<bool> should_wait_for_keypress;
+		should_wait_for_keypress = false;
+		auto should_restart = run(config_file_name, should_wait_for_keypress);
+		return_code = should_restart ? 5 : 0;
+
+		for (auto& thread : get_thread_infos())
+		{
+			if (thread->name != "main thread" && thread->name != "tbb-worker-thread")
+				CASPAR_LOG(warning) << L"Thread left running: " << thread->name << L" (" << thread->native_id << L")";
+		}
+		
+		CASPAR_LOG(info) << "Successfully shutdown CasparCG Server.";
+
+		if (should_wait_for_keypress)
+			wait_for_keypress();
+	}
+	catch(const boost::property_tree::file_parser_error& e)
+	{
+		CASPAR_LOG_CURRENT_EXCEPTION();
+		CASPAR_LOG(fatal) << "At " << u8(config_file_name) << ":" << e.line() << ": " << e.message() << ". Please check the configuration file (" << u8(config_file_name) << ") for errors.";
+		wait_for_keypress();
+	}
+	catch (const user_error& e)
+	{
+		CASPAR_LOG_CURRENT_EXCEPTION_AT_LEVEL(debug);
+		CASPAR_LOG(fatal) << get_message_and_context(e) << " Please check the configuration file (" << u8(config_file_name) << ") for errors. Turn on log level debug for stacktrace.";
+		wait_for_keypress();
+	}
+	catch(...)
+	{
+		CASPAR_LOG_CURRENT_EXCEPTION();
+		CASPAR_LOG(fatal) << L"Unhandled exception in main thread. Please report this error on the CasparCG forums (www.casparcg.com/forum).";
+		boost::this_thread::sleep_for(boost::chrono::milliseconds(1000));
+		std::wcout << L"\n\nCasparCG will automatically shutdown. See the log file located at the configured log-file folder for more information.\n\n";
+		boost::this_thread::sleep_for(boost::chrono::milliseconds(4000));
+	}
+
+	return return_code;
+}