aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@online.no>2022-02-23 12:13:20 +0100
committerTor Egge <Tor.Egge@online.no>2022-02-23 12:13:20 +0100
commit12866a11dfb578e3989dc5eaa60c5faff25ec03c (patch)
treed962816111c604adcc29be9d854807b59bd9acbe
parentca12adcd84dea21451ef6f5094702ad9f555ec7c (diff)
Sync executors at end of test to keep *this live until
tasks have complete.
-rw-r--r--searchlib/src/apps/tests/btreestress_test.cpp4
1 files changed, 4 insertions, 0 deletions
diff --git a/searchlib/src/apps/tests/btreestress_test.cpp b/searchlib/src/apps/tests/btreestress_test.cpp
index f185deed248..c47fc3dad85 100644
--- a/searchlib/src/apps/tests/btreestress_test.cpp
+++ b/searchlib/src/apps/tests/btreestress_test.cpp
@@ -205,6 +205,8 @@ TEST_F("Test single threaded lower_bound reader during updates", Fixture)
f._reportWork = true;
f._writer.execute(makeLambdaTask([this, cnt]() { f.writeWork(cnt); }));
f._readers.execute(makeLambdaTask([this]() { f.readWork(); }));
+ f._writer.sync();
+ f._readers.sync();
}
TEST_F("Test multithreaded lower_bound reader during updates", Fixture)
@@ -216,6 +218,8 @@ TEST_F("Test multithreaded lower_bound reader during updates", Fixture)
f._readers.execute(makeLambdaTask([this]() { f.readWork(); }));
f._readers.execute(makeLambdaTask([this]() { f.readWork(); }));
f._readers.execute(makeLambdaTask([this]() { f.readWork(); }));
+ f._writer.sync();
+ f._readers.sync();
}
TEST_MAIN() { TEST_RUN_ALL(); }