@@ -434,17 +434,19 @@ class CSigSharesManager : public CRecoveredSigsListener
434434
435435 void AsyncSign (CQuorumCPtr quorum, const uint256& id, const uint256& msgHash)
436436 EXCLUSIVE_LOCKS_REQUIRED(!cs_pendingSigns, !cs);
437- std::optional<CSigShare> CreateSigShare (const CQuorum& quorum, const uint256& id, const uint256& msgHash) const EXCLUSIVE_LOCKS_REQUIRED(!cs);
438- void ForceReAnnouncement (const CQuorum& quorum, Consensus::LLMQType llmqType, const uint256& id, const uint256& msgHash) EXCLUSIVE_LOCKS_REQUIRED(!cs);
437+ std::optional<CSigShare> CreateSigShare (const CQuorum& quorum, const uint256& id, const uint256& msgHash) const
438+ EXCLUSIVE_LOCKS_REQUIRED(!cs);
439+ void ForceReAnnouncement (const CQuorum& quorum, Consensus::LLMQType llmqType, const uint256& id,
440+ const uint256& msgHash) EXCLUSIVE_LOCKS_REQUIRED(!cs);
439441
440- [[nodiscard]] MessageProcessingResult HandleNewRecoveredSig (const CRecoveredSig& recoveredSig) override EXCLUSIVE_LOCKS_REQUIRED(!cs);
442+ [[nodiscard]] MessageProcessingResult HandleNewRecoveredSig (const CRecoveredSig& recoveredSig) override
443+ EXCLUSIVE_LOCKS_REQUIRED(!cs);
441444
442445 static CDeterministicMNCPtr SelectMemberForRecovery (const CQuorum& quorum, const uint256& id, int attempt);
443446
444447 bool AsyncSignIfMember (Consensus::LLMQType llmqType, CSigningManager& sigman, const uint256& id,
445448 const uint256& msgHash, const uint256& quorumHash = uint256(), bool allowReSign = false,
446- bool allowDiffMsgHashSigning = false)
447- EXCLUSIVE_LOCKS_REQUIRED(!cs_pendingSigns, !cs);
449+ bool allowDiffMsgHashSigning = false) EXCLUSIVE_LOCKS_REQUIRED(!cs_pendingSigns, !cs);
448450
449451 void NotifyRecoveredSig (const std::shared_ptr<const CRecoveredSig>& sig) const EXCLUSIVE_LOCKS_REQUIRED(!cs);
450452
@@ -453,7 +455,8 @@ class CSigSharesManager : public CRecoveredSigsListener
453455 bool ProcessMessageSigSesAnn (const CNode& pfrom, const CSigSesAnn& ann) EXCLUSIVE_LOCKS_REQUIRED(!cs);
454456 bool ProcessMessageSigSharesInv (const CNode& pfrom, const CSigSharesInv& inv) EXCLUSIVE_LOCKS_REQUIRED(!cs);
455457 bool ProcessMessageGetSigShares (const CNode& pfrom, const CSigSharesInv& inv) EXCLUSIVE_LOCKS_REQUIRED(!cs);
456- bool ProcessMessageBatchedSigShares (const CNode& pfrom, const CBatchedSigShares& batchedSigShares) EXCLUSIVE_LOCKS_REQUIRED(!cs);
458+ bool ProcessMessageBatchedSigShares (const CNode& pfrom, const CBatchedSigShares& batchedSigShares)
459+ EXCLUSIVE_LOCKS_REQUIRED(!cs);
457460 void ProcessMessageSigShare (NodeId fromId, const CSigShare& sigShare) EXCLUSIVE_LOCKS_REQUIRED(!cs);
458461
459462 static bool VerifySigSharesInv (Consensus::LLMQType llmqType, const CSigSharesInv& inv);
@@ -462,17 +465,20 @@ class CSigSharesManager : public CRecoveredSigsListener
462465
463466 bool CollectPendingSigSharesToVerify (
464467 size_t maxUniqueSessions, std::unordered_map<NodeId, std::vector<CSigShare>>& retSigShares,
465- std::unordered_map<std::pair<Consensus::LLMQType, uint256>, CQuorumCPtr, StaticSaltedHasher>& retQuorums) EXCLUSIVE_LOCKS_REQUIRED(!cs);
468+ std::unordered_map<std::pair<Consensus::LLMQType, uint256>, CQuorumCPtr, StaticSaltedHasher>& retQuorums)
469+ EXCLUSIVE_LOCKS_REQUIRED(!cs);
466470 bool ProcessPendingSigShares () EXCLUSIVE_LOCKS_REQUIRED(!cs);
467471
468472 void ProcessPendingSigShares (
469473 const std::vector<CSigShare>& sigSharesToProcess,
470- const std::unordered_map<std::pair<Consensus::LLMQType, uint256>, CQuorumCPtr, StaticSaltedHasher>& quorums) EXCLUSIVE_LOCKS_REQUIRED(!cs);
474+ const std::unordered_map<std::pair<Consensus::LLMQType, uint256>, CQuorumCPtr, StaticSaltedHasher>& quorums)
475+ EXCLUSIVE_LOCKS_REQUIRED(!cs);
471476
472477 void ProcessSigShare (const CSigShare& sigShare, const CQuorumCPtr& quorum) EXCLUSIVE_LOCKS_REQUIRED(!cs);
473478 void TryRecoverSig (const CQuorum& quorum, const uint256& id, const uint256& msgHash) EXCLUSIVE_LOCKS_REQUIRED(!cs);
474479
475- bool GetSessionInfoByRecvId (NodeId nodeId, uint32_t sessionId, CSigSharesNodeState::SessionInfo& retInfo) EXCLUSIVE_LOCKS_REQUIRED(!cs);
480+ bool GetSessionInfoByRecvId (NodeId nodeId, uint32_t sessionId, CSigSharesNodeState::SessionInfo& retInfo)
481+ EXCLUSIVE_LOCKS_REQUIRED(!cs);
476482 static CSigShare RebuildSigShare (const CSigSharesNodeState::SessionInfo& session, const std::pair<uint16_t , CBLSLazySignature>& in);
477483
478484 void Cleanup () EXCLUSIVE_LOCKS_REQUIRED(!cs);
@@ -482,10 +488,13 @@ class CSigSharesManager : public CRecoveredSigsListener
482488 void BanNode (NodeId nodeId) EXCLUSIVE_LOCKS_REQUIRED(!cs);
483489
484490 bool SendMessages () EXCLUSIVE_LOCKS_REQUIRED(!cs);
485- void CollectSigSharesToRequest (std::unordered_map<NodeId, Uint256HashMap<CSigSharesInv>>& sigSharesToRequest) EXCLUSIVE_LOCKS_REQUIRED(cs);
486- void CollectSigSharesToSend (std::unordered_map<NodeId, Uint256HashMap<CBatchedSigShares>>& sigSharesToSend) EXCLUSIVE_LOCKS_REQUIRED(cs);
491+ void CollectSigSharesToRequest (std::unordered_map<NodeId, Uint256HashMap<CSigSharesInv>>& sigSharesToRequest)
492+ EXCLUSIVE_LOCKS_REQUIRED(cs);
493+ void CollectSigSharesToSend (std::unordered_map<NodeId, Uint256HashMap<CBatchedSigShares>>& sigSharesToSend)
494+ EXCLUSIVE_LOCKS_REQUIRED(cs);
487495 void CollectSigSharesToSendConcentrated (std::unordered_map<NodeId, std::vector<CSigShare>>& sigSharesToSend, const std::vector<CNode*>& vNodes) EXCLUSIVE_LOCKS_REQUIRED(cs);
488- void CollectSigSharesToAnnounce (std::unordered_map<NodeId, Uint256HashMap<CSigSharesInv>>& sigSharesToAnnounce) EXCLUSIVE_LOCKS_REQUIRED(cs);
496+ void CollectSigSharesToAnnounce (std::unordered_map<NodeId, Uint256HashMap<CSigSharesInv>>& sigSharesToAnnounce)
497+ EXCLUSIVE_LOCKS_REQUIRED(cs);
489498 void SignPendingSigShares () EXCLUSIVE_LOCKS_REQUIRED(!cs_pendingSigns, !cs);
490499 void WorkThreadMain () EXCLUSIVE_LOCKS_REQUIRED(!cs_pendingSigns, !cs);
491500};
0 commit comments