|
|
@ -177,7 +177,7 @@ namespace client |
|
|
|
{ |
|
|
|
{ |
|
|
|
if (bytes_transferred > 0) |
|
|
|
if (bytes_transferred > 0) |
|
|
|
Write (m_StreamBuffer, bytes_transferred); // postpone termination
|
|
|
|
Write (m_StreamBuffer, bytes_transferred); // postpone termination
|
|
|
|
else if (ecode == boost::asio::error::timed_out && && m_Stream && m_Stream->IsOpen ()) |
|
|
|
else if (ecode == boost::asio::error::timed_out && m_Stream && m_Stream->IsOpen ()) |
|
|
|
StreamReceive (); |
|
|
|
StreamReceive (); |
|
|
|
else |
|
|
|
else |
|
|
|
Terminate (); |
|
|
|
Terminate (); |
|
|
@ -553,7 +553,6 @@ namespace client |
|
|
|
++itr; |
|
|
|
++itr; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
<<<<<<< HEAD |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void I2PUDPClientTunnel::ExpireStale(const uint64_t delta) { |
|
|
|
void I2PUDPClientTunnel::ExpireStale(const uint64_t delta) { |
|
|
|
std::lock_guard<std::mutex> lock(m_SessionsMutex); |
|
|
|
std::lock_guard<std::mutex> lock(m_SessionsMutex); |
|
|
|