diff options
Diffstat (limited to 'storageapi')
| -rw-r--r-- | storageapi/src/vespa/storageapi/message/bucket.cpp | 6 | ||||
| -rw-r--r-- | storageapi/src/vespa/storageapi/message/bucket.h | 7 |
2 files changed, 9 insertions, 4 deletions
diff --git a/storageapi/src/vespa/storageapi/message/bucket.cpp b/storageapi/src/vespa/storageapi/message/bucket.cpp index fdc19d63134..2e2ca82079d 100644 --- a/storageapi/src/vespa/storageapi/message/bucket.cpp +++ b/storageapi/src/vespa/storageapi/message/bucket.cpp @@ -509,7 +509,8 @@ std::ostream& operator<<(std::ostream& out, const RequestBucketInfoReply::Entry& RequestBucketInfoReply::RequestBucketInfoReply(const RequestBucketInfoCommand& cmd) : StorageReply(cmd), - _buckets() + _buckets(), + _full_bucket_fetch(cmd.hasSystemState()) { } RequestBucketInfoReply::~RequestBucketInfoReply() = default; @@ -519,6 +520,9 @@ RequestBucketInfoReply::print(std::ostream& out, bool verbose, const std::string& indent) const { out << "RequestBucketInfoReply(" << _buckets.size(); + if (_full_bucket_fetch) { + out << ", full fetch"; + } if (verbose) { out << "\n" << indent << " "; std::copy(_buckets.begin(), _buckets.end(), diff --git a/storageapi/src/vespa/storageapi/message/bucket.h b/storageapi/src/vespa/storageapi/message/bucket.h index cde440b91de..61766fb1f11 100644 --- a/storageapi/src/vespa/storageapi/message/bucket.h +++ b/storageapi/src/vespa/storageapi/message/bucket.h @@ -338,9 +338,8 @@ class RequestBucketInfoCommand : public StorageCommand { vespalib::string _distributionHash; public: - explicit RequestBucketInfoCommand( - document::BucketSpace bucketSpace, - const std::vector<document::BucketId>& buckets); + RequestBucketInfoCommand(document::BucketSpace bucketSpace, + const std::vector<document::BucketId>& buckets); RequestBucketInfoCommand(document::BucketSpace bucketSpace, uint16_t distributor, const lib::ClusterState& state, @@ -388,6 +387,7 @@ public: typedef vespalib::Array<Entry> EntryVector; private: EntryVector _buckets; + bool _full_bucket_fetch; public: @@ -395,6 +395,7 @@ public: ~RequestBucketInfoReply(); const EntryVector & getBucketInfo() const { return _buckets; } EntryVector & getBucketInfo() { return _buckets; } + [[nodiscard]] bool full_bucket_fetch() const noexcept { return _full_bucket_fetch; } void print(std::ostream& out, bool verbose, const std::string& indent) const override; DECLARE_STORAGEREPLY(RequestBucketInfoReply, onRequestBucketInfoReply) }; |