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/mutable_buffer_tests.cpp | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) (limited to 'tests/mutable_buffer_tests.cpp') diff --git a/tests/mutable_buffer_tests.cpp b/tests/mutable_buffer_tests.cpp index 16f9269..816c8b0 100644 --- a/tests/mutable_buffer_tests.cpp +++ b/tests/mutable_buffer_tests.cpp @@ -38,7 +38,7 @@ START_TEST(t_create) ck_assert_int_eq(buffer->get_tombstone_count(), 0); { - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); ck_assert_int_eq(view.get_tombstone_count(), 0); ck_assert_int_eq(view.get_record_count(), 0); } @@ -68,7 +68,7 @@ START_TEST(t_insert) cnt++; ck_assert_int_eq(buffer->get_record_count(), cnt); - ck_assert_int_eq(buffer->get_buffer_view().get_record_count(), cnt); + ck_assert_int_eq(buffer->get_buffer_view(buffer->debug_get_head()).get_record_count(), cnt); ck_assert_int_eq(buffer->get_tail(), cnt); } @@ -85,7 +85,7 @@ START_TEST(t_insert) cnt++; ck_assert_int_eq(buffer->get_record_count(), cnt); - ck_assert_int_eq(buffer->get_buffer_view().get_record_count(), cnt); + ck_assert_int_eq(buffer->get_buffer_view(buffer->debug_get_head()).get_record_count(), cnt); ck_assert_int_eq(buffer->get_tombstone_count(), 0); ck_assert_int_eq(buffer->is_at_low_watermark(), true); @@ -131,14 +131,14 @@ START_TEST(t_advance_head) Wrapped *view_records = new Wrapped[buffer->get_record_count()]; { /* get a view of the pre-advanced state */ - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); ck_assert_int_eq(view.get_record_count(), cnt); view.copy_to_buffer((psudb::byte *) view_records); /* advance the head */ ck_assert_int_eq(buffer->advance_head(new_head), 1); ck_assert_int_eq(buffer->get_record_count(), 25); - ck_assert_int_eq(buffer->get_buffer_view().get_record_count(), 25); + ck_assert_int_eq(buffer->get_buffer_view(buffer->debug_get_head()).get_record_count(), 25); ck_assert_int_eq(view.get_record_count(), cnt); ck_assert_int_eq(buffer->get_available_capacity(), 200 - cnt); @@ -272,7 +272,7 @@ START_TEST(t_bview_get) { /* get a view of the pre-advanced state */ - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); auto reccnt = view.get_record_count(); /* scan the records in the view */ @@ -291,7 +291,7 @@ START_TEST(t_bview_get) { /* get a new view (should have fewer records) */ - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); auto reccnt = view.get_record_count(); /* verify the scan again */ @@ -311,7 +311,7 @@ START_TEST(t_bview_get) { /* get a new view (should have fewer records) */ - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); auto reccnt = view.get_record_count(); /* verify the scan again */ @@ -364,7 +364,7 @@ START_TEST(t_bview_delete) Rec fdr2 = {300, 300}; { /* get a new view (should have fewer records) */ - auto view = buffer->get_buffer_view(); + auto view = buffer->get_buffer_view(buffer->debug_get_head()); ck_assert_int_eq(view.delete_record(dr1), 1); ck_assert_int_eq(view.delete_record(dr2), 1); ck_assert_int_eq(view.delete_record(dr3), 1); -- cgit v1.2.3