diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-20 12:01:13 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-20 12:01:13 +0000 |
commit | ff551559deacaacc3bb77699686bb6c65e08a818 (patch) | |
tree | fcfa8056cd61aa89bfa50728ab6983fa85ce4c88 /searchcore | |
parent | c5c86dd6b6f0baf2b807ed9cd2dbc16bb507cab8 (diff) |
Add debug dumping and other minor followup on PR comments.
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp b/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp index 308b5e67f61..8bec6f9dd68 100644 --- a/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp +++ b/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp @@ -741,10 +741,10 @@ PersistenceEngine::getWLock() const namespace { -class UnRegisterExecutor : public vespalib::IDestructorCallback { +class SyncExecutorOnDestruction : public vespalib::IDestructorCallback { public: - UnRegisterExecutor(std::shared_ptr<BucketExecutor> executor) : _executor(std::move(executor)) { } - ~UnRegisterExecutor() override { + explicit SyncExecutorOnDestruction(std::shared_ptr<BucketExecutor> executor) : _executor(std::move(executor)) { } + ~SyncExecutorOnDestruction() override { if (_executor) { _executor->sync(); } @@ -760,7 +760,7 @@ PersistenceEngine::register_executor(std::shared_ptr<BucketExecutor> executor) { assert(_bucket_executor.expired()); _bucket_executor = executor; - return std::make_unique<UnRegisterExecutor>(executor); + return std::make_unique<SyncExecutorOnDestruction>(executor); } } // storage |