diff options
Diffstat (limited to 'searchcore/src/tests/proton/index/indexmanager_test.cpp')
-rw-r--r-- | searchcore/src/tests/proton/index/indexmanager_test.cpp | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/searchcore/src/tests/proton/index/indexmanager_test.cpp b/searchcore/src/tests/proton/index/indexmanager_test.cpp index 6cca28f5b43..1e33482b055 100644 --- a/searchcore/src/tests/proton/index/indexmanager_test.cpp +++ b/searchcore/src/tests/proton/index/indexmanager_test.cpp @@ -2,7 +2,7 @@ #include <vespa/fastos/file.h> #include <vespa/searchcore/proton/index/indexmanager.h> -#include <vespa/searchcore/proton/test/transport_helper.h> +#include <vespa/searchcore/proton/server/executorthreadingservice.h> #include <vespa/searchcorespi/index/index_manager_stats.h> #include <vespa/searchcorespi/index/indexcollection.h> #include <vespa/searchcorespi/index/indexflushtarget.h> @@ -24,6 +24,7 @@ #include <vespa/vespalib/util/destructor_callbacks.h> #include <vespa/vespalib/util/gate.h> #include <vespa/vespalib/util/size_literals.h> +#include <vespa/vespalib/util/threadstackexecutor.h> #include <vespa/vespalib/util/time.h> #include <set> #include <thread> @@ -52,6 +53,7 @@ using search::memoryindex::FieldIndexCollection; using search::queryeval::Source; using std::set; using std::string; +using vespalib::ThreadStackExecutor; using vespalib::makeLambdaTask; using std::chrono::duration_cast; @@ -106,7 +108,8 @@ struct IndexManagerTest : public ::testing::Test { SerialNum _serial_num; IndexManagerDummyReconfigurer _reconfigurer; DummyFileHeaderContext _fileHeaderContext; - TransportAndExecutorService _service; + vespalib::ThreadStackExecutor _sharedExecutor; + ExecutorThreadingService _writeService; std::unique_ptr<IndexManager> _index_manager; Schema _schema; DocBuilder _builder; @@ -115,7 +118,8 @@ struct IndexManagerTest : public ::testing::Test { : _serial_num(0), _reconfigurer(), _fileHeaderContext(), - _service(1), + _sharedExecutor(1, 0x10000), + _writeService(_sharedExecutor), _index_manager(), _schema(getSchema()), _builder(_schema) @@ -126,13 +130,13 @@ struct IndexManagerTest : public ::testing::Test { } ~IndexManagerTest() { - _service.shutdown(); + _writeService.shutdown(); } template <class FunctionType> inline void runAsMaster(FunctionType &&function) { vespalib::Gate gate; - _service.write().master().execute(makeLambdaTask([&gate,function = std::move(function)]() { + _writeService.master().execute(makeLambdaTask([&gate,function = std::move(function)]() { function(); gate.countDown(); })); @@ -141,7 +145,7 @@ struct IndexManagerTest : public ::testing::Test { template <class FunctionType> inline void runAsIndex(FunctionType &&function) { vespalib::Gate gate; - _service.write().index().execute(makeLambdaTask([&gate,function = std::move(function)]() { + _writeService.index().execute(makeLambdaTask([&gate,function = std::move(function)]() { function(); gate.countDown(); })); @@ -206,7 +210,7 @@ IndexManagerTest::resetIndexManager() { _index_manager.reset(); _index_manager = std::make_unique<IndexManager>(index_dir, IndexConfig(), getSchema(), 1, - _reconfigurer, _service.write(), _service.shared(), + _reconfigurer, _writeService, _sharedExecutor, TuneFileIndexManager(), TuneFileAttributes(), _fileHeaderContext); } |