Skip to content

Commit fa4ea99

Browse files
author
MarcoFalke
committed
init: Setup scheduler in tests and init in exactly the same way
1 parent 25ad2c6 commit fa4ea99

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

src/init.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1317,8 +1317,7 @@ bool AppInitMain(const util::Ref& context, NodeContext& node)
13171317
node.scheduler = MakeUnique<CScheduler>();
13181318

13191319
// Start the lightweight task scheduler thread
1320-
CScheduler::Function serviceLoop = [&node]{ node.scheduler->serviceQueue(); };
1321-
threadGroup.create_thread(std::bind(&TraceThread<CScheduler::Function>, "scheduler", serviceLoop));
1320+
threadGroup.create_thread([&] { TraceThread("scheduler", [&] { node.scheduler->serviceQueue(); }); });
13221321

13231322
// Gather some entropy once per minute.
13241323
node.scheduler->scheduleEvery([]{

src/test/util/setup_common.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ TestingSetup::TestingSetup(const std::string& chainName, const std::vector<const
129129

130130
// We have to run a scheduler thread to prevent ActivateBestChain
131131
// from blocking due to queue overrun.
132-
threadGroup.create_thread([&]{ m_node.scheduler->serviceQueue(); });
132+
threadGroup.create_thread([&] { TraceThread("scheduler", [&] { m_node.scheduler->serviceQueue(); }); });
133133
GetMainSignals().RegisterBackgroundSignalScheduler(*m_node.scheduler);
134134

135135
pblocktree.reset(new CBlockTreeDB(1 << 20, true));

0 commit comments

Comments
 (0)