| 567 | } |
| 568 | |
| 569 | bool SSU2Server::AddPendingOutgoingSession (std::shared_ptr<SSU2Session> session) |
| 570 | { |
| 571 | if (!session) return false; |
| 572 | std::lock_guard<std::mutex> l(m_PendingOutgoingSessionsMutex); |
| 573 | return m_PendingOutgoingSessions.emplace (session->GetRemoteEndpoint (), session).second; |
| 574 | } |
| 575 | |
| 576 | std::shared_ptr<SSU2Session> SSU2Server::FindSession (const i2p::data::IdentHash& ident) |
| 577 | { |
no outgoing calls
no test coverage detected