summaryrefslogtreecommitdiffstats
path: root/searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-01-03 20:51:16 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-01-03 20:51:16 +0000
commit53b6bceedfdc2080b0286e6ca6e86a4f5c05901c (patch)
treedd72552f3fcc4b19520c29895a39d07556326c3e /searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp
parent2d770a1c8d584acc0c4c6260f44f7f0099166ecc (diff)
Improve the distribution by using a indirect mapping that should improve
chance for better loaddistribution.
Diffstat (limited to 'searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp')
-rw-r--r--searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp12
1 files changed, 5 insertions, 7 deletions
diff --git a/searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp b/searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp
index 77caf535405..558d24551a8 100644
--- a/searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp
+++ b/searchlib/src/tests/common/sequencedtaskexecutor/sequencedtaskexecutor_test.cpp
@@ -19,10 +19,7 @@ class Fixture
public:
SequencedTaskExecutor _threads;
- Fixture()
- : _threads(2)
- {
- }
+ Fixture() : _threads(2) { }
};
@@ -101,7 +98,7 @@ TEST_F("require that task with different component ids are not serialized", Fixt
std::shared_ptr<TestObj> tv(std::make_shared<TestObj>());
EXPECT_EQUAL(0, tv->_val);
f._threads.execute(0, [=]() { usleep(2000); tv->modify(0, 14); });
- f._threads.execute(1, [=]() { tv->modify(14, 42); });
+ f._threads.execute(2, [=]() { tv->modify(14, 42); });
tv->wait(2);
if (tv->_fail != 1) {
continue;
@@ -175,12 +172,13 @@ vespalib::string makeAltComponentId(Fixture &f)
TEST_F("require that task with different string component ids are not serialized", Fixture)
{
- int tryCnt = detectSerializeFailure(f, "1", 100);
+ int tryCnt = detectSerializeFailure(f, "2", 100);
EXPECT_TRUE(tryCnt < 100);
}
-TEST_F("require that task with different string component ids mapping to the same executor id are serialized", Fixture)
+TEST_F("require that task with different string component ids mapping to the same executor id are serialized",
+ Fixture)
{
vespalib::string altComponentId = makeAltComponentId(f);
LOG(info, "second string component id is \"%s\"", altComponentId.c_str());