From 2ded45f5a20f38fdfd9f348c446c38dc713a5591 Mon Sep 17 00:00:00 2001 From: Douglas Rumbaugh Date: Mon, 3 Mar 2025 13:41:19 -0500 Subject: Fixed a few concurrency bugs --- tests/include/wss.h | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'tests/include/wss.h') diff --git a/tests/include/wss.h b/tests/include/wss.h index 01327d2..5185567 100644 --- a/tests/include/wss.h +++ b/tests/include/wss.h @@ -41,7 +41,7 @@ typedef wss::Query Q; START_TEST(t_wss_query) { auto buffer = create_weighted_mbuffer(1000); - auto shard = Shard(buffer->get_buffer_view()); + auto shard = Shard(buffer->get_buffer_view(buffer->debug_get_head())); auto rng = gsl_rng_alloc(gsl_rng_mt19937); size_t k = 20; @@ -77,7 +77,7 @@ START_TEST(t_buffer_wss_query) parms.sample_size = k; { - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); auto query = Q::local_preproc_buffer(&view, &parms); Q::distribute_query(&parms, {}, query); auto result = Q::local_query_buffer(query); -- cgit v1.2.3