| /rocksdb-6.9/db/ |
| D | range_tombstone_fragmenter.cc | 86 auto it = cur_end_keys.begin(); in FragmentTombstones()
105 cur_end_keys.erase(cur_end_keys.begin(), it); in FragmentTombstones()
121 std::sort(seqnums_to_flush.begin(), seqnums_to_flush.end(), in FragmentTombstones()
136 std::lower_bound(snapshots.begin(), snapshots.end(), seq); in FragmentTombstones()
137 if (upper_bound_it == snapshots.begin()) { in FragmentTombstones()
151 seq_set_.insert(seqnums_to_flush.begin(), seqnums_to_flush.end()); in FragmentTombstones()
249 pos_ = tombstones_->begin(); in SeekToFirst()
258 pos_ = tombstones_->begin(); in SeekToTopFirst()
322 if (pos_ == tombstones_->begin()) { in SeekForPrevToCoveringTombstone()
352 if (pos_ == tombstones_->begin()) { in ScanBackwardToVisibleTombstone()
[all …]
|
| D | experimental.cc | 16 const Slice* begin, const Slice* end) { in SuggestCompactRange() argument
21 return db->SuggestCompactRange(column_family, begin, end); in SuggestCompactRange()
45 Status SuggestCompactRange(DB* db, const Slice* begin, const Slice* end) { in SuggestCompactRange() argument
46 return SuggestCompactRange(db, db->DefaultColumnFamily(), begin, end); in SuggestCompactRange()
|
| D | log_writer.cc | 63 bool begin = true; in AddRecord() local
90 if (begin && end) { in AddRecord()
92 } else if (begin) { in AddRecord()
103 begin = false; in AddRecord()
|
| D | db_iter_stress_test.cc | 200 data->entries.begin(), data->entries.end(), in Seek()
202 iter = (int)(it - data->entries.begin()); in Seek()
212 data->entries.begin(), data->entries.end(), in SeekForPrev()
214 iter = (int)(it - data->entries.begin()); in SeekForPrev()
271 auto it = std::partition_point(data->entries.begin(), data->entries.end(), in FindNextKey()
285 if (it != data->entries.begin()) { in FindNextKey()
300 auto it = std::partition_point(data->entries.begin(), data->entries.end(), in FindValueForCurrentKey()
476 std::sort(data.entries.begin(), data.entries.end()); in TEST_F()
|
| D | pinned_iterators_manager.h | 61 std::sort(pinned_ptrs_.begin(), pinned_ptrs_.end()); in ReleasePinnedData()
62 auto unique_end = std::unique(pinned_ptrs_.begin(), pinned_ptrs_.end()); in ReleasePinnedData()
64 for (auto i = pinned_ptrs_.begin(); i != unique_end; ++i) { in ReleasePinnedData()
|
| D | range_tombstone_fragmenter.h | 45 std::vector<RangeTombstoneStack>::const_iterator begin() const { in begin() function
46 return tombstones_.begin(); in begin()
54 return std::next(tombstone_seqs_.begin(), idx); in seq_iter()
58 return tombstone_seqs_.begin(); in seq_begin()
|
| D | version_set.cc | 366 batch_iter_(range->begin()), in FilePickerMultiGet()
367 batch_iter_prev_(range->begin()), in FilePickerMultiGet()
2705 std::sort(temp->begin(), temp->end(), in SortFileByOverlappingRatio()
2741 std::partial_sort(temp.begin(), temp.begin() + num, temp.end(), in UpdateFilesByCompactionPri()
2914 if (begin != nullptr) { in GetOverlappingInputs()
2915 user_begin = begin->user_key(); in GetOverlappingInputs()
2929 auto iter = index.begin(); in GetOverlappingInputs()
2934 if (begin != nullptr && in GetOverlappingInputs()
2953 if (begin != nullptr && in GetOverlappingInputs()
3018 if (begin != nullptr) { in GetOverlappingInputsRangeBinarySearch()
[all …]
|
| /rocksdb-6.9/memtable/ |
| D | vectorrep.cc | 119 return std::find(bucket_->begin(), bucket_->end(), key) != bucket_->end(); in Contains()
160 std::sort(bucket_->begin(), bucket_->end(), Compare(compare_)); in DoSort()
161 cit_ = bucket_->begin(); in DoSort()
167 std::sort(bucket_->begin(), bucket_->end(), Compare(compare_)); in DoSort()
168 cit_ = bucket_->begin(); in DoSort()
202 if (cit_ == bucket_->begin()) { in Prev()
219 cit_ = std::equal_range(bucket_->begin(), in Seek()
237 cit_ = bucket_->begin(); in SeekToFirst()
|
| /rocksdb-6.9/util/ |
| D | vector_iterator.h | 30 std::sort(indices_.begin(), indices_.end(), indexed_cmp_); in VectorIterator()
41 current_ = std::lower_bound(indices_.begin(), indices_.end(), target, in Seek()
43 indices_.begin(); in Seek()
47 current_ = std::lower_bound(indices_.begin(), indices_.end(), target, in SeekForPrev()
49 indices_.begin(); in SeekForPrev()
|
| D | autovector.h | 247 return *begin();
252 return *begin();
318 iterator begin() { return iterator(this, 0); }
320 const_iterator begin() const { return const_iterator(this, 0); }
332 reverse_iterator rend() { return reverse_iterator(begin()); }
335 return const_reverse_iterator(begin());
352 vect_.assign(other.vect_.begin(), other.vect_.end());
|
| D | autovector_test.cc | 153 ASSERT_EQ(vec.front(), *vec.begin()); in TEST_F()
155 ASSERT_TRUE(vec.begin() < vec.end()); in TEST_F()
181 auto pos = vec.begin(); in TEST_F()
191 pos = vec.begin(); in TEST_F()
196 ASSERT_TRUE(pos >= vec.begin()); in TEST_F()
199 size_t diff = static_cast<size_t>(pos - vec.begin()); in TEST_F()
251 for (auto pos = v.begin(); pos != end; ++pos) { in BenchmarkSequenceAccess()
|
| D | hash_map.h | 34 bucket.begin(), bucket.end(), in Contains()
47 bucket.begin(), bucket.end(), in Delete()
61 bucket.begin(), bucket.end(), in Get()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 34 return *pending_outputs_.begin(); in MinObsoleteSstNumberToKeep()
81 job_context->min_pending_output = *pending_outputs_.begin(); in FindObsoleteFiles()
187 while (alive_log_files_.begin()->number < min_log_number) { in FindObsoleteFiles()
188 auto& earliest = *alive_log_files_.begin(); in FindObsoleteFiles()
235 job_context->log_recycle_files.assign(log_recycle_files_.begin(), in FindObsoleteFiles()
314 state.log_recycle_files.begin(), state.log_recycle_files.end()); in PurgeObsoleteFiles()
342 std::sort(candidate_files.begin(), candidate_files.end(), in PurgeObsoleteFiles()
345 std::unique(candidate_files.begin(), candidate_files.end()), in PurgeObsoleteFiles()
522 std::sort(old_info_log_files.begin(), old_info_log_files.end()); in PurgeObsoleteFiles()
681 std::sort(paths.begin(), paths.end()); in CleanupFilesAfterRecovery()
[all …]
|
| D | db_impl_experimental.cc | 24 const Slice* begin, const Slice* end) { in SuggestCompactRange() argument
28 if (begin != nullptr) { in SuggestCompactRange()
29 start_key.SetMinPossibleForUserKey(*begin); in SuggestCompactRange()
40 level, begin == nullptr ? nullptr : &start_key, in SuggestCompactRange()
84 std::sort(l0_files.begin(), l0_files.end(), in PromoteL0()
|
| D | db_impl_compaction_flush.cc | 91 for (auto it = logs_.begin(); in SyncClosedLogs()
693 Range range(*begin, *end); in CompactRange()
752 level, begin, end); in CompactRange()
1447 if (begin == nullptr || in RunManualCompaction()
1450 manual.begin = nullptr; in RunManualCompaction()
1453 manual.begin = &begin_storage; in RunManualCompaction()
2071 auto cfd = *compaction_queue_.begin(); in PopFirstFromCompactionQueue()
2552 (m->begin ? m->begin->DebugString().c_str() : "(begin)"), in BackgroundCompaction()
2572 (m->begin ? m->begin->DebugString().c_str() : "(begin)"), in BackgroundCompaction()
2937 m->begin = &m->tmp_storage; in BackgroundCompaction()
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | db.h | 536 std::copy(status.begin(), status.end(), statuses);
559 std::copy(status.begin(), status.end(), statuses);
560 std::copy(tss.begin(), tss.end(), timestamps);
600 std::copy(status.begin(), status.end(), statuses);
621 std::copy(status.begin(), status.end(), statuses);
622 std::copy(tss.begin(), tss.end(), timestamps);
1076 const Slice* begin, const Slice* end) { in CompactRange() argument
1077 return CompactRange(options, DefaultColumnFamily(), begin, end); in CompactRange()
1088 return CompactRange(options, column_family, begin, end);
1092 const Slice* begin, const Slice* end, bool change_level = false,
[all …]
|
| D | experimental.h | 16 const Slice* begin, const Slice* end);
17 Status SuggestCompactRange(DB* db, const Slice* begin, const Slice* end);
|
| /rocksdb-6.9/table/ |
| D | table_reader.h | 107 for (auto iter = mget_range->begin(); iter != mget_range->end(); ++iter) {
116 virtual Status Prefetch(const Slice* begin = nullptr,
118 (void) begin;
|
| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend2.cc | 38 for (auto it = merge_in.operand_list.begin(); in FullMergeV2()
58 for (auto it = merge_in.operand_list.begin(); in FullMergeV2()
98 for (std::deque<Slice>::const_iterator it = operand_list.begin() + 1; in _AssocPartialMergeMulti()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_lock_mgr.cc | 115 paths_buffer_.begin(), in Resize()
116 paths_buffer_.begin() + (paths_buffer_.size() - target_size)); in Resize()
138 std::rotate(working.begin(), working.begin() + buffer_idx_, working.end()); in Normalize()
149 std::reverse(working.begin(), working.end()); in PrepareBuffer()
495 std::reverse(path.begin(), path.end()); in IncrementWaiters()
599 auto txn_it = std::find(txns.begin(), txns.end(), txn_id); in UnLockKey()
707 std::sort(cf_ids.begin(), cf_ids.end()); in GetLockStatusData()
|
| /rocksdb-6.9/tools/rdb/ |
| D | db_wrapper.cc | 416 ROCKSDB_NAMESPACE::Slice begin = *v8::String::Utf8Value(args[0]->ToString()); in CompactRangeDefault() local
418 db_wrapper->status_ = db_wrapper->db_->CompactRange(&end, &begin); in CompactRangeDefault()
427 ROCKSDB_NAMESPACE::Slice begin = *v8::String::Utf8Value(args[0]->ToString()); in CompactColumnFamily() local
431 db_wrapper->columnFamilies_[cf], &begin, &end); in CompactColumnFamily()
444 ROCKSDB_NAMESPACE::Slice begin = *v8::String::Utf8Value(args[0]->ToString()); in CompactOptions() local
462 &begin, &end, true, target_level, target_path_id in CompactOptions()
476 ROCKSDB_NAMESPACE::Slice begin = *v8::String::Utf8Value(args[0]->ToString()); in CompactAll() local
496 db_wrapper->columnFamilies_[cf], &begin, &end, true, target_level, in CompactAll()
|
| D | API.md | 110 # begin (string) - First key in the range to compact.
117 db_obj.compactRange(begin, end)
118 db_obj.compactRange(begin, end, options)
119 db_obj.compactRange(begin, end, column_family)
120 db_obj.compactRange(begin, end, options, column_family)
|
| /rocksdb-6.9/utilities/ |
| D | util_merge_operators_test.cc | 23 std::vector<Slice> operands_slice(operands.begin(), operands.end()); in FullMergeV2()
41 std::vector<Slice> operands_slice(operands.begin(), operands.end()); in FullMergeV2()
65 std::deque<Slice> operands_slice(operands.begin(), operands.end()); in PartialMergeMulti()
|
| /rocksdb-6.9/table/block_based/ |
| D | full_filter_block.cc | 221 const Status s = GetOrReadFilterBlock(no_io, range->begin()->get_context, in MayMatch()
244 MultiGetRange filter_range(*range, range->begin(), range->end()); in MayMatch()
245 for (auto iter = filter_range.begin(); iter != filter_range.end(); ++iter) { in MayMatch()
259 for (auto iter = filter_range.begin(); iter != filter_range.end(); ++iter) { in MayMatch()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | RocksDB.java | 3133 public void compactRange(final byte[] begin, final byte[] end) in compactRange() argument
3135 compactRange(null, begin, end); in compactRange()
3166 final byte[] begin, final byte[] end) throws RocksDBException { in compactRange() argument
3168 begin, begin == null ? -1 : begin.length, in compactRange()
3284 public void compactRange(final byte[] begin, final byte[] end, in compactRange() argument
3287 compactRange(null, begin, end, changeLevel, targetLevel, targetPathId); in compactRange()
3327 final byte[] begin, final byte[] end, final boolean changeLevel, in compactRange() argument
3335 begin, begin == null ? -1 : begin.length, in compactRange()
3357 final byte[] begin, final byte[] end, in compactRange() argument
3360 begin, begin == null ? -1 : begin.length, in compactRange()
[all …]
|