diff options
Diffstat (limited to 'searchlib/src/tests/tensor/hnsw_index')
| -rw-r--r-- | searchlib/src/tests/tensor/hnsw_index/stress_hnsw_mt.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/searchlib/src/tests/tensor/hnsw_index/stress_hnsw_mt.cpp b/searchlib/src/tests/tensor/hnsw_index/stress_hnsw_mt.cpp index ea443cfe252..fa6f760a33f 100644 --- a/searchlib/src/tests/tensor/hnsw_index/stress_hnsw_mt.cpp +++ b/searchlib/src/tests/tensor/hnsw_index/stress_hnsw_mt.cpp @@ -12,7 +12,6 @@ #include <vespa/vespalib/data/slime/slime.h> #include <vespa/vespalib/util/threadstackexecutor.h> #include <vespa/vespalib/util/blockingthreadstackexecutor.h> -#include <vespa/vespalib/util/gate.h> #include <vespa/vespalib/util/lambdatask.h> #include <vector> @@ -352,6 +351,10 @@ TEST_F(Stressor, stress) gen_operation(); if (i % 1000 == 0) { fprintf(stderr, "generating operations %d / %d\n", i, NUM_OPS); + auto r = write_thread.execute(vespalib::makeLambdaTask([&]() { + EXPECT_TRUE(index->check_link_symmetry()); + })); + EXPECT_EQ(bool(r), false); } } fprintf(stderr, "waiting for queued operations...\n"); @@ -359,6 +362,7 @@ TEST_F(Stressor, stress) write_thread.sync(); in_progress->invalidateCachedCount(); EXPECT_EQ(in_progress->countTrueBits(), 0); + EXPECT_TRUE(index->check_link_symmetry()); fprintf(stderr, "all done.\n"); } |