summaryrefslogtreecommitdiffstats
path: root/tests/include/rangequery.h
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2024-02-05 15:17:25 -0500
committerDouglas Rumbaugh <dbr4@psu.edu>2024-02-05 15:17:25 -0500
commitdb4806d9dd9757273a14e6c3ea92e5a087239145 (patch)
tree3766b79180d9d3b2167b0ff8d74cd9e73bfc5298 /tests/include/rangequery.h
parentfca660859bd8133cff53592b17abf4c8a51fc2c0 (diff)
downloaddynamic-extension-db4806d9dd9757273a14e6c3ea92e5a087239145.tar.gz
Set up tombstone deletes properly
Diffstat (limited to 'tests/include/rangequery.h')
-rw-r--r--tests/include/rangequery.h19
1 files changed, 11 insertions, 8 deletions
diff --git a/tests/include/rangequery.h b/tests/include/rangequery.h
index 1ac0891..b9694a4 100644
--- a/tests/include/rangequery.h
+++ b/tests/include/rangequery.h
@@ -64,14 +64,17 @@ START_TEST(t_buffer_range_query)
parms.lower_bound = 300;
parms.upper_bound = 500;
- auto state = rq::Query<Shard, Rec>::get_buffer_query_state(buffer->get_buffer_view(), &parms);
- auto result = rq::Query<Shard, Rec>::buffer_query(state, &parms);
- rq::Query<Shard, Rec>::delete_buffer_query_state(state);
-
- ck_assert_int_eq(result.size(), parms.upper_bound - parms.lower_bound + 1);
- for (size_t i=0; i<result.size(); i++) {
- ck_assert_int_le(result[i].rec.key, parms.upper_bound);
- ck_assert_int_ge(result[i].rec.key, parms.lower_bound);
+ {
+ auto view = buffer->get_buffer_view();
+ auto state = rq::Query<Shard, Rec>::get_buffer_query_state(&view, &parms);
+ auto result = rq::Query<Shard, Rec>::buffer_query(state, &parms);
+ rq::Query<Shard, Rec>::delete_buffer_query_state(state);
+
+ ck_assert_int_eq(result.size(), parms.upper_bound - parms.lower_bound + 1);
+ for (size_t i=0; i<result.size(); i++) {
+ ck_assert_int_le(result[i].rec.key, parms.upper_bound);
+ ck_assert_int_ge(result[i].rec.key, parms.lower_bound);
+ }
}
delete buffer;