mirrors/i2pd
2
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd synced 2024-09-20 02:10:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

check if session is established before sending peer test

Browse Source
This commit is contained in:
orignal 2022-06-02 15:04:35 -04:00
parent 87a434c377
commit d3a9cc8fde
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
libi2pd/SSU2.cpp
View File

@ -1590,7 +1590,7 @@ namespace transport
size_t SSU2Session::CreatePeerTestBlock (uint8_t * buf, size_t len) size_t SSU2Session::CreatePeerTestBlock (uint8_t * buf, size_t len)
{ {
auto localAddress = FindLocalAddress (); auto localAddress = FindLocalAddress ();
if (localAddress) return 0; if (!localAddress) return 0;
// signed data // signed data
uint32_t nonce; uint32_t nonce;
RAND_bytes ((uint8_t *)&nonce, 4); RAND_bytes ((uint8_t *)&nonce, 4);
@ -2150,14 +2150,17 @@ namespace transport
auto it = m_SessionsByRouterHash.find (router->GetIdentHash ()); auto it = m_SessionsByRouterHash.find (router->GetIdentHash ());
if (it != m_SessionsByRouterHash.end ()) if (it != m_SessionsByRouterHash.end ())
{ {
it->second->SendPeerTest (); if (it->second->IsEstablished ())
it->second->SendPeerTest ();
else
{
auto s = it->second;
s->SetOnEstablished ([s]() { s->SendPeerTest (); });
}
return true; return true;
} }
auto s = std::make_shared<SSU2Session> (*this, router, addr); auto s = std::make_shared<SSU2Session> (*this, router, addr);
s->SetOnEstablished ([s]() s->SetOnEstablished ([s]() {s->SendPeerTest (); });
{
s->SendPeerTest ();
});
s->Connect (); s->Connect ();
return true; return true;
} }