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/rangequery.h | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'tests/include/rangequery.h') diff --git a/tests/include/rangequery.h b/tests/include/rangequery.h index f7bb7c1..076a37f 100644 --- a/tests/include/rangequery.h +++ b/tests/include/rangequery.h @@ -40,7 +40,7 @@ START_TEST(t_range_query) { auto buffer = create_sequential_mbuffer(100, 1000); - auto shard = Shard(buffer->get_buffer_view()); + auto shard = Shard(buffer->get_buffer_view(buffer->debug_get_head())); rq::Query::Parameters parms = {300, 500}; @@ -67,7 +67,7 @@ START_TEST(t_buffer_range_query) rq::Query::Parameters parms = {300, 500}; { - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); auto query = rq::Query::local_preproc_buffer(&view, &parms); auto result = rq::Query::local_query_buffer(query); delete query; @@ -89,8 +89,8 @@ START_TEST(t_range_query_merge) auto buffer1 = create_sequential_mbuffer(100, 200); auto buffer2 = create_sequential_mbuffer(400, 1000); - auto shard1 = Shard(buffer1->get_buffer_view()); - auto shard2 = Shard(buffer2->get_buffer_view()); + auto shard1 = Shard(buffer1->get_buffer_view(buffer1->debug_get_head())); + auto shard2 = Shard(buffer2->get_buffer_view(buffer2->debug_get_head())); rq::Query::Parameters parms = {150, 500}; -- cgit v1.2.3