win_iocp_io_context.hpp 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340
  1. //
  2. // detail/win_iocp_io_context.hpp
  3. // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  4. //
  5. // Copyright (c) 2003-2019 Christopher M. Kohlhoff (chris at kohlhoff dot com)
  6. //
  7. // Distributed under the Boost Software License, Version 1.0. (See accompanying
  8. // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  9. //
  10. #ifndef BOOST_ASIO_DETAIL_WIN_IOCP_IO_CONTEXT_HPP
  11. #define BOOST_ASIO_DETAIL_WIN_IOCP_IO_CONTEXT_HPP
  12. #if defined(_MSC_VER) && (_MSC_VER >= 1200)
  13. # pragma once
  14. #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
  15. #include <boost/asio/detail/config.hpp>
  16. #if defined(BOOST_ASIO_HAS_IOCP)
  17. #include <boost/asio/detail/limits.hpp>
  18. #include <boost/asio/detail/mutex.hpp>
  19. #include <boost/asio/detail/op_queue.hpp>
  20. #include <boost/asio/detail/scoped_ptr.hpp>
  21. #include <boost/asio/detail/socket_types.hpp>
  22. #include <boost/asio/detail/thread.hpp>
  23. #include <boost/asio/detail/thread_context.hpp>
  24. #include <boost/asio/detail/timer_queue_base.hpp>
  25. #include <boost/asio/detail/timer_queue_set.hpp>
  26. #include <boost/asio/detail/wait_op.hpp>
  27. #include <boost/asio/detail/win_iocp_operation.hpp>
  28. #include <boost/asio/detail/win_iocp_thread_info.hpp>
  29. #include <boost/asio/execution_context.hpp>
  30. #include <boost/asio/detail/push_options.hpp>
  31. namespace boost {
  32. namespace asio {
  33. namespace detail {
  34. class wait_op;
  35. class win_iocp_io_context
  36. : public execution_context_service_base<win_iocp_io_context>,
  37. public thread_context
  38. {
  39. public:
  40. // Constructor. Specifies a concurrency hint that is passed through to the
  41. // underlying I/O completion port.
  42. BOOST_ASIO_DECL win_iocp_io_context(boost::asio::execution_context& ctx,
  43. int concurrency_hint = -1, bool own_thread = true);
  44. // Destructor.
  45. BOOST_ASIO_DECL ~win_iocp_io_context();
  46. // Destroy all user-defined handler objects owned by the service.
  47. BOOST_ASIO_DECL void shutdown();
  48. // Initialise the task. Nothing to do here.
  49. void init_task()
  50. {
  51. }
  52. // Register a handle with the IO completion port.
  53. BOOST_ASIO_DECL boost::system::error_code register_handle(
  54. HANDLE handle, boost::system::error_code& ec);
  55. // Run the event loop until stopped or no more work.
  56. BOOST_ASIO_DECL size_t run(boost::system::error_code& ec);
  57. // Run until stopped or one operation is performed.
  58. BOOST_ASIO_DECL size_t run_one(boost::system::error_code& ec);
  59. // Run until timeout, interrupted, or one operation is performed.
  60. BOOST_ASIO_DECL size_t wait_one(long usec, boost::system::error_code& ec);
  61. // Poll for operations without blocking.
  62. BOOST_ASIO_DECL size_t poll(boost::system::error_code& ec);
  63. // Poll for one operation without blocking.
  64. BOOST_ASIO_DECL size_t poll_one(boost::system::error_code& ec);
  65. // Stop the event processing loop.
  66. BOOST_ASIO_DECL void stop();
  67. // Determine whether the io_context is stopped.
  68. bool stopped() const
  69. {
  70. return ::InterlockedExchangeAdd(&stopped_, 0) != 0;
  71. }
  72. // Restart in preparation for a subsequent run invocation.
  73. void restart()
  74. {
  75. ::InterlockedExchange(&stopped_, 0);
  76. }
  77. // Notify that some work has started.
  78. void work_started()
  79. {
  80. ::InterlockedIncrement(&outstanding_work_);
  81. }
  82. // Notify that some work has finished.
  83. void work_finished()
  84. {
  85. if (::InterlockedDecrement(&outstanding_work_) == 0)
  86. stop();
  87. }
  88. // Return whether a handler can be dispatched immediately.
  89. bool can_dispatch()
  90. {
  91. return thread_call_stack::contains(this) != 0;
  92. }
  93. // Request invocation of the given operation and return immediately. Assumes
  94. // that work_started() has not yet been called for the operation.
  95. void post_immediate_completion(win_iocp_operation* op, bool)
  96. {
  97. work_started();
  98. post_deferred_completion(op);
  99. }
  100. // Request invocation of the given operation and return immediately. Assumes
  101. // that work_started() was previously called for the operation.
  102. BOOST_ASIO_DECL void post_deferred_completion(win_iocp_operation* op);
  103. // Request invocation of the given operation and return immediately. Assumes
  104. // that work_started() was previously called for the operations.
  105. BOOST_ASIO_DECL void post_deferred_completions(
  106. op_queue<win_iocp_operation>& ops);
  107. // Request invocation of the given operation using the thread-private queue
  108. // and return immediately. Assumes that work_started() has not yet been
  109. // called for the operation.
  110. void post_private_immediate_completion(win_iocp_operation* op)
  111. {
  112. post_immediate_completion(op, false);
  113. }
  114. // Request invocation of the given operation using the thread-private queue
  115. // and return immediately. Assumes that work_started() was previously called
  116. // for the operation.
  117. void post_private_deferred_completion(win_iocp_operation* op)
  118. {
  119. post_deferred_completion(op);
  120. }
  121. // Enqueue the given operation following a failed attempt to dispatch the
  122. // operation for immediate invocation.
  123. void do_dispatch(operation* op)
  124. {
  125. post_immediate_completion(op, false);
  126. }
  127. // Process unfinished operations as part of a shutdown operation. Assumes
  128. // that work_started() was previously called for the operations.
  129. BOOST_ASIO_DECL void abandon_operations(op_queue<operation>& ops);
  130. // Called after starting an overlapped I/O operation that did not complete
  131. // immediately. The caller must have already called work_started() prior to
  132. // starting the operation.
  133. BOOST_ASIO_DECL void on_pending(win_iocp_operation* op);
  134. // Called after starting an overlapped I/O operation that completed
  135. // immediately. The caller must have already called work_started() prior to
  136. // starting the operation.
  137. BOOST_ASIO_DECL void on_completion(win_iocp_operation* op,
  138. DWORD last_error = 0, DWORD bytes_transferred = 0);
  139. // Called after starting an overlapped I/O operation that completed
  140. // immediately. The caller must have already called work_started() prior to
  141. // starting the operation.
  142. BOOST_ASIO_DECL void on_completion(win_iocp_operation* op,
  143. const boost::system::error_code& ec, DWORD bytes_transferred = 0);
  144. // Add a new timer queue to the service.
  145. template <typename Time_Traits>
  146. void add_timer_queue(timer_queue<Time_Traits>& timer_queue);
  147. // Remove a timer queue from the service.
  148. template <typename Time_Traits>
  149. void remove_timer_queue(timer_queue<Time_Traits>& timer_queue);
  150. // Schedule a new operation in the given timer queue to expire at the
  151. // specified absolute time.
  152. template <typename Time_Traits>
  153. void schedule_timer(timer_queue<Time_Traits>& queue,
  154. const typename Time_Traits::time_type& time,
  155. typename timer_queue<Time_Traits>::per_timer_data& timer, wait_op* op);
  156. // Cancel the timer associated with the given token. Returns the number of
  157. // handlers that have been posted or dispatched.
  158. template <typename Time_Traits>
  159. std::size_t cancel_timer(timer_queue<Time_Traits>& queue,
  160. typename timer_queue<Time_Traits>::per_timer_data& timer,
  161. std::size_t max_cancelled = (std::numeric_limits<std::size_t>::max)());
  162. // Move the timer operations associated with the given timer.
  163. template <typename Time_Traits>
  164. void move_timer(timer_queue<Time_Traits>& queue,
  165. typename timer_queue<Time_Traits>::per_timer_data& to,
  166. typename timer_queue<Time_Traits>::per_timer_data& from);
  167. // Get the concurrency hint that was used to initialise the io_context.
  168. int concurrency_hint() const
  169. {
  170. return concurrency_hint_;
  171. }
  172. private:
  173. #if defined(WINVER) && (WINVER < 0x0500)
  174. typedef DWORD dword_ptr_t;
  175. typedef ULONG ulong_ptr_t;
  176. #else // defined(WINVER) && (WINVER < 0x0500)
  177. typedef DWORD_PTR dword_ptr_t;
  178. typedef ULONG_PTR ulong_ptr_t;
  179. #endif // defined(WINVER) && (WINVER < 0x0500)
  180. // Dequeues at most one operation from the I/O completion port, and then
  181. // executes it. Returns the number of operations that were dequeued (i.e.
  182. // either 0 or 1).
  183. BOOST_ASIO_DECL size_t do_one(DWORD msec, boost::system::error_code& ec);
  184. // Helper to calculate the GetQueuedCompletionStatus timeout.
  185. BOOST_ASIO_DECL static DWORD get_gqcs_timeout();
  186. // Helper function to add a new timer queue.
  187. BOOST_ASIO_DECL void do_add_timer_queue(timer_queue_base& queue);
  188. // Helper function to remove a timer queue.
  189. BOOST_ASIO_DECL void do_remove_timer_queue(timer_queue_base& queue);
  190. // Called to recalculate and update the timeout.
  191. BOOST_ASIO_DECL void update_timeout();
  192. // Helper class to call work_finished() on block exit.
  193. struct work_finished_on_block_exit;
  194. // Helper class for managing a HANDLE.
  195. struct auto_handle
  196. {
  197. HANDLE handle;
  198. auto_handle() : handle(0) {}
  199. ~auto_handle() { if (handle) ::CloseHandle(handle); }
  200. };
  201. // The IO completion port used for queueing operations.
  202. auto_handle iocp_;
  203. // The count of unfinished work.
  204. long outstanding_work_;
  205. // Flag to indicate whether the event loop has been stopped.
  206. mutable long stopped_;
  207. // Flag to indicate whether there is an in-flight stop event. Every event
  208. // posted using PostQueuedCompletionStatus consumes non-paged pool, so to
  209. // avoid exhausting this resouce we limit the number of outstanding events.
  210. long stop_event_posted_;
  211. // Flag to indicate whether the service has been shut down.
  212. long shutdown_;
  213. enum
  214. {
  215. // Timeout to use with GetQueuedCompletionStatus on older versions of
  216. // Windows. Some versions of windows have a "bug" where a call to
  217. // GetQueuedCompletionStatus can appear stuck even though there are events
  218. // waiting on the queue. Using a timeout helps to work around the issue.
  219. default_gqcs_timeout = 500,
  220. // Maximum waitable timer timeout, in milliseconds.
  221. max_timeout_msec = 5 * 60 * 1000,
  222. // Maximum waitable timer timeout, in microseconds.
  223. max_timeout_usec = max_timeout_msec * 1000,
  224. // Completion key value used to wake up a thread to dispatch timers or
  225. // completed operations.
  226. wake_for_dispatch = 1,
  227. // Completion key value to indicate that an operation has posted with the
  228. // original last_error and bytes_transferred values stored in the fields of
  229. // the OVERLAPPED structure.
  230. overlapped_contains_result = 2
  231. };
  232. // Timeout to use with GetQueuedCompletionStatus.
  233. const DWORD gqcs_timeout_;
  234. // Helper class to run the scheduler in its own thread.
  235. struct thread_function;
  236. friend struct thread_function;
  237. // Function object for processing timeouts in a background thread.
  238. struct timer_thread_function;
  239. friend struct timer_thread_function;
  240. // Background thread used for processing timeouts.
  241. scoped_ptr<thread> timer_thread_;
  242. // A waitable timer object used for waiting for timeouts.
  243. auto_handle waitable_timer_;
  244. // Non-zero if timers or completed operations need to be dispatched.
  245. long dispatch_required_;
  246. // Mutex for protecting access to the timer queues and completed operations.
  247. mutex dispatch_mutex_;
  248. // The timer queues.
  249. timer_queue_set timer_queues_;
  250. // The operations that are ready to dispatch.
  251. op_queue<win_iocp_operation> completed_ops_;
  252. // The concurrency hint used to initialise the io_context.
  253. const int concurrency_hint_;
  254. // The thread that is running the io_context.
  255. scoped_ptr<thread> thread_;
  256. };
  257. } // namespace detail
  258. } // namespace asio
  259. } // namespace boost
  260. #include <boost/asio/detail/pop_options.hpp>
  261. #include <boost/asio/detail/impl/win_iocp_io_context.hpp>
  262. #if defined(BOOST_ASIO_HEADER_ONLY)
  263. # include <boost/asio/detail/impl/win_iocp_io_context.ipp>
  264. #endif // defined(BOOST_ASIO_HEADER_ONLY)
  265. #endif // defined(BOOST_ASIO_HAS_IOCP)
  266. #endif // BOOST_ASIO_DETAIL_WIN_IOCP_IO_CONTEXT_HPP