mirror of
https://github.com/PurpleI2P/i2pd.git
synced 2025-03-07 06:09:42 +00:00
Compare commits
1 Commits
53e6ae5097
...
82ef1c37bc
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
82ef1c37bc |
@@ -764,7 +764,6 @@ namespace client
|
|||||||
void I2CPSession::AddRoutingSession (const i2p::data::IdentHash& signingKey, std::shared_ptr<i2p::garlic::GarlicRoutingSession> remoteSession)
|
void I2CPSession::AddRoutingSession (const i2p::data::IdentHash& signingKey, std::shared_ptr<i2p::garlic::GarlicRoutingSession> remoteSession)
|
||||||
{
|
{
|
||||||
if (!remoteSession) return;
|
if (!remoteSession) return;
|
||||||
remoteSession->SetAckRequestInterval (I2CP_SESSION_ACK_REQUEST_INTERVAL);
|
|
||||||
std::lock_guard<std::mutex> l(m_RoutingSessionsMutex);
|
std::lock_guard<std::mutex> l(m_RoutingSessionsMutex);
|
||||||
m_RoutingSessions[signingKey] = remoteSession;
|
m_RoutingSessions[signingKey] = remoteSession;
|
||||||
}
|
}
|
||||||
@@ -1111,12 +1110,12 @@ namespace client
|
|||||||
void I2CPServer::Stop ()
|
void I2CPServer::Stop ()
|
||||||
{
|
{
|
||||||
m_Acceptor.cancel ();
|
m_Acceptor.cancel ();
|
||||||
|
{
|
||||||
decltype(m_Sessions) sessions;
|
auto sessions = m_Sessions;
|
||||||
m_Sessions.swap (sessions);
|
for (auto& it: sessions)
|
||||||
for (auto& it: sessions)
|
it.second->Stop ();
|
||||||
it.second->Stop ();
|
}
|
||||||
|
m_Sessions.clear ();
|
||||||
StopIOService ();
|
StopIOService ();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -31,7 +31,6 @@ namespace client
|
|||||||
const size_t I2CP_MAX_MESSAGE_LENGTH = 65535;
|
const size_t I2CP_MAX_MESSAGE_LENGTH = 65535;
|
||||||
const size_t I2CP_MAX_SEND_QUEUE_SIZE = 1024*1024; // in bytes, 1M
|
const size_t I2CP_MAX_SEND_QUEUE_SIZE = 1024*1024; // in bytes, 1M
|
||||||
const int I2CP_LEASESET_CREATION_TIMEOUT = 10; // in seconds
|
const int I2CP_LEASESET_CREATION_TIMEOUT = 10; // in seconds
|
||||||
const int I2CP_SESSION_ACK_REQUEST_INTERVAL = 12100; // in milliseconds
|
|
||||||
|
|
||||||
const size_t I2CP_HEADER_LENGTH_OFFSET = 0;
|
const size_t I2CP_HEADER_LENGTH_OFFSET = 0;
|
||||||
const size_t I2CP_HEADER_TYPE_OFFSET = I2CP_HEADER_LENGTH_OFFSET + 4;
|
const size_t I2CP_HEADER_TYPE_OFFSET = I2CP_HEADER_LENGTH_OFFSET + 4;
|
||||||
|
|||||||
Reference in New Issue
Block a user