From 03a861745ba35cab857b04a036add9a651501360 Mon Sep 17 00:00:00 2001 From: orignal Date: Fri, 20 Sep 2019 20:09:25 -0400 Subject: [PATCH] removed CloseSession --- libi2pd/Transports.cpp | 22 ---------------------- libi2pd/Transports.h | 2 -- 2 files changed, 24 deletions(-) diff --git a/libi2pd/Transports.cpp b/libi2pd/Transports.cpp index a2783f6c..93db02d8 100644 --- a/libi2pd/Transports.cpp +++ b/libi2pd/Transports.cpp @@ -503,28 +503,6 @@ namespace transport } } } - - void Transports::CloseSession (std::shared_ptr router) - { - if (!router) return; - m_Service->post (std::bind (&Transports::PostCloseSession, this, router)); - } - - void Transports::PostCloseSession (std::shared_ptr router) - { - auto ssuSession = m_SSUServer ? m_SSUServer->FindSession (router) : nullptr; - if (ssuSession) // try SSU first - { - m_SSUServer->DeleteSession (ssuSession); - LogPrint (eLogDebug, "Transports: SSU session closed"); - } - auto ntcpSession = m_NTCPServer ? m_NTCPServer->FindNTCPSession(router->GetIdentHash()) : nullptr; - if (ntcpSession) // try deleting ntcp session too - { - ntcpSession->Terminate (); - LogPrint(eLogDebug, "Transports: NTCP session closed"); - } - } void Transports::DetectExternalIP () { diff --git a/libi2pd/Transports.h b/libi2pd/Transports.h index 798c90a9..117092ad 100644 --- a/libi2pd/Transports.h +++ b/libi2pd/Transports.h @@ -92,7 +92,6 @@ namespace transport void SendMessage (const i2p::data::IdentHash& ident, std::shared_ptr msg); void SendMessages (const i2p::data::IdentHash& ident, const std::vector >& msgs); - void CloseSession (std::shared_ptr router); void PeerConnected (std::shared_ptr session); void PeerDisconnected (std::shared_ptr session); @@ -131,7 +130,6 @@ namespace transport void RequestComplete (std::shared_ptr r, const i2p::data::IdentHash& ident); void HandleRequestComplete (std::shared_ptr r, i2p::data::IdentHash ident); void PostMessages (i2p::data::IdentHash ident, std::vector > msgs); - void PostCloseSession (std::shared_ptr router); bool ConnectToPeer (const i2p::data::IdentHash& ident, Peer& peer); void HandlePeerCleanupTimer (const boost::system::error_code& ecode); void HandlePeerTestTimer (const boost::system::error_code& ecode);