diff options
| author | Tor Egge <Tor.Egge@online.no> | 2022-03-01 16:50:12 +0100 |
|---|---|---|
| committer | Tor Egge <Tor.Egge@online.no> | 2022-03-01 16:50:12 +0100 |
| commit | bdcc901a07111d134337a1812831a69722f66b2c (patch) | |
| tree | 4e8b37987bde73d0af84e4473429c20ca12ecc07 /vespalib/src/tests/util | |
| parent | 5e47261cea32b37ff20a0fa97f668f05da3b6aed (diff) | |
Sync executors at end of stress test.
Diffstat (limited to 'vespalib/src/tests/util')
| -rw-r--r-- | vespalib/src/tests/util/generationhandler_stress/generation_handler_stress_test.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/vespalib/src/tests/util/generationhandler_stress/generation_handler_stress_test.cpp b/vespalib/src/tests/util/generationhandler_stress/generation_handler_stress_test.cpp index 16e15a8b8a7..0689909da09 100644 --- a/vespalib/src/tests/util/generationhandler_stress/generation_handler_stress_test.cpp +++ b/vespalib/src/tests/util/generationhandler_stress/generation_handler_stress_test.cpp @@ -174,6 +174,8 @@ Fixture::stressTest(uint32_t writeCnt) for (uint32_t i = 0; i < readThreads; ++i) { _readers->execute(std::make_unique<ReadWorkTask>(*this, context)); } + _writer.sync(); + _readers->sync(); } using GenerationHandlerStressTest = Fixture; |