X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=shell%2Fmain.cpp;h=aabc6ab9b867c8adf24287c87154765315e25c68;hb=93b9e5dca7229dca21bf6fa21d75380bc417d0ad;hp=395d0ecf9925067c45fed09f9cb462e66c555bee;hpb=ef42efb386eb4ea852925b8ea5bc63fc0cadb6da;p=casparcg diff --git a/shell/main.cpp b/shell/main.cpp index 395d0ecf9..aabc6ab9b 100644 --- a/shell/main.cpp +++ b/shell/main.cpp @@ -1,47 +1,49 @@ /* -* copyright (c) 2010 Sveriges Television AB +* Copyright (c) 2011 Sveriges Television AB * -* This file is part of CasparCG. +* 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 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 . +* 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 . * +* 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 -#include "resource.h" - -#include "server.h" +#include "stdafx.h" #ifdef _DEBUG #define _CRTDBG_MAP_ALLOC #include #include +#else + #include #endif -#define NOMINMAX -#define WIN32_LEAN_AND_MEAN +#include "resource.h" + +#include "server.h" -#include +#include #include #include #include #include +#include #include #include @@ -50,37 +52,22 @@ #include #include -#include -#include -#include +#include +#include +#include #include #include #include -#include - #include #include #include #include +#include -#include - -struct application_state -{ - enum type - { - running, - shutdown, - pause_and_shutdown - }; -}; - -boost::condition_variable shutdown_cond; -boost::mutex shutdown_mut; -tbb::atomic shutdown_event; - +using namespace caspar; + // 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; @@ -94,27 +81,14 @@ void change_icon( const HICON 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); + EnableMenuItem(GetSystemMenu(GetConsoleWindow(), FALSE), SC_CLOSE , MF_GRAYED); + DrawMenuBar(GetConsoleWindow()); + //SetConsoleCtrlHandler(HandlerRoutine, true); // Configure console size and position. auto coord = GetLargestConsoleWindowSize(hOut); @@ -131,7 +105,7 @@ void setup_console_window() // Set console title. std::wstringstream str; - str << "CasparCG Server " << caspar::env::version(); + str << "CasparCG Server " << env::version() << L" x64 "; #ifdef COMPILE_RELEASE str << " Release"; #elif COMPILE_PROFILE @@ -146,34 +120,29 @@ void setup_console_window() void print_info() { + CASPAR_LOG(info) << L"################################################################################"; CASPAR_LOG(info) << L"Copyright (c) 2010 Sveriges Television AB, www.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"################################################################################"; + CASPAR_LOG(info) << L"Starting CasparCG Video and Graphics Playout Server " << env::version(); + CASPAR_LOG(info) << L"on " << win_product_name() << L" " << win_sp_version(); + CASPAR_LOG(info) << cpu_info(); + CASPAR_LOG(info) << system_product_name(); - 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"Decklink " << decklink::version(); + BOOST_FOREACH(auto device, decklink::device_list()) + CASPAR_LOG(info) << L" - " << 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"Bluefish " << bluefish::version(); + BOOST_FOREACH(auto device, bluefish::device_list()) + CASPAR_LOG(info) << L" - " << 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(); + CASPAR_LOG(info) << L"Flash " << flash::version(); + CASPAR_LOG(info) << L"FreeImage " << image::version(); + CASPAR_LOG(info) << L"FFMPEG-avcodec " << ffmpeg::avcodec_version(); + CASPAR_LOG(info) << L"FFMPEG-avformat " << ffmpeg::avformat_version(); + CASPAR_LOG(info) << L"FFMPEG-avfilter " << ffmpeg::avfilter_version(); + CASPAR_LOG(info) << L"FFMPEG-avutil " << ffmpeg::avutil_version(); + CASPAR_LOG(info) << L"FFMPEG-swscale " << ffmpeg::swscale_version(); } LONG WINAPI UserUnhandledExceptionFilter(EXCEPTION_POINTERS* info) @@ -192,30 +161,137 @@ LONG WINAPI UserUnhandledExceptionFilter(EXCEPTION_POINTERS* info) return EXCEPTION_EXECUTE_HANDLER; } +void run() +{ + // Create server object which initializes channels, protocols and controllers. + server caspar_server; + + auto server = spl::make_shared(5253); + caspar_server.subscribe(server); + + //auto console_obs = reactive::make_observer([](const monitor::event& e) + //{ + // std::stringstream str; + // str << e; + // CASPAR_LOG(trace) << str.str().c_str(); + //}); + + //caspar_server.subscribe(console_obs); + + // Create a amcp parser for console commands. + protocol::amcp::AMCPProtocolStrategy amcp(caspar_server.channels()); + + // Create a dummy client which prints amcp responses to console. + auto console_client = std::make_shared(); + + std::wstring wcmd; + while(true) + { + std::getline(std::wcin, wcmd); // TODO: It's blocking... + + boost::to_upper(wcmd); + + if(wcmd == L"EXIT" || wcmd == L"Q" || wcmd == L"QUIT" || wcmd == L"BYE") + break; + + // 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(wcmd.substr(1, 2)); + file = wcmd.substr(4, wcmd.length()-1); + } + catch(...) + { + num = boost::lexical_cast(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(n); + + for(int i = 1; i <= num; ++i) + wcmd += L"\r\nPLAY 1-" + boost::lexical_cast(i) + L" " + file + L" LOOP";// + L" SLIDE 100 LOOP"; + } + + wcmd += L"\r\n"; + amcp.Parse(wcmd.c_str(), static_cast(wcmd.length()), console_client); + } + CASPAR_LOG(info) << "Successfully shutdown CasparCG Server."; +} + 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 ); + HANDLE hLogFile; + hLogFile = CreateFile(L"crt_log.txt", GENERIC_WRITE, FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL); + std::shared_ptr crt_log(nullptr, [](HANDLE h){::CloseHandle(h);}); + + _CrtSetDbgFlag (_CRTDBG_ALLOC_MEM_DF | _CRTDBG_LEAK_CHECK_DF); + _CrtSetReportMode(_CRT_WARN, _CRTDBG_MODE_FILE); + _CrtSetReportFile(_CRT_WARN, hLogFile); + _CrtSetReportMode(_CRT_ERROR, _CRTDBG_MODE_FILE); + _CrtSetReportFile(_CRT_ERROR, hLogFile); + _CrtSetReportMode(_CRT_ASSERT, _CRTDBG_MODE_FILE); + _CrtSetReportFile(_CRT_ASSERT, hLogFile); #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"); - + win32_exception::install_handler(); + // Increase time precision. This will increase accuracy of function like Sleep(1) from 10 ms to 1 ms. struct inc_prec { @@ -223,14 +299,14 @@ int main(int argc, wchar_t* argv[]) ~inc_prec(){timeEndPeriod(1);} } inc_prec; - // Install unstructured exception handlers into all tbb threads. + // Install SEH 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(); + //detail::SetThreadName(GetCurrentThreadId(), "tbb-worker-thread"); + win32_exception::install_handler(); } } tbb_thread_installer; @@ -238,122 +314,34 @@ int main(int argc, wchar_t* argv[]) try { - { - // Configure environment properties from configuration. - caspar::env::configure("casparcg.config"); + // Configure environment properties from configuration. + env::configure(L"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(); + log::set_log_level(env::properties().get(L"configuration.log-level", L"debug")); - // Print environment information. - print_info(); - - std::stringstream str; - boost::property_tree::xml_writer_settings 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(); + #ifdef _DEBUG + if(env::properties().get(L"configuration.debugging.remote", false)) + MessageBox(nullptr, TEXT("Now is the time to connect for remote debugging..."), TEXT("Debug"), MB_OK | MB_TOPMOST); + #endif - 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(wcmd.substr(1, 2)); - file = wcmd.substr(4, wcmd.length()-1); - } - catch(...) - { - num = boost::lexical_cast(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(n); - - for(int i = 1; i <= num; ++i) - wcmd += L"\r\nPLAY 1-" + boost::lexical_cast(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 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.' + // Start logging to file. + log::add_file_sink(env::log_folder()); + std::wcout << L"Logging [info] or higher severity to " << env::log_folder() << std::endl << std::endl; + + // Setup console window. + setup_console_window(); - if(shutdown_event == application_state::pause_and_shutdown) - system("pause"); + // Print environment information. + print_info(); + + std::wstringstream str; + boost::property_tree::xml_writer_settings w(' ', 3); + boost::property_tree::write_xml(str, env::properties(), w); + CASPAR_LOG(info) << L"casparcg.config:\n-----------------------------------------\n" << str.str().c_str() << L"-----------------------------------------"; + + run(); + + system("pause"); } catch(boost::property_tree::file_parser_error&) { @@ -361,17 +349,14 @@ int main(int argc, wchar_t* argv[]) CASPAR_LOG(fatal) << L"Unhandled configuration error in main thread. Please check the configuration file (casparcg.config) for errors."; system("pause"); } - 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)."; - } + Sleep(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"; + Sleep(4000); + } - CASPAR_LOG(info) << "Successfully shutdown CasparCG Server."; return 0; } \ No newline at end of file