diff options
Diffstat (limited to 'tests/include/shard_standard.h')
| -rw-r--r-- | tests/include/shard_standard.h | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/tests/include/shard_standard.h b/tests/include/shard_standard.h index 0b5ab00..996d947 100644 --- a/tests/include/shard_standard.h +++ b/tests/include/shard_standard.h @@ -58,7 +58,7 @@ START_TEST(t_mbuffer_init) buffer->append(r); } - 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; @@ -73,9 +73,9 @@ START_TEST(t_shard_init) auto mbuffer2 = create_test_mbuffer<R>(n); auto mbuffer3 = create_test_mbuffer<R>(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<const Shard*> shards = {shard1, shard2, shard3}; auto shard4 = new Shard(shards); @@ -122,8 +122,8 @@ START_TEST(t_full_cancelation) auto buffer = create_double_seq_mbuffer<R>(n, false); auto buffer_ts = create_double_seq_mbuffer<R>(n, true); - Shard* shard = new Shard(buffer->get_buffer_view()); - Shard* shard_ts = new Shard(buffer_ts->get_buffer_view()); + Shard* shard = new Shard(buffer->get_buffer_view(buffer->debug_get_head())); + Shard* shard_ts = new Shard(buffer_ts->get_buffer_view(buffer_ts->debug_get_head())); ck_assert_int_eq(shard->get_record_count(), n); ck_assert_int_eq(shard->get_tombstone_count(), 0); @@ -151,10 +151,10 @@ START_TEST(t_point_lookup) size_t n = 10000; auto buffer = create_double_seq_mbuffer<R>(n, false); - auto isam = Shard(buffer->get_buffer_view()); + auto isam = 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; i++) { auto rec = view.get(i); @@ -177,7 +177,7 @@ START_TEST(t_point_lookup_miss) size_t n = 10000; auto buffer = create_double_seq_mbuffer<R>(n, false); - auto isam = Shard(buffer->get_buffer_view()); + auto isam = Shard(buffer->get_buffer_view(buffer->debug_get_head())); for (uint32_t i=n + 100; i<2*n; i++) { R r = R{i, i}; |