Allow QueueAssignmentAdvisory do CSL from the second part of LeaderAdvisory

Signed-off-by: Emelia Lei <[email protected]>

Author: emelialei88

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
 
@@ -1694,7 +1693,7 @@ void ClusterStateManager::processQueueAssignmentAdvisory(
             }
         }
         else {
-            if (delayed || fromLeaderAdvisory) {
+            if (delayed) {
                 AppInfos appIdInfos(d_allocator_p);
 
                 mqbc::ClusterUtil::parseQueueInfo(&appIdInfos,
@@ -1706,7 +1705,7 @@ void ClusterStateManager::processQueueAssignmentAdvisory(
                                        queueInfo.partitionId(),
                                        appIdInfos);
             }
-            // When this function is called from
+            // When this function is not buffered, called from
             // processQueueAssignmentAdvisory, assignQueue will
             // be triggered through mqbblp::ClusterStateManager::onCommit
         }
@@ -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,

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`.

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");

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`.

src/groups/mqb/mqbi/mqbi_clusterstatemanager.h

@@ -86,9 +86,9 @@ class ClusterStateManager {
         AfterPartitionPrimaryAssignmentCb;
 
     /// Pair of (appId, appKey)
-    typedef bsl::pair<bsl::string, mqbu::StorageKey> AppInfo;
+    typedef bsl::pair<bsl::string, mqbu::StorageKey>          AppInfo;
     typedef bsl::unordered_map<bsl::string, mqbu::StorageKey> 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`.