dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-10-06 09:58:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

retry publishing LeaseSet if no floodfills or tunnels

Browse Source
This commit is contained in:
orignal
2026-10-03 22:08:44 -04:00
parent 466e99fa55
commit 39b2f82c24
2 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Destination.cpp
+14 -7
View File
@@ -666,6 +666,8 @@ namespace client
{
LogPrint (eLogError, "Destination: Can't publish LeaseSet, no more floodfills found");
m_ExcludedFloodfills.clear ();
// try again later
SchedulePublishRetry ();
return;
}
auto outbound = m_Pool->GetNextOutboundTunnel (nullptr, floodfill->GetCompatibleTransports (false));
@@ -698,13 +700,8 @@ namespace client
if (!floodfill || !outbound || !inbound)
{
// we can't publish now
m_ExcludedFloodfills.clear ();
m_PublishReplyToken = 1; // dummy non-zero value
// try again after a while
LogPrint (eLogInfo, "Destination: Can't publish LeaseSet because destination is not ready. Try publishing again after ", PUBLISH_CONFIRMATION_TIMEOUT, " milliseconds");
m_PublishConfirmationTimer.expires_after (std::chrono::milliseconds(PUBLISH_CONFIRMATION_TIMEOUT));
m_PublishConfirmationTimer.async_wait (std::bind (&LeaseSetDestination::HandlePublishConfirmationTimer,
shared_from_this (), std::placeholders::_1, PUBLISH_CONFIRMATION_TIMEOUT));
// try again layer
SchedulePublishRetry ();
return;
}
}
@@ -733,6 +730,16 @@ namespace client
m_LastSubmissionTime = ts;
}
void LeaseSetDestination::SchedulePublishRetry ()
{
m_ExcludedFloodfills.clear ();
m_PublishReplyToken = 1; // dummy non-zero value
LogPrint (eLogInfo, "Destination: Can't publish LeaseSet because destination is not ready. Try publishing again after ", PUBLISH_CONFIRMATION_TIMEOUT, " milliseconds");
m_PublishConfirmationTimer.expires_after (std::chrono::milliseconds(PUBLISH_RETRY_INTERVAL));
m_PublishConfirmationTimer.async_wait (std::bind (&LeaseSetDestination::HandlePublishConfirmationTimer,
shared_from_this (), std::placeholders::_1, PUBLISH_RETRY_INTERVAL));
}
void LeaseSetDestination::HandlePublishConfirmationTimer (const boost::system::error_code& ecode, uint64_t publishConfirmationTimeout)
{
if (ecode != boost::asio::error::operation_aborted)