summaryrefslogtreecommitdiffstats
path: root/storage/src/vespa/storage/persistence/persistencethread.h
diff options
context:
space:
mode:
Diffstat (limited to 'storage/src/vespa/storage/persistence/persistencethread.h')
-rw-r--r--storage/src/vespa/storage/persistence/persistencethread.h9
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;