Mirrors/i2pd
2
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-01-22 21:37:17 +01:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

don't wait for remote LeaseSet request complete

Browse source
This commit is contained in:
orignal 2015-03-23 22:23:40 -04:00
parent 6125288e95
commit 3f4bd13091
2 changed files with 1 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
Streaming.cpp
View file

@ -607,19 +607,10 @@ namespace stream
{ {
LogPrint (eLogInfo, "All leases are expired. Trying to request"); LogPrint (eLogInfo, "All leases are expired. Trying to request");
m_RemoteLeaseSet = nullptr; m_RemoteLeaseSet = nullptr;
m_LocalDestination.GetOwner ().RequestDestination (m_RemoteIdentity.GetIdentHash (), m_LocalDestination.GetOwner ().RequestDestination (m_RemoteIdentity.GetIdentHash ());
std::bind (&Stream::HandleLeaseSetRequestComplete, shared_from_this (), std::placeholders::_1));
} }
} }
void Stream::HandleLeaseSetRequestComplete (bool success)
{
if (success)
{
LogPrint (eLogInfo, "New LeaseSet found");
UpdateCurrentRemoteLease ();
}
}
void Stream::ScheduleResend () void Stream::ScheduleResend ()
{ {

1
Streaming.h
View file

@ -147,7 +147,6 @@ namespace stream
template<typename Buffer, typename ReceiveHandler> template<typename Buffer, typename ReceiveHandler>
void HandleReceiveTimer (const boost::system::error_code& ecode, const Buffer& buffer, ReceiveHandler handler); void HandleReceiveTimer (const boost::system::error_code& ecode, const Buffer& buffer, ReceiveHandler handler);
void HandleLeaseSetRequestComplete (bool success);
void ScheduleResend (); void ScheduleResend ();
void HandleResendTimer (const boost::system::error_code& ecode); void HandleResendTimer (const boost::system::error_code& ecode);