| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker_level.cc | 22 if (!vstorage->ExpiredTtlFiles().empty()) { in NeedsCompaction()
246 if (start_level_inputs_.empty()) { in SetupInitialFiles()
252 if (!start_level_inputs_.empty()) { in SetupInitialFiles()
260 if (start_level_inputs_.empty()) { in SetupInitialFiles()
284 if (start_level_inputs_.empty()) { in SetupInitialFiles()
286 if (!start_level_inputs_.empty()) { in SetupInitialFiles()
293 if (start_level_inputs_.empty()) { in SetupInitialFiles()
295 if (!start_level_inputs_.empty()) { in SetupInitialFiles()
351 if (start_level_inputs_.empty()) { in PickCompaction()
412 assert(!ioptions.cf_paths.empty()); in GetPathId()
[all …]
|
| D | compaction_picker.cc | 171 assert(!inputs.empty()); in GetRange()
200 assert(!inputs1.empty() || !inputs2.empty()); in GetRange()
201 if (inputs1.empty()) { in GetRange()
203 } else if (inputs2.empty()) { in GetRange()
222 if (in.empty()) { in GetRange()
247 assert(!inputs->empty()); in ExpandInputsToCleanCut()
274 assert(!inputs->empty()); in ExpandInputsToCleanCut()
304 if (!in.empty()) { in FilesRangeOverlapWithCompaction()
399 if (!input_set->empty()) { in GetCompactionInputsFromFileNumbers()
446 assert(!inputs->empty()); in SetupOtherInputs()
[all …]
|
| D | compaction_picker_universal.cc | 230 while (!smallest_key_priority_q.empty()) { in IsInputFilesNonOverlapping()
270 if (!vstorage->FilesMarkedForPeriodicCompaction().empty()) { in NeedsCompaction()
273 if (!vstorage->FilesMarkedForCompaction().empty()) { in NeedsCompaction()
379 (vstorage_->FilesMarkedForPeriodicCompaction().empty() && in PickCompaction()
380 vstorage_->FilesMarkedForCompaction().empty() && in PickCompaction()
398 if (!vstorage_->FilesMarkedForPeriodicCompaction().empty()) { in PickCompaction()
547 assert(!ioptions.cf_paths.empty()); in GetPathId()
776 assert(!sorted_runs_.empty()); in PickCompactionToReduceSizeAmp()
888 if (start_level_inputs.empty()) { in PickDeleteTriggeredCompaction()
936 if (!output_level_inputs.empty()) { in PickDeleteTriggeredCompaction()
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_tier.cc | 105 PersistentTieredCache::~PersistentTieredCache() { assert(tiers_.empty()); } in ~PersistentTieredCache()
108 assert(!tiers_.empty()); in Open()
113 assert(!tiers_.empty()); in Close()
122 assert(!tiers_.empty()); in Erase()
127 assert(!tiers_.empty()); in Stats()
132 assert(!tiers_.empty()); in PrintStats()
138 assert(!tiers_.empty()); in Insert()
145 assert(!tiers_.empty()); in Lookup()
150 if (!tiers_.empty()) { in AddTier()
|
| /rocksdb-6.9/db/ |
| D | snapshot_impl.h | 62 bool empty() const { return list_.next_ == &list_; } in empty() function
63 SnapshotImpl* oldest() const { assert(!empty()); return list_.next_; } in oldest()
64 SnapshotImpl* newest() const { assert(!empty()); return list_.prev_; } in newest()
109 if (empty()) {
118 if (ret.empty() || ret.back() != s->next_->number_) {
137 if (empty()) { in GetNewest()
144 if (empty()) { in GetOldestSnapshotTime()
152 if (empty()) { in GetOldestSnapshotSequence()
|
| D | builder.cc | 57 column_family_name.empty()); in NewTableBuilder()
91 column_family_name.empty()); in BuildTable()
151 snapshots.empty() ? 0 : snapshots.back(), in BuildTable()
187 bool empty = builder->NumEntries() == 0 && tp.num_range_deletions == 0; in BuildTable() local
190 if (!s.ok() || empty) { in BuildTable()
197 if (s.ok() && !empty) { in BuildTable()
210 if (s.ok() && !empty) { in BuildTable()
214 if (io_status->ok() && !empty) { in BuildTable()
217 if (io_status->ok() && !empty) { in BuildTable()
229 if (s.ok() && !empty) { in BuildTable()
|
| D | range_del_aggregator.cc | 166 while (!active_iters_.empty() && in ShouldDelete()
177 while (!inactive_iters_.empty() && in ShouldDelete()
187 return active_seqnums_.empty() in ShouldDelete()
209 while (!active_iters_.empty() && in ShouldDelete()
220 while (!inactive_iters_.empty() && in ShouldDelete()
230 return active_seqnums_.empty() in ShouldDelete()
317 if (input_iter == nullptr || input_iter->empty()) { in AddTombstones()
339 if (input_iter == nullptr || input_iter->empty()) { in AddTombstones()
395 return !heap_.empty() && BeforeEndKey(heap_.top()); in Valid()
|
| D | job_context.h | 53 return !superversions_to_free.empty() || in HaveSomethingToDelete()
54 !write_stall_notifications.empty(); in HaveSomethingToDelete()
56 return !superversions_to_free.empty(); in HaveSomethingToDelete()
97 assert(write_stall_notifications.empty()); in ~SuperVersionContext()
99 assert(superversions_to_free.empty()); in ~SuperVersionContext()
|
| D | range_tombstone_fragmenter.cc | 111 assert(tombstones_.empty() || in FragmentTombstones()
190 if (!cur_end_keys.empty() && icmp.user_comparator()->Compare( in FragmentTombstones()
200 if (!cur_end_keys.empty()) { in FragmentTombstones()
254 if (tombstones_->empty()) { in SeekToTopFirst()
271 if (tombstones_->empty()) { in SeekToTopLast()
283 if (tombstones_->empty()) { in Seek()
292 if (tombstones_->empty()) { in SeekForPrev()
316 if (tombstones_->empty()) { in SeekForPrevToCoveringTombstone()
|
| D | memtable_list.cc | 122 if (range->empty()) { in MultiGet()
248 if (include_history && !memlist_history_.empty()) { in GetEarliestSequenceNumber()
250 } else if (!memlist_.empty()) { in GetEarliestSequenceNumber()
292 if (!memlist_history_.empty()) { in ApproximateMemoryUsageExcludingLast()
316 while (MemtableLimitExceeded(usage) && !memlist_history_.empty()) { in TrimHistory()
369 assert(!mems.empty()); in RollbackMemtableFlush()
429 if (memlist.empty() || !memlist.back()->flush_completed_) { in TryInstallMemtableFlushResults()
595 if (!current_->memlist_.empty()) { in ApproximateOldestKeyTime()
663 if (!mems_list[k]->empty()) { in InstallMemtableAtomicFlushResults()
682 assert(!mems->empty()); in InstallMemtableAtomicFlushResults()
|
| /rocksdb-6.9/util/ |
| D | rate_limiter.cc | 146 ((!queue_[Env::IO_HIGH].empty() && in Request()
148 (!queue_[Env::IO_LOW].empty() && in Request()
175 (!queue_[Env::IO_HIGH].empty() && in Request()
177 (!queue_[Env::IO_LOW].empty() && in Request()
180 (!queue_[Env::IO_HIGH].empty() && in Request()
182 (!queue_[Env::IO_LOW].empty() && in Request()
199 assert((queue_[Env::IO_HIGH].empty() || in Request()
201 (queue_[Env::IO_LOW].empty() || in Request()
203 if (!queue_[Env::IO_HIGH].empty()) { in Request()
205 } else if (!queue_[Env::IO_LOW].empty()) { in Request()
[all …]
|
| D | heap.h | 57 assert(!empty()); in top()
62 assert(!empty()); in replace_top()
68 assert(!empty()); in replace_top()
74 assert(!empty()); in pop()
77 if (!empty()) { in pop()
95 bool empty() const { return data_.empty(); } in empty() function
|
| D | autovector_test.cc | 39 ASSERT_TRUE(vec.empty()); in TEST_F()
44 ASSERT_TRUE(!vec.empty()); in TEST_F()
63 ASSERT_TRUE(vec.empty()); in TEST_F()
72 ASSERT_TRUE(!vec.empty()); in TEST_F()
85 ASSERT_TRUE(vec.empty()); in TEST_F()
115 ASSERT_EQ(a.empty(), b.empty()); in AssertEqual()
186 ASSERT_TRUE(!old->empty()); in TEST_F()
|
| D | autovector.h | 217 bool empty() const { return size() == 0; }
246 assert(!empty());
251 assert(!empty());
256 assert(!empty());
261 assert(!empty());
295 assert(!empty());
296 if (!vect_.empty()) {
|
| D | channel.h | 31 return buffer_.empty() && eof_; in eof()
51 cv_.wait(lk, [&] { return eof_ || !buffer_.empty(); }); in read()
52 if (eof_ && buffer_.empty()) { in read()
|
| D | heap_test.cc | 90 assert((size == 0) == ref.empty()); in TEST_P()
91 ASSERT_EQ(size == 0, heap.empty()); in TEST_P()
102 ASSERT_TRUE(heap.empty()); in TEST_P()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 33 if (!pending_outputs_.empty()) { in MinObsoleteSstNumberToKeep()
80 if (!pending_outputs_.empty()) { in FindObsoleteFiles()
109 InfoLogPrefix info_log_prefix(!immutable_db_options_.db_log_dir.empty(), in FindObsoleteFiles()
169 if (!immutable_db_options_.db_log_dir.empty() && in FindObsoleteFiles()
183 if (!alive_log_files_.empty() && !logs_.empty()) { in FindObsoleteFiles()
215 while (!logs_.empty() && logs_.front().number < min_log_number) { in FindObsoleteFiles()
229 assert(!logs_.empty()); in FindObsoleteFiles()
233 assert(job_context->logs_to_free.empty()); in FindObsoleteFiles()
474 ((!dir_to_sync.empty() && dir_to_sync.back() == '/') || in PurgeObsoleteFiles()
475 (!to_delete.empty() && to_delete.front() == '/') in PurgeObsoleteFiles()
[all …]
|
| /rocksdb-6.9/table/ |
| D | table_properties.cc | 119 filter_policy_name.empty() ? std::string("N/A") : filter_policy_name, in ToString()
123 prefix_extractor_name.empty() ? std::string("N/A") in ToString()
136 column_family_name.empty() ? std::string("N/A") : column_family_name, in ToString()
140 comparator_name.empty() ? std::string("N/A") : comparator_name, in ToString()
145 merge_operator_name.empty() ? std::string("N/A") : merge_operator_name, in ToString()
149 property_collectors_names.empty() ? std::string("N/A") in ToString()
155 compression_name.empty() ? std::string("N/A") : compression_name, in ToString()
160 compression_options.empty() ? std::string("N/A") : compression_options, in ToString()
|
| D | meta_blocks.cc | 100 if (!props.filter_policy_name.empty()) { in AddTableProperty()
103 if (!props.comparator_name.empty()) { in AddTableProperty()
107 if (!props.merge_operator_name.empty()) { in AddTableProperty()
110 if (!props.prefix_extractor_name.empty()) { in AddTableProperty()
114 if (!props.property_collectors_names.empty()) { in AddTableProperty()
118 if (!props.column_family_name.empty()) { in AddTableProperty()
122 if (!props.compression_name.empty()) { in AddTableProperty()
125 if (!props.compression_options.empty()) { in AddTableProperty()
283 if (!last_key.empty() && in ReadProperties()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_tool.cc | 57 if (!FLAGS_hdfs.empty()) { in db_stress_tool()
58 if (!FLAGS_env_uri.empty()) { in db_stress_tool()
63 } else if (!FLAGS_env_uri.empty()) { in db_stress_tool()
170 if (FLAGS_db.empty()) { in db_stress_tool()
178 FLAGS_secondaries_base.empty()) { in db_stress_tool()
206 if (!FLAGS_key_len_percent_dist.empty()) { in db_stress_tool()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.h | 530 assert(heap_.empty()); in ~PreparedHeap()
531 assert(erased_heap_.empty()); in ~PreparedHeap()
536 inline bool empty() { return top() == kMaxSequenceNumber; } in empty() function
541 if (heap_.empty()) { in push()
554 while (!heap_.empty() && !erased_heap_.empty() &&
568 while (heap_.empty() && !erased_heap_.empty()) {
580 if (!empty()) { in erase()
588 assert(heap_.empty() || heap_.front() != seq); in erase()
650 if (!delayed_prepared_.empty()) { in SmallestUnCommittedSeq()
654 bool empty = min_prepare == kMaxSequenceNumber; in SmallestUnCommittedSeq() local
[all …]
|
| D | write_unprepared_txn.cc | 53 if (!unprep_seqs_.empty()) { in ~WriteUnpreparedTxn()
56 assert(!name_.empty()); in ~WriteUnpreparedTxn()
96 assert(active_iterators_.empty()); in Initialize()
103 if (active_iterators_.empty()) { in HandleWrite()
268 !unflushed_save_points_->empty()) { in FlushWriteBatchToDB()
276 if (name_.empty()) { in FlushWriteBatchToDBInternal()
520 if (unprep_seqs_.empty()) { in CommitWithoutPrepareInternal()
541 const bool empty = working_batch->Count() == 0; in CommitInternal() local
545 if (!empty && for_recovery) { in CommitInternal()
552 const bool includes_data = !empty && !for_recovery; in CommitInternal()
[all …]
|
| /rocksdb-6.9/file/ |
| D | filename.cc | 189 if (log_dir.empty()) { in InfoLogFileName()
203 if (log_dir.empty()) { in OldInfoLogFileName()
294 if (!rest.empty()) { in ParseFileName()
305 if (!rest.empty()) { in ParseFileName()
399 if (db_id.empty()) { in SetIdentityFile()
404 assert(!id.empty()); in SetIdentityFile()
432 if (!db_log_dir.empty()) { in GetInfoLogFiles()
438 InfoLogPrefix info_log_prefix(!db_log_dir.empty(), dbname); in GetInfoLogFiles()
459 if (!dst.empty() && c == kFilePathSeparator && in NormalizePath()
|
| /rocksdb-6.9/build_tools/ |
| D | gnu_parallel | 4840 sub empty { subroutine
4845 return $empty;
7021 sub empty { subroutine
7025 return $empty;
7191 sub empty { subroutine
7194 $empty &&= $self->{'arg_sub_queue'}->empty();
7196 return $empty;
7256 sub empty { subroutine
7300 sub empty { subroutine
7325 $empty = 0;
[all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2014-06-23-plaintable-a-new-file-format.markdown | 18 1. Queries efficiently return empty results
37 …empty queries, we added a bloom filter check before the query. This adds only one cache miss for n…
|