diff options
Diffstat (limited to 'boost/asio/impl/io_service.ipp')
-rw-r--r-- | boost/asio/impl/io_service.ipp | 157 |
1 files changed, 157 insertions, 0 deletions
diff --git a/boost/asio/impl/io_service.ipp b/boost/asio/impl/io_service.ipp new file mode 100644 index 0000000000..1e3af48f75 --- /dev/null +++ b/boost/asio/impl/io_service.ipp @@ -0,0 +1,157 @@ +// +// impl/io_service.ipp +// ~~~~~~~~~~~~~~~~~~~ +// +// Copyright (c) 2003-2012 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// +// Distributed under the Boost Software License, Version 1.0. (See accompanying +// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) +// + +#ifndef BOOST_ASIO_IMPL_IO_SERVICE_IPP +#define BOOST_ASIO_IMPL_IO_SERVICE_IPP + +#if defined(_MSC_VER) && (_MSC_VER >= 1200) +# pragma once +#endif // defined(_MSC_VER) && (_MSC_VER >= 1200) + +#include <boost/asio/detail/config.hpp> +#include <boost/limits.hpp> +#include <boost/asio/io_service.hpp> +#include <boost/asio/detail/scoped_ptr.hpp> +#include <boost/asio/detail/service_registry.hpp> +#include <boost/asio/detail/throw_error.hpp> + +#if defined(BOOST_ASIO_HAS_IOCP) +# include <boost/asio/detail/win_iocp_io_service.hpp> +#else +# include <boost/asio/detail/task_io_service.hpp> +#endif + +#include <boost/asio/detail/push_options.hpp> + +namespace boost { +namespace asio { + +io_service::io_service() + : service_registry_(new boost::asio::detail::service_registry( + *this, static_cast<impl_type*>(0), + (std::numeric_limits<std::size_t>::max)())), + impl_(service_registry_->first_service<impl_type>()) +{ +} + +io_service::io_service(std::size_t concurrency_hint) + : service_registry_(new boost::asio::detail::service_registry( + *this, static_cast<impl_type*>(0), concurrency_hint)), + impl_(service_registry_->first_service<impl_type>()) +{ +} + +io_service::~io_service() +{ + delete service_registry_; +} + +std::size_t io_service::run() +{ + boost::system::error_code ec; + std::size_t s = impl_.run(ec); + boost::asio::detail::throw_error(ec); + return s; +} + +std::size_t io_service::run(boost::system::error_code& ec) +{ + return impl_.run(ec); +} + +std::size_t io_service::run_one() +{ + boost::system::error_code ec; + std::size_t s = impl_.run_one(ec); + boost::asio::detail::throw_error(ec); + return s; +} + +std::size_t io_service::run_one(boost::system::error_code& ec) +{ + return impl_.run_one(ec); +} + +std::size_t io_service::poll() +{ + boost::system::error_code ec; + std::size_t s = impl_.poll(ec); + boost::asio::detail::throw_error(ec); + return s; +} + +std::size_t io_service::poll(boost::system::error_code& ec) +{ + return impl_.poll(ec); +} + +std::size_t io_service::poll_one() +{ + boost::system::error_code ec; + std::size_t s = impl_.poll_one(ec); + boost::asio::detail::throw_error(ec); + return s; +} + +std::size_t io_service::poll_one(boost::system::error_code& ec) +{ + return impl_.poll_one(ec); +} + +void io_service::stop() +{ + impl_.stop(); +} + +bool io_service::stopped() const +{ + return impl_.stopped(); +} + +void io_service::reset() +{ + impl_.reset(); +} + +void io_service::notify_fork(boost::asio::io_service::fork_event event) +{ + service_registry_->notify_fork(event); +} + +io_service::service::service(boost::asio::io_service& owner) + : owner_(owner), + next_(0) +{ +} + +io_service::service::~service() +{ +} + +void io_service::service::fork_service(boost::asio::io_service::fork_event) +{ +} + +service_already_exists::service_already_exists() + : std::logic_error("Service already exists.") +{ +} + +invalid_service_owner::invalid_service_owner() + : std::logic_error("Invalid service owner.") +{ +} + +} // namespace asio +} // namespace boost + +#include <boost/asio/detail/pop_options.hpp> + +#endif // BOOST_ASIO_IMPL_IO_SERVICE_IPP |