diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-04 22:20:35 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-04 22:35:17 +0000 |
| commit | 416ff1764ce98954b3b15fcae0f6a50d76b38323 (patch) | |
| tree | 8974071929be2d3723db0a14567dcbeb2f7a1797 /searchlib/src/apps | |
| parent | 130d4607a359ae2740bdeeb0179a731751f979a0 (diff) | |
Move sequenced task executors to staging vespalib
Diffstat (limited to 'searchlib/src/apps')
| -rw-r--r-- | searchlib/src/apps/tests/memoryindexstress_test.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/searchlib/src/apps/tests/memoryindexstress_test.cpp b/searchlib/src/apps/tests/memoryindexstress_test.cpp index dc950b84508..6bbd93bda84 100644 --- a/searchlib/src/apps/tests/memoryindexstress_test.cpp +++ b/searchlib/src/apps/tests/memoryindexstress_test.cpp @@ -9,7 +9,6 @@ #include <vespa/document/repo/documenttyperepo.h> #include <vespa/document/repo/fixedtyperepo.h> #include <vespa/searchlib/common/scheduletaskcallback.h> -#include <vespa/searchlib/common/sequencedtaskexecutor.h> #include <vespa/searchlib/fef/matchdata.h> #include <vespa/searchlib/fef/matchdatalayout.h> #include <vespa/searchlib/fef/termfieldmatchdata.h> @@ -24,6 +23,7 @@ #include <vespa/searchlib/util/rand48.h> #include <vespa/vespalib/testkit/testapp.h> #include <vespa/vespalib/util/threadstackexecutor.h> +#include <vespa/vespalib/util/sequencedtaskexecutor.h> #include <vespa/log/log.h> LOG_SETUP("memoryindexstress_test"); @@ -195,8 +195,8 @@ struct Fixture { Schema schema; DocumentTypeRepo repo; vespalib::ThreadStackExecutor _executor; - std::unique_ptr<search::ISequencedTaskExecutor> _invertThreads; - std::unique_ptr<search::ISequencedTaskExecutor> _pushThreads; + std::unique_ptr<vespalib::ISequencedTaskExecutor> _invertThreads; + std::unique_ptr<vespalib::ISequencedTaskExecutor> _pushThreads; MemoryIndex index; uint32_t _readThreads; vespalib::ThreadStackExecutor _writer; // 1 write thread @@ -247,8 +247,8 @@ Fixture::Fixture(uint32_t readThreads) : schema(makeSchema()), repo(makeDocTypeRepoConfig()), _executor(1, 128 * 1024), - _invertThreads(search::SequencedTaskExecutor::create(2)), - _pushThreads(search::SequencedTaskExecutor::create(2)), + _invertThreads(vespalib::SequencedTaskExecutor::create(2)), + _pushThreads(vespalib::SequencedTaskExecutor::create(2)), index(schema, MockFieldLengthInspector(), *_invertThreads, *_pushThreads), _readThreads(readThreads), _writer(1, 128 * 1024), |