diff options
author | Geir Storli <geirstorli@yahoo.no> | 2017-11-17 13:19:33 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-11-17 13:19:33 +0100 |
commit | 8307b856d58a3696c47772e552a1f06973b775c7 (patch) | |
tree | dd5dbff5eae564a9e4436f17db340168c6859d40 /storage | |
parent | ef6ad29be045374dbd5a885d036fe12a95c5dc9c (diff) | |
parent | 528b3cdb541141f81c1c557cc49de27923180c9b (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.cpp | 17 |
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; } } |