summaryrefslogtreecommitdiff
path: root/src/mongo/db/storage
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/storage')
-rw-r--r--src/mongo/db/storage/rocks/rocks_recovery_unit.cpp11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/mongo/db/storage/rocks/rocks_recovery_unit.cpp b/src/mongo/db/storage/rocks/rocks_recovery_unit.cpp
index f25e38cc5a8..4c992b2e7f0 100644
--- a/src/mongo/db/storage/rocks/rocks_recovery_unit.cpp
+++ b/src/mongo/db/storage/rocks/rocks_recovery_unit.cpp
@@ -54,7 +54,8 @@ namespace {
class PrefixStrippingIterator : public RocksIterator {
public:
// baseIterator is consumed
- PrefixStrippingIterator(std::string prefix, Iterator* baseIterator,
+ PrefixStrippingIterator(std::string prefix,
+ Iterator* baseIterator,
RocksCompactionScheduler* compactionScheduler,
std::unique_ptr<rocksdb::Slice> upperBound,
std::function<void(RocksIterator*)> deletionCallback)
@@ -70,7 +71,9 @@ public:
*_upperBound.get() = rocksdb::Slice(_nextPrefix);
}
- ~PrefixStrippingIterator() { _deletionCallback(this); }
+ ~PrefixStrippingIterator() {
+ _deletionCallback(this);
+ }
virtual bool Valid() const {
return _baseIterator->Valid() && _baseIterator->key().starts_with(_prefixSlice) &&
@@ -108,7 +111,9 @@ public:
endOp();
}
- virtual rocksdb::Slice* GetUpperBound() override { return _upperBound.get(); }
+ virtual rocksdb::Slice* GetUpperBound() override {
+ return _upperBound.get();
+ }
virtual void Refresh(rocksdb::Iterator* newBaseIterator) override {
if (_baseIterator->Valid()) {