diff options
author | Tor Egge <Tor.Egge@online.no> | 2022-02-23 12:13:20 +0100 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2022-02-23 12:13:20 +0100 |
commit | 12866a11dfb578e3989dc5eaa60c5faff25ec03c (patch) | |
tree | d962816111c604adcc29be9d854807b59bd9acbe | |
parent | ca12adcd84dea21451ef6f5094702ad9f555ec7c (diff) |
Sync executors at end of test to keep *this live until
tasks have complete.
-rw-r--r-- | searchlib/src/apps/tests/btreestress_test.cpp | 4 |
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(); } |