PurpleI2P/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-08-26 08:41:50 +00:00
Code Issues Releases Activity

read more data from socket if available and stream buffer is not full

Browse Source
This commit is contained in:
orignal 2025-05-07 18:54:55 -04:00
parent 209eb174c6
commit 246bc43dea
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
libi2pd_client/I2PTunnel.cpp
View File

@ -183,6 +183,29 @@ namespace client
}
else
{
if (bytes_transferred < I2P_TUNNEL_CONNECTION_BUFFER_SIZE && !m_SSL)
{
boost::system::error_code ec;
size_t moreBytes = m_Socket->available(ec);
if (!ec && moreBytes && m_Stream)
{
// read more data from socket before sending to stream
if (bytes_transferred + moreBytes > I2P_TUNNEL_CONNECTION_BUFFER_SIZE)
moreBytes = I2P_TUNNEL_CONNECTION_BUFFER_SIZE - bytes_transferred;
if (m_Stream->GetSendBufferSize () < I2P_TUNNEL_CONNECTION_STREAM_MAX_SEND_BUFFER_SIZE)
{
size_t remaining = I2P_TUNNEL_CONNECTION_STREAM_MAX_SEND_BUFFER_SIZE - m_Stream->GetSendBufferSize ();
if (remaining < moreBytes) moreBytes = remaining;
}
else
moreBytes = 0;
}
if (moreBytes)
{
moreBytes = boost::asio::read (*m_Socket, boost::asio::buffer(m_Buffer + bytes_transferred, moreBytes), boost::asio::transfer_all (), ec);
if (!ec) bytes_transferred += moreBytes;
}
}
WriteToStream (m_Buffer, bytes_transferred);
Receive (); // try to receive more while being sent to stream
}