Skip to content

Commit 5a6e64d

Browse files
refactor: use std::move for CQuorumCPtr in StartQuorumDataRecoveryThread
1 parent 46856fc commit 5a6e64d

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/llmq/quorums.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -293,7 +293,7 @@ void CQuorumManager::TriggerQuorumDataRecoveryThreads(CConnman& connman, const C
293293
}
294294

295295
// Finally start the thread which triggers the requests for this quorum
296-
StartQuorumDataRecoveryThread(connman, pQuorum, pIndex, nDataMask);
296+
StartQuorumDataRecoveryThread(connman, std::move(pQuorum), pIndex, nDataMask);
297297
}
298298
}
299299
}
@@ -913,7 +913,7 @@ void CQuorumManager::StartCachePopulatorThread(const CQuorumCPtr pQuorum) const
913913
});
914914
}
915915

916-
void CQuorumManager::StartQuorumDataRecoveryThread(CConnman& connman, const CQuorumCPtr pQuorum,
916+
void CQuorumManager::StartQuorumDataRecoveryThread(CConnman& connman, CQuorumCPtr pQuorum,
917917
const CBlockIndex* pIndex, uint16_t nDataMaskIn) const
918918
{
919919
assert(m_mn_activeman);
@@ -924,7 +924,7 @@ void CQuorumManager::StartQuorumDataRecoveryThread(CConnman& connman, const CQuo
924924
return;
925925
}
926926

927-
workerPool.push([&connman, pQuorum, pIndex, nDataMaskIn, this](int threadId) {
927+
workerPool.push([&connman, pQuorum = std::move(pQuorum), pIndex, nDataMaskIn, this](int threadId) {
928928
size_t nTries{0};
929929
uint16_t nDataMask{nDataMaskIn};
930930
int64_t nTimeLastSuccess{0};

src/llmq/quorums.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -312,7 +312,7 @@ class CQuorumManager
312312
size_t GetQuorumRecoveryStartOffset(const CQuorum& quorum, const CBlockIndex* pIndex) const;
313313

314314
void StartCachePopulatorThread(const CQuorumCPtr pQuorum) const;
315-
void StartQuorumDataRecoveryThread(CConnman& connman, const CQuorumCPtr pQuorum, const CBlockIndex* pIndex,
315+
void StartQuorumDataRecoveryThread(CConnman& connman, CQuorumCPtr pQuorum, const CBlockIndex* pIndex,
316316
uint16_t nDataMask) const;
317317

318318
void StartCleanupOldQuorumDataThread(const CBlockIndex* pIndex) const;

0 commit comments

Comments
 (0)