diff options
Diffstat (limited to 'storage')
4 files changed, 16 insertions, 0 deletions
diff --git a/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp b/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp index 02c92fc1650..bbde377fdec 100644 --- a/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp +++ b/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp @@ -3,6 +3,7 @@ #include "persistenceproviderwrapper.h" #include <vespa/document/fieldvalue/document.h> #include <vespa/document/update/documentupdate.h> +#include <vespa/vespalib/util/idestructorcallback.h> #include <sstream> #define LOG_SPI(ops) \ @@ -202,6 +203,12 @@ PersistenceProviderWrapper::join(const spi::Bucket& source1, return _spi.join(source1, source2, target, context); } +std::unique_ptr<vespalib::IDestructorCallback> +PersistenceProviderWrapper::register_resource_usage_listener(spi::IResourceUsageListener& listener) +{ + return _spi.register_resource_usage_listener(listener); +} + spi::Result PersistenceProviderWrapper::removeEntry(const spi::Bucket& bucket, spi::Timestamp timestamp, diff --git a/storage/src/tests/persistence/common/persistenceproviderwrapper.h b/storage/src/tests/persistence/common/persistenceproviderwrapper.h index 4061343c8da..cc26b251e67 100644 --- a/storage/src/tests/persistence/common/persistenceproviderwrapper.h +++ b/storage/src/tests/persistence/common/persistenceproviderwrapper.h @@ -111,6 +111,7 @@ public: spi::Result join(const spi::Bucket& source1, const spi::Bucket& source2, const spi::Bucket& target, spi::Context&) override; spi::Result removeEntry(const spi::Bucket&, spi::Timestamp, spi::Context&) override; + std::unique_ptr<vespalib::IDestructorCallback> register_resource_usage_listener(spi::IResourceUsageListener& listener) override; }; } // storage diff --git a/storage/src/vespa/storage/persistence/provider_error_wrapper.cpp b/storage/src/vespa/storage/persistence/provider_error_wrapper.cpp index 26cfe845eef..cf83741f5bb 100644 --- a/storage/src/vespa/storage/persistence/provider_error_wrapper.cpp +++ b/storage/src/vespa/storage/persistence/provider_error_wrapper.cpp @@ -2,6 +2,7 @@ #include "provider_error_wrapper.h" #include "persistenceutil.h" +#include <vespa/vespalib/util/idestructorcallback.h> namespace storage { @@ -155,6 +156,12 @@ ProviderErrorWrapper::join(const spi::Bucket& source1, const spi::Bucket& source return checkResult(_impl.join(source1, source2, target, context)); } +std::unique_ptr<vespalib::IDestructorCallback> +ProviderErrorWrapper::register_resource_usage_listener(spi::IResourceUsageListener& listener) +{ + return _impl.register_resource_usage_listener(listener); +} + spi::Result ProviderErrorWrapper::removeEntry(const spi::Bucket& bucket, spi::Timestamp ts, spi::Context& context) { diff --git a/storage/src/vespa/storage/persistence/provider_error_wrapper.h b/storage/src/vespa/storage/persistence/provider_error_wrapper.h index 5e5682a8bb4..fa24dbeea45 100644 --- a/storage/src/vespa/storage/persistence/provider_error_wrapper.h +++ b/storage/src/vespa/storage/persistence/provider_error_wrapper.h @@ -58,6 +58,7 @@ public: spi::BucketIdListResult getModifiedBuckets(BucketSpace bucketSpace) const override; spi::Result split(const spi::Bucket& source, const spi::Bucket& target1, const spi::Bucket& target2, spi::Context&) override; spi::Result join(const spi::Bucket& source1, const spi::Bucket& source2, const spi::Bucket& target, spi::Context&) override; + std::unique_ptr<vespalib::IDestructorCallback> register_resource_usage_listener(spi::IResourceUsageListener& listener) override; spi::Result removeEntry(const spi::Bucket&, spi::Timestamp, spi::Context&) override; spi::PersistenceProvider& getProviderImplementation() { |