@ -743,6 +743,8 @@ namespace util
s << endpoint.address ().to_string () << ":" << endpoint.port ();
if (!outgoing) s << "-->";
s << " [" << it.second->GetNumSentBytes () << ":" << it.second->GetNumReceivedBytes () << "]";
if (it.second->GetRelayTag ())
s << " [itag:" << it.second->GetRelayTag () << "]";
s << "<br>";
s << std::endl;
}
@ -28,6 +28,11 @@ namespace transport
delete it.second;
void SSUData::Stop ()
{
m_ResendTimer.cancel ();
void SSUData::AdjustPacketSize (const i2p::data::RouterInfo& remoteRouter)
auto ssuAddress = remoteRouter.GetSSUAddress ();
@ -78,6 +78,7 @@ namespace transport
SSUData (SSUSession& session);
~SSUData ();
void Stop ();
void ProcessMessage (uint8_t * buf, size_t len);
void Send (i2p::I2NPMessage * msg);
@ -763,6 +763,7 @@ namespace transport
m_State = eSessionStateClosed;
SendSesionDestroyed ();
transports.PeerDisconnected (shared_from_this ());
m_Data.Stop ();
m_Timer.cancel ();