PIVX Core  5.6.99
P2P Digital Currency
quorums_init.cpp
Go to the documentation of this file.
1 // Copyright (c) 2018-2021 The Dash Core developers
2 // Copyright (c) 2022 The PIVX Core developers
3 // Distributed under the MIT/X11 software license, see the accompanying
4 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
5 
6 #include "llmq/quorums_init.h"
7 
8 #include "bls/bls_worker.h"
9 #include "dbwrapper.h"
10 #include "llmq/quorums.h"
11 #include "llmq/quorums_blockprocessor.h"
12 #include "llmq/quorums_debug.h"
13 #include "llmq/quorums_dkgsessionmgr.h"
14 #include "quorums_chainlocks.h"
15 #include "quorums_signing.h"
16 #include "quorums_signing_shares.h"
17 
18 namespace llmq
19 {
20 
21 CBLSWorker* blsWorker;
22 CDBWrapper* llmqDb;
23 
24 void InitLLMQSystem(CEvoDB& evoDb, CScheduler* scheduler, bool unitTests)
25 {
26  llmqDb = new CDBWrapper(unitTests ? "" : (GetDataDir() / "llmq"), 1 << 20, unitTests, false, CLIENT_VERSION | ADDRV2_FORMAT);
27  blsWorker = new CBLSWorker();
28 
29  quorumDKGDebugManager.reset(new CDKGDebugManager());
30  quorumBlockProcessor.reset(new CQuorumBlockProcessor(evoDb));
31  quorumDKGSessionManager.reset(new CDKGSessionManager(*llmqDb, *blsWorker));
32  quorumManager.reset(new CQuorumManager(evoDb, *blsWorker, *quorumDKGSessionManager));
33  quorumSigSharesManager.reset(new CSigSharesManager());
34  quorumSigningManager.reset(new CSigningManager(*llmqDb, unitTests));
35  chainLocksHandler.reset(new CChainLocksHandler(scheduler));
36 }
37 
38 void DestroyLLMQSystem()
39 {
40  chainLocksHandler.reset();
41  quorumSigningManager.reset();
42  quorumSigSharesManager.reset();
43  quorumDKGSessionManager.reset();
44  quorumBlockProcessor.reset();
45  quorumDKGDebugManager.reset();
46  quorumManager.reset();
47  delete blsWorker;
48  blsWorker = nullptr;
49  delete llmqDb;
50  llmqDb = nullptr;
51 }
52 
53 void StartLLMQSystem()
54 {
55  if (blsWorker) {
56  blsWorker->Start();
57  }
58  if (quorumDKGSessionManager) {
59  quorumDKGSessionManager->StartThreads();
60  }
61  if (quorumSigSharesManager) {
62  quorumSigSharesManager->RegisterAsRecoveredSigsListener();
63  quorumSigSharesManager->StartWorkerThread();
64  }
65  if (chainLocksHandler) {
66  chainLocksHandler->Start();
67  }
68 }
69 
70 void StopLLMQSystem()
71 {
72  if (chainLocksHandler) {
73  chainLocksHandler->Stop();
74  }
75  if (quorumSigSharesManager) {
76  quorumSigSharesManager->StopWorkerThread();
77  quorumSigSharesManager->UnregisterAsRecoveredSigsListener();
78  }
79  if (quorumDKGSessionManager) {
80  quorumDKGSessionManager->StopThreads();
81  }
82  if (blsWorker) {
83  blsWorker->Stop();
84  }
85 }
86 
87 void InterruptLLMQSystem()
88 {
89  if (quorumSigSharesManager) {
90  quorumSigSharesManager->Interrupt();
91  }
92 }
93 
94 } // namespace llmq
bls_worker.h
CBLSWorker::Start
void Start()
Definition: bls_worker.cpp:63
CBLSWorker::Stop
void Stop()
Definition: bls_worker.cpp:71
CEvoDB
Definition: evodb.h:32
llmq::CQuorumManager
The quorum manager maintains quorums which were mined on chain.
Definition: quorums.h:81
evoDb
std::unique_ptr< CEvoDB > evoDb
Definition: evodb.cpp:10
llmq
Definition: quorums.cpp:26
llmq::DestroyLLMQSystem
void DestroyLLMQSystem()
Definition: quorums_init.cpp:38
llmq::StartLLMQSystem
void StartLLMQSystem()
Definition: quorums_init.cpp:53
llmq::quorumBlockProcessor
std::unique_ptr< CQuorumBlockProcessor > quorumBlockProcessor
Definition: quorums_blockprocessor.cpp:23
llmq::quorumManager
std::unique_ptr< CQuorumManager > quorumManager
Definition: quorums.cpp:31
llmq::InterruptLLMQSystem
void InterruptLLMQSystem()
Definition: quorums_init.cpp:87
llmq::StopLLMQSystem
void StopLLMQSystem()
Definition: quorums_init.cpp:70
llmq::quorumDKGDebugManager
std::unique_ptr< CDKGDebugManager > quorumDKGDebugManager
Definition: quorums_debug.cpp:17
llmq::quorumDKGSessionManager
std::unique_ptr< CDKGSessionManager > quorumDKGSessionManager
Definition: quorums_dkgsessionmgr.cpp:17
llmq::quorumSigningManager
std::unique_ptr< CSigningManager > quorumSigningManager
Definition: quorums_signing.cpp:25
llmq::quorumSigSharesManager
std::unique_ptr< CSigSharesManager > quorumSigSharesManager
Definition: quorums_signing_shares.cpp:26
llmq::chainLocksHandler
std::unique_ptr< CChainLocksHandler > chainLocksHandler
Definition: quorums_chainlocks.cpp:24
llmq::blsWorker
CBLSWorker * blsWorker
Definition: quorums_init.cpp:21
llmq::InitLLMQSystem
void InitLLMQSystem(CEvoDB &evoDb, CScheduler *scheduler, bool unitTests)
Definition: quorums_init.cpp:24
llmq::llmqDb
CDBWrapper * llmqDb
Definition: quorums_init.cpp:22
quorums_blockprocessor.h
quorums_chainlocks.h
quorums_debug.h
quorums_dkgsessionmgr.h
quorums_init.h
quorums_signing.h
quorums_signing_shares.h
GetDataDir
const fs::path & GetDataDir(bool fNetSpecific)
Definition: system.cpp:724
scheduler
CScheduler scheduler
Definition: walletprocessblock.cpp:97
Generated on Wed Apr 2 2025 00:40:29 for PIVX Core by doxygen 1.9.1