diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-19 07:46:55 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-19 13:54:30 +0000 |
commit | 5e676a8ffc0034848366293ad744e0850c585884 (patch) | |
tree | 7f440a67a5af24f340dcbf8bd3c0a94087b7ca17 /storage/src/tests/persistence/common | |
parent | 317fedff48f7211e9d48c7d407d0512bd4ee65b9 (diff) |
Implement bucketexecutor interface and.
Diffstat (limited to 'storage/src/tests/persistence/common')
-rw-r--r-- | storage/src/tests/persistence/common/persistenceproviderwrapper.cpp | 6 | ||||
-rw-r--r-- | storage/src/tests/persistence/common/persistenceproviderwrapper.h | 1 |
2 files changed, 7 insertions, 0 deletions
diff --git a/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp b/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp index bbde377fdec..21a94a3e957 100644 --- a/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp +++ b/storage/src/tests/persistence/common/persistenceproviderwrapper.cpp @@ -209,6 +209,12 @@ PersistenceProviderWrapper::register_resource_usage_listener(spi::IResourceUsage return _spi.register_resource_usage_listener(listener); } +std::unique_ptr<vespalib::IDestructorCallback> +PersistenceProviderWrapper::register_executor(std::shared_ptr<spi::BucketExecutor> executor) +{ + return _spi.register_executor(std::move(executor)); +} + 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 b07f9c5e0f5..085a60c0e86 100644 --- a/storage/src/tests/persistence/common/persistenceproviderwrapper.h +++ b/storage/src/tests/persistence/common/persistenceproviderwrapper.h @@ -110,6 +110,7 @@ public: 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; + std::unique_ptr<vespalib::IDestructorCallback> register_executor(std::shared_ptr<spi::BucketExecutor>) override; }; } // storage |