aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/index/indexmanager_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'searchcore/src/tests/proton/index/indexmanager_test.cpp')
-rw-r--r--searchcore/src/tests/proton/index/indexmanager_test.cpp18
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);
}