| 815 | } |
| 816 | |
| 817 | void NTCP2Session::HandleSessionCreatedReceived (const boost::system::error_code& ecode, std::size_t bytes_transferred) |
| 818 | { |
| 819 | if (ecode) |
| 820 | { |
| 821 | LogPrint (eLogWarning, "NTCP2: SessionCreated read error: ", ecode.message ()); |
| 822 | Terminate (); |
| 823 | } |
| 824 | else |
| 825 | { |
| 826 | m_HandshakeInterval = i2p::util::GetMillisecondsSinceEpoch () - m_HandshakeInterval; |
| 827 | boost::asio::post (m_Server.GetEstablisherService (), |
| 828 | [s = shared_from_this (), bytes_transferred] () |
| 829 | { |
| 830 | s->ProcessSessionCreated (bytes_transferred); |
| 831 | }); |
| 832 | } |
| 833 | } |
| 834 | |
| 835 | void NTCP2Session::ProcessSessionCreated (size_t len) |
| 836 | { |
nothing calls this directly
no test coverage detected