PurpleI2P/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-01-31 04:44:13 +00:00
Code Issues Releases Activity

temporary disable RelayRespond resend from Bob because it might be not acked

Browse Source
This commit is contained in:
orignal 2024-10-04 14:06:02 -04:00
parent 4436c49ccc
commit 58245bf121
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
libi2pd/SSU2Session.cpp
View File

@ -1982,6 +1982,7 @@ namespace transport
packet->payloadSize += CreatePaddingBlock (packet->payload + packet->payloadSize, m_MaxPayloadSize - packet->payloadSize); packet->payloadSize += CreatePaddingBlock (packet->payload + packet->payloadSize, m_MaxPayloadSize - packet->payloadSize);
uint32_t packetNum = session->SendData (packet->payload, packet->payloadSize); uint32_t packetNum = session->SendData (packet->payload, packet->payloadSize);
packet->sendTime = mts; packet->sendTime = mts;
// Charlie always responds with RelayResponse
session->m_SentPackets.emplace (packetNum, packet); session->m_SentPackets.emplace (packetNum, packet);
} }
@ -2068,8 +2069,8 @@ namespace transport
code, bufbe32toh (buf + 33), token, isV4); code, bufbe32toh (buf + 33), token, isV4);
packet->payloadSize += CreatePaddingBlock (packet->payload + packet->payloadSize, m_MaxPayloadSize - packet->payloadSize); packet->payloadSize += CreatePaddingBlock (packet->payload + packet->payloadSize, m_MaxPayloadSize - packet->payloadSize);
/*uint32_t packetNum = */SendData (packet->payload, packet->payloadSize); /*uint32_t packetNum = */SendData (packet->payload, packet->payloadSize);
// for some reason Bob never ack this RelayResponse // sometimes Bob doesn't ack this RelayResponse
// TODO: unccomend line below once the problem is resolved // TODO: uncomment line below once the problem is resolved
//packet->sendTime = mts; //packet->sendTime = mts;
//m_SentPackets.emplace (packetNum, packet); //m_SentPackets.emplace (packetNum, packet);
} }
@ -2106,9 +2107,11 @@ namespace transport
memcpy (payload + 3, buf, len); // forward to Alice as is memcpy (payload + 3, buf, len); // forward to Alice as is
packet->payloadSize = len + 3; packet->payloadSize = len + 3;
packet->payloadSize += CreatePaddingBlock (payload + packet->payloadSize, m_MaxPayloadSize - packet->payloadSize); packet->payloadSize += CreatePaddingBlock (payload + packet->payloadSize, m_MaxPayloadSize - packet->payloadSize);
uint32_t packetNum = it->second.first->SendData (packet->payload, packet->payloadSize); /*uint32_t packetNum = */it->second.first->SendData (packet->payload, packet->payloadSize);
packet->sendTime = i2p::util::GetMillisecondsSinceEpoch (); // sometimes Alice doesn't ack this RelayResponse
it->second.first->m_SentPackets.emplace (packetNum, packet); // TODO: uncomment line below once the problem is resolved
//packet->sendTime = i2p::util::GetMillisecondsSinceEpoch ();
//it->second.first->m_SentPackets.emplace (packetNum, packet);
} }
else else
{ {