diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-09-05 09:47:37 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-09-05 09:47:37 +0000 |
commit | 72c03cb0620d5d246af0fd8246c252d9acb64a8e (patch) | |
tree | ff9198303061e37625d8d6fdd44b1093ab283784 /storage/src | |
parent | f100b75a98be3f7a60b6f2d944b2281a2423bf1c (diff) |
Unify on uint16_t and repair intellij auto conversion.
Diffstat (limited to 'storage/src')
-rw-r--r-- | storage/src/vespa/storage/distributor/operations/idealstate/setbucketstateoperation.cpp | 15 |
1 files changed, 5 insertions, 10 deletions
diff --git a/storage/src/vespa/storage/distributor/operations/idealstate/setbucketstateoperation.cpp b/storage/src/vespa/storage/distributor/operations/idealstate/setbucketstateoperation.cpp index 3b99fa9f035..531f7f64b68 100644 --- a/storage/src/vespa/storage/distributor/operations/idealstate/setbucketstateoperation.cpp +++ b/storage/src/vespa/storage/distributor/operations/idealstate/setbucketstateoperation.cpp @@ -10,10 +10,6 @@ LOG_SETUP(".distributor.operation.idealstate.setactive"); namespace storage::distributor { -namespace { - -} - SetBucketStateOperation::SetBucketStateOperation(const ClusterContext& cluster_ctx, const BucketAndNodes& nodes, const std::vector<uint16_t>& wantedActiveNodes) @@ -35,8 +31,8 @@ SetBucketStateOperation::enqueueSetBucketStateCommand(uint16_t node, bool active bool SetBucketStateOperation::shouldBeActive(uint16_t node) const { - for (unsigned short _wantedActiveNode : _wantedActiveNodes) { - if (_wantedActiveNode == node) { + for (uint16_t wantedActiveNode : _wantedActiveNodes) { + if (wantedActiveNode == node) { return true; } } @@ -45,8 +41,8 @@ SetBucketStateOperation::shouldBeActive(uint16_t node) const void SetBucketStateOperation::activateNode(DistributorStripeMessageSender& sender) { - for (unsigned short _wantedActiveNode : _wantedActiveNodes) { - enqueueSetBucketStateCommand(_wantedActiveNode, true); + for (uint16_t wantedActiveNode : _wantedActiveNodes) { + enqueueSetBucketStateCommand(wantedActiveNode, true); } _tracker.flushQueue(sender); _ok = true; @@ -55,8 +51,7 @@ SetBucketStateOperation::activateNode(DistributorStripeMessageSender& sender) { void SetBucketStateOperation::deactivateNodes(DistributorStripeMessageSender& sender) { - const std::vector<uint16_t>& nodes(getNodes()); - for (unsigned short node : nodes) { + for (uint16_t node : getNodes()) { if (!shouldBeActive(node)) { enqueueSetBucketStateCommand(node, false); } |