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/rangecount.h | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'tests/include/rangecount.h') diff --git a/tests/include/rangecount.h b/tests/include/rangecount.h index b77c77d..2640e84 100644 --- a/tests/include/rangecount.h +++ b/tests/include/rangecount.h @@ -38,7 +38,7 @@ START_TEST(t_range_count) { 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())); rc::Query::Parameters parms = {300, 500}; @@ -61,7 +61,7 @@ START_TEST(t_buffer_range_count) rc::Query::Parameters parms = {300, 500}; { - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); auto query = rc::Query::local_preproc_buffer(&view, &parms); auto result = rc::Query::local_query_buffer(query); delete query; @@ -79,8 +79,8 @@ START_TEST(t_range_count_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())); rc::Query::Parameters parms = {150, 500}; -- cgit v1.2.3