| /rocksdb-6.9/db/ |
| D | range_tombstone_fragmenter.cc | 249 pos_ = tombstones_->begin(); in SeekToFirst()
258 pos_ = tombstones_->begin(); in SeekToTopFirst()
304 if (pos_ == tombstones_->end()) { in SeekToCoveringTombstone()
327 --pos_; in SeekForPrevToCoveringTombstone()
337 ++pos_; in ScanForwardToVisibleTombstone()
356 --pos_; in ScanBackwardToVisibleTombstone()
366 ++pos_; in Next()
371 ++pos_; in TopNext()
372 if (pos_ == tombstones_->end()) { in TopNext()
389 --pos_; in Prev()
[all …]
|
| D | range_tombstone_fragmenter.h | 138 Slice value() const override { return pos_->end_key; } in value()
145 pos_ = tombstones_->end(); in Invalidate()
154 Slice start_key() const { return pos_->start_key; } in start_key()
155 Slice end_key() const { return pos_->end_key; } in end_key()
158 return ParsedInternalKey(pos_->start_key, kMaxSequenceNumber, in parsed_start_key()
162 return ParsedInternalKey(pos_->end_key, kMaxSequenceNumber, in parsed_end_key()
225 if (pos_ != tombstones_->end() && seq_pos_ != tombstones_->seq_end() && in MaybePinKey()
226 (pinned_pos_ != pos_ || pinned_seq_pos_ != seq_pos_)) { in MaybePinKey()
228 pinned_pos_ = pos_; in MaybePinKey()
238 return Valid() && seq_pos_ != tombstones_->seq_iter(pos_->seq_end_idx); in ValidPos()
[all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier_file_buffer.h | 26 assert(!pos_); in CacheWriteBuffer()
33 assert(pos_ + size <= size_); in Append()
34 memcpy(buf_.get() + pos_, buf, size); in Append()
35 pos_ += size; in Append()
36 assert(pos_ <= size_); in Append()
40 assert(pos_ <= size_); in FillTrailingZeros()
41 memset(buf_.get() + pos_, '0', size_ - pos_); in FillTrailingZeros()
42 pos_ = size_; in FillTrailingZeros()
45 void Reset() { pos_ = 0; } in Reset()
48 size_t Used() const { return pos_; } in Used()
[all …]
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_env.h | 35 ssize_t pos_; member
41 pos_(-1), in FileState()
45 FileState() : pos_(-1), pos_at_last_sync_(-1), pos_at_last_flush_(-1) {} in FileState()
47 bool IsFullySynced() const { return pos_ <= 0 || pos_ == pos_at_last_sync_; } in IsFullySynced()
|
| D | fault_injection_test_fs.h | 39 ssize_t pos_; member
46 pos_(-1), in FSFileState()
50 FSFileState() : pos_(-1), pos_at_last_sync_(-1), pos_at_last_flush_(-1) {} in FSFileState()
52 bool IsFullySynced() const { return pos_ <= 0 || pos_ == pos_at_last_sync_; } in IsFullySynced()
|
| D | fault_injection_test_env.cc | 93 assert(pos_ >= sync_pos); in DropRandomUnsyncedData()
94 int range = static_cast<int>(pos_ - sync_pos); in DropRandomUnsyncedData()
116 state_.pos_ = 0; in TestWritableFile()
131 state_.pos_ += data.size(); in Append()
149 state_.pos_at_last_flush_ = state_.pos_; in Flush()
159 state_.pos_at_last_sync_ = state_.pos_; in Sync()
|
| D | fault_injection_test_fs.cc | 78 state_.pos_ = 0; in TestFSWritableFile()
94 state_.pos_ += data.size(); in Append()
124 state_.pos_at_last_flush_ = state_.pos_; in Flush()
137 state_.pos_at_last_sync_ = state_.pos_; in Sync()
|
| /rocksdb-6.9/env/ |
| D | mock_env.cc | 182 explicit MockSequentialFile(MemFile* file) : file_(file), pos_(0) { in MockSequentialFile()
189 Status s = file_->Read(pos_, n, result, scratch); in Read()
191 pos_ += result->size(); in Read()
197 if (pos_ > file_->Size()) { in Skip()
200 const uint64_t available = file_->Size() - pos_; in Skip()
204 pos_ += static_cast<size_t>(n); in Skip()
210 size_t pos_; member in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockSequentialFile
|
| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 138 unsigned int pos_; member in ROCKSDB_NAMESPACE::RandomGenerator
145 pos_ = 0; in RandomGenerator()
150 if (pos_ + len > data_.size()) { in Generate()
151 pos_ = 0; in Generate()
153 pos_ += len; in Generate()
154 return Slice(data_.data() + pos_ - len, len); in Generate()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 1567 unsigned int pos_; member in ROCKSDB_NAMESPACE::RandomGenerator
1599 pos_ = 0; in RandomGenerator()
1604 if (pos_ + len > data_.size()) { in Generate()
1605 pos_ = 0; in Generate()
1607 pos_ += len; in Generate()
1608 return Slice(data_.data() + pos_ - len, len); in Generate()
|