13 #include <netinet/in.h>
14 #include <boost/shared_ptr.hpp>
15 #include <sys/socket.h>
28 work_(new
boost::asio::io_service::work(io_service_)) {
49 io_service_.run_one();
71 return (io_service_.stopped());
98 void post(
const std::function<
void ()>& callback) {
99 io_service_.post(callback);
103 boost::asio::io_service io_service_;
104 boost::shared_ptr<boost::asio::io_service::work> work_;
135 return (io_impl_->stopped());
145 io_impl_->stopWork();
148 boost::asio::io_service&
150 return (io_impl_->get_io_service());
155 return (io_impl_->post(callback));
IOServiceImpl()
The constructor.
void run_one()
Run the underlying event loop for a single event.
void poll()
Run the underlying event loop for a ready events.
boost::asio::io_service & get_io_service()
Return the native io_service object used in this wrapper.
void run()
Start the underlying event loop.
void stopWork()
Removes IO service work object to let it finish running when all handlers have been invoked.
~IOServiceImpl()
The destructor.
void stop()
Stop the underlying event loop.
void restart()
Restarts the IOService in preparation for a subsequent run() invocation.
void post(const std::function< void()> &callback)
Post a callback on the IO service.
bool stopped() const
Indicates if the IOService has been stopped.
The IOService class is a wrapper for the ASIO io_service class.
void run_one()
Run the underlying event loop for a single event.
~IOService()
The destructor.
void run()
Start the underlying event loop.
IOService()
The constructor.
boost::asio::io_service & get_io_service()
Return the native io_service object used in this wrapper.
void stop()
Stop the underlying event loop.
void restart()
Restarts the IOService in preparation for a subsequent run() invocation.
bool stopped() const
Indicates if the IOService has been stopped.
void stopWork()
Removes IO service work object to let it finish running when all handlers have been invoked.
void poll()
Run the underlying event loop for a ready events.
void post(const std::function< void()> &callback)
Post a callback to the end of the queue.
A wrapper interface for the ASIO library.
Defines the logger used by the top-level component of kea-lfc.