summaryrefslogtreecommitdiffstats
path: root/include/query/rangecount.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 /include/query/rangecount.h
parentfca660859bd8133cff53592b17abf4c8a51fc2c0 (diff)
downloaddynamic-extension-db4806d9dd9757273a14e6c3ea92e5a087239145.tar.gz
Set up tombstone deletes properly
Diffstat (limited to 'include/query/rangecount.h')
-rw-r--r--include/query/rangecount.h14
1 files changed, 7 insertions, 7 deletions
diff --git a/include/query/rangecount.h b/include/query/rangecount.h
index 7d88b1d..70d57d8 100644
--- a/include/query/rangecount.h
+++ b/include/query/rangecount.h
@@ -33,10 +33,10 @@ struct State {
template <RecordInterface R>
struct BufferState {
- BufferView<R> buffer;
+ BufferView<R> *buffer;
- BufferState(BufferView<R> buffer)
- : buffer(std::move(buffer)) {}
+ BufferState(BufferView<R> *buffer)
+ : buffer(buffer) {}
};
template <ShardInterface S, KVPInterface R>
@@ -55,8 +55,8 @@ public:
return res;
}
- static void* get_buffer_query_state(BufferView<R> buffer, void *parms) {
- auto res = new BufferState<R>(std::move(buffer));
+ static void* get_buffer_query_state(BufferView<R> *buffer, void *parms) {
+ auto res = new BufferState<R>(buffer);
return res;
}
@@ -123,8 +123,8 @@ public:
res.rec.value = 0; // tombstones
records.emplace_back(res);
- for (size_t i=0; i<s->buffer.get_record_count(); i++) {
- auto rec = s->buffer.get(i);
+ for (size_t i=0; i<s->buffer->get_record_count(); i++) {
+ auto rec = s->buffer->get(i);
if (rec->rec.key >= p->lower_bound && rec->rec.key <= p->upper_bound
&& !rec->is_deleted()) {
if (rec->is_tombstone()) {