90b1b71967
* Let ProcessPendingInstantSendLocks return true when it did some work * Introduce own worker thread for CInstantSendManager Instead of using the scheduler. * Remove scheduler from CInstantSendManager * Add missing reset() call for workInterrupt
122 lines
3.3 KiB
C++
122 lines
3.3 KiB
C++
// Copyright (c) 2018-2019 The Dash Core developers
|
|
// Distributed under the MIT/X11 software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#include "quorums_init.h"
|
|
|
|
#include "quorums.h"
|
|
#include "quorums_blockprocessor.h"
|
|
#include "quorums_commitment.h"
|
|
#include "quorums_chainlocks.h"
|
|
#include "quorums_debug.h"
|
|
#include "quorums_dkgsessionmgr.h"
|
|
#include "quorums_instantsend.h"
|
|
#include "quorums_signing.h"
|
|
#include "quorums_signing_shares.h"
|
|
|
|
#include "dbwrapper.h"
|
|
#include "scheduler.h"
|
|
|
|
namespace llmq
|
|
{
|
|
|
|
CBLSWorker* blsWorker;
|
|
|
|
CDBWrapper* llmqDb;
|
|
|
|
void InitLLMQSystem(CEvoDB& evoDb, CScheduler* scheduler, bool unitTests, bool fWipe)
|
|
{
|
|
llmqDb = new CDBWrapper(unitTests ? "" : (GetDataDir() / "llmq"), 1 << 20, unitTests, fWipe);
|
|
blsWorker = new CBLSWorker();
|
|
|
|
quorumDKGDebugManager = new CDKGDebugManager(scheduler);
|
|
quorumBlockProcessor = new CQuorumBlockProcessor(evoDb);
|
|
quorumDKGSessionManager = new CDKGSessionManager(*llmqDb, *blsWorker);
|
|
quorumManager = new CQuorumManager(evoDb, *blsWorker, *quorumDKGSessionManager);
|
|
quorumSigSharesManager = new CSigSharesManager();
|
|
quorumSigningManager = new CSigningManager(*llmqDb, unitTests);
|
|
chainLocksHandler = new CChainLocksHandler(scheduler);
|
|
quorumInstantSendManager = new CInstantSendManager(*llmqDb);
|
|
}
|
|
|
|
void DestroyLLMQSystem()
|
|
{
|
|
delete quorumInstantSendManager;
|
|
quorumInstantSendManager = nullptr;
|
|
delete chainLocksHandler;
|
|
chainLocksHandler = nullptr;
|
|
delete quorumSigningManager;
|
|
quorumSigningManager = nullptr;
|
|
delete quorumSigSharesManager;
|
|
quorumSigSharesManager = nullptr;
|
|
delete quorumManager;
|
|
quorumManager = NULL;
|
|
delete quorumDKGSessionManager;
|
|
quorumDKGSessionManager = NULL;
|
|
delete quorumBlockProcessor;
|
|
quorumBlockProcessor = nullptr;
|
|
delete quorumDKGDebugManager;
|
|
quorumDKGDebugManager = nullptr;
|
|
delete blsWorker;
|
|
blsWorker = nullptr;
|
|
delete llmqDb;
|
|
llmqDb = nullptr;
|
|
}
|
|
|
|
void StartLLMQSystem()
|
|
{
|
|
quorumBlockProcessor->UpgradeDB();
|
|
|
|
if (blsWorker) {
|
|
blsWorker->Start();
|
|
}
|
|
if (quorumDKGDebugManager) {
|
|
quorumDKGDebugManager->StartScheduler();
|
|
}
|
|
if (quorumDKGSessionManager) {
|
|
quorumDKGSessionManager->StartMessageHandlerPool();
|
|
}
|
|
if (quorumSigSharesManager) {
|
|
quorumSigSharesManager->RegisterAsRecoveredSigsListener();
|
|
quorumSigSharesManager->StartWorkerThread();
|
|
}
|
|
if (chainLocksHandler) {
|
|
chainLocksHandler->Start();
|
|
}
|
|
if (quorumInstantSendManager) {
|
|
quorumInstantSendManager->Start();
|
|
}
|
|
}
|
|
|
|
void StopLLMQSystem()
|
|
{
|
|
if (quorumInstantSendManager) {
|
|
quorumInstantSendManager->Stop();
|
|
}
|
|
if (chainLocksHandler) {
|
|
chainLocksHandler->Stop();
|
|
}
|
|
if (quorumSigSharesManager) {
|
|
quorumSigSharesManager->StopWorkerThread();
|
|
quorumSigSharesManager->UnregisterAsRecoveredSigsListener();
|
|
}
|
|
if (quorumDKGSessionManager) {
|
|
quorumDKGSessionManager->StopMessageHandlerPool();
|
|
}
|
|
if (blsWorker) {
|
|
blsWorker->Stop();
|
|
}
|
|
}
|
|
|
|
void InterruptLLMQSystem()
|
|
{
|
|
if (quorumSigSharesManager) {
|
|
quorumSigSharesManager->InterruptWorkerThread();
|
|
}
|
|
if (quorumInstantSendManager) {
|
|
quorumInstantSendManager->InterruptWorkerThread();
|
|
}
|
|
}
|
|
|
|
}
|