Pass scheduler to InitLLMQSystem

Author: codablock

src/init.cpp

@@ -1747,7 +1747,7 @@ bool AppInitMain(boost::thread_group& threadGroup, CScheduler& scheduler)
                 pcoinsdbview = new CCoinsViewDB(nCoinDBCache, false, fReindex || fReindexChainState);
                 pcoinscatcher = new CCoinsViewErrorCatcher(pcoinsdbview);
                 pcoinsTip = new CCoinsViewCache(pcoinscatcher);
-                llmq::InitLLMQSystem(*evoDb);
+                llmq::InitLLMQSystem(*evoDb, &scheduler);
 
                 if (fReindex) {
                     pblocktree->WriteReindexing(true);

src/llmq/quorums_init.cpp

@@ -8,12 +8,14 @@
 #include "quorums_commitment.h"
 #include "quorums_dkgsessionmgr.h"
 
+#include "scheduler.h"
+
 namespace llmq
 {
 
 static CBLSWorker blsWorker;
 
-void InitLLMQSystem(CEvoDB& evoDb)
+void InitLLMQSystem(CEvoDB& evoDb, CScheduler* scheduler)
 {
     quorumBlockProcessor = new CQuorumBlockProcessor(evoDb);
     quorumDKGSessionManager = new CDKGSessionManager(evoDb, blsWorker);

src/llmq/quorums_init.h

@@ -6,14 +6,15 @@
 #define DASH_QUORUMS_INIT_H
 
 class CEvoDB;
+class CScheduler;
 
 namespace llmq
 {
 
 // If true, we will connect to all new quorums and watch their communication
 static const bool DEFAULT_WATCH_QUORUMS = false;
 
-void InitLLMQSystem(CEvoDB& evoDb);
+void InitLLMQSystem(CEvoDB& evoDb, CScheduler* scheduler);
 void DestroyLLMQSystem();
 
 }

src/qt/test/rpcnestedtests.cpp

@@ -55,7 +55,7 @@ void RPCNestedTests::rpcNestedTests()
     pcoinsdbview = new CCoinsViewDB(1 << 23, true);
     deterministicMNManager = new CDeterministicMNManager(*evoDb);
 
-    llmq::InitLLMQSystem(*evoDb);
+    llmq::InitLLMQSystem(*evoDb, nullptr);
 
     pcoinsTip = new CCoinsViewCache(pcoinsdbview);
     InitBlockIndex(chainparams);

src/test/test_dash.cpp

@@ -78,7 +78,7 @@ TestingSetup::TestingSetup(const std::string& chainName) : BasicTestingSetup(cha
         mempool.setSanityCheck(1.0);
         pblocktree = new CBlockTreeDB(1 << 20, true);
         pcoinsdbview = new CCoinsViewDB(1 << 23, true);
-        llmq::InitLLMQSystem(*evoDb);
+        llmq::InitLLMQSystem(*evoDb, nullptr);
         pcoinsTip = new CCoinsViewCache(pcoinsdbview);
         InitBlockIndex(chainparams);
         {