ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2026-09-27 23:48:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(consensus): detect lagged validatedLedgerWork at enqueue

Browse Source 
observeJobs only fires at run time after the 20s lag. Use jobDiagnostics
queued:lagged plus pending Export latches as the pre-stop work evidence.
This commit is contained in:
Nicholas Dudfield
2026-09-18 19:36:05 +07:00
parent 7e73ee52c3
commit 293b946941
1 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/test/consensus/SteppingExtensions_test.cpp
View File

@@ -1281,17 +1281,6 @@ class SteppingExtensions_test : public beast::unit_test::suite
auto const stats = world.observed;
net.controller().setJobLag(
observer, jtADVANCE, "validatedLedgerWork", 20s);
net.controller().observeJobs(
[&net, stats](
std::uint32_t id, JobType type, std::string const& name) {
if (id != observer || !net.isLive(id))
return;
if (type != jtADVANCE || name != "validatedLedgerWork")
return;
auto& ce = net.node(id).app().getConsensusExtensions();
if (ce.hasEligiblePendingExports())
stats->queuedExportWork = true;
});
auto const payment = world.submit(
observer,
@@ -1304,9 +1293,19 @@ class SteppingExtensions_test : public beast::unit_test::suite
return std::nullopt;
auto const origin = tx->getID();
net.runTo(warmLedger + 6);
net.controller().observeJobs({});
auto const diag = net.jobDiagnostics();
stats->queuedExportWork =
diag.find("validatedLedgerWork") != std::string::npos &&
diag.find("queued:lagged") != std::string::npos &&
net.node(observer)
.app()
.getConsensusExtensions()
.hasEligiblePendingExports();
if (!BEAST_EXPECT(stats->queuedExportWork))
{
log << " no queued Export work: " << diag << std::endl;
return std::nullopt;
}
BEAST_EXPECT(!net.node(observer).app().getValidatorKeys().keys);
BEAST_EXPECT(stats->ownReleases[observer] == 0);
BEAST_EXPECT(stats->secrets[observer] == 0);