123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347 |
- #ifndef ASIO_DETAIL_WIN_IOCP_IO_CONTEXT_HPP
- #define ASIO_DETAIL_WIN_IOCP_IO_CONTEXT_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif
- #include "asio/detail/config.hpp"
- #if defined(ASIO_HAS_IOCP)
- #include "asio/detail/limits.hpp"
- #include "asio/detail/mutex.hpp"
- #include "asio/detail/op_queue.hpp"
- #include "asio/detail/scoped_ptr.hpp"
- #include "asio/detail/socket_types.hpp"
- #include "asio/detail/thread.hpp"
- #include "asio/detail/thread_context.hpp"
- #include "asio/detail/timer_queue_base.hpp"
- #include "asio/detail/timer_queue_set.hpp"
- #include "asio/detail/wait_op.hpp"
- #include "asio/detail/win_iocp_operation.hpp"
- #include "asio/detail/win_iocp_thread_info.hpp"
- #include "asio/execution_context.hpp"
- #include "asio/detail/push_options.hpp"
- namespace asio {
- namespace detail {
- class wait_op;
- class win_iocp_io_context
- : public execution_context_service_base<win_iocp_io_context>,
- public thread_context
- {
- public:
-
-
- ASIO_DECL win_iocp_io_context(asio::execution_context& ctx,
- int concurrency_hint = -1, bool own_thread = true);
-
- ASIO_DECL ~win_iocp_io_context();
-
- ASIO_DECL void shutdown();
-
- void init_task()
- {
- }
-
- ASIO_DECL asio::error_code register_handle(
- HANDLE handle, asio::error_code& ec);
-
- ASIO_DECL size_t run(asio::error_code& ec);
-
- ASIO_DECL size_t run_one(asio::error_code& ec);
-
- ASIO_DECL size_t wait_one(long usec, asio::error_code& ec);
-
- ASIO_DECL size_t poll(asio::error_code& ec);
-
- ASIO_DECL size_t poll_one(asio::error_code& ec);
-
- ASIO_DECL void stop();
-
- bool stopped() const
- {
- return ::InterlockedExchangeAdd(&stopped_, 0) != 0;
- }
-
- void restart()
- {
- ::InterlockedExchange(&stopped_, 0);
- }
-
- void work_started()
- {
- ::InterlockedIncrement(&outstanding_work_);
- }
-
- void work_finished()
- {
- if (::InterlockedDecrement(&outstanding_work_) == 0)
- stop();
- }
-
- ASIO_DECL bool can_dispatch();
-
- ASIO_DECL void capture_current_exception();
-
-
- void post_immediate_completion(win_iocp_operation* op, bool)
- {
- work_started();
- post_deferred_completion(op);
- }
-
-
- ASIO_DECL void post_deferred_completion(win_iocp_operation* op);
-
-
- ASIO_DECL void post_deferred_completions(
- op_queue<win_iocp_operation>& ops);
-
-
-
- void post_private_immediate_completion(win_iocp_operation* op)
- {
- post_immediate_completion(op, false);
- }
-
-
-
- void post_private_deferred_completion(win_iocp_operation* op)
- {
- post_deferred_completion(op);
- }
-
-
- void do_dispatch(operation* op)
- {
- post_immediate_completion(op, false);
- }
-
-
- ASIO_DECL void abandon_operations(op_queue<operation>& ops);
-
-
-
- ASIO_DECL void on_pending(win_iocp_operation* op);
-
-
-
- ASIO_DECL void on_completion(win_iocp_operation* op,
- DWORD last_error = 0, DWORD bytes_transferred = 0);
-
-
-
- ASIO_DECL void on_completion(win_iocp_operation* op,
- const asio::error_code& ec, DWORD bytes_transferred = 0);
-
- template <typename Time_Traits>
- void add_timer_queue(timer_queue<Time_Traits>& timer_queue);
-
- template <typename Time_Traits>
- void remove_timer_queue(timer_queue<Time_Traits>& timer_queue);
-
-
- template <typename Time_Traits>
- void schedule_timer(timer_queue<Time_Traits>& queue,
- const typename Time_Traits::time_type& time,
- typename timer_queue<Time_Traits>::per_timer_data& timer, wait_op* op);
-
-
- template <typename Time_Traits>
- std::size_t cancel_timer(timer_queue<Time_Traits>& queue,
- typename timer_queue<Time_Traits>::per_timer_data& timer,
- std::size_t max_cancelled = (std::numeric_limits<std::size_t>::max)());
-
- template <typename Time_Traits>
- void cancel_timer_by_key(timer_queue<Time_Traits>& queue,
- typename timer_queue<Time_Traits>::per_timer_data* timer,
- void* cancellation_key);
-
- template <typename Time_Traits>
- void move_timer(timer_queue<Time_Traits>& queue,
- typename timer_queue<Time_Traits>::per_timer_data& to,
- typename timer_queue<Time_Traits>::per_timer_data& from);
-
- int concurrency_hint() const
- {
- return concurrency_hint_;
- }
- private:
- #if defined(WINVER) && (WINVER < 0x0500)
- typedef DWORD dword_ptr_t;
- typedef ULONG ulong_ptr_t;
- #else
- typedef DWORD_PTR dword_ptr_t;
- typedef ULONG_PTR ulong_ptr_t;
- #endif
-
-
-
- ASIO_DECL size_t do_one(DWORD msec,
- win_iocp_thread_info& this_thread, asio::error_code& ec);
-
- ASIO_DECL static DWORD get_gqcs_timeout();
-
- ASIO_DECL void do_add_timer_queue(timer_queue_base& queue);
-
- ASIO_DECL void do_remove_timer_queue(timer_queue_base& queue);
-
- ASIO_DECL void update_timeout();
-
- struct work_finished_on_block_exit;
-
- struct auto_handle
- {
- HANDLE handle;
- auto_handle() : handle(0) {}
- ~auto_handle() { if (handle) ::CloseHandle(handle); }
- };
-
- auto_handle iocp_;
-
- long outstanding_work_;
-
- mutable long stopped_;
-
-
-
- long stop_event_posted_;
-
- long shutdown_;
- enum
- {
- #if !defined(_WIN32_WINNT) || (_WIN32_WINNT < 0x0600)
-
-
-
-
- default_gqcs_timeout = 500,
- #endif
-
- max_timeout_msec = 5 * 60 * 1000,
-
- max_timeout_usec = max_timeout_msec * 1000,
-
-
- wake_for_dispatch = 1,
-
-
-
- overlapped_contains_result = 2
- };
-
- const DWORD gqcs_timeout_;
-
- struct thread_function;
- friend struct thread_function;
-
- struct timer_thread_function;
- friend struct timer_thread_function;
-
- scoped_ptr<thread> timer_thread_;
-
- auto_handle waitable_timer_;
-
- long dispatch_required_;
-
- mutex dispatch_mutex_;
-
- timer_queue_set timer_queues_;
-
- op_queue<win_iocp_operation> completed_ops_;
-
- const int concurrency_hint_;
-
- scoped_ptr<thread> thread_;
- };
- }
- }
- #include "asio/detail/pop_options.hpp"
- #include "asio/detail/impl/win_iocp_io_context.hpp"
- #if defined(ASIO_HEADER_ONLY)
- # include "asio/detail/impl/win_iocp_io_context.ipp"
- #endif
- #endif
- #endif
|