diff options
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp')
-rw-r--r-- | searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp index 9657619be40..45d4354564e 100644 --- a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp +++ b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp @@ -43,6 +43,7 @@ #include <vespa/vespalib/util/monitored_refcount.h> #include <vespa/vespalib/util/size_literals.h> #include <vespa/vespalib/util/threadstackexecutor.h> +#include <vespa/fnet/transport.h> #include <unistd.h> #include <thread> @@ -348,6 +349,8 @@ public: test::DiskMemUsageNotifier _diskMemUsageNotifier; BucketCreateNotifier _bucketCreateNotifier; MonitoredRefCount _refCount; + FastOS_ThreadPool _threadPool; + FNET_Transport _transport; MaintenanceController _mc; MaintenanceControllerFixture(); @@ -767,8 +770,11 @@ MaintenanceControllerFixture::MaintenanceControllerFixture() _attributeUsageFilter(), _bucketCreateNotifier(), _refCount(), - _mc(_threadService, _genericExecutor, _refCount, _docTypeName) + _threadPool(64_Ki), + _transport(), + _mc(_transport, _threadService, _genericExecutor, _refCount, _docTypeName) { + _transport.Start(&_threadPool); std::vector<MyDocumentSubDB *> subDBs; subDBs.push_back(&_ready); subDBs.push_back(&_removed); @@ -779,6 +785,7 @@ MaintenanceControllerFixture::MaintenanceControllerFixture() MaintenanceControllerFixture::~MaintenanceControllerFixture() { + _transport.ShutDown(true); stopMaintenance(); } |