diff options
Diffstat (limited to 'searchcore/src/tests/proton/flushengine/flushengine_test.cpp')
| -rw-r--r-- | searchcore/src/tests/proton/flushengine/flushengine_test.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/searchcore/src/tests/proton/flushengine/flushengine_test.cpp b/searchcore/src/tests/proton/flushengine/flushengine_test.cpp index dd8096e1d46..fd6274e83a6 100644 --- a/searchcore/src/tests/proton/flushengine/flushengine_test.cpp +++ b/searchcore/src/tests/proton/flushengine/flushengine_test.cpp @@ -727,6 +727,9 @@ TEST_F("require that high pri concurrency works", Fixture(2, 1ms)) auto handler = std::make_shared<SimpleHandler>(Targets({target1, target2, target3, target4, target5}), "handler", 9); f.putFlushHandler("handler", handler); f.engine.start(); + EXPECT_EQUAL(2u, f.engine.maxConcurrentNormal()); + EXPECT_EQUAL(3u, f.engine.maxConcurrentTotal()); + EXPECT_EQUAL(f.engine.maxConcurrentTotal(), f.engine.get_executor().getNumThreads()); EXPECT_TRUE(target1->_initDone.await(LONG_TIMEOUT)); EXPECT_TRUE(target2->_initDone.await(LONG_TIMEOUT)); |