Class implementing TCP-based channel to create faces. More...
#include <tcp-channel.hpp>
Public Member Functions | |
TcpChannel (const tcp::Endpoint &localEndpoint) | |
Create TCP channel for the local endpoint. More... | |
bool | isListening () const override |
Returns whether the channel is listening. More... | |
size_t | size () const override |
Returns the number of faces in the channel. More... | |
void | listen (const FaceCreatedCallback &onFaceCreated, const FaceCreationFailedCallback &onAcceptFailed, int backlog=boost::asio::ip::tcp::acceptor::max_connections) |
Enable listening on the local endpoint, accept connections, and create faces when remote host makes a connection. More... | |
void | connect (const tcp::Endpoint &remoteEndpoint, ndn::nfd::FacePersistency persistency, bool wantLocalFields, bool wantLpReliability, const FaceCreatedCallback &onFaceCreated, const FaceCreationFailedCallback &onConnectFailed, time::nanoseconds timeout=time::seconds(4)) |
Create a face by establishing a TCP connection to remoteEndpoint . More... | |
Public Member Functions inherited from nfd::face::Channel | |
virtual | ~Channel () |
const FaceUri & | getUri () const |
Additional Inherited Members | |
Protected Member Functions inherited from nfd::face::Channel | |
void | setUri (const FaceUri &uri) |
Class implementing TCP-based channel to create faces.
Channel can create faces as a response to incoming TCP connections (TcpChannel::listen needs to be called for that to work) or explicitly after using TcpChannel::connect method.
Definition at line 47 of file tcp-channel.hpp.
|
explicit |
Create TCP channel for the local endpoint.
To enable creation faces upon incoming connections, one needs to explicitly call TcpChannel::listen method.
Definition at line 38 of file tcp-channel.cpp.
References NFD_LOG_CHAN_INFO, and nfd::face::Channel::setUri().
|
inlineoverridevirtual |
Returns whether the channel is listening.
Implements nfd::face::Channel.
Definition at line 60 of file tcp-channel.hpp.
Referenced by listen().
|
inlineoverridevirtual |
Returns the number of faces in the channel.
Implements nfd::face::Channel.
Definition at line 66 of file tcp-channel.hpp.
References websocketpp::extensions::permessage_deflate::mode::accept, websocketpp::transport::asio::socket::error::socket, and websocketpp::transport::error::timeout.
void nfd::face::TcpChannel::listen | ( | const FaceCreatedCallback & | onFaceCreated, |
const FaceCreationFailedCallback & | onAcceptFailed, | ||
int | backlog = boost::asio::ip::tcp::acceptor::max_connections |
||
) |
Enable listening on the local endpoint, accept connections, and create faces when remote host makes a connection.
onFaceCreated | Callback to notify successful creation of the face |
onAcceptFailed | Callback to notify when channel fails (accept call returns an error) |
backlog | The maximum length of the queue of pending incoming connections |
Definition at line 48 of file tcp-channel.cpp.
References websocketpp::extensions::permessage_deflate::mode::accept, isListening(), NFD_LOG_CHAN_DEBUG, and NFD_LOG_CHAN_WARN.
void nfd::face::TcpChannel::connect | ( | const tcp::Endpoint & | remoteEndpoint, |
ndn::nfd::FacePersistency | persistency, | ||
bool | wantLocalFields, | ||
bool | wantLpReliability, | ||
const FaceCreatedCallback & | onFaceCreated, | ||
const FaceCreationFailedCallback & | onConnectFailed, | ||
time::nanoseconds | timeout = time::seconds(4) |
||
) |
Create a face by establishing a TCP connection to remoteEndpoint
.
Definition at line 70 of file tcp-channel.cpp.
References websocketpp::extensions::permessage_deflate::mode::accept, nfd::face::GenericLinkService::Options::allowLocalFields, nfd::scheduler::cancel(), nfd::face::connectFaceClosedSignal(), ndn::nfd::FACE_PERSISTENCY_ON_DEMAND, nfd::getGlobalIoService(), nfd::face::LpReliability::Options::isEnabled, NFD_LOG_CHAN_DEBUG, NFD_LOG_CHAN_TRACE, websocketpp::transport::error::operation_aborted, nfd::face::GenericLinkService::Options::reliabilityOptions, nfd::scheduler::schedule(), and websocketpp::transport::asio::socket::error::socket.