@@ -206,22 +206,25 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re
206206
207207 // check if the object is being deleted
208208 if instance .GetDeletionTimestamp ().IsZero () {
209- if err = r .addFinalizerToVR (ctx , logger , instance ); err != nil {
209+ err = r .addFinalizerToVR (ctx , logger , instance )
210+ err != nil {
210211 logger .Error (err , "Failed to add VolumeReplication finalizer" )
211212
212213 return reconcile.Result {}, err
213214 }
214215
215216 if pvc != nil {
216- if err = r .addFinalizerToPVC (ctx , logger , pvc ); err != nil {
217+ err = r .addFinalizerToPVC (ctx , logger , pvc )
218+ if err != nil {
217219 logger .Error (err , "Failed to add PersistentVolumeClaim finalizer" )
218220
219221 return reconcile.Result {}, err
220222 }
221223 }
222224
223225 if vg != nil {
224- if err = r .addFinalizerToVG (ctx , logger , vg ); err != nil {
226+ err = r .addFinalizerToVG (ctx , logger , vg )
227+ if err != nil {
225228 logger .Error (err , "Failed to add VolumeGroup finalizer" )
226229
227230 return reconcile.Result {}, err
@@ -237,22 +240,25 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re
237240 }
238241
239242 if pvc != nil {
240- if err = r .removeFinalizerFromPVC (ctx , logger , pvc ); err != nil {
243+ err = r .removeFinalizerFromPVC (ctx , logger , pvc )
244+ if err != nil {
241245 logger .Error (err , "Failed to remove PersistentVolumeClaim finalizer" )
242246
243247 return reconcile.Result {}, err
244248 }
245249 }
246250 if vg != nil {
247- if err = r .removeFinalizerFromVG (ctx , logger , vg ); err != nil {
251+ err = r .removeFinalizerFromVG (ctx , logger , vg )
252+ if err != nil {
248253 logger .Error (err , "Failed to remove VolumeGroup finalizer" )
249254
250255 return reconcile.Result {}, err
251256 }
252257 }
253258 // once all finalizers have been removed, the object will be
254259 // deleted
255- if err = r .removeFinalizerFromVR (ctx , logger , instance ); err != nil {
260+ err = r .removeFinalizerFromVR (ctx , logger , instance )
261+ if err != nil {
256262 logger .Error (err , "Failed to remove VolumeReplication finalizer" )
257263
258264 return reconcile.Result {}, err
@@ -265,14 +271,16 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re
265271 }
266272
267273 instance .Status .LastStartTime = getCurrentTime ()
268- if err = r .Client .Update (ctx , instance ); err != nil {
274+ err = r .Client .Update (ctx , instance )
275+ if err != nil {
269276 logger .Error (err , "failed to update status" )
270277
271278 return reconcile.Result {}, err
272279 }
273280
274281 // enable replication on every reconcile
275- if err = r .enableReplication (logger , replicationSource , replicationHandle , parameters , secret ); err != nil {
282+ err = r .enableReplication (logger , replicationSource , replicationHandle , parameters , secret )
283+ if err != nil {
276284 logger .Error (err , "failed to enable replication" )
277285 setFailureCondition (instance )
278286
@@ -441,7 +449,8 @@ func (r *VolumeReplicationReconciler) updateReplicationStatus(
441449 instance .Status .State = state
442450 instance .Status .Message = message
443451 instance .Status .ObservedGeneration = instance .Generation
444- if err := r .Client .Status ().Update (ctx , instance ); err != nil {
452+ err := r .Client .Status ().Update (ctx , instance )
453+ if err != nil {
445454 logger .Error (err , "failed to update status" )
446455
447456 return err
@@ -634,7 +643,8 @@ func (r *VolumeReplicationReconciler) disableVolumeReplication(logger logr.Logge
634643 resp := volumeReplication .Disable ()
635644
636645 if resp .Error != nil {
637- if isKnownError := resp .HasKnownGRPCError (disableReplicationKnownErrors ); isKnownError {
646+ isKnownError := resp .HasKnownGRPCError (disableReplicationKnownErrors )
647+ if isKnownError {
638648 logger .Info ("volume not found" , "replicationSource" , replicationSource )
639649
640650 return nil
0 commit comments