123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645 |
- #ifndef BOOST_ASIO_IO_SERVICE_HPP
- #define BOOST_ASIO_IO_SERVICE_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif
- #include <boost/asio/detail/push_options.hpp>
- #include <boost/asio/detail/push_options.hpp>
- #include <cstddef>
- #include <stdexcept>
- #include <typeinfo>
- #include <boost/config.hpp>
- #include <boost/throw_exception.hpp>
- #include <boost/system/error_code.hpp>
- #include <boost/asio/detail/pop_options.hpp>
- #include <boost/asio/detail/dev_poll_reactor_fwd.hpp>
- #include <boost/asio/detail/epoll_reactor_fwd.hpp>
- #include <boost/asio/detail/kqueue_reactor_fwd.hpp>
- #include <boost/asio/detail/noncopyable.hpp>
- #include <boost/asio/detail/select_reactor_fwd.hpp>
- #include <boost/asio/detail/service_registry_fwd.hpp>
- #include <boost/asio/detail/signal_init.hpp>
- #include <boost/asio/detail/task_io_service_fwd.hpp>
- #include <boost/asio/detail/win_iocp_io_service_fwd.hpp>
- #include <boost/asio/detail/winsock_init.hpp>
- #include <boost/asio/detail/wrapped_handler.hpp>
- namespace boost {
- namespace asio {
- class io_service;
- template <typename Service> Service& use_service(io_service& ios);
- template <typename Service> void add_service(io_service& ios, Service* svc);
- template <typename Service> bool has_service(io_service& ios);
- class io_service
- : private noncopyable
- {
- private:
-
- #if defined(BOOST_ASIO_HAS_IOCP)
- typedef detail::win_iocp_io_service impl_type;
- friend class detail::win_iocp_overlapped_ptr;
- #elif defined(BOOST_ASIO_HAS_EPOLL)
- typedef detail::task_io_service<detail::epoll_reactor<false> > impl_type;
- #elif defined(BOOST_ASIO_HAS_KQUEUE)
- typedef detail::task_io_service<detail::kqueue_reactor<false> > impl_type;
- #elif defined(BOOST_ASIO_HAS_DEV_POLL)
- typedef detail::task_io_service<detail::dev_poll_reactor<false> > impl_type;
- #else
- typedef detail::task_io_service<detail::select_reactor<false> > impl_type;
- #endif
- public:
- class work;
- friend class work;
- class id;
- class service;
- class strand;
-
- io_service();
-
-
- explicit io_service(std::size_t concurrency_hint);
-
-
- ~io_service();
-
-
- std::size_t run();
-
-
- std::size_t run(boost::system::error_code& ec);
-
-
-
- std::size_t run_one();
-
-
-
- std::size_t run_one(boost::system::error_code& ec);
-
-
-
- std::size_t poll();
-
-
-
- std::size_t poll(boost::system::error_code& ec);
-
-
-
- std::size_t poll_one();
-
-
-
- std::size_t poll_one(boost::system::error_code& ec);
-
-
- void stop();
-
-
- void reset();
-
-
- template <typename CompletionHandler>
- void dispatch(CompletionHandler handler);
-
-
- template <typename CompletionHandler>
- void post(CompletionHandler handler);
-
-
-
- template <typename Handler>
- #if defined(GENERATING_DOCUMENTATION)
- unspecified
- #else
- detail::wrapped_handler<io_service&, Handler>
- #endif
- wrap(Handler handler);
-
-
- template <typename Service>
- friend Service& use_service(io_service& ios);
-
-
- template <typename Service>
- friend void add_service(io_service& ios, Service* svc);
-
-
- template <typename Service>
- friend bool has_service(io_service& ios);
- private:
- #if defined(BOOST_WINDOWS) || defined(__CYGWIN__)
- detail::winsock_init<> init_;
- #elif defined(__sun) || defined(__QNX__) || defined(__hpux) || defined(_AIX) \
- || defined(__osf__)
- detail::signal_init<> init_;
- #endif
-
- boost::asio::detail::service_registry* service_registry_;
-
- impl_type& impl_;
- };
- class io_service::work
- {
- public:
-
-
- explicit work(boost::asio::io_service& io_service);
-
-
- work(const work& other);
-
-
- ~work();
-
-
- boost::asio::io_service& io_service();
-
- boost::asio::io_service& get_io_service();
- private:
-
- void operator=(const work& other);
-
- boost::asio::io_service& io_service_;
- };
- class io_service::id
- : private noncopyable
- {
- public:
-
- id() {}
- };
- class io_service::service
- : private noncopyable
- {
- public:
-
-
- boost::asio::io_service& io_service();
-
- boost::asio::io_service& get_io_service();
- protected:
-
-
- service(boost::asio::io_service& owner);
-
- virtual ~service();
- private:
-
- virtual void shutdown_service() = 0;
- friend class boost::asio::detail::service_registry;
- boost::asio::io_service& owner_;
- const std::type_info* type_info_;
- const boost::asio::io_service::id* id_;
- service* next_;
- };
- class service_already_exists
- : public std::logic_error
- {
- public:
- service_already_exists()
- : std::logic_error("Service already exists.")
- {
- }
- };
- class invalid_service_owner
- : public std::logic_error
- {
- public:
- invalid_service_owner()
- : std::logic_error("Invalid service owner.")
- {
- }
- };
- }
- }
- #include <boost/asio/impl/io_service.ipp>
- #include <boost/asio/detail/pop_options.hpp>
- #endif
|