Chris@16: // Chris@16: // detail/impl/win_static_mutex.ipp Chris@16: // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ Chris@16: // Chris@101: // Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com) Chris@16: // Chris@16: // Distributed under the Boost Software License, Version 1.0. (See accompanying Chris@16: // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) Chris@16: // Chris@16: Chris@16: #ifndef BOOST_ASIO_DETAIL_IMPL_WIN_STATIC_MUTEX_IPP Chris@16: #define BOOST_ASIO_DETAIL_IMPL_WIN_STATIC_MUTEX_IPP Chris@16: Chris@16: #if defined(_MSC_VER) && (_MSC_VER >= 1200) Chris@16: # pragma once Chris@16: #endif // defined(_MSC_VER) && (_MSC_VER >= 1200) Chris@16: Chris@16: #include Chris@16: Chris@16: #if defined(BOOST_ASIO_WINDOWS) Chris@16: Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: Chris@16: #include Chris@16: Chris@16: namespace boost { Chris@16: namespace asio { Chris@16: namespace detail { Chris@16: Chris@16: void win_static_mutex::init() Chris@16: { Chris@16: int error = do_init(); Chris@16: boost::system::error_code ec(error, Chris@16: boost::asio::error::get_system_category()); Chris@16: boost::asio::detail::throw_error(ec, "static_mutex"); Chris@16: } Chris@16: Chris@16: int win_static_mutex::do_init() Chris@16: { Chris@16: using namespace std; // For sprintf. Chris@16: wchar_t mutex_name[128]; Chris@16: #if defined(BOOST_ASIO_HAS_SECURE_RTL) Chris@16: swprintf_s( Chris@16: #else // defined(BOOST_ASIO_HAS_SECURE_RTL) Chris@16: _snwprintf( Chris@16: #endif // defined(BOOST_ASIO_HAS_SECURE_RTL) Chris@16: mutex_name, 128, L"asio-58CCDC44-6264-4842-90C2-F3C545CB8AA7-%u-%p", Chris@16: static_cast(::GetCurrentProcessId()), this); Chris@16: Chris@16: HANDLE mutex = ::CreateMutexW(0, TRUE, mutex_name); Chris@16: DWORD last_error = ::GetLastError(); Chris@16: if (mutex == 0) Chris@16: return ::GetLastError(); Chris@16: Chris@16: if (last_error == ERROR_ALREADY_EXISTS) Chris@16: ::WaitForSingleObject(mutex, INFINITE); Chris@16: Chris@16: if (initialised_) Chris@16: { Chris@16: ::ReleaseMutex(mutex); Chris@16: ::CloseHandle(mutex); Chris@16: return 0; Chris@16: } Chris@16: Chris@16: #if defined(__MINGW32__) Chris@16: // Not sure if MinGW supports structured exception handling, so for now Chris@16: // we'll just call the Windows API and hope. Chris@16: # if defined(UNDER_CE) Chris@16: ::InitializeCriticalSection(&crit_section_); Chris@16: # else Chris@16: if (!::InitializeCriticalSectionAndSpinCount(&crit_section_, 0x80000000)) Chris@16: { Chris@16: last_error = ::GetLastError(); Chris@16: ::ReleaseMutex(mutex); Chris@16: ::CloseHandle(mutex); Chris@16: return last_error; Chris@16: } Chris@16: # endif Chris@16: #else Chris@16: __try Chris@16: { Chris@16: # if defined(UNDER_CE) Chris@16: ::InitializeCriticalSection(&crit_section_); Chris@16: # else Chris@16: if (!::InitializeCriticalSectionAndSpinCount(&crit_section_, 0x80000000)) Chris@16: { Chris@16: last_error = ::GetLastError(); Chris@16: ::ReleaseMutex(mutex); Chris@16: ::CloseHandle(mutex); Chris@16: return last_error; Chris@16: } Chris@16: # endif Chris@16: } Chris@16: __except(GetExceptionCode() == STATUS_NO_MEMORY Chris@16: ? EXCEPTION_EXECUTE_HANDLER : EXCEPTION_CONTINUE_SEARCH) Chris@16: { Chris@16: ::ReleaseMutex(mutex); Chris@16: ::CloseHandle(mutex); Chris@16: return ERROR_OUTOFMEMORY; Chris@16: } Chris@16: #endif Chris@16: Chris@16: initialised_ = true; Chris@16: ::ReleaseMutex(mutex); Chris@16: ::CloseHandle(mutex); Chris@16: return 0; Chris@16: } Chris@16: Chris@16: } // namespace detail Chris@16: } // namespace asio Chris@16: } // namespace boost Chris@16: Chris@16: #include Chris@16: Chris@16: #endif // defined(BOOST_ASIO_WINDOWS) Chris@16: Chris@16: #endif // BOOST_ASIO_DETAIL_IMPL_WIN_STATIC_MUTEX_IPP