diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2024-02-05 15:17:25 -0500 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2024-02-05 15:17:25 -0500 |
| commit | db4806d9dd9757273a14e6c3ea92e5a087239145 (patch) | |
| tree | 3766b79180d9d3b2167b0ff8d74cd9e73bfc5298 /include/query/rangecount.h | |
| parent | fca660859bd8133cff53592b17abf4c8a51fc2c0 (diff) | |
| download | dynamic-extension-db4806d9dd9757273a14e6c3ea92e5a087239145.tar.gz | |
Set up tombstone deletes properly
Diffstat (limited to 'include/query/rangecount.h')
| -rw-r--r-- | include/query/rangecount.h | 14 |
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()) { |