mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

sstables: Factor out code resetting values for a new partition.

Browse Source 
Signed-off-by: Vladimir Krivopalov <vladimir@scylladb.com>
Message-Id: <83a3a4ce6942b036be447bcfeb66142828e75293.1539396572.git.vladimir@scylladb.com>
(cherry picked from commit 926b6430fd)
This commit is contained in:
Vladimir Krivopalov
2018-10-12 19:10:30 -07:00
committed by Avi Kivity
parent aeb418af9e
commit f30fe7bd17
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
sstables/mp_row_consumer.hh
View File

@@ -897,6 +897,14 @@ class mp_row_consumer_m : public consumer_m {
return proceed(!_reader->is_buffer_full());
}
inline void reset_for_new_partition() {
_is_mutation_end = true;
_in_progress_row.reset();
_stored_row.reset();
_stored_tombstone.reset();
_mf_filter.reset();
}
public:
/*
@@ -1238,22 +1246,14 @@ public:
virtual proceed consume_partition_end() override {
sstlog.trace("mp_row_consumer_m {}: consume_partition_end()", this);
_is_mutation_end = true;
_in_progress_row.reset();
_stored_row.reset();
_stored_tombstone.reset();
_mf_filter.reset();
reset_for_new_partition();
return proceed::no;
}
virtual void reset(sstables::indexable_element el) override {
sstlog.trace("mp_row_consumer_m {}: reset({})", this, static_cast<int>(el));
if (el == indexable_element::partition) {
_is_mutation_end = true;
_in_progress_row.reset();
_stored_row.reset();
_stored_tombstone.reset();
_mf_filter.reset();
reset_for_new_partition();
} else {
_is_mutation_end = false;
}