aboutsummaryrefslogtreecommitdiffstats
path: root/storage/src
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-09-05 09:47:37 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2023-09-05 09:47:37 +0000
commit72c03cb0620d5d246af0fd8246c252d9acb64a8e (patch)
treeff9198303061e37625d8d6fdd44b1093ab283784 /storage/src
parentf100b75a98be3f7a60b6f2d944b2281a2423bf1c (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.cpp15
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);
}