28 #if defined(__linux__) 29 #include <linux/sockios.h> 30 #include <sys/ioctl.h> 38 time::milliseconds TcpTransport::s_initialReconnectWait = 1_s;
39 time::milliseconds TcpTransport::s_maxReconnectWait = 5_min;
40 float TcpTransport::s_reconnectWaitMultiplier = 2.0f;
44 , m_remoteEndpoint(m_socket.remote_endpoint())
45 , m_nextReconnectWait(s_initialReconnectWait)
51 this->
setLinkType(ndn::nfd::LINK_TYPE_POINT_TO_POINT);
65 #if defined(__linux__) 67 if (ioctl(
m_socket.native_handle(), SIOCOUTQNSD, &nsd) < 0) {
68 NFD_LOG_FACE_WARN(
"Failed to obtain send queue length from socket: " << std::strerror(errno));
89 if (oldPersistency == ndn::nfd::FACE_PERSISTENCY_PERMANENT) {
101 if (this->
getPersistency() == ndn::nfd::FACE_PERSISTENCY_PERMANENT) {
106 boost::system::error_code error;
118 TcpTransport::reconnect()
129 BOOST_ASSERT(
getPersistency() == ndn::nfd::FACE_PERSISTENCY_PERMANENT);
137 m_reconnectEvent =
scheduler::schedule(m_nextReconnectWait, [
this] { this->handleReconnectTimeout(); });
138 m_socket.async_connect(m_remoteEndpoint, [
this] (
const auto& e) { this->handleReconnect(e); });
142 TcpTransport::handleReconnect(
const boost::system::error_code& error)
147 error == boost::asio::error::operation_aborted) {
157 m_reconnectEvent.
cancel();
158 m_nextReconnectWait = s_initialReconnectWait;
167 TcpTransport::handleReconnectTimeout()
170 boost::system::error_code error;
174 m_nextReconnectWait =
175 std::min(time::duration_cast<time::milliseconds>(m_nextReconnectWait * s_reconnectWaitMultiplier),
185 m_reconnectEvent.
cancel();
void resetReceiveBuffer()
void setLocalUri(const FaceUri &uri)
#define NFD_LOG_FACE_TRACE(msg)
Log a message at TRACE level.
void setScope(ndn::nfd::FaceScope scope)
#define NFD_LOG_MEMBER_INIT_SPECIALIZED(cls, name)
const ssize_t MTU_UNLIMITED
indicates the transport has no limit on payload size
the transport is being closed due to a failure
Implements Transport for stream-based protocols.
#define NFD_LOG_FACE_WARN(msg)
Log a message at WARN level.
size_t getSendQueueBytes() const
bool canChangePersistencyToImpl(ndn::nfd::FacePersistency newPersistency) const final
invoked by canChangePersistencyTo to perform the check
ssize_t getSendQueueLength() final
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
TcpTransport(protocol::socket &&socket, ndn::nfd::FacePersistency persistency, ndn::nfd::FaceScope faceScope)
the transport is closed, and can be safely deallocated
#define NFD_LOG_FACE_INFO(msg)
Log a message at INFO level.
void setLinkType(ndn::nfd::LinkType linkType)
the transport is being closed gracefully, either by the peer or by a call to close() ...
void afterChangePersistency(ndn::nfd::FacePersistency oldPersistency) final
invoked after the persistency has been changed
void setPersistency(ndn::nfd::FacePersistency newPersistency)
changes face persistency setting
void handleError(const boost::system::error_code &error) final
ndn::nfd::FacePersistency getPersistency() const
void doClose() final
performs Transport specific operations to close the transport
EventId schedule(time::nanoseconds after, const EventCallback &event)
Schedule an event.
TransportState getState() const
void doClose() override
performs Transport specific operations to close the transport
void setState(TransportState newState)
set transport state
void setRemoteUri(const FaceUri &uri)
the transport is up and can transmit packets
void cancel()
Cancels the event manually.
virtual void handleError(const boost::system::error_code &error)
protocol::socket m_socket
the transport is temporarily down, and is being recovered
boost::asio::io_service & getGlobalIoService()