#include <reactive_socket_service.hpp>

Public Types | |
| enum | { max_buffers = 16 } |
| typedef Protocol | protocol_type |
| typedef Protocol::endpoint | endpoint_type |
| typedef socket_type | native_type |
Public Member Functions | |
| reactive_socket_service (asio::io_service &io_service) | |
| void | shutdown_service () |
| Destroy all user-defined handler objects owned by the service. | |
| void | construct (implementation_type &impl) |
| void | destroy (implementation_type &impl) |
| asio::error_code | open (implementation_type &impl, const protocol_type &protocol, asio::error_code &ec) |
| asio::error_code | assign (implementation_type &impl, const protocol_type &protocol, const native_type &native_socket, asio::error_code &ec) |
| bool | is_open (const implementation_type &impl) const |
| asio::error_code | close (implementation_type &impl, asio::error_code &ec) |
| native_type | native (implementation_type &impl) |
| asio::error_code | cancel (implementation_type &impl, asio::error_code &ec) |
| bool | at_mark (const implementation_type &impl, asio::error_code &ec) const |
| std::size_t | available (const implementation_type &impl, asio::error_code &ec) const |
| asio::error_code | bind (implementation_type &impl, const endpoint_type &endpoint, asio::error_code &ec) |
| asio::error_code | listen (implementation_type &impl, int backlog, asio::error_code &ec) |
| template<typename Option> | |
| asio::error_code | set_option (implementation_type &impl, const Option &option, asio::error_code &ec) |
| template<typename Option> | |
| asio::error_code | get_option (const implementation_type &impl, Option &option, asio::error_code &ec) const |
| template<typename IO_Control_Command> | |
| asio::error_code | io_control (implementation_type &impl, IO_Control_Command &command, asio::error_code &ec) |
| endpoint_type | local_endpoint (const implementation_type &impl, asio::error_code &ec) const |
| endpoint_type | remote_endpoint (const implementation_type &impl, asio::error_code &ec) const |
| asio::error_code | shutdown (implementation_type &impl, socket_base::shutdown_type what, asio::error_code &ec) |
| Disable sends or receives on the socket. | |
| template<typename ConstBufferSequence> | |
| size_t | send (implementation_type &impl, const ConstBufferSequence &buffers, socket_base::message_flags flags, asio::error_code &ec) |
| template<typename ConstBufferSequence, typename Handler> | |
| void | async_send (implementation_type &impl, const ConstBufferSequence &buffers, socket_base::message_flags flags, Handler handler) |
| template<typename ConstBufferSequence> | |
| size_t | send_to (implementation_type &impl, const ConstBufferSequence &buffers, const endpoint_type &destination, socket_base::message_flags flags, asio::error_code &ec) |
| template<typename ConstBufferSequence, typename Handler> | |
| void | async_send_to (implementation_type &impl, const ConstBufferSequence &buffers, const endpoint_type &destination, socket_base::message_flags flags, Handler handler) |
| template<typename MutableBufferSequence> | |
| size_t | receive (implementation_type &impl, const MutableBufferSequence &buffers, socket_base::message_flags flags, asio::error_code &ec) |
| template<typename MutableBufferSequence, typename Handler> | |
| void | async_receive (implementation_type &impl, const MutableBufferSequence &buffers, socket_base::message_flags flags, Handler handler) |
| template<typename MutableBufferSequence> | |
| size_t | receive_from (implementation_type &impl, const MutableBufferSequence &buffers, endpoint_type &sender_endpoint, socket_base::message_flags flags, asio::error_code &ec) |
| template<typename MutableBufferSequence, typename Handler> | |
| void | async_receive_from (implementation_type &impl, const MutableBufferSequence &buffers, endpoint_type &sender_endpoint, socket_base::message_flags flags, Handler handler) |
| template<typename Socket> | |
| asio::error_code | accept (implementation_type &impl, Socket &peer, endpoint_type *peer_endpoint, asio::error_code &ec) |
| template<typename Socket, typename Handler> | |
| void | async_accept (implementation_type &impl, Socket &peer, endpoint_type *peer_endpoint, Handler handler) |
| asio::error_code | connect (implementation_type &impl, const endpoint_type &peer_endpoint, asio::error_code &ec) |
| template<typename Handler> | |
| void | async_connect (implementation_type &impl, const endpoint_type &peer_endpoint, Handler handler) |
Private Attributes | |
| Reactor & | reactor_ |
Classes | |
| class | accept_handler |
| class | connect_handler |
| class | implementation_type |
| class | receive_from_handler |
| class | receive_handler |
| class | send_handler |
| class | send_to_handler |
Definition at line 39 of file reactive_socket_service.hpp.
| typedef Protocol asio::detail::reactive_socket_service< Protocol, Reactor >::protocol_type |
Definition at line 45 of file reactive_socket_service.hpp.
| typedef Protocol::endpoint asio::detail::reactive_socket_service< Protocol, Reactor >::endpoint_type |
Definition at line 48 of file reactive_socket_service.hpp.
| typedef socket_type asio::detail::reactive_socket_service< Protocol, Reactor >::native_type |
Definition at line 51 of file reactive_socket_service.hpp.
| anonymous enum |
| asio::detail::reactive_socket_service< Protocol, Reactor >::reactive_socket_service | ( | asio::io_service & | io_service | ) | [inline] |
Definition at line 92 of file reactive_socket_service.hpp.
| void asio::detail::reactive_socket_service< Protocol, Reactor >::shutdown_service | ( | ) | [inline, virtual] |
Destroy all user-defined handler objects owned by the service.
Implements asio::io_service::service.
Definition at line 100 of file reactive_socket_service.hpp.
| void asio::detail::reactive_socket_service< Protocol, Reactor >::construct | ( | implementation_type & | impl | ) | [inline] |
Definition at line 105 of file reactive_socket_service.hpp.
References asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::invalid_socket, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::construct(), asio::socket_acceptor_service< Protocol >::construct(), and asio::datagram_socket_service< Protocol >::construct().
| void asio::detail::reactive_socket_service< Protocol, Reactor >::destroy | ( | implementation_type & | impl | ) | [inline] |
Definition at line 112 of file reactive_socket_service.hpp.
References asio::detail::socket_ops::close(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::detail::invalid_socket, asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, asio::detail::socket_ops::setsockopt(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_linger.
Referenced by asio::stream_socket_service< Protocol >::destroy(), asio::socket_acceptor_service< Protocol >::destroy(), and asio::datagram_socket_service< Protocol >::destroy().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::open | ( | implementation_type & | impl, | |
| const protocol_type & | protocol, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 144 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::already_open, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_holder::get(), asio::detail::invalid_socket, asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::native_ecat, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, asio::detail::socket_holder::release(), asio::detail::socket_ops::socket(), and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::open(), asio::socket_acceptor_service< Protocol >::open(), and asio::datagram_socket_service< Protocol >::open().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::assign | ( | implementation_type & | impl, | |
| const protocol_type & | protocol, | |||
| const native_type & | native_socket, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 172 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::already_open, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::native_ecat, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::assign(), asio::socket_acceptor_service< Protocol >::assign(), and asio::datagram_socket_service< Protocol >::assign().
| bool asio::detail::reactive_socket_service< Protocol, Reactor >::is_open | ( | const implementation_type & | impl | ) | const [inline] |
Definition at line 196 of file reactive_socket_service.hpp.
References asio::detail::invalid_socket, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::detail::reactive_socket_service< Protocol, Reactor >::accept(), asio::detail::reactive_socket_service< Protocol, Reactor >::assign(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_accept(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_connect(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_receive(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_receive_from(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_send(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_send_to(), asio::detail::reactive_socket_service< Protocol, Reactor >::at_mark(), asio::detail::reactive_socket_service< Protocol, Reactor >::available(), asio::detail::reactive_socket_service< Protocol, Reactor >::bind(), asio::detail::reactive_socket_service< Protocol, Reactor >::cancel(), asio::detail::reactive_socket_service< Protocol, Reactor >::close(), asio::detail::reactive_socket_service< Protocol, Reactor >::connect(), asio::detail::reactive_socket_service< Protocol, Reactor >::get_option(), asio::detail::reactive_socket_service< Protocol, Reactor >::io_control(), asio::stream_socket_service< Protocol >::is_open(), asio::socket_acceptor_service< Protocol >::is_open(), asio::datagram_socket_service< Protocol >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::listen(), asio::detail::reactive_socket_service< Protocol, Reactor >::local_endpoint(), asio::detail::reactive_socket_service< Protocol, Reactor >::open(), asio::detail::reactive_socket_service< Protocol, Reactor >::receive(), asio::detail::reactive_socket_service< Protocol, Reactor >::receive_from(), asio::detail::reactive_socket_service< Protocol, Reactor >::remote_endpoint(), asio::detail::reactive_socket_service< Protocol, Reactor >::send(), asio::detail::reactive_socket_service< Protocol, Reactor >::send_to(), asio::detail::reactive_socket_service< Protocol, Reactor >::set_option(), and asio::detail::reactive_socket_service< Protocol, Reactor >::shutdown().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::close | ( | implementation_type & | impl, | |
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 202 of file reactive_socket_service.hpp.
References asio::detail::socket_ops::close(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::detail::invalid_socket, asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, and asio::detail::socket_error_retval.
Referenced by asio::stream_socket_service< Protocol >::close(), asio::socket_acceptor_service< Protocol >::close(), and asio::datagram_socket_service< Protocol >::close().
| native_type asio::detail::reactive_socket_service< Protocol, Reactor >::native | ( | implementation_type & | impl | ) | [inline] |
Definition at line 228 of file reactive_socket_service.hpp.
References asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::native(), asio::socket_acceptor_service< Protocol >::native(), and asio::datagram_socket_service< Protocol >::native().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::cancel | ( | implementation_type & | impl, | |
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 234 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::cancel(), asio::socket_acceptor_service< Protocol >::cancel(), and asio::datagram_socket_service< Protocol >::cancel().
| bool asio::detail::reactive_socket_service< Protocol, Reactor >::at_mark | ( | const implementation_type & | impl, | |
| asio::error_code & | ec | |||
| ) | const [inline] |
Definition at line 249 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::error_base< T >::not_socket, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, and asio::error_code::value().
Referenced by asio::stream_socket_service< Protocol >::at_mark(), and asio::datagram_socket_service< Protocol >::at_mark().
| std::size_t asio::detail::reactive_socket_service< Protocol, Reactor >::available | ( | const implementation_type & | impl, | |
| asio::error_code & | ec | |||
| ) | const [inline] |
Definition at line 268 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::error_base< T >::not_socket, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, and asio::error_code::value().
Referenced by asio::stream_socket_service< Protocol >::available(), and asio::datagram_socket_service< Protocol >::available().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::bind | ( | implementation_type & | impl, | |
| const endpoint_type & | endpoint, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 287 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::socket_ops::bind(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::bind(), asio::socket_acceptor_service< Protocol >::bind(), and asio::datagram_socket_service< Protocol >::bind().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::listen | ( | implementation_type & | impl, | |
| int | backlog, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 301 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::socket_ops::listen(), and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::socket_acceptor_service< Protocol >::listen().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::set_option | ( | implementation_type & | impl, | |
| const Option & | option, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 316 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::custom_socket_option_level, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::enable_connection_aborted, asio::detail::enable_connection_aborted_option, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::error_base< T >::invalid_argument, asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::socket_ops::setsockopt(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_linger.
Referenced by asio::stream_socket_service< Protocol >::set_option(), asio::socket_acceptor_service< Protocol >::set_option(), and asio::datagram_socket_service< Protocol >::set_option().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::get_option | ( | const implementation_type & | impl, | |
| Option & | option, | |||
| asio::error_code & | ec | |||
| ) | const [inline] |
Definition at line 359 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::custom_socket_option_level, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::enable_connection_aborted, asio::detail::enable_connection_aborted_option, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_ops::getsockopt(), asio::detail::error_base< T >::invalid_argument, asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::get_option(), asio::socket_acceptor_service< Protocol >::get_option(), and asio::datagram_socket_service< Protocol >::get_option().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::io_control | ( | implementation_type & | impl, | |
| IO_Control_Command & | command, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 401 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_non_blocking.
Referenced by asio::stream_socket_service< Protocol >::io_control(), asio::socket_acceptor_service< Protocol >::io_control(), and asio::datagram_socket_service< Protocol >::io_control().
| endpoint_type asio::detail::reactive_socket_service< Protocol, Reactor >::local_endpoint | ( | const implementation_type & | impl, | |
| asio::error_code & | ec | |||
| ) | const [inline] |
Definition at line 427 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::socket_ops::getsockname(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::local_endpoint(), asio::socket_acceptor_service< Protocol >::local_endpoint(), and asio::datagram_socket_service< Protocol >::local_endpoint().
| endpoint_type asio::detail::reactive_socket_service< Protocol, Reactor >::remote_endpoint | ( | const implementation_type & | impl, | |
| asio::error_code & | ec | |||
| ) | const [inline] |
Definition at line 445 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::socket_ops::getpeername(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::remote_endpoint(), and asio::datagram_socket_service< Protocol >::remote_endpoint().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::shutdown | ( | implementation_type & | impl, | |
| socket_base::shutdown_type | what, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Disable sends or receives on the socket.
Definition at line 463 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::socket_ops::shutdown(), and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::shutdown(), and asio::datagram_socket_service< Protocol >::shutdown().
| size_t asio::detail::reactive_socket_service< Protocol, Reactor >::send | ( | implementation_type & | impl, | |
| const ConstBufferSequence & | buffers, | |||
| socket_base::message_flags | flags, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 478 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::buffer(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_ops::init_buf(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::max_buffers, asio::detail::socket_ops::poll_write(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::socket_ops::send(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, asio::detail::error_base< T >::try_again, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_non_blocking, and asio::detail::error_base< T >::would_block.
Referenced by asio::stream_socket_service< Protocol >::send(), and asio::datagram_socket_service< Protocol >::send().
| void asio::detail::reactive_socket_service< Protocol, Reactor >::async_send | ( | implementation_type & | impl, | |
| const ConstBufferSequence & | buffers, | |||
| socket_base::message_flags | flags, | |||
| Handler | handler | |||
| ) | [inline] |
Definition at line 594 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::bind_handler(), asio::buffer(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::io_service::service::io_service(), asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::max_buffers, asio::io_service::post(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::async_send(), and asio::datagram_socket_service< Protocol >::async_send().
| size_t asio::detail::reactive_socket_service< Protocol, Reactor >::send_to | ( | implementation_type & | impl, | |
| const ConstBufferSequence & | buffers, | |||
| const endpoint_type & | destination, | |||
| socket_base::message_flags | flags, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 648 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::buffer(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_ops::init_buf(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::max_buffers, asio::detail::socket_ops::poll_write(), asio::detail::socket_ops::sendto(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, asio::detail::error_base< T >::try_again, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_non_blocking, and asio::detail::error_base< T >::would_block.
Referenced by asio::datagram_socket_service< Protocol >::send_to().
| void asio::detail::reactive_socket_service< Protocol, Reactor >::async_send_to | ( | implementation_type & | impl, | |
| const ConstBufferSequence & | buffers, | |||
| const endpoint_type & | destination, | |||
| socket_base::message_flags | flags, | |||
| Handler | handler | |||
| ) | [inline] |
Definition at line 760 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::bind_handler(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::io_service::service::io_service(), asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::io_service::post(), asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::datagram_socket_service< Protocol >::async_send_to().
| size_t asio::detail::reactive_socket_service< Protocol, Reactor >::receive | ( | implementation_type & | impl, | |
| const MutableBufferSequence & | buffers, | |||
| socket_base::message_flags | flags, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 794 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::buffer(), asio::detail::error_base< T >::eof, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_ops::init_buf(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::max_buffers, asio::detail::socket_ops::poll_read(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::socket_ops::recv(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, asio::detail::error_base< T >::try_again, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_non_blocking, and asio::detail::error_base< T >::would_block.
Referenced by asio::stream_socket_service< Protocol >::receive(), and asio::datagram_socket_service< Protocol >::receive().
| void asio::detail::reactive_socket_service< Protocol, Reactor >::async_receive | ( | implementation_type & | impl, | |
| const MutableBufferSequence & | buffers, | |||
| socket_base::message_flags | flags, | |||
| Handler | handler | |||
| ) | [inline] |
Definition at line 920 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::bind_handler(), asio::buffer(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::io_service::service::io_service(), asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::max_buffers, asio::detail::message_out_of_band, asio::io_service::post(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::async_receive(), and asio::datagram_socket_service< Protocol >::async_receive().
| size_t asio::detail::reactive_socket_service< Protocol, Reactor >::receive_from | ( | implementation_type & | impl, | |
| const MutableBufferSequence & | buffers, | |||
| endpoint_type & | sender_endpoint, | |||
| socket_base::message_flags | flags, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 984 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::buffer(), asio::detail::error_base< T >::eof, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_ops::init_buf(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::reactive_socket_service< Protocol, Reactor >::max_buffers, asio::detail::socket_ops::poll_read(), asio::detail::socket_ops::recvfrom(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, asio::detail::error_base< T >::try_again, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_non_blocking, and asio::detail::error_base< T >::would_block.
Referenced by asio::datagram_socket_service< Protocol >::receive_from().
| void asio::detail::reactive_socket_service< Protocol, Reactor >::async_receive_from | ( | implementation_type & | impl, | |
| const MutableBufferSequence & | buffers, | |||
| endpoint_type & | sender_endpoint, | |||
| socket_base::message_flags | flags, | |||
| Handler | handler | |||
| ) | [inline] |
Definition at line 1114 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::bind_handler(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::io_service::service::io_service(), asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::io_service::post(), asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::datagram_socket_service< Protocol >::async_receive_from().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::accept | ( | implementation_type & | impl, | |
| Socket & | peer, | |||
| endpoint_type * | peer_endpoint, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 1147 of file reactive_socket_service.hpp.
References asio::detail::socket_ops::accept(), asio::detail::error_base< T >::already_open, asio::detail::error_base< T >::bad_descriptor, asio::detail::error_base< T >::connection_aborted, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::enable_connection_aborted, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::socket_holder::get(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::detail::socket_ops::poll_read(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::socket_holder::release(), asio::detail::socket_holder::reset(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, asio::detail::error_base< T >::try_again, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::user_set_non_blocking, and asio::detail::error_base< T >::would_block.
Referenced by asio::socket_acceptor_service< Protocol >::accept().
| void asio::detail::reactive_socket_service< Protocol, Reactor >::async_accept | ( | implementation_type & | impl, | |
| Socket & | peer, | |||
| endpoint_type * | peer_endpoint, | |||
| Handler | handler | |||
| ) | [inline] |
Definition at line 1294 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::already_open, asio::detail::error_base< T >::bad_descriptor, asio::detail::bind_handler(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::enable_connection_aborted, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::io_service::service::io_service(), asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::io_service::post(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::protocol_, asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::socket_acceptor_service< Protocol >::async_accept().
| asio::error_code asio::detail::reactive_socket_service< Protocol, Reactor >::connect | ( | implementation_type & | impl, | |
| const endpoint_type & | peer_endpoint, | |||
| asio::error_code & | ec | |||
| ) | [inline] |
Definition at line 1332 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::socket_ops::connect(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), and asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_.
Referenced by asio::stream_socket_service< Protocol >::connect(), and asio::datagram_socket_service< Protocol >::connect().
| void asio::detail::reactive_socket_service< Protocol, Reactor >::async_connect | ( | implementation_type & | impl, | |
| const endpoint_type & | peer_endpoint, | |||
| Handler | handler | |||
| ) | [inline] |
Definition at line 1425 of file reactive_socket_service.hpp.
References asio::detail::error_base< T >::bad_descriptor, asio::detail::bind_handler(), asio::detail::socket_ops::connect(), asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::flags_, asio::detail::error_base< T >::in_progress, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::internal_non_blocking, asio::io_service::service::io_service(), asio::detail::socket_ops::ioctl(), asio::detail::reactive_socket_service< Protocol, Reactor >::is_open(), asio::io_service::post(), asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_, asio::detail::reactive_socket_service< Protocol, Reactor >::implementation_type::socket_, and asio::detail::error_base< T >::would_block.
Referenced by asio::stream_socket_service< Protocol >::async_connect(), and asio::datagram_socket_service< Protocol >::async_connect().
Reactor& asio::detail::reactive_socket_service< Protocol, Reactor >::reactor_ [private] |
Definition at line 1478 of file reactive_socket_service.hpp.
Referenced by asio::detail::reactive_socket_service< Protocol, Reactor >::assign(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_accept(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_connect(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_receive(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_receive_from(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_send(), asio::detail::reactive_socket_service< Protocol, Reactor >::async_send_to(), asio::detail::reactive_socket_service< Protocol, Reactor >::cancel(), asio::detail::reactive_socket_service< Protocol, Reactor >::close(), asio::detail::reactive_socket_service< Protocol, Reactor >::destroy(), and asio::detail::reactive_socket_service< Protocol, Reactor >::open().
1.5.6