0a5e8eb862
Later commits will introduce checks for "safe TXs" which might abort the signing on first try, but succeed a few seconds later, so we periodically retry to sign the tip.
101 lines
2.8 KiB
C++
101 lines
2.8 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 "scheduler.h"
|
|
|
|
namespace llmq
|
|
{
|
|
|
|
static CBLSWorker blsWorker;
|
|
|
|
void InitLLMQSystem(CEvoDB& evoDb, CScheduler* scheduler, bool unitTests)
|
|
{
|
|
quorumDKGDebugManager = new CDKGDebugManager(scheduler);
|
|
quorumBlockProcessor = new CQuorumBlockProcessor(evoDb);
|
|
quorumDKGSessionManager = new CDKGSessionManager(evoDb, blsWorker);
|
|
quorumManager = new CQuorumManager(evoDb, blsWorker, *quorumDKGSessionManager);
|
|
quorumSigSharesManager = new CSigSharesManager();
|
|
quorumSigningManager = new CSigningManager(unitTests);
|
|
chainLocksHandler = new CChainLocksHandler(scheduler);
|
|
quorumInstantSendManager = new CInstantSendManager(scheduler);
|
|
}
|
|
|
|
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;
|
|
}
|
|
|
|
void StartLLMQSystem()
|
|
{
|
|
if (quorumDKGDebugManager) {
|
|
quorumDKGDebugManager->StartScheduler();
|
|
}
|
|
if (quorumDKGSessionManager) {
|
|
quorumDKGSessionManager->StartMessageHandlerPool();
|
|
}
|
|
if (quorumSigSharesManager) {
|
|
quorumSigSharesManager->RegisterAsRecoveredSigsListener();
|
|
quorumSigSharesManager->StartWorkerThread();
|
|
}
|
|
if (chainLocksHandler) {
|
|
chainLocksHandler->Start();
|
|
}
|
|
if (quorumInstantSendManager) {
|
|
quorumInstantSendManager->RegisterAsRecoveredSigsListener();
|
|
}
|
|
}
|
|
|
|
void StopLLMQSystem()
|
|
{
|
|
if (quorumInstantSendManager) {
|
|
quorumInstantSendManager->UnregisterAsRecoveredSigsListener();
|
|
}
|
|
if (chainLocksHandler) {
|
|
chainLocksHandler->Stop();
|
|
}
|
|
if (quorumSigSharesManager) {
|
|
quorumSigSharesManager->StopWorkerThread();
|
|
quorumSigSharesManager->UnregisterAsRecoveredSigsListener();
|
|
}
|
|
if (quorumDKGSessionManager) {
|
|
quorumDKGSessionManager->StopMessageHandlerPool();
|
|
}
|
|
}
|
|
|
|
void InterruptLLMQSystem()
|
|
{
|
|
if (quorumSigSharesManager) {
|
|
quorumSigSharesManager->InterruptWorkerThread();
|
|
}
|
|
}
|
|
|
|
}
|