1//
2// impl/io_service.ipp
3// ~~~~~~~~~~~~~~~~~~~
4//
5// Copyright (c) 2003-2015 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
11#ifndef BOOST_ASIO_IMPL_IO_SERVICE_IPP
12#define BOOST_ASIO_IMPL_IO_SERVICE_IPP
13
14#if defined(_MSC_VER) && (_MSC_VER >= 1200)
15# pragma once
16#endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
17
18#include <boost/asio/detail/config.hpp>
19#include <boost/asio/io_service.hpp>
20#include <boost/asio/detail/limits.hpp>
21#include <boost/asio/detail/scoped_ptr.hpp>
22#include <boost/asio/detail/service_registry.hpp>
23#include <boost/asio/detail/throw_error.hpp>
24
25#if defined(BOOST_ASIO_HAS_IOCP)
26# include <boost/asio/detail/win_iocp_io_service.hpp>
27#else
28# include <boost/asio/detail/task_io_service.hpp>
29#endif
30
31#include <boost/asio/detail/push_options.hpp>
32
33namespace boost {
34namespace asio {
35
36io_service::io_service()
37 : service_registry_(new boost::asio::detail::service_registry(
38 *this, static_cast<impl_type*>(0),
39 (std::numeric_limits<std::size_t>::max)())),
40 impl_(service_registry_->first_service<impl_type>())
41{
42}
43
44io_service::io_service(std::size_t concurrency_hint)
45 : service_registry_(new boost::asio::detail::service_registry(
46 *this, static_cast<impl_type*>(0), concurrency_hint)),
47 impl_(service_registry_->first_service<impl_type>())
48{
49}
50
51io_service::~io_service()
52{
53 delete service_registry_;
54}
55
56std::size_t io_service::run()
57{
58 boost::system::error_code ec;
59 std::size_t s = impl_.run(ec);
60 boost::asio::detail::throw_error(ec);
61 return s;
62}
63
64std::size_t io_service::run(boost::system::error_code& ec)
65{
66 return impl_.run(ec);
67}
68
69std::size_t io_service::run_one()
70{
71 boost::system::error_code ec;
72 std::size_t s = impl_.run_one(ec);
73 boost::asio::detail::throw_error(ec);
74 return s;
75}
76
77std::size_t io_service::run_one(boost::system::error_code& ec)
78{
79 return impl_.run_one(ec);
80}
81
82std::size_t io_service::poll()
83{
84 boost::system::error_code ec;
85 std::size_t s = impl_.poll(ec);
86 boost::asio::detail::throw_error(ec);
87 return s;
88}
89
90std::size_t io_service::poll(boost::system::error_code& ec)
91{
92 return impl_.poll(ec);
93}
94
95std::size_t io_service::poll_one()
96{
97 boost::system::error_code ec;
98 std::size_t s = impl_.poll_one(ec);
99 boost::asio::detail::throw_error(ec);
100 return s;
101}
102
103std::size_t io_service::poll_one(boost::system::error_code& ec)
104{
105 return impl_.poll_one(ec);
106}
107
108void io_service::stop()
109{
110 impl_.stop();
111}
112
113bool io_service::stopped() const
114{
115 return impl_.stopped();
116}
117
118void io_service::reset()
119{
120 impl_.reset();
121}
122
123void io_service::notify_fork(boost::asio::io_service::fork_event event)
124{
125 service_registry_->notify_fork(event);
126}
127
128io_service::service::service(boost::asio::io_service& owner)
129 : owner_(owner),
130 next_(0)
131{
132}
133
134io_service::service::~service()
135{
136}
137
138void io_service::service::fork_service(boost::asio::io_service::fork_event)
139{
140}
141
142service_already_exists::service_already_exists()
143 : std::logic_error("Service already exists.")
144{
145}
146
147invalid_service_owner::invalid_service_owner()
148 : std::logic_error("Invalid service owner.")
149{
150}
151
152} // namespace asio
153} // namespace boost
154
155#include <boost/asio/detail/pop_options.hpp>
156
157#endif // BOOST_ASIO_IMPL_IO_SERVICE_IPP
158

source code of boost/boost/asio/impl/io_service.ipp