a transport using TCP socket More...
#include <tcp-transport.hpp>
Public Member Functions | |
TcpTransport (const std::string &host, const std::string &port="6363") | |
~TcpTransport () | |
virtual void | connect (boost::asio::io_service &ioService, const ReceiveCallback &receiveCallback) override |
asynchronously open the connection More... | |
virtual void | close () override |
Close the connection. More... | |
virtual void | pause () override |
pause the transport More... | |
virtual void | resume () override |
resume the transport More... | |
virtual void | send (const Block &wire) override |
send a TLV block through the transport More... | |
virtual void | send (const Block &header, const Block &payload) override |
send two memory blocks through the transport More... | |
NDN_CXX_PUBLIC_WITH_TESTS_ELSE_PRIVATE std::string | getSocketHostAndPortFromUri (const std::string &uri) |
Public Member Functions inherited from ndn::Transport | |
Transport () | |
virtual | ~Transport ()=default |
bool | isConnected () const |
bool | isReceiving () const |
Static Public Member Functions | |
static shared_ptr< TcpTransport > | create (const std::string &uri) |
Create transport with parameters defined in URI. More... | |
Public Attributes | |
NDN_CXX_PUBLIC_WITH_TESTS_ELSE_PRIVATE | __pad0__: static std::pair<std::string |
Friends | |
class | StreamTransportImpl< TcpTransport, boost::asio::ip::tcp > |
class | StreamTransportWithResolverImpl< TcpTransport, boost::asio::ip::tcp > |
Additional Inherited Members | |
Public Types inherited from ndn::Transport | |
typedef function< void(const Block &wire)> | ReceiveCallback |
typedef function< void()> | ErrorCallback |
Protected Member Functions inherited from ndn::Transport | |
void | receive (const Block &wire) |
invoke the receive callback More... | |
Protected Attributes inherited from ndn::Transport | |
boost::asio::io_service * | m_ioService |
bool | m_isConnected |
bool | m_isReceiving |
ReceiveCallback | m_receiveCallback |
a transport using TCP socket
Definition at line 46 of file tcp-transport.hpp.
|
explicit |
Definition at line 28 of file tcp-transport.cpp.
References ~TcpTransport().
|
default |
Referenced by TcpTransport().
|
overridevirtual |
asynchronously open the connection
ioService | io_service to create socket on |
receiveCallback | callback function when a TLV block is received; must not be empty |
boost::system::system_error | connection cannot be established |
Reimplemented from ndn::Transport.
Definition at line 77 of file tcp-transport.cpp.
References ndn::Transport::connect().
|
overridevirtual |
|
overridevirtual |
pause the transport
Implements ndn::Transport.
Definition at line 113 of file tcp-transport.cpp.
|
overridevirtual |
resume the transport
Implements ndn::Transport.
Definition at line 121 of file tcp-transport.cpp.
|
overridevirtual |
send a TLV block through the transport
Implements ndn::Transport.
Definition at line 91 of file tcp-transport.cpp.
send two memory blocks through the transport
Scatter/gather API is utilized to send two non-consecutive memory blocks together (as part of the same message in datagram-oriented transports).
Implements ndn::Transport.
Definition at line 98 of file tcp-transport.cpp.
|
static |
Create transport with parameters defined in URI.
Transport::Error | incorrect URI or unsupported protocol is specified |
Definition at line 37 of file tcp-transport.cpp.
References getSocketHostAndPortFromUri().
std::pair< std::string, std::string > ndn::TcpTransport::getSocketHostAndPortFromUri | ( | const std::string & | uri | ) |
Definition at line 44 of file tcp-transport.cpp.
References ndn::util::FaceUri::getHost(), ndn::util::FaceUri::getPort(), and ndn::util::FaceUri::getScheme().
Referenced by create().
|
friend |
Definition at line 88 of file tcp-transport.hpp.
|
friend |
Definition at line 89 of file tcp-transport.hpp.
NDN_CXX_PUBLIC_WITH_TESTS_ELSE_PRIVATE ndn::TcpTransport::__pad0__ |
Definition at line 80 of file tcp-transport.hpp.