A Transport that communicates on a connected TCP socket. More...
#include <tcp-transport.hpp>
Public Member Functions | |
TcpTransport (protocol::socket &&socket, ndn::nfd::FacePersistency persistency) | |
Public Member Functions inherited from nfd::face::StreamTransport< boost::asio::ip::tcp > | |
StreamTransport (typename protocol::socket &&socket) | |
Construct stream transport. More... | |
Public Member Functions inherited from nfd::face::Transport | |
Transport () | |
constructor More... | |
virtual | ~Transport () |
void | setFaceAndLinkService (Face &face, LinkService &service) |
set Face and LinkService for Transport More... | |
const Face * | getFace () const |
const LinkService * | getLinkService () const |
LinkService * | getLinkService () |
virtual const Counters & | getCounters () const |
void | close () |
request the transport to be closed More... | |
void | send (Packet &&packet) |
send a link-layer packet More... | |
FaceUri | getLocalUri () const |
FaceUri | getRemoteUri () const |
ndn::nfd::FaceScope | getScope () const |
ndn::nfd::FacePersistency | getPersistency () const |
void | setPersistency (ndn::nfd::FacePersistency persistency) |
changes face persistency setting More... | |
ndn::nfd::LinkType | getLinkType () const |
ssize_t | getMtu () const |
TransportState | getState () const |
time::steady_clock::TimePoint | getExpirationTime () const |
Protected Member Functions | |
void | beforeChangePersistency (ndn::nfd::FacePersistency newPersistency) final |
invoked before persistency is changed More... | |
void | doClose () final |
performs Transport specific operations to close the transport More... | |
void | handleError (const boost::system::error_code &error) final |
Protected Member Functions inherited from nfd::face::StreamTransport< boost::asio::ip::tcp > | |
void | deferredClose () |
virtual void | doSend (Transport::Packet &&packet) override |
performs Transport specific operations to send a packet More... | |
void | sendFromQueue () |
void | handleSend (const boost::system::error_code &error, size_t nBytesSent) |
void | startReceive () |
void | handleReceive (const boost::system::error_code &error, size_t nBytesReceived) |
void | processErrorCode (const boost::system::error_code &error) |
void | resetReceiveBuffer () |
void | resetSendQueue () |
NFD_LOG_INCLASS_DECLARE () | |
Protected Member Functions inherited from nfd::face::Transport | |
void | receive (Packet &&packet) |
receive a link-layer packet More... | |
void | setLocalUri (const FaceUri &uri) |
void | setRemoteUri (const FaceUri &uri) |
void | setScope (ndn::nfd::FaceScope scope) |
void | setLinkType (ndn::nfd::LinkType linkType) |
void | setMtu (ssize_t mtu) |
void | setState (TransportState newState) |
set transport state More... | |
void | setExpirationTime (const time::steady_clock::TimePoint &expirationTime) |
Additional Inherited Members | |
Public Types inherited from nfd::face::StreamTransport< boost::asio::ip::tcp > | |
typedef boost::asio::ip::tcp | protocol |
Public Types inherited from nfd::face::Transport | |
typedef uint64_t | EndpointId |
identifies an endpoint on the link More... | |
typedef TransportCounters | Counters |
counters provided by Transport More... | |
Public Attributes inherited from nfd::face::Transport | |
signal::Signal< Transport, TransportState, TransportState > | afterStateChange |
signals when transport state changes More... | |
Protected Attributes inherited from nfd::face::StreamTransport< boost::asio::ip::tcp > | |
protocol::socket | m_socket |
Protected Attributes inherited from nfd::face::TransportCounters | |
PacketCounter | nInPackets |
count of incoming packets More... | |
PacketCounter | nOutPackets |
count of outgoing packets More... | |
ByteCounter | nInBytes |
total incoming bytes More... | |
ByteCounter | nOutBytes |
total outgoing bytes More... | |
A Transport that communicates on a connected TCP socket.
When persistency is set to permanent, whenever the TCP connection is severed, the transport state is set to DOWN, and the connection is retried periodically with exponential backoff until it is reestablished
Definition at line 42 of file tcp-transport.hpp.
nfd::face::TcpTransport::TcpTransport | ( | protocol::socket && | socket, |
ndn::nfd::FacePersistency | persistency | ||
) |
Definition at line 37 of file tcp-transport.cpp.
References ndn::nfd::FACE_SCOPE_LOCAL, ndn::nfd::FACE_SCOPE_NON_LOCAL, ndn::nfd::LINK_TYPE_POINT_TO_POINT, nfd::face::StreamTransport< boost::asio::ip::tcp >::m_socket, nfd::face::MTU_UNLIMITED, NFD_LOG_FACE_INFO, nfd::face::Transport::setLinkType(), nfd::face::Transport::setLocalUri(), nfd::face::Transport::setMtu(), nfd::face::Transport::setPersistency(), nfd::face::Transport::setRemoteUri(), and nfd::face::Transport::setScope().
|
finalprotectedvirtual |
invoked before persistency is changed
std::invalid_argument | new persistency is not supported |
std::runtime_error | transition is disallowed |
Implements nfd::face::Transport.
Definition at line 59 of file tcp-transport.cpp.
References doClose(), nfd::face::DOWN, ndn::nfd::FACE_PERSISTENCY_PERMANENT, nfd::face::FAILED, nfd::face::Transport::getPersistency(), nfd::face::Transport::getState(), and nfd::face::Transport::setState().
|
finalprotectedvirtual |
performs Transport specific operations to close the transport
This is invoked once by close()
after changing state to CLOSING. It will not be invoked by Transport class if the transport is already CLOSING or CLOSED.
When the cleanup procedure is complete, this method should change state to CLOSED. This transition can happen synchronously or asynchronously.
Reimplemented from nfd::face::StreamTransport< boost::asio::ip::tcp >.
Definition at line 158 of file tcp-transport.cpp.
References nfd::scheduler::ScopedEventId::cancel(), and nfd::face::StreamTransport< Protocol >::doClose().
Referenced by beforeChangePersistency().
|
finalprotectedvirtual |
Reimplemented from nfd::face::StreamTransport< boost::asio::ip::tcp >.
Definition at line 72 of file tcp-transport.cpp.
References nfd::scheduler::ScopedEventId::cancel(), nfd::face::CLOSED, nfd::face::CLOSING, nfd::face::DOWN, ndn::nfd::FACE_PERSISTENCY_PERMANENT, nfd::face::FAILED, nfd::getGlobalIoService(), nfd::face::Transport::getPersistency(), nfd::face::Transport::getState(), nfd::face::StreamTransport< Protocol >::handleError(), nfd::face::StreamTransport< boost::asio::ip::tcp >::m_socket, NFD_LOG_FACE_TRACE, nfd::detail::SimulatorIo::post(), nfd::face::StreamTransport< boost::asio::ip::tcp >::resetReceiveBuffer(), nfd::face::StreamTransport< boost::asio::ip::tcp >::resetSendQueue(), nfd::scheduler::schedule(), nfd::face::Transport::setLocalUri(), nfd::face::Transport::setState(), nfd::face::StreamTransport< boost::asio::ip::tcp >::startReceive(), and nfd::face::UP.