diff options
Diffstat (limited to 'storage/src/vespa/storage/persistence/persistencethread.h')
-rw-r--r-- | storage/src/vespa/storage/persistence/persistencethread.h | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/storage/src/vespa/storage/persistence/persistencethread.h b/storage/src/vespa/storage/persistence/persistencethread.h index fcecc963658..32387bc6826 100644 --- a/storage/src/vespa/storage/persistence/persistencethread.h +++ b/storage/src/vespa/storage/persistence/persistencethread.h @@ -10,6 +10,7 @@ #include <vespa/storage/common/bucketmessages.h> #include <vespa/storage/common/storagecomponent.h> #include <vespa/storage/common/statusmessages.h> +#include <vespa/vespalib/util/isequencedtaskexecutor.h> namespace storage { @@ -19,9 +20,9 @@ class TestAndSetHelper; class PersistenceThread final : public DiskThread, public Types { public: - PersistenceThread(ServiceLayerComponentRegister&, const config::ConfigUri & configUri, - spi::PersistenceProvider& provider, FileStorHandler& filestorHandler, - FileStorThreadMetrics& metrics, uint16_t deviceIndex); + PersistenceThread(vespalib::ISequencedTaskExecutor *, ServiceLayerComponentRegister&, + const config::ConfigUri & configUri, spi::PersistenceProvider& provider, + FileStorHandler& filestorHandler, FileStorThreadMetrics& metrics, uint16_t deviceIndex); ~PersistenceThread() override; /** Waits for current operation to be finished. */ @@ -48,7 +49,7 @@ public: private: uint32_t _stripeId; PersistenceUtil _env; - uint32_t _warnOnSlowOperations; + vespalib::ISequencedTaskExecutor * _sequencedExecutor; spi::PersistenceProvider& _spi; ProcessAllHandler _processAllHandler; MergeHandler _mergeHandler; |