ctrl: Demote volume if the state is primary

Madhu-1 · Madhu-1 · commit 8caf81af5c5c · 2021-11-16T13:49:22.000+05:30
Demote the volume only once if the instance
state is primary.

Signed-off-by: Madhu Rajanna &lt;madhupr007@gmail.com&gt;
diff --git a/controllers/volumereplication_controller.go b/controllers/volumereplication_controller.go
@@ -237,11 +237,8 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re
 				}, nil
 			}
 		} else {
-			replicationErr = r.markVolumeAsSecondary(instance, logger, volumeHandle, replicationHandle, parameters, secret)
-			// resync volume if successfully marked Secondary
-			if replicationErr == nil {
-				requeueForResync, replicationErr = r.resyncVolume(instance, logger, volumeHandle, replicationHandle, parameters, secret)
-			}
+			// resync volume as the volume is already marked Secondary
+			requeueForResync, replicationErr = r.resyncVolume(instance, logger, volumeHandle, replicationHandle, parameters, secret)
 		}
 
 	case replicationv1alpha1.Resync:

Original file line number	Diff line number	Diff line change
`@@ -237,11 +237,8 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re`
`237`	`237`	`}, nil`
`238`	`238`	`}`
`239`	`239`	`} else {`
`240`		`- replicationErr = r.markVolumeAsSecondary(instance, logger, volumeHandle, replicationHandle, parameters, secret)`
`241`		`- // resync volume if successfully marked Secondary`
`242`		`- if replicationErr == nil {`
`243`		`- requeueForResync, replicationErr = r.resyncVolume(instance, logger, volumeHandle, replicationHandle, parameters, secret)`
`244`		`- }`
	`240`	`+ // resync volume as the volume is already marked Secondary`
	`241`	`+ requeueForResync, replicationErr = r.resyncVolume(instance, logger, volumeHandle, replicationHandle, parameters, secret)`
`245`	`242`	`}`
`246`	`243`
`247`	`244`	`case replicationv1alpha1.Resync:`