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/shard_string.h | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'tests/include/shard_string.h') diff --git a/tests/include/shard_string.h b/tests/include/shard_string.h index 7a3d761..bd428ee 100644 --- a/tests/include/shard_string.h +++ b/tests/include/shard_string.h @@ -48,7 +48,7 @@ START_TEST(t_mbuffer_init) buffer->append(recs[i]); } - Shard* shard = new Shard(buffer->get_buffer_view()); + Shard* shard = new Shard(buffer->get_buffer_view(buffer->debug_get_head())); ck_assert_uint_eq(shard->get_record_count(), 512); delete buffer; @@ -63,9 +63,9 @@ START_TEST(t_shard_init) auto mbuffer2 = create_test_mbuffer(n); auto mbuffer3 = create_test_mbuffer(n); - auto shard1 = new Shard(mbuffer1->get_buffer_view()); - auto shard2 = new Shard(mbuffer2->get_buffer_view()); - auto shard3 = new Shard(mbuffer3->get_buffer_view()); + auto shard1 = new Shard(mbuffer1->get_buffer_view(mbuffer1->debug_get_head())); + auto shard2 = new Shard(mbuffer2->get_buffer_view(mbuffer2->debug_get_head())); + auto shard3 = new Shard(mbuffer3->get_buffer_view(mbuffer3->debug_get_head())); std::vector shards = {shard1, shard2, shard3}; auto shard4 = new Shard(shards); @@ -110,10 +110,10 @@ START_TEST(t_point_lookup) size_t n = 10000; auto buffer = create_test_mbuffer(n); - auto shard = Shard(buffer->get_buffer_view()); + auto shard = Shard(buffer->get_buffer_view(buffer->debug_get_head())); { - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); for (size_t i=0; i(n); - auto shard = Shard(buffer->get_buffer_view()); + auto shard = Shard(buffer->get_buffer_view(buffer->debug_get_head())); for (size_t i=n + 100; i<2*n; i++) { const char *c = "computer"; -- cgit v1.2.3