From ba1dcd889e54af3c16c2122c000cca94ca03d22e Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Mon, 6 Apr 2020 15:06:43 +0000 Subject: Add control for kind_of_watermark and reaction time. --- .../sequencedtaskexecutor_test.cpp | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) (limited to 'staging_vespalib/src/tests') diff --git a/staging_vespalib/src/tests/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp b/staging_vespalib/src/tests/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp index f5f04738e92..70d0f1c743d 100644 --- a/staging_vespalib/src/tests/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp +++ b/staging_vespalib/src/tests/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp @@ -1,6 +1,8 @@ // Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. #include +#include + #include #include @@ -245,6 +247,26 @@ TEST("require that you distribute well") { EXPECT_EQUAL(97u, seven->getComponentEffectiveHashSize()); } +TEST("Test creation of different types") { + auto iseq = SequencedTaskExecutor::create(1); + + EXPECT_EQUAL(1u, iseq->getNumExecutors()); + auto * seq = dynamic_cast(iseq.get()); + ASSERT_TRUE(seq != nullptr); + + iseq = SequencedTaskExecutor::create(1, 1000, Executor::OptimizeFor::LATENCY); + seq = dynamic_cast(iseq.get()); + ASSERT_TRUE(seq != nullptr); + + iseq = SequencedTaskExecutor::create(1, 1000, Executor::OptimizeFor::THROUGHPUT); + seq = dynamic_cast(iseq.get()); + ASSERT_TRUE(seq != nullptr); + + iseq = SequencedTaskExecutor::create(1, 1000, Executor::OptimizeFor::ADAPTIVE, 17); + auto aseq = dynamic_cast(iseq.get()); + ASSERT_TRUE(aseq != nullptr); +} + } TEST_MAIN() { TEST_RUN_ALL(); } -- cgit v1.2.3