Chris@16
|
1 //
|
Chris@16
|
2 // detail/impl/win_static_mutex.ipp
|
Chris@16
|
3 // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
Chris@16
|
4 //
|
Chris@101
|
5 // Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com)
|
Chris@16
|
6 //
|
Chris@16
|
7 // Distributed under the Boost Software License, Version 1.0. (See accompanying
|
Chris@16
|
8 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
|
Chris@16
|
9 //
|
Chris@16
|
10
|
Chris@16
|
11 #ifndef BOOST_ASIO_DETAIL_IMPL_WIN_STATIC_MUTEX_IPP
|
Chris@16
|
12 #define BOOST_ASIO_DETAIL_IMPL_WIN_STATIC_MUTEX_IPP
|
Chris@16
|
13
|
Chris@16
|
14 #if defined(_MSC_VER) && (_MSC_VER >= 1200)
|
Chris@16
|
15 # pragma once
|
Chris@16
|
16 #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
|
Chris@16
|
17
|
Chris@16
|
18 #include <boost/asio/detail/config.hpp>
|
Chris@16
|
19
|
Chris@16
|
20 #if defined(BOOST_ASIO_WINDOWS)
|
Chris@16
|
21
|
Chris@16
|
22 #include <cstdio>
|
Chris@16
|
23 #include <boost/asio/detail/throw_error.hpp>
|
Chris@16
|
24 #include <boost/asio/detail/win_static_mutex.hpp>
|
Chris@16
|
25 #include <boost/asio/error.hpp>
|
Chris@16
|
26
|
Chris@16
|
27 #include <boost/asio/detail/push_options.hpp>
|
Chris@16
|
28
|
Chris@16
|
29 namespace boost {
|
Chris@16
|
30 namespace asio {
|
Chris@16
|
31 namespace detail {
|
Chris@16
|
32
|
Chris@16
|
33 void win_static_mutex::init()
|
Chris@16
|
34 {
|
Chris@16
|
35 int error = do_init();
|
Chris@16
|
36 boost::system::error_code ec(error,
|
Chris@16
|
37 boost::asio::error::get_system_category());
|
Chris@16
|
38 boost::asio::detail::throw_error(ec, "static_mutex");
|
Chris@16
|
39 }
|
Chris@16
|
40
|
Chris@16
|
41 int win_static_mutex::do_init()
|
Chris@16
|
42 {
|
Chris@16
|
43 using namespace std; // For sprintf.
|
Chris@16
|
44 wchar_t mutex_name[128];
|
Chris@16
|
45 #if defined(BOOST_ASIO_HAS_SECURE_RTL)
|
Chris@16
|
46 swprintf_s(
|
Chris@16
|
47 #else // defined(BOOST_ASIO_HAS_SECURE_RTL)
|
Chris@16
|
48 _snwprintf(
|
Chris@16
|
49 #endif // defined(BOOST_ASIO_HAS_SECURE_RTL)
|
Chris@16
|
50 mutex_name, 128, L"asio-58CCDC44-6264-4842-90C2-F3C545CB8AA7-%u-%p",
|
Chris@16
|
51 static_cast<unsigned int>(::GetCurrentProcessId()), this);
|
Chris@16
|
52
|
Chris@16
|
53 HANDLE mutex = ::CreateMutexW(0, TRUE, mutex_name);
|
Chris@16
|
54 DWORD last_error = ::GetLastError();
|
Chris@16
|
55 if (mutex == 0)
|
Chris@16
|
56 return ::GetLastError();
|
Chris@16
|
57
|
Chris@16
|
58 if (last_error == ERROR_ALREADY_EXISTS)
|
Chris@16
|
59 ::WaitForSingleObject(mutex, INFINITE);
|
Chris@16
|
60
|
Chris@16
|
61 if (initialised_)
|
Chris@16
|
62 {
|
Chris@16
|
63 ::ReleaseMutex(mutex);
|
Chris@16
|
64 ::CloseHandle(mutex);
|
Chris@16
|
65 return 0;
|
Chris@16
|
66 }
|
Chris@16
|
67
|
Chris@16
|
68 #if defined(__MINGW32__)
|
Chris@16
|
69 // Not sure if MinGW supports structured exception handling, so for now
|
Chris@16
|
70 // we'll just call the Windows API and hope.
|
Chris@16
|
71 # if defined(UNDER_CE)
|
Chris@16
|
72 ::InitializeCriticalSection(&crit_section_);
|
Chris@16
|
73 # else
|
Chris@16
|
74 if (!::InitializeCriticalSectionAndSpinCount(&crit_section_, 0x80000000))
|
Chris@16
|
75 {
|
Chris@16
|
76 last_error = ::GetLastError();
|
Chris@16
|
77 ::ReleaseMutex(mutex);
|
Chris@16
|
78 ::CloseHandle(mutex);
|
Chris@16
|
79 return last_error;
|
Chris@16
|
80 }
|
Chris@16
|
81 # endif
|
Chris@16
|
82 #else
|
Chris@16
|
83 __try
|
Chris@16
|
84 {
|
Chris@16
|
85 # if defined(UNDER_CE)
|
Chris@16
|
86 ::InitializeCriticalSection(&crit_section_);
|
Chris@16
|
87 # else
|
Chris@16
|
88 if (!::InitializeCriticalSectionAndSpinCount(&crit_section_, 0x80000000))
|
Chris@16
|
89 {
|
Chris@16
|
90 last_error = ::GetLastError();
|
Chris@16
|
91 ::ReleaseMutex(mutex);
|
Chris@16
|
92 ::CloseHandle(mutex);
|
Chris@16
|
93 return last_error;
|
Chris@16
|
94 }
|
Chris@16
|
95 # endif
|
Chris@16
|
96 }
|
Chris@16
|
97 __except(GetExceptionCode() == STATUS_NO_MEMORY
|
Chris@16
|
98 ? EXCEPTION_EXECUTE_HANDLER : EXCEPTION_CONTINUE_SEARCH)
|
Chris@16
|
99 {
|
Chris@16
|
100 ::ReleaseMutex(mutex);
|
Chris@16
|
101 ::CloseHandle(mutex);
|
Chris@16
|
102 return ERROR_OUTOFMEMORY;
|
Chris@16
|
103 }
|
Chris@16
|
104 #endif
|
Chris@16
|
105
|
Chris@16
|
106 initialised_ = true;
|
Chris@16
|
107 ::ReleaseMutex(mutex);
|
Chris@16
|
108 ::CloseHandle(mutex);
|
Chris@16
|
109 return 0;
|
Chris@16
|
110 }
|
Chris@16
|
111
|
Chris@16
|
112 } // namespace detail
|
Chris@16
|
113 } // namespace asio
|
Chris@16
|
114 } // namespace boost
|
Chris@16
|
115
|
Chris@16
|
116 #include <boost/asio/detail/pop_options.hpp>
|
Chris@16
|
117
|
Chris@16
|
118 #endif // defined(BOOST_ASIO_WINDOWS)
|
Chris@16
|
119
|
Chris@16
|
120 #endif // BOOST_ASIO_DETAIL_IMPL_WIN_STATIC_MUTEX_IPP
|