summaryrefslogtreecommitdiffstats
path: root/tests/mutable_buffer_tests.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/mutable_buffer_tests.cpp')
-rw-r--r--tests/mutable_buffer_tests.cpp18
1 files changed, 9 insertions, 9 deletions
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<Rec> *view_records = new Wrapped<Rec>[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);