diff options
| -rw-r--r-- | storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp | 3 | ||||
| -rw-r--r-- | storage/src/vespa/storage/distributor/statechecker.cpp | 1 |
2 files changed, 4 insertions, 0 deletions
diff --git a/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp b/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp index 42d9e3d4a3d..142ff72bc79 100644 --- a/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp +++ b/storage/src/vespa/storage/distributor/operations/idealstate/idealstateoperation.cpp @@ -185,6 +185,9 @@ public: } }; +// TODO STRIPE replace with check for pending cluster state transition. +// Null-bucket messages are not intercepted nor observeable by stripes, +// only by the top-level distributor. bool checkNullBucketRequestBucketInfoMessage(uint16_t node, document::BucketSpace bucketSpace, diff --git a/storage/src/vespa/storage/distributor/statechecker.cpp b/storage/src/vespa/storage/distributor/statechecker.cpp index 82b8371e163..049e39fa3fc 100644 --- a/storage/src/vespa/storage/distributor/statechecker.cpp +++ b/storage/src/vespa/storage/distributor/statechecker.cpp @@ -79,6 +79,7 @@ StateChecker::Context::Context(const DistributorNodeContext& node_ctx_in, db(distributorBucketSpace.getBucketDatabase()), stats(statsTracker) { + // TODO STRIPE use existing cache for computing ideal storage nodes for bucket idealState = distribution.getIdealStorageNodes(systemState, bucket.getBucketId()); unorderedIdealState.insert(idealState.begin(), idealState.end()); } |