X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=shell%2Fmain.cpp;h=2eac1b8b646fc52a9d0aff964189d3bfd30128f1;hb=643e36a8e992512d16aa6f3a16e663c14c3cbdd3;hp=59fe7882b9f0a5ae8bf80fa4df4d64de1f4040f7;hpb=9e3d038a1064e8dd4b35b167935430a7ba8a885a;p=casparcg

diff --git a/shell/main.cpp b/shell/main.cpp
index 59fe7882b..2eac1b8b6 100644
--- a/shell/main.cpp
+++ b/shell/main.cpp
@@ -1,376 +1,368 @@
-/*
-* 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/>.
-*
-*/
-
-// 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 <tbb/tbbmalloc_proxy.h>
-
-#include "resource.h"
-
-#include "server.h"
-
-#ifdef _DEBUG
-	#define _CRTDBG_MAP_ALLOC
-	#include <stdlib.h>
-	#include <crtdbg.h>
-#endif
-
-#define NOMINMAX
-#define WIN32_LEAN_AND_MEAN
-
-#include <windows.h>
-#include <winnt.h>
-#include <mmsystem.h>
-#include <atlbase.h>
-
-#include <protocol/amcp/AMCPProtocolStrategy.h>
-
-#include <modules/bluefish/bluefish.h>
-#include <modules/decklink/decklink.h>
-#include <modules/flash/flash.h>
-#include <modules/ffmpeg/ffmpeg.h>
-#include <modules/image/image.h>
-
-#include <common/env.h>
-#include <common/exception/win32_exception.h>
-#include <common/exception/exceptions.h>
-#include <common/log/log.h>
-#include <common/gl/gl_check.h>
-#include <common/os/windows/current_version.h>
-#include <common/os/windows/system_info.h>
-
-#include <core/mixer/gpu/ogl_device.h>
-
-#include <tbb/task_scheduler_init.h>
-#include <tbb/task_scheduler_observer.h>
-
-#include <boost/property_tree/detail/file_parser_error.hpp>
-#include <boost/property_tree/xml_parser.hpp>
-
-#include <algorithm>
-
-struct application_state
-{
-	enum type
-	{
-		running,
-		shutdown,
-		pause_and_shutdown
-	};
-};
-
-boost::condition_variable	shutdown_cond;
-boost::mutex				shutdown_mut;
-tbb::atomic<int>			shutdown_event;
-
-// NOTE: This is needed in order to make CComObject work since this is not a real ATL project.
-CComModule _AtlModule;
-extern __declspec(selectany) CAtlModule* _pAtlModule = &_AtlModule;
-
-void change_icon( const HICON hNewIcon )
-{
-   auto hMod = ::LoadLibrary(L"Kernel32.dll"); 
-   typedef DWORD(__stdcall *SCI)(HICON);
-   auto pfnSetConsoleIcon = reinterpret_cast<SCI>(::GetProcAddress(hMod, "SetConsoleIcon")); 
-   pfnSetConsoleIcon(hNewIcon); 
-   ::FreeLibrary(hMod);
-}
-
-BOOL WINAPI HandlerRoutine(__in  DWORD dwCtrlType)
-{
-	switch(dwCtrlType)
-	{
-	case CTRL_CLOSE_EVENT:
-	case CTRL_SHUTDOWN_EVENT:
-		shutdown_event = application_state::shutdown;
-		shutdown_cond.notify_all();
-		return true;
-	}
-	return false;
-}
-
-void setup_console_window()
-{	 
-	auto hOut = GetStdHandle(STD_OUTPUT_HANDLE);
-
-	// Disable close button in console to avoid shutdown without cleanup.
-	//EnableMenuItem(GetSystemMenu(GetConsoleWindow(), FALSE), SC_CLOSE , MF_GRAYED);
-	//DrawMenuBar(GetConsoleWindow());
-	SetConsoleCtrlHandler(HandlerRoutine, true);
-
-	// Configure console size and position.
-	auto coord = GetLargestConsoleWindowSize(hOut);
-	coord.X /= 2;
-
-	SetConsoleScreenBufferSize(hOut, coord);
-
-	SMALL_RECT DisplayArea = {0, 0, 0, 0};
-	DisplayArea.Right = coord.X-1;
-	DisplayArea.Bottom = (coord.Y-1)/2;
-	SetConsoleWindowInfo(hOut, TRUE, &DisplayArea);
-		 
-	change_icon(::LoadIcon(GetModuleHandle(0), MAKEINTRESOURCE(101)));
-
-	// Set console title.
-	std::wstringstream str;
-	str << "CasparCG Server " << caspar::env::version();
-#ifdef COMPILE_RELEASE
-	str << " Release";
-#elif  COMPILE_PROFILE
-	str << " Profile";
-#elif  COMPILE_DEVELOP
-	str << " Develop";
-#elif  COMPILE_DEBUG
-	str << " Debug";
-#endif
-	SetConsoleTitle(str.str().c_str());
-}
-
-void print_info()
-{
-	CASPAR_LOG(info) << L"Copyright (c) 2010 Sveriges Television AB, www.casparcg.com, <info@casparcg.com>";
-	CASPAR_LOG(info) << L"Starting CasparCG Video and Graphics Playout Server " << caspar::env::version();
-	CASPAR_LOG(info) << L"on " << caspar::get_win_product_name() << L" " << caspar::get_win_sp_version();
-	CASPAR_LOG(info) << caspar::get_cpu_info();
-	CASPAR_LOG(info) << caspar::get_system_product_name();
-	CASPAR_LOG(info) << L"Flash " << caspar::flash::get_version();
-	CASPAR_LOG(info) << L"Flash-Template-Host " << caspar::flash::get_cg_version();
-	CASPAR_LOG(info) << L"FreeImage " << caspar::image::get_version();
-	
-	CASPAR_LOG(info) << L"Decklink " << caspar::decklink::get_version();
-	auto deck = caspar::decklink::get_device_list();
-	std::for_each(deck.begin(), deck.end(), [](const std::wstring& device)
-	{
-		CASPAR_LOG(info) << device;
-	});
-		
-	CASPAR_LOG(info) << L"Bluefish " << caspar::bluefish::get_version();
-	auto blue = caspar::bluefish::get_device_list();
-	std::for_each(blue.begin(), blue.end(), [](const std::wstring& device)
-	{
-		CASPAR_LOG(info) << device;
-	});
-	
-	CASPAR_LOG(info) << L"FFMPEG-avcodec "  << caspar::ffmpeg::get_avcodec_version();
-	CASPAR_LOG(info) << L"FFMPEG-avformat " << caspar::ffmpeg::get_avformat_version();
-	CASPAR_LOG(info) << L"FFMPEG-avfilter " << caspar::ffmpeg::get_avfilter_version();
-	CASPAR_LOG(info) << L"FFMPEG-avutil "	<< caspar::ffmpeg::get_avutil_version();
-	CASPAR_LOG(info) << L"FFMPEG-swscale "  << caspar::ffmpeg::get_swscale_version();
-}
-
-LONG WINAPI UserUnhandledExceptionFilter(EXCEPTION_POINTERS* info)
-{
-	try
-	{
-		CASPAR_LOG(fatal) << L"#######################\n UNHANDLED EXCEPTION: \n" 
-			<< L"Adress:" << info->ExceptionRecord->ExceptionAddress << L"\n"
-			<< L"Code:" << info->ExceptionRecord->ExceptionCode << L"\n"
-			<< L"Flag:" << info->ExceptionRecord->ExceptionFlags << L"\n"
-			<< L"Info:" << info->ExceptionRecord->ExceptionInformation << L"\n"
-			<< L"Continuing execution. \n#######################";
-	}
-	catch(...){}
-
-    return EXCEPTION_EXECUTE_HANDLER;
-}
-
-int main(int argc, wchar_t* argv[])
-{	
-	static_assert(sizeof(void*) == 4, "64-bit code generation is not supported.");
-	
-	SetUnhandledExceptionFilter(UserUnhandledExceptionFilter);
-
-	std::wcout << L"Type \"q\" to close application." << std::endl;
-	
-	// Set debug mode.
-	#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 );
-	#endif
-
-	// Increase process priotity.
-	SetPriorityClass(GetCurrentProcess(), ABOVE_NORMAL_PRIORITY_CLASS);
-
-	// Install structured exception handler.
-	caspar::win32_exception::install_handler();
-
-	caspar::log::set_log_level(L"debug");
-			
-	// Increase time precision. This will increase accuracy of function like Sleep(1) from 10 ms to 1 ms.
-	struct inc_prec
-	{
-		inc_prec(){timeBeginPeriod(1);}
-		~inc_prec(){timeEndPeriod(1);}
-	} inc_prec;	
-
-	// Install unstructured exception handlers 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)
-		{
-			//caspar::detail::SetThreadName(GetCurrentThreadId(), "tbb-worker-thread");
-			caspar::win32_exception::install_handler();
-		}
-	} tbb_thread_installer;
-
-	tbb::task_scheduler_init init;
-	
-	try 
-	{
-		{
-			// Configure environment properties from configuration.
-			caspar::env::configure("casparcg.config");
-				
-		#ifdef _DEBUG
-			if(caspar::env::properties().get("configuration.debugging.remote", false))
-				MessageBox(nullptr, TEXT("Now is the time to connect for remote debugging..."), TEXT("Debug"), MB_OK | MB_TOPMOST);
-		#endif	 
-
-			// Start logging to file.
-			caspar::log::add_file_sink(caspar::env::log_folder());			
-			std::wcout << L"Logging [info] or higher severity to " << caspar::env::log_folder() << std::endl << std::endl;
-		
-			// Setup console window.
-			setup_console_window();
-
-			// Print environment information.
-			print_info();
-			
-			std::stringstream str;
-			boost::property_tree::xml_writer_settings<char> w(' ', 3);
-			boost::property_tree::write_xml(str, caspar::env::properties(), w);
-			CASPAR_LOG(info) << L"casparcg.config:\n-----------------------------------------\n" << str.str().c_str() << L"-----------------------------------------";
-				
-			// Create server object which initializes channels, protocols and controllers.
-			caspar::server caspar_server;
-				
-			// Create a amcp parser for console commands.
-			caspar::protocol::amcp::AMCPProtocolStrategy amcp(caspar_server.get_channels());
-
-			// Create a dummy client which prints amcp responses to console.
-			auto console_client = std::make_shared<caspar::IO::ConsoleClientInfo>();
-
-			boost::thread input_thread([&]
-			{
-				while(shutdown_event == application_state::running)
-				{
-					std::wstring wcmd;
-					std::getline(std::wcin, wcmd); // TODO: It's blocking...
-
-					try
-					{
-						if(wcmd == L"exit" || wcmd == L"q")
-						{
-							shutdown_event = application_state::pause_and_shutdown;
-							shutdown_cond.notify_all();
-							return;
-						}
-
-						// 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"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";
-						}
-
-						wcmd += L"\r\n";
-						amcp.Parse(wcmd.c_str(), wcmd.length(), console_client);
-					}
-					catch(...)
-					{
-						CASPAR_LOG_CURRENT_EXCEPTION();
-					}
-				}
-			});
-
-			boost::unique_lock<boost::mutex> lock(shutdown_mut);
-			while(shutdown_event == application_state::running)			
-				shutdown_cond.wait(lock);				
-		}	
-			
-		Sleep(500); // CAPSAR_LOG is asynchronous. Try to get text in correct order.'
-
-		if(shutdown_event == application_state::pause_and_shutdown)
-			system("pause");	
-	}
-	catch(boost::property_tree::file_parser_error&)
-	{
-		CASPAR_LOG_CURRENT_EXCEPTION();
-		CASPAR_LOG(fatal) << L"Unhandled configuration error in main thread. Please check the configuration file (casparcg.config) for errors.";
-	}
-	catch(caspar::gl::ogl_exception&)
-	{
-		CASPAR_LOG_CURRENT_EXCEPTION();
-		CASPAR_LOG(fatal) << L"Unhandled OpenGL Error in main thread. Please try to update graphics drivers for OpenGL 3.0+ Support.";
-	}
-	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).";
-	}	
-	
-	CASPAR_LOG(info) << "Successfully shutdown CasparCG Server.";
-	return 0;
-}
\ No newline at end of file
+/*
+* 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>
+#include <clocale>
+
+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;
+}