summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorGeir Storli <geirstorli@yahoo.no>2017-11-17 13:19:33 +0100
committerGitHub <noreply@github.com>2017-11-17 13:19:33 +0100
commit8307b856d58a3696c47772e552a1f06973b775c7 (patch)
treedd5dbff5eae564a9e4436f17db340168c6859d40 /storage
parentef6ad29be045374dbd5a885d036fe12a95c5dc9c (diff)
parent528b3cdb541141f81c1c557cc49de27923180c9b (diff)
Merge pull request #4171 from vespa-engine/toregge/simplify-check-for-pending-request-bucket-info-command
Simplify check for pending RequestBucketInfoCommand.
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp17
1 files changed, 4 insertions, 13 deletions
diff --git a/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp b/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp
index 1e4067eb128..2337129e375 100644
--- a/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp
+++ b/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp
@@ -196,19 +196,10 @@ checkNullBucketRequestBucketInfoMessage(uint16_t node,
const PendingMessageTracker& tracker)
{
RequestBucketInfoChecker rchk;
- for (;;) {
- // Check messages sent to null-bucket (i.e. any bucket) for the node.
- document::Bucket nullBucket(bucketSpace, document::BucketId());
- tracker.checkPendingMessages(node, nullBucket, rchk);
- if (rchk.blocked) {
- return true;
- }
- if (bucketSpace == BucketSpace::placeHolder()) {
- break;
- }
- bucketSpace = BucketSpace::placeHolder();
- }
- return false;
+ // Check messages sent to null-bucket (i.e. any bucket) for the node.
+ document::Bucket nullBucket(bucketSpace, document::BucketId());
+ tracker.checkPendingMessages(node, nullBucket, rchk);
+ return rchk.blocked;
}
}