summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorGeir Storli <geirst@oath.com>2017-11-03 12:59:43 +0000
committerGeir Storli <geirst@oath.com>2017-11-03 12:59:43 +0000
commit2b74ce28ac3d356daf984e1574fe68039f230351 (patch)
tree9463f56a33cc7a57ec1a981f54ab2a018e7259af /storage
parente324f2a1a8ff518b7abc515b4bd17baa2dffb4cd (diff)
Rename forEachBucket() -> forEachBucketChunked().
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/bucketdb/bucketmanager.cpp8
-rw-r--r--storage/src/vespa/storage/common/content_bucket_space_repo.h4
2 files changed, 6 insertions, 6 deletions
diff --git a/storage/src/vespa/storage/bucketdb/bucketmanager.cpp b/storage/src/vespa/storage/bucketdb/bucketmanager.cpp
index 03694a0fc7b..5d4fd07c75e 100644
--- a/storage/src/vespa/storage/bucketdb/bucketmanager.cpp
+++ b/storage/src/vespa/storage/bucketdb/bucketmanager.cpp
@@ -227,7 +227,7 @@ BucketManager::updateMetrics(bool updateDocCount)
uint32_t diskCount = _component.getDiskCount();
if (!updateDocCount || _doneInitialized) {
MetricsUpdater m(diskCount);
- _component.getBucketSpaceRepo().forEachBucket(
+ _component.getBucketSpaceRepo().forEachBucketChunked(
m, "BucketManager::updateMetrics");
if (updateDocCount) {
for (uint16_t i = 0; i< diskCount; i++) {
@@ -244,7 +244,7 @@ BucketManager::updateMetrics(bool updateDocCount)
void BucketManager::updateMinUsedBits()
{
MetricsUpdater m(_component.getDiskCount());
- _component.getBucketSpaceRepo().forEachBucket(
+ _component.getBucketSpaceRepo().forEachBucketChunked(
m, "BucketManager::updateMetrics");
// When going through to get sizes, we also record min bits
MinimumUsedBitsTracker& bitTracker(_component.getMinUsedBitsTracker());
@@ -357,7 +357,7 @@ BucketManager::reportStatus(std::ostream& out,
framework::PartlyXmlStatusReporter xmlReporter(*this, out, path);
xmlReporter << vespalib::xml::XmlTag("buckets");
BucketDBDumper dumper(xmlReporter.getStream());
- _component.getBucketSpaceRepo().forEachBucket(
+ _component.getBucketSpaceRepo().forEachBucketChunked(
dumper, "BucketManager::reportStatus");
xmlReporter << vespalib::xml::XmlEndTag();
} else {
@@ -376,7 +376,7 @@ BucketManager::dump(std::ostream& out) const
{
vespalib::XmlOutputStream xos(out);
BucketDBDumper dumper(xos);
- _component.getBucketSpaceRepo().forEachBucket(dumper, "BucketManager::dump");
+ _component.getBucketSpaceRepo().forEachBucketChunked(dumper, "BucketManager::dump");
}
diff --git a/storage/src/vespa/storage/common/content_bucket_space_repo.h b/storage/src/vespa/storage/common/content_bucket_space_repo.h
index f6afa6002eb..3dee0eee9bd 100644
--- a/storage/src/vespa/storage/common/content_bucket_space_repo.h
+++ b/storage/src/vespa/storage/common/content_bucket_space_repo.h
@@ -26,8 +26,8 @@ public:
size_t getBucketMemoryUsage() const;
template <typename Functor>
- void forEachBucket(Functor &functor,
- const char *clientId) const {
+ void forEachBucketChunked(Functor &functor,
+ const char *clientId) const {
for (const auto &elem : _map) {
elem.second->bucketDatabase().chunkedAll(functor, clientId);
}