diff --git a/HTTPServer.cpp b/HTTPServer.cpp index 0f30cc47..361d0a20 100644 --- a/HTTPServer.cpp +++ b/HTTPServer.cpp @@ -540,7 +540,7 @@ namespace util RunRequest(); } else // follow-on - m_Stream->Send ((uint8_t *)m_Buffer, bytes_transferred, 10); + m_Stream->Send ((uint8_t *)m_Buffer, bytes_transferred); Receive (); } /*else if (ecode != boost::asio::error::operation_aborted) @@ -879,7 +879,7 @@ namespace util m_Stream = i2p::stream::CreateStream (*leaseSet); if (m_Stream) { - m_Stream->Send ((uint8_t *)buf, len, 10); + m_Stream->Send ((uint8_t *)buf, len); AsyncStreamReceive (); } } diff --git a/I2PTunnel.cpp b/I2PTunnel.cpp index 6abcf417..3093e1d2 100644 --- a/I2PTunnel.cpp +++ b/I2PTunnel.cpp @@ -13,7 +13,7 @@ namespace stream m_Socket (socket), m_Owner (owner) { m_Stream = m_Owner->GetLocalDestination ()->CreateNewOutgoingStream (*leaseSet); - m_Stream->Send (m_Buffer, 0, 0); // connect + m_Stream->Send (m_Buffer, 0); // connect StreamReceive (); Receive (); } @@ -64,7 +64,7 @@ namespace stream else { if (m_Stream) - m_Stream->Send (m_Buffer, bytes_transferred, 0); + m_Stream->Send (m_Buffer, bytes_transferred); Receive (); } } diff --git a/SAM.cpp b/SAM.cpp index 4db0f284..8312449d 100644 --- a/SAM.cpp +++ b/SAM.cpp @@ -249,7 +249,7 @@ namespace stream m_SocketType = eSAMSocketTypeStream; session->sockets.push_back (this); m_Stream = session->localDestination->CreateNewOutgoingStream (*leaseSet); - m_Stream->Send ((uint8_t *)m_Buffer, 0, 0); // connect + m_Stream->Send ((uint8_t *)m_Buffer, 0); // connect I2PReceive (); SendMessageReply (SAM_STREAM_STATUS_OK, strlen(SAM_STREAM_STATUS_OK), false); } @@ -345,7 +345,7 @@ namespace stream else { if (m_Stream) - m_Stream->Send ((uint8_t *)m_Buffer, bytes_transferred, 0); + m_Stream->Send ((uint8_t *)m_Buffer, bytes_transferred); Receive (); } } diff --git a/SOCKS.cpp b/SOCKS.cpp index 7f6174cc..7d686073 100644 --- a/SOCKS.cpp +++ b/SOCKS.cpp @@ -93,7 +93,7 @@ namespace proxy } LogPrint("--- socks4a sock forward: ", len); - m_stream->Send(m_sock_buff, len, 1); + m_stream->Send(m_sock_buff, len); } void SOCKS4AHandler::HandleSockRecv(const boost::system::error_code & ecode, std::size_t len) diff --git a/Streaming.cpp b/Streaming.cpp index 9744d475..0d65452a 100644 --- a/Streaming.cpp +++ b/Streaming.cpp @@ -96,7 +96,7 @@ namespace stream SendQuickAck (); else if (isSyn) // we have to send SYN back to incoming connection - Send (nullptr, 0, 0); // also sets m_IsOpen + Send (nullptr, 0); // also sets m_IsOpen } else { @@ -229,7 +229,7 @@ namespace stream m_ResendTimer.cancel (); } - size_t Stream::Send (const uint8_t * buf, size_t len, int timeout) + size_t Stream::Send (const uint8_t * buf, size_t len) { bool isNoAck = m_LastReceivedSequenceNumber < 0; // first packet while (!m_IsOpen || len > 0) diff --git a/Streaming.h b/Streaming.h index 8b681bef..f8ad815f 100644 --- a/Streaming.h +++ b/Streaming.h @@ -92,7 +92,7 @@ namespace stream StreamingDestination * GetLocalDestination () { return m_LocalDestination; }; void HandleNextPacket (Packet * packet); - size_t Send (const uint8_t * buf, size_t len, int timeout); // timeout in seconds + size_t Send (const uint8_t * buf, size_t len); template void AsyncReceive (const Buffer& buffer, ReceiveHandler handler, int timeout = 0);