123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249 |
- #ifndef BOOST_ASIO_DETAIL_DEV_POLL_REACTOR_HPP
- #define BOOST_ASIO_DETAIL_DEV_POLL_REACTOR_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif
- #include <boost/asio/detail/config.hpp>
- #if defined(BOOST_ASIO_HAS_DEV_POLL)
- #include <cstddef>
- #include <vector>
- #include <sys/devpoll.h>
- #include <boost/asio/detail/hash_map.hpp>
- #include <boost/asio/detail/limits.hpp>
- #include <boost/asio/detail/mutex.hpp>
- #include <boost/asio/detail/op_queue.hpp>
- #include <boost/asio/detail/reactor_op.hpp>
- #include <boost/asio/detail/reactor_op_queue.hpp>
- #include <boost/asio/detail/scheduler_task.hpp>
- #include <boost/asio/detail/select_interrupter.hpp>
- #include <boost/asio/detail/socket_types.hpp>
- #include <boost/asio/detail/timer_queue_base.hpp>
- #include <boost/asio/detail/timer_queue_set.hpp>
- #include <boost/asio/detail/wait_op.hpp>
- #include <boost/asio/execution_context.hpp>
- #include <boost/asio/detail/push_options.hpp>
- namespace boost {
- namespace asio {
- namespace detail {
- class dev_poll_reactor
- : public execution_context_service_base<dev_poll_reactor>,
- public scheduler_task
- {
- public:
- enum op_types { read_op = 0, write_op = 1,
- connect_op = 1, except_op = 2, max_ops = 3 };
-
- struct per_descriptor_data
- {
- };
-
- BOOST_ASIO_DECL dev_poll_reactor(boost::asio::execution_context& ctx);
-
- BOOST_ASIO_DECL ~dev_poll_reactor();
-
- BOOST_ASIO_DECL void shutdown();
-
- BOOST_ASIO_DECL void notify_fork(
- boost::asio::execution_context::fork_event fork_ev);
-
- BOOST_ASIO_DECL void init_task();
-
-
- BOOST_ASIO_DECL int register_descriptor(socket_type, per_descriptor_data&);
-
-
- BOOST_ASIO_DECL int register_internal_descriptor(
- int op_type, socket_type descriptor,
- per_descriptor_data& descriptor_data, reactor_op* op);
-
- BOOST_ASIO_DECL void move_descriptor(socket_type descriptor,
- per_descriptor_data& target_descriptor_data,
- per_descriptor_data& source_descriptor_data);
-
- void post_immediate_completion(operation* op, bool is_continuation) const;
-
- BOOST_ASIO_DECL static void call_post_immediate_completion(
- operation* op, bool is_continuation, const void* self);
-
-
- BOOST_ASIO_DECL void start_op(int op_type, socket_type descriptor,
- per_descriptor_data&, reactor_op* op,
- bool is_continuation, bool allow_speculative,
- void (*on_immediate)(operation*, bool, const void*),
- const void* immediate_arg);
-
-
- void start_op(int op_type, socket_type descriptor,
- per_descriptor_data& descriptor_data, reactor_op* op,
- bool is_continuation, bool allow_speculative)
- {
- start_op(op_type, descriptor, descriptor_data,
- op, is_continuation, allow_speculative,
- &dev_poll_reactor::call_post_immediate_completion, this);
- }
-
-
-
- BOOST_ASIO_DECL void cancel_ops(socket_type descriptor, per_descriptor_data&);
-
-
-
- BOOST_ASIO_DECL void cancel_ops_by_key(socket_type descriptor,
- per_descriptor_data& descriptor_data,
- int op_type, void* cancellation_key);
-
-
-
- BOOST_ASIO_DECL void deregister_descriptor(socket_type descriptor,
- per_descriptor_data&, bool closing);
-
-
-
- BOOST_ASIO_DECL void deregister_internal_descriptor(
- socket_type descriptor, per_descriptor_data&);
-
-
- BOOST_ASIO_DECL void cleanup_descriptor_data(per_descriptor_data&);
-
- template <typename Time_Traits>
- void add_timer_queue(timer_queue<Time_Traits>& queue);
-
- template <typename Time_Traits>
- void remove_timer_queue(timer_queue<Time_Traits>& 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& target,
- typename timer_queue<Time_Traits>::per_timer_data& source);
-
- BOOST_ASIO_DECL void run(long usec, op_queue<operation>& ops);
-
- BOOST_ASIO_DECL void interrupt();
- private:
-
-
- BOOST_ASIO_DECL static int do_dev_poll_create();
-
- BOOST_ASIO_DECL void do_add_timer_queue(timer_queue_base& queue);
-
- BOOST_ASIO_DECL void do_remove_timer_queue(timer_queue_base& queue);
-
-
-
- BOOST_ASIO_DECL int get_timeout(int msec);
-
-
-
- BOOST_ASIO_DECL void cancel_ops_unlocked(socket_type descriptor,
- const boost::system::error_code& ec);
-
- BOOST_ASIO_DECL ::pollfd& add_pending_event_change(int descriptor);
-
- scheduler& scheduler_;
-
- boost::asio::detail::mutex mutex_;
-
- int dev_poll_fd_;
-
- std::vector< ::pollfd> pending_event_changes_;
-
- hash_map<int, std::size_t> pending_event_change_index_;
-
- select_interrupter interrupter_;
-
- reactor_op_queue<socket_type> op_queue_[max_ops];
-
- timer_queue_set timer_queues_;
-
- bool shutdown_;
- };
- }
- }
- }
- #include <boost/asio/detail/pop_options.hpp>
- #include <boost/asio/detail/impl/dev_poll_reactor.hpp>
- #if defined(BOOST_ASIO_HEADER_ONLY)
- # include <boost/asio/detail/impl/dev_poll_reactor.ipp>
- #endif
- #endif
- #endif
|