From 6534252c226a47603a7224d74d40ef943c51a926 Mon Sep 17 00:00:00 2001 From: Anton Nikiforov Date: Wed, 10 Jan 2024 15:17:05 +0300 Subject: [PATCH] [#799] policer: Refactor method `processNodes` Signed-off-by: Anton Nikiforov --- pkg/services/policer/check.go | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/pkg/services/policer/check.go b/pkg/services/policer/check.go index 73f83b2a..bb6313d0 100644 --- a/pkg/services/policer/check.go +++ b/pkg/services/policer/check.go @@ -132,21 +132,21 @@ func (p *Policer) processNodes(ctx context.Context, requirements *placementRequi cancel() - if client.IsErrObjectNotFound(err) { - checkedNodes.submitReplicaCandidate(nodes[i]) - continue - } - - if isClientErrMaintenance(err) { - shortage, uncheckedCopies = p.handleMaintenance(nodes[i], checkedNodes, shortage, uncheckedCopies) - } else if err != nil { - p.log.Error(logs.PolicerReceiveObjectHeaderToCheckPolicyCompliance, - zap.Stringer("object", addr), - zap.String("error", err.Error()), - ) - } else { + if err == nil { shortage-- checkedNodes.submitReplicaHolder(nodes[i]) + } else { + if client.IsErrObjectNotFound(err) { + checkedNodes.submitReplicaCandidate(nodes[i]) + continue + } else if isClientErrMaintenance(err) { + shortage, uncheckedCopies = p.handleMaintenance(nodes[i], checkedNodes, shortage, uncheckedCopies) + } else { + p.log.Error(logs.PolicerReceiveObjectHeaderToCheckPolicyCompliance, + zap.Stringer("object", addr), + zap.String("error", err.Error()), + ) + } } }