diff --git a/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.cpp b/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.cpp index 9172f2361..4232521be 100644 --- a/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.cpp +++ b/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.cpp @@ -1484,8 +1484,7 @@ void ClusterStateManager::processQueueAssignmentRequest( void ClusterStateManager::processQueueAssignmentAdvisory( const bmqp_ctrlmsg::ControlMessage& message, mqbnet::ClusterNode* source, - bool delayed, - bool fromLeaderAdvisory) + bool delayed) { // executed by the cluster *DISPATCHER* thread @@ -2161,8 +2160,7 @@ void ClusterStateManager::processLeaderAdvisory( processQueueAssignmentAdvisory(controlMsg, source, - false /* not delayed */, - true /* called from leaderAdvisory */); + false /* not delayed */); // Leader status and sequence number are updated unconditionally. It may // have been updated by one of the routines called earlier in this method, diff --git a/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.h b/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.h index d08b3de0c..d73d7c4b3 100644 --- a/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.h +++ b/src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.h @@ -489,11 +489,10 @@ class ClusterStateManager BSLS_KEYWORD_FINAL /// TODO_CSL: This is the current workflow which we should be able to /// remove after the new workflow via /// ClusterQueueHelper::onQueueAssigned() is stable. - void processQueueAssignmentAdvisory( - const bmqp_ctrlmsg::ControlMessage& message, - mqbnet::ClusterNode* source, - bool delayed = false, - bool fromLeaderAdvisory = false) BSLS_KEYWORD_OVERRIDE; + void + processQueueAssignmentAdvisory(const bmqp_ctrlmsg::ControlMessage& message, + mqbnet::ClusterNode* source, + bool delayed = false) BSLS_KEYWORD_OVERRIDE; /// Process the queue unAssigned advisory in the specified `message` /// received from the specified `source`. diff --git a/src/groups/mqb/mqbc/mqbc_clusterstatemanager.cpp b/src/groups/mqb/mqbc/mqbc_clusterstatemanager.cpp index e6ee31236..1ba151f73 100644 --- a/src/groups/mqb/mqbc/mqbc_clusterstatemanager.cpp +++ b/src/groups/mqb/mqbc/mqbc_clusterstatemanager.cpp @@ -1784,8 +1784,7 @@ void ClusterStateManager::processQueueAssignmentRequest( void ClusterStateManager::processQueueAssignmentAdvisory( BSLS_ANNOTATION_UNUSED const bmqp_ctrlmsg::ControlMessage& message, BSLS_ANNOTATION_UNUSED mqbnet::ClusterNode* source, - BSLS_ANNOTATION_UNUSED bool delayed, - BSLS_ANNOTATION_UNUSED bool fromLeaderAdvisory) + BSLS_ANNOTATION_UNUSED bool delayed) { BSLS_ASSERT_SAFE(false && "This method should only be invoked in non-CSL mode"); diff --git a/src/groups/mqb/mqbc/mqbc_clusterstatemanager.h b/src/groups/mqb/mqbc/mqbc_clusterstatemanager.h index e162ac0f1..57228c840 100644 --- a/src/groups/mqb/mqbc/mqbc_clusterstatemanager.h +++ b/src/groups/mqb/mqbc/mqbc_clusterstatemanager.h @@ -589,11 +589,10 @@ class ClusterStateManager BSLS_KEYWORD_FINAL /// TODO_CSL: This is the current workflow which we should be able to /// remove after the new workflow via /// ClusterQueueHelper::onQueueAssigned() is stable. - void processQueueAssignmentAdvisory( - const bmqp_ctrlmsg::ControlMessage& message, - mqbnet::ClusterNode* source, - bool delayed = false, - bool fromLeaderAdvisory = false) BSLS_KEYWORD_OVERRIDE; + void + processQueueAssignmentAdvisory(const bmqp_ctrlmsg::ControlMessage& message, + mqbnet::ClusterNode* source, + bool delayed = false) BSLS_KEYWORD_OVERRIDE; /// Process the queue unAssigned advisory in the specified `message` /// received from the specified `source`. diff --git a/src/groups/mqb/mqbi/mqbi_clusterstatemanager.h b/src/groups/mqb/mqbi/mqbi_clusterstatemanager.h index 6d3ce91ef..6e45208dd 100644 --- a/src/groups/mqb/mqbi/mqbi_clusterstatemanager.h +++ b/src/groups/mqb/mqbi/mqbi_clusterstatemanager.h @@ -86,9 +86,9 @@ class ClusterStateManager { AfterPartitionPrimaryAssignmentCb; /// Pair of (appId, appKey) - typedef bsl::pair AppInfo; + typedef bsl::pair AppInfo; typedef bsl::unordered_map AppInfos; - typedef AppInfos::const_iterator AppInfosCIter; + typedef AppInfos::const_iterator AppInfosCIter; struct QueueAssignmentResult { enum Enum { @@ -336,8 +336,7 @@ class ClusterStateManager { virtual void processQueueAssignmentAdvisory(const bmqp_ctrlmsg::ControlMessage& message, mqbnet::ClusterNode* source, - bool delayed = false, - bool fromLeaderAdvisory = false) = 0; + bool delayed = false) = 0; /// Process the queue unAssigned advisory in the specified `message` /// received from the specified `source`.