TEST 2

Signed-off-by: Utkarsh Bhatt <[email protected]>

microceph/ceph/replication_rbd.go

@@ -470,17 +470,21 @@ func handlePoolDePro(rh *RbdReplicationHandler, poolName string) error {
 	logger.Infof("REPRBD: op(%s), pool(%s)", rh.Request.RequestType, poolName)
 
 	for _, peer := range poolInfo.Peers {
+		logger.Infof("REPRBD: op(%s), pool(%s), peer(%s)", rh.Request.RequestType, poolName, peer.RemoteName)
 		// Perform operation only if the remote cluster is a known peer.
 		if peer.RemoteName == rh.Request.RemoteName {
-			if rh.Request.RequestType == constants.EventPromoteReplication {
+			logger.Infof("REPRBD: YES")
+			if rh.Request.RequestType == types.PromoteReplicationRequest {
+				logger.Infof("REPRBD: PROMOTE")
 				// Promote the pool to primary.
 				err := handlePoolPromotion(rh, poolName)
 				if err != nil {
 					// Stop if failed.
 					logger.Errorf("REPRBD: failed to promote local site to primary: %v", err)
 					return err
 				}
-			} else if rh.Request.RequestType == constants.EventDemoteReplication {
+			} else if rh.Request.RequestType == types.DemoteReplicationRequest {
+				logger.Infof("REPRBD: DEMOTE")
 				// Demote the pool to secondary.
 				err := handlePoolDemotion(rh, poolName)
 				if err != nil {