mirror of
https://github.com/XRPLF/rippled.git
synced 2025-11-27 06:25:51 +00:00
Don't tolerate failed ledger acquires in the publication stream.
This commit is contained in:
@@ -745,10 +745,15 @@ std::list<Ledger::pointer> LedgerMaster::findNewLedgersToPublish(boost::recursiv
|
|||||||
WriteLog (lsWARNING, LedgerMaster) << "Failed to acquire a published ledger";
|
WriteLog (lsWARNING, LedgerMaster) << "Failed to acquire a published ledger";
|
||||||
getApp().getInboundLedgers().dropLedger(hash);
|
getApp().getInboundLedgers().dropLedger(hash);
|
||||||
acq = getApp().getInboundLedgers().findCreate(hash, seq);
|
acq = getApp().getInboundLedgers().findCreate(hash, seq);
|
||||||
if (acq->isComplete() && !acq->isFailed())
|
if (acq->isComplete())
|
||||||
|
{
|
||||||
|
if (acq->isFailed())
|
||||||
|
getApp().getInboundLedgers().dropLedger(hash);
|
||||||
|
else
|
||||||
ledger = acq->getLedger();
|
ledger = acq->getLedger();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (ledger && (ledger->getLedgerSeq() == pubSeq))
|
if (ledger && (ledger->getLedgerSeq() == pubSeq))
|
||||||
{ // We acquired the next ledger we need to publish
|
{ // We acquired the next ledger we need to publish
|
||||||
|
|||||||
Reference in New Issue
Block a user