Implements a forwarder-side transport that can be paired with another transport. More...
#include <daemon/face/internal-transport.hpp>
Public Types | |
using | Counters = TransportCounters |
Counters provided by a transport. More... | |
Public Member Functions | |
InternalForwarderTransport (const FaceUri &localUri=FaceUri("internal://"), const FaceUri &remoteUri=FaceUri("internal://"), ndn::nfd::FaceScope scope=ndn::nfd::FACE_SCOPE_LOCAL, ndn::nfd::LinkType linkType=ndn::nfd::LINK_TYPE_POINT_TO_POINT) | |
bool | canChangePersistencyTo (ndn::nfd::FacePersistency newPersistency) const |
Check whether the persistency can be changed to newPersistency . More... | |
void | close () |
Request the transport to be closed. More... | |
virtual const Counters & | getCounters () const |
time::steady_clock::time_point | getExpirationTime () const noexcept |
Returns the expiration time of the transport. More... | |
const Face * | getFace () const noexcept |
Returns the Face to which this transport is attached. More... | |
const LinkService * | getLinkService () const noexcept |
Returns the LinkService to which this transport is attached. More... | |
LinkService * | getLinkService () noexcept |
Returns the LinkService to which this transport is attached. More... | |
ndn::nfd::LinkType | getLinkType () const noexcept |
Returns the link type of the transport. More... | |
FaceUri | getLocalUri () const noexcept |
Returns a FaceUri representing the local endpoint. More... | |
ssize_t | getMtu () const noexcept |
Returns the maximum payload size. More... | |
ndn::nfd::FacePersistency | getPersistency () const noexcept |
Returns the current persistency setting of the transport. More... | |
FaceUri | getRemoteUri () const noexcept |
Returns a FaceUri representing the remote endpoint. More... | |
ndn::nfd::FaceScope | getScope () const noexcept |
Returns whether the transport is local or non-local for scope control purposes. More... | |
ssize_t | getSendQueueCapacity () const noexcept |
Returns the capacity of the send queue (in bytes). More... | |
virtual ssize_t | getSendQueueLength () |
Returns the current send queue length of the transport (in octets). More... | |
TransportState | getState () const noexcept |
Returns the current transport state. More... | |
void | receivePacket (const Block &packet) final |
void | send (const Block &packet) |
Send a link-layer packet. More... | |
void | setFaceAndLinkService (Face &face, LinkService &service) noexcept |
Set Face and LinkService for this transport. More... | |
void | setPeer (InternalTransportBase *peer) noexcept |
void | setPersistency (ndn::nfd::FacePersistency newPersistency) |
Changes the persistency setting of the transport. More... | |
Public Attributes | |
signal::Signal< Transport, TransportState, TransportState > | afterStateChange |
Called when the transport state changes. More... | |
Protected Member Functions | |
virtual void | afterChangePersistency (ndn::nfd::FacePersistency oldPersistency) |
Invoked after the persistency has been changed. More... | |
virtual bool | canChangePersistencyToImpl (ndn::nfd::FacePersistency newPersistency) const |
Invoked by canChangePersistencyTo to perform the check. More... | |
void | doClose () final |
Performs Transport specific operations to close the transport. More... | |
void | receive (const Block &packet, const EndpointId &endpoint={}) |
Pass a received link-layer packet to the upper layer for further processing. More... | |
void | setExpirationTime (const time::steady_clock::time_point &expirationTime) noexcept |
void | setLinkType (ndn::nfd::LinkType linkType) noexcept |
void | setLocalUri (const FaceUri &uri) noexcept |
void | setMtu (ssize_t mtu) noexcept |
void | setRemoteUri (const FaceUri &uri) noexcept |
void | setScope (ndn::nfd::FaceScope scope) noexcept |
void | setSendQueueCapacity (ssize_t sendQueueCapacity) noexcept |
void | setState (TransportState newState) |
Set transport state. More... | |
Protected Attributes | |
ByteCounter | nInBytes |
Total bytes received. More... | |
PacketCounter | nInPackets |
Count of incoming packets. More... | |
ByteCounter | nOutBytes |
Total bytes sent. More... | |
PacketCounter | nOutPackets |
Count of outgoing packets. More... | |
Implements a forwarder-side transport that can be paired with another transport.
Definition at line 51 of file internal-transport.hpp.
|
inherited |
Counters provided by a transport.
Definition at line 128 of file transport.hpp.
|
explicit |
Definition at line 36 of file internal-transport.cpp.
|
protectedvirtualinherited |
Invoked after the persistency has been changed.
The base class implementation does nothing. When overridden in a subclass, the function should update internal states after persistency setting has been changed.
Reimplemented in nfd::face::UnicastUdpTransport, nfd::face::UnicastEthernetTransport, and nfd::face::TcpTransport.
Definition at line 170 of file transport.cpp.
|
inherited |
Check whether the persistency can be changed to newPersistency
.
This function serves as the external API, and invokes the protected function canChangePersistencyToImpl() to perform further checks if newPersistency
differs from the current persistency.
Definition at line 130 of file transport.cpp.
|
protectedvirtualinherited |
Invoked by canChangePersistencyTo to perform the check.
Base class implementation returns false.
newPersistency | the new persistency, guaranteed to be different from current persistency |
Reimplemented in nfd::face::UnicastUdpTransport, nfd::face::UnicastEthernetTransport, and nfd::face::TcpTransport.
Definition at line 146 of file transport.cpp.
|
inherited |
Request the transport to be closed.
This operation is effective only if transport is in UP or DOWN state, otherwise it has no effect. The transport changes state to CLOSING, and performs cleanup procedure. The state will be changed to CLOSED when cleanup is complete, which may happen synchronously or asynchronously.
Definition at line 67 of file transport.cpp.
|
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.
Implements nfd::face::Transport.
Definition at line 68 of file internal-transport.cpp.
|
inlinevirtualinherited |
Reimplemented in nfd::face::WebSocketTransport.
Definition at line 179 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the expiration time of the transport.
time::steady_clock::time_point::max() | The transport has an indefinite lifetime. |
Definition at line 315 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the Face to which this transport is attached.
Definition at line 155 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the LinkService to which this transport is attached.
Definition at line 164 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the LinkService to which this transport is attached.
Definition at line 173 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the link type of the transport.
Definition at line 263 of file transport.hpp.
|
inlinenoexceptinherited |
Returns a FaceUri representing the local endpoint.
Definition at line 209 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the maximum payload size.
MTU_UNLIMITED | The transport has no limit on payload size. |
This size is the maximum packet size that can be sent or received through this transport.
For a datagram-based transport, this is typically the Maximum Transmission Unit (MTU), after the overhead of headers introduced by the transport has been accounted for. For a stream-based transport, this is typically unlimited (MTU_UNLIMITED).
Definition at line 279 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the current persistency setting of the transport.
Definition at line 236 of file transport.hpp.
|
inlinenoexceptinherited |
Returns a FaceUri representing the remote endpoint.
Definition at line 218 of file transport.hpp.
|
inlinenoexceptinherited |
Returns whether the transport is local or non-local for scope control purposes.
Definition at line 227 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the capacity of the send queue (in bytes).
QUEUE_UNSUPPORTED | The transport does not support queue capacity retrieval. |
QUEUE_ERROR | The transport was unable to retrieve the queue capacity. |
Definition at line 290 of file transport.hpp.
|
inlinevirtualinherited |
Returns the current send queue length of the transport (in octets).
QUEUE_UNSUPPORTED | The transport does not support queue length retrieval. |
QUEUE_ERROR | The transport was unable to retrieve the queue length. |
Reimplemented in nfd::face::StreamTransport< Protocol >, nfd::face::StreamTransport< boost::asio::ip::tcp >, nfd::face::StreamTransport< boost::asio::local::stream_protocol >, nfd::face::DatagramTransport< Protocol, Addressing >, nfd::face::DatagramTransport< boost::asio::ip::udp, Unicast >, nfd::face::DatagramTransport< boost::asio::ip::udp, Multicast >, nfd::face::TcpTransport, and nfd::face::MulticastUdpTransport.
Definition at line 326 of file transport.hpp.
|
inlinenoexceptinherited |
Returns the current transport state.
Definition at line 300 of file transport.hpp.
|
protectedinherited |
Pass a received link-layer packet to the upper layer for further processing.
packet | The received packet, must be a valid and well-formed TLV block |
endpoint | The source endpoint, optional for unicast transports |
Definition at line 101 of file transport.cpp.
|
finalvirtual |
Implements nfd::face::InternalTransportBase.
Definition at line 50 of file internal-transport.cpp.
|
inherited |
Send a link-layer packet.
packet | the packet to be sent, must be a valid and well-formed TLV block |
Definition at line 80 of file transport.cpp.
|
inlineprotectednoexceptinherited |
Definition at line 386 of file transport.hpp.
|
noexceptinherited |
Set Face and LinkService for this transport.
Definition at line 57 of file transport.cpp.
|
inlineprotectednoexceptinherited |
Definition at line 361 of file transport.hpp.
|
inlineprotectednoexceptinherited |
Definition at line 343 of file transport.hpp.
|
protectednoexceptinherited |
Definition at line 114 of file transport.cpp.
|
inlinenoexcept |
Definition at line 61 of file internal-transport.hpp.
|
inherited |
Changes the persistency setting of the transport.
Definition at line 152 of file transport.cpp.
|
inlineprotectednoexceptinherited |
Definition at line 349 of file transport.hpp.
|
inlineprotectednoexceptinherited |
Definition at line 355 of file transport.hpp.
|
inlineprotectednoexceptinherited |
Definition at line 370 of file transport.hpp.
|
protectedinherited |
Set transport state.
Only the following transitions are valid: UP->DOWN, DOWN->UP, UP/DOWN->CLOSING/FAILED, CLOSING/FAILED->CLOSED
std::runtime_error | transition is invalid. |
Definition at line 175 of file transport.cpp.
|
inherited |
Called when the transport state changes.
Definition at line 308 of file transport.hpp.
|
inherited |
Total bytes received.
This counter includes headers imposed by NFD (such as NDNLP), but excludes the overhead of the underlying protocol (such as IP header).
For a datagram-based transport, an incoming packet that cannot be parsed as TLV will not be counted.
Definition at line 85 of file transport.hpp.
|
inherited |
Count of incoming packets.
A 'packet' typically means a top-level TLV element.
For a datagram-based transport, an incoming packet that cannot be parsed as TLV will not be counted.
Definition at line 65 of file transport.hpp.
|
inherited |
Total bytes sent.
This counter includes headers imposed by NFD (such as NDNLP), but excludes the overhead of the underlying protocol (such as IP header).
This counter is increased only when the transport is UP.
Definition at line 95 of file transport.hpp.
|
inherited |
Count of outgoing packets.
A 'packet' typically means a top-level TLV element.
This counter is incremented only when the transport is UP.
Definition at line 74 of file transport.hpp.