diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-06 15:06:43 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-06 15:06:43 +0000 |
commit | ba1dcd889e54af3c16c2122c000cca94ca03d22e (patch) | |
tree | b7e069e930d2812cba79e982f005198ffe7eb727 /staging_vespalib/src/tests | |
parent | b5882399caf70648f9dba597696d20019e574fea (diff) |
Add control for kind_of_watermark and reaction time.
Diffstat (limited to 'staging_vespalib/src/tests')
-rw-r--r-- | staging_vespalib/src/tests/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp | 22 |
1 files changed, 22 insertions, 0 deletions
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 <vespa/vespalib/util/sequencedtaskexecutor.h> +#include <vespa/vespalib/util/adaptive_sequenced_executor.h> + #include <vespa/vespalib/testkit/testapp.h> #include <vespa/vespalib/test/insertion_operators.h> @@ -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<SequencedTaskExecutor *>(iseq.get()); + ASSERT_TRUE(seq != nullptr); + + iseq = SequencedTaskExecutor::create(1, 1000, Executor::OptimizeFor::LATENCY); + seq = dynamic_cast<SequencedTaskExecutor *>(iseq.get()); + ASSERT_TRUE(seq != nullptr); + + iseq = SequencedTaskExecutor::create(1, 1000, Executor::OptimizeFor::THROUGHPUT); + seq = dynamic_cast<SequencedTaskExecutor *>(iseq.get()); + ASSERT_TRUE(seq != nullptr); + + iseq = SequencedTaskExecutor::create(1, 1000, Executor::OptimizeFor::ADAPTIVE, 17); + auto aseq = dynamic_cast<AdaptiveSequencedExecutor *>(iseq.get()); + ASSERT_TRUE(aseq != nullptr); +} + } TEST_MAIN() { TEST_RUN_ALL(); } |