Implements Transport for stream-based protocols. More...
#include <stream-transport.hpp>
Public Types | |
typedef Protocol | 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 Member Functions | |
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 | |
virtual void | doClose () 1 |
performs Transport specific operations to close the transport More... | |
void | deferredClose () |
virtual void | doSend (Transport::Packet &&packet) 1 |
performs Transport specific operations to send a packet More... | |
void | sendFromQueue () |
void | handleSend (const boost::system::error_code &error, size_t nBytesSent) |
void | handleReceive (const boost::system::error_code &error, size_t nBytesReceived) |
void | processErrorCode (const boost::system::error_code &error) |
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) |
virtual void | beforeChangePersistency (ndn::nfd::FacePersistency newPersistency)=0 |
invoked before persistency is changed More... | |
Protected Attributes | |
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... | |
Additional Inherited Members | |
Public Attributes inherited from nfd::face::Transport | |
signal::Signal< Transport, TransportState, TransportState > | afterStateChange |
signals when transport state changes More... | |
Implements Transport for stream-based protocols.
Protocol | a stream-based protocol in Boost.Asio |
Definition at line 42 of file stream-transport.hpp.
typedef Protocol nfd::face::StreamTransport< Protocol >::protocol |
Definition at line 45 of file stream-transport.hpp.
|
explicit |
Construct stream transport.
socket | Protocol-specific socket for the created transport |
Definition at line 91 of file stream-transport.hpp.
|
protectedvirtual |
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.
Implements nfd::face::Transport.
Reimplemented in nfd::face::DECL_CLASS_FINAL, and nfd::face::DECL_CLASS_FINAL.
Definition at line 103 of file stream-transport.hpp.
Referenced by nfd::face::StreamTransport< boost::asio::local::stream_protocol >::handleReceive(), and nfd::face::StreamTransport< boost::asio::local::stream_protocol >::processErrorCode().
|
protected |
Definition at line 135 of file stream-transport.hpp.
|
protectedvirtual |
performs Transport specific operations to send a packet
packet | the packet, which must be a well-formed TLV block |
Implements nfd::face::Transport.
Definition at line 152 of file stream-transport.hpp.
|
protected |
Definition at line 165 of file stream-transport.hpp.
Referenced by nfd::face::StreamTransport< boost::asio::local::stream_protocol >::doSend(), and nfd::face::StreamTransport< boost::asio::local::stream_protocol >::handleSend().
|
protected |
Definition at line 175 of file stream-transport.hpp.
|
protected |
Definition at line 192 of file stream-transport.hpp.
|
protected |
Definition at line 243 of file stream-transport.hpp.
Referenced by nfd::face::StreamTransport< boost::asio::local::stream_protocol >::handleReceive(), and nfd::face::StreamTransport< boost::asio::local::stream_protocol >::handleSend().
|
protected |
|
protected |
Definition at line 79 of file stream-transport.hpp.
Referenced by nfd::face::StreamTransport< boost::asio::local::stream_protocol >::deferredClose(), nfd::face::StreamTransport< boost::asio::local::stream_protocol >::doClose(), nfd::face::StreamTransport< boost::asio::local::stream_protocol >::handleReceive(), and nfd::face::StreamTransport< boost::asio::local::stream_protocol >::sendFromQueue().