diff --git a/internal/rbd/replicationcontrollerserver.go b/internal/rbd/replicationcontrollerserver.go index 26ba62654..c940c019c 100644 --- a/internal/rbd/replicationcontrollerserver.go +++ b/internal/rbd/replicationcontrollerserver.go @@ -633,7 +633,7 @@ func checkHealthyPrimary(ctx context.Context, rbdVol *rbdVolume) error { return fmt.Errorf("failed to get local status: %w", err) } - if !localStatus.Up && localStatus.State != librbd.MirrorImageStatusStateStopped { + if !localStatus.Up || localStatus.State != librbd.MirrorImageStatusStateStopped { return fmt.Errorf("%s %w. State is up=%t, state=%q", rbdVol, ErrUnHealthyMirroredImage,