diff options
Diffstat (limited to 'vbench/src/tests/handler_thread')
-rw-r--r-- | vbench/src/tests/handler_thread/.gitignore | 1 | ||||
-rw-r--r-- | vbench/src/tests/handler_thread/CMakeLists.txt | 9 | ||||
-rw-r--r-- | vbench/src/tests/handler_thread/FILES | 1 | ||||
-rw-r--r-- | vbench/src/tests/handler_thread/handler_thread_test.cpp | 30 |
4 files changed, 41 insertions, 0 deletions
diff --git a/vbench/src/tests/handler_thread/.gitignore b/vbench/src/tests/handler_thread/.gitignore new file mode 100644 index 00000000000..41890930291 --- /dev/null +++ b/vbench/src/tests/handler_thread/.gitignore @@ -0,0 +1 @@ +vbench_handler_thread_test_app diff --git a/vbench/src/tests/handler_thread/CMakeLists.txt b/vbench/src/tests/handler_thread/CMakeLists.txt new file mode 100644 index 00000000000..ee69cc594de --- /dev/null +++ b/vbench/src/tests/handler_thread/CMakeLists.txt @@ -0,0 +1,9 @@ +# Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +vespa_add_executable(vbench_handler_thread_test_app + SOURCES + handler_thread_test.cpp + DEPENDS + vbench_test + vbench +) +vespa_add_test(NAME vbench_handler_thread_test_app COMMAND vbench_handler_thread_test_app) diff --git a/vbench/src/tests/handler_thread/FILES b/vbench/src/tests/handler_thread/FILES new file mode 100644 index 00000000000..978aa147772 --- /dev/null +++ b/vbench/src/tests/handler_thread/FILES @@ -0,0 +1 @@ +handler_thread_test.cpp diff --git a/vbench/src/tests/handler_thread/handler_thread_test.cpp b/vbench/src/tests/handler_thread/handler_thread_test.cpp new file mode 100644 index 00000000000..43f0c4d4a1b --- /dev/null +++ b/vbench/src/tests/handler_thread/handler_thread_test.cpp @@ -0,0 +1,30 @@ +// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +#include <vespa/vespalib/testkit/testapp.h> +#include <vbench/test/all.h> + +using namespace vbench; + +struct MyHandler : Handler<int> { + std::vector<int> values; + virtual void handle(std::unique_ptr<int> value) { + values.push_back(*value); + vespalib::Thread::sleep(10); // for improved coverage + } +}; + +TEST("handler thread") { + MyHandler handler; + HandlerThread<int> th(handler); + th.handle(std::unique_ptr<int>(new int(1))); + th.handle(std::unique_ptr<int>(new int(2))); + th.handle(std::unique_ptr<int>(new int(3))); + th.join(); + th.handle(std::unique_ptr<int>(new int(4))); + th.handle(std::unique_ptr<int>(new int(5))); + ASSERT_EQUAL(3u, handler.values.size()); + EXPECT_EQUAL(1, handler.values[0]); + EXPECT_EQUAL(2, handler.values[1]); + EXPECT_EQUAL(3, handler.values[2]); +} + +TEST_MAIN() { TEST_RUN_ALL(); } |