TMP

Author: kaikulimu

src/groups/mqb/mqbc/mqbc_storagemanager.cpp

@@ -1145,6 +1145,8 @@ void StorageManager::processShutdownEventDispatched(int partitionId)
     mqbs::FileStore* fs = d_fileStores[partitionId].get();
     BSLS_ASSERT_SAFE(fs);
 
+    // TODO fs.execute(&clearPrimaryForPartition2 || &shutdownMyBro); Then
+    // dispatch e_STOPPED
     EventData eventDataVec;
     eventDataVec.emplace_back(d_clusterData_p->membership().selfNode(),
                               -1,  // placeholder requestId
@@ -3911,6 +3913,8 @@ void StorageManager::stop()
     d_isStarted = false;
 
     for (size_t pid = 0; pid < d_fileStores.size(); ++pid) {
+        // TODO fs.execute(&clearPrimaryForPartition2 || &shutdownMyBro); Then
+        // dispatch e_STOPPED
         EventData eventDataVec;
         eventDataVec.emplace_back(d_clusterData_p->membership().selfNode(),
                                   -1,  // placeholder requestId
@@ -4202,6 +4206,13 @@ void StorageManager::setPrimaryForPartition(int                  partitionId,
                      partitionId < static_cast<int>(d_fileStores.size()));
     BSLS_ASSERT_SAFE(primaryNode);
 
+    /** TODO Call:
+    PartitionInfo&   pinfo = d_partitionInfoVec[partitionId];
+    pinfo.setPrimary(primaryNode);
+    pinfo.setPrimaryLeaseId(primaryLeaseId);
+    pinfo.setPrimaryStatus(bmqp_ctrlmsg::PrimaryStatus::E_PASSIVE);
+    */
+
     if (primaryNode->nodeId() ==
         d_clusterData_p->membership().selfNode()->nodeId()) {
         processPrimaryDetect(partitionId, primaryNode, primaryLeaseId);