Chris@16
|
1 //
|
Chris@16
|
2 // detail/win_event.hpp
|
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_WIN_EVENT_HPP
|
Chris@16
|
12 #define BOOST_ASIO_DETAIL_WIN_EVENT_HPP
|
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 <boost/asio/detail/assert.hpp>
|
Chris@16
|
23 #include <boost/asio/detail/noncopyable.hpp>
|
Chris@16
|
24 #include <boost/asio/detail/socket_types.hpp>
|
Chris@16
|
25
|
Chris@16
|
26 #include <boost/asio/detail/push_options.hpp>
|
Chris@16
|
27
|
Chris@16
|
28 namespace boost {
|
Chris@16
|
29 namespace asio {
|
Chris@16
|
30 namespace detail {
|
Chris@16
|
31
|
Chris@16
|
32 class win_event
|
Chris@16
|
33 : private noncopyable
|
Chris@16
|
34 {
|
Chris@16
|
35 public:
|
Chris@16
|
36 // Constructor.
|
Chris@16
|
37 BOOST_ASIO_DECL win_event();
|
Chris@16
|
38
|
Chris@16
|
39 // Destructor.
|
Chris@101
|
40 BOOST_ASIO_DECL ~win_event();
|
Chris@16
|
41
|
Chris@101
|
42 // Signal the event. (Retained for backward compatibility.)
|
Chris@16
|
43 template <typename Lock>
|
Chris@16
|
44 void signal(Lock& lock)
|
Chris@16
|
45 {
|
Chris@101
|
46 this->signal_all(lock);
|
Chris@101
|
47 }
|
Chris@101
|
48
|
Chris@101
|
49 // Signal all waiters.
|
Chris@101
|
50 template <typename Lock>
|
Chris@101
|
51 void signal_all(Lock& lock)
|
Chris@101
|
52 {
|
Chris@16
|
53 BOOST_ASIO_ASSERT(lock.locked());
|
Chris@16
|
54 (void)lock;
|
Chris@101
|
55 state_ |= 1;
|
Chris@101
|
56 ::SetEvent(events_[0]);
|
Chris@16
|
57 }
|
Chris@16
|
58
|
Chris@101
|
59 // Unlock the mutex and signal one waiter.
|
Chris@16
|
60 template <typename Lock>
|
Chris@101
|
61 void unlock_and_signal_one(Lock& lock)
|
Chris@16
|
62 {
|
Chris@16
|
63 BOOST_ASIO_ASSERT(lock.locked());
|
Chris@101
|
64 state_ |= 1;
|
Chris@101
|
65 bool have_waiters = (state_ > 1);
|
Chris@16
|
66 lock.unlock();
|
Chris@101
|
67 if (have_waiters)
|
Chris@101
|
68 ::SetEvent(events_[1]);
|
Chris@101
|
69 }
|
Chris@101
|
70
|
Chris@101
|
71 // If there's a waiter, unlock the mutex and signal it.
|
Chris@101
|
72 template <typename Lock>
|
Chris@101
|
73 bool maybe_unlock_and_signal_one(Lock& lock)
|
Chris@101
|
74 {
|
Chris@101
|
75 BOOST_ASIO_ASSERT(lock.locked());
|
Chris@101
|
76 state_ |= 1;
|
Chris@101
|
77 if (state_ > 1)
|
Chris@101
|
78 {
|
Chris@101
|
79 lock.unlock();
|
Chris@101
|
80 ::SetEvent(events_[1]);
|
Chris@101
|
81 return true;
|
Chris@101
|
82 }
|
Chris@101
|
83 return false;
|
Chris@16
|
84 }
|
Chris@16
|
85
|
Chris@16
|
86 // Reset the event.
|
Chris@16
|
87 template <typename Lock>
|
Chris@16
|
88 void clear(Lock& lock)
|
Chris@16
|
89 {
|
Chris@16
|
90 BOOST_ASIO_ASSERT(lock.locked());
|
Chris@16
|
91 (void)lock;
|
Chris@101
|
92 ::ResetEvent(events_[0]);
|
Chris@101
|
93 state_ &= ~std::size_t(1);
|
Chris@16
|
94 }
|
Chris@16
|
95
|
Chris@16
|
96 // Wait for the event to become signalled.
|
Chris@16
|
97 template <typename Lock>
|
Chris@16
|
98 void wait(Lock& lock)
|
Chris@16
|
99 {
|
Chris@16
|
100 BOOST_ASIO_ASSERT(lock.locked());
|
Chris@101
|
101 while ((state_ & 1) == 0)
|
Chris@101
|
102 {
|
Chris@101
|
103 state_ += 2;
|
Chris@101
|
104 lock.unlock();
|
Chris@101
|
105 ::WaitForMultipleObjects(2, events_, false, INFINITE);
|
Chris@101
|
106 lock.lock();
|
Chris@101
|
107 state_ -= 2;
|
Chris@101
|
108 }
|
Chris@16
|
109 }
|
Chris@16
|
110
|
Chris@16
|
111 private:
|
Chris@101
|
112 HANDLE events_[2];
|
Chris@101
|
113 std::size_t state_;
|
Chris@16
|
114 };
|
Chris@16
|
115
|
Chris@16
|
116 } // namespace detail
|
Chris@16
|
117 } // namespace asio
|
Chris@16
|
118 } // namespace boost
|
Chris@16
|
119
|
Chris@16
|
120 #include <boost/asio/detail/pop_options.hpp>
|
Chris@16
|
121
|
Chris@16
|
122 #if defined(BOOST_ASIO_HEADER_ONLY)
|
Chris@16
|
123 # include <boost/asio/detail/impl/win_event.ipp>
|
Chris@16
|
124 #endif // defined(BOOST_ASIO_HEADER_ONLY)
|
Chris@16
|
125
|
Chris@16
|
126 #endif // defined(BOOST_ASIO_WINDOWS)
|
Chris@16
|
127
|
Chris@16
|
128 #endif // BOOST_ASIO_DETAIL_WIN_EVENT_HPP
|