bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

mutation/mutation_compactor: fix indentation

Browse Source 
Left broken by the previous patch.
This commit is contained in:
Botond Dénes
2023-05-09 06:58:43 -04:00
parent 3d5b70e0d7
commit 18ed94e60b
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
mutation/mutation_compactor.hh
View File

@@ -463,19 +463,19 @@ public:
// Only check if the active tombstone has to be closed, if the partition
// was cut by the consumer. Otherwise, leave the stream as-is.
if (_stop) {
if (_effective_tombstone) {
auto rtc = range_tombstone_change(position_in_partition::after_key(_schema, _last_pos), tombstone{});
// do_consume() overwrites _effective_tombstone with {}, so save and restore it.
auto prev_tombstone = _effective_tombstone;
do_consume(std::move(rtc), consumer, gc_consumer);
_effective_tombstone = prev_tombstone;
} else if (_validator.validator().current_tombstone()) {
// It is possible that the range-tombstone providing the active
// tombstone was purged and never got to the consumer and therefore
// didn't set `_effective_tombstone`. In this case we generate a
// closing tombstone just for the validator.
_validator(mutation_fragment_v2::kind::range_tombstone_change, position_in_partition::after_key(_schema, _last_pos), tombstone{});
}
if (_effective_tombstone) {
auto rtc = range_tombstone_change(position_in_partition::after_key(_schema, _last_pos), tombstone{});
// do_consume() overwrites _effective_tombstone with {}, so save and restore it.
auto prev_tombstone = _effective_tombstone;
do_consume(std::move(rtc), consumer, gc_consumer);
_effective_tombstone = prev_tombstone;
} else if (_validator.validator().current_tombstone()) {
// It is possible that the range-tombstone providing the active
// tombstone was purged and never got to the consumer and therefore
// didn't set `_effective_tombstone`. In this case we generate a
// closing tombstone just for the validator.
_validator(mutation_fragment_v2::kind::range_tombstone_change, position_in_partition::after_key(_schema, _last_pos), tombstone{});
}
}
_validator.on_end_of_partition();
if (!_empty_partition_in_gc_consumer) {