implementation detail of a Boost.Asio-based stream-oriented transport with resolver support More...
#include <stream-transport-with-resolver-impl.hpp>
Public Types | |
using | Impl = StreamTransportWithResolverImpl< BaseTransport, Protocol > |
Public Types inherited from ndn::StreamTransportImpl< BaseTransport, Protocol > | |
typedef StreamTransportImpl< BaseTransport, Protocol > | Impl |
typedef std::list< Block > | BlockSequence |
typedef std::list< BlockSequence > | TransmissionQueue |
Public Member Functions | |
StreamTransportWithResolverImpl (BaseTransport &transport, boost::asio::io_service &ioService) | |
void | connect (const typename Protocol::resolver::query &query) |
Public Member Functions inherited from ndn::StreamTransportImpl< BaseTransport, Protocol > | |
StreamTransportImpl (BaseTransport &transport, boost::asio::io_service &ioService) | |
void | connect (const typename Protocol::endpoint &endpoint) |
void | close () |
void | pause () |
void | resume () |
void | send (const Block &wire) |
void | send (const Block &header, const Block &payload) |
Protected Member Functions | |
void | resolveHandler (const boost::system::error_code &error, typename Protocol::resolver::iterator endpoint, const shared_ptr< typename Protocol::resolver > &) |
Protected Member Functions inherited from ndn::StreamTransportImpl< BaseTransport, Protocol > | |
void | connectHandler (const boost::system::error_code &error) |
void | connectTimeoutHandler (const boost::system::error_code &error) |
void | send (BlockSequence &&sequence) |
void | asyncWrite () |
void | handleAsyncWrite (const boost::system::error_code &error, TransmissionQueue::iterator queueItem) |
void | asyncReceive () |
void | handleAsyncReceive (const boost::system::error_code &error, std::size_t nBytesRecvd) |
bool | processAllReceived (uint8_t *buffer, size_t &offset, size_t nBytesAvailable) |
Additional Inherited Members | |
Protected Attributes inherited from ndn::StreamTransportImpl< BaseTransport, Protocol > | |
BaseTransport & | m_transport |
Protocol::socket | m_socket |
uint8_t | m_inputBuffer [MAX_NDN_PACKET_SIZE] |
size_t | m_inputBufferSize |
TransmissionQueue | m_transmissionQueue |
bool | m_isConnecting |
boost::asio::deadline_timer | m_connectTimer |
implementation detail of a Boost.Asio-based stream-oriented transport with resolver support
Definition at line 33 of file stream-transport-with-resolver-impl.hpp.
using ndn::StreamTransportWithResolverImpl< BaseTransport, Protocol >::Impl = StreamTransportWithResolverImpl<BaseTransport,Protocol> |
Definition at line 36 of file stream-transport-with-resolver-impl.hpp.
|
inline |
Definition at line 38 of file stream-transport-with-resolver-impl.hpp.
|
inline |
Definition at line 44 of file stream-transport-with-resolver-impl.hpp.
References ndn::StreamTransportImpl< BaseTransport, Protocol >::connectTimeoutHandler(), ndn::StreamTransportImpl< BaseTransport, Protocol >::m_connectTimer, ndn::StreamTransportImpl< BaseTransport, Protocol >::m_isConnecting, ndn::StreamTransportImpl< BaseTransport, Protocol >::m_socket, and ndn::StreamTransportWithResolverImpl< BaseTransport, Protocol >::resolveHandler().
|
inlineprotected |
Definition at line 63 of file stream-transport-with-resolver-impl.hpp.
References ndn::StreamTransportImpl< BaseTransport, Protocol >::connectHandler(), ndn::StreamTransportImpl< BaseTransport, Protocol >::m_socket, ndn::StreamTransportImpl< BaseTransport, Protocol >::m_transport, and websocketpp::error::operation_canceled.
Referenced by ndn::StreamTransportWithResolverImpl< BaseTransport, Protocol >::connect().