Home
last modified time | relevance | path

Searched refs:end (Results 1 – 25 of 232) sorted by relevance

12345678910

/rocksdb-6.9/util/
Dtimer_queue.h77 item.end = tp + std::chrono::milliseconds(milliseconds); in add()
78 TEST_SYNC_POINT_CALLBACK("TimeQueue::Add:item.end", &item.end); in add()
108 newItem.end = Clock::time_point(); in cancel()
132 item.end = Clock::time_point(); in cancelAll()
150 auto end = calcWaitTime_lock(); in run() local
151 if (end.first) { in run()
154 m_checkWork.wait_until(lk, end.second); in run()
174 return std::make_pair(true, m_items.top().end); in calcWaitTime_lock()
187 while (m_items.size() && m_items.top().end <= Clock::now()) { in checkWork()
214 Clock::time_point end; member
[all …]
Dstring_util.cc199 if (iter == std::end(convert_map)) { in UnescapeChar()
211 if (iter == std::end(convert_map)) { in EscapeChar()
253 size_t end = str.size() - 1; in trim() local
254 while (isspace(str[start]) != 0 && start < end) { in trim()
257 while (isspace(str[end]) != 0 && start < end) { in trim()
258 --end; in trim()
260 if (start <= end) { in trim()
261 return str.substr(start, end - start + 1); in trim()
386 size_t end = value.find(':', start); in ParseVectorInt() local
387 if (end == std::string::npos) { in ParseVectorInt()
[all …]
Dhash_map.h34 bucket.begin(), bucket.end(), in Contains()
36 return it != bucket.end(); in Contains()
47 bucket.begin(), bucket.end(), in Delete()
49 if (it != bucket.end()) { in Delete()
50 auto last = bucket.end() - 1; in Delete()
61 bucket.begin(), bucket.end(), in Get()
Dautovector_test.cc154 ASSERT_EQ(vec.back(), *(vec.end() - 1)); in TEST_F()
155 ASSERT_TRUE(vec.begin() < vec.end()); in TEST_F()
182 while (pos != vec.end()) { in TEST_F()
188 ASSERT_TRUE(pos == vec.end() || old_val != *pos); in TEST_F()
197 ASSERT_TRUE(pos <= vec.end()); in TEST_F()
250 auto end = v.end(); in BenchmarkSequenceAccess() local
251 for (auto pos = v.begin(); pos != end; ++pos) { in BenchmarkSequenceAccess()
/rocksdb-6.9/db/
Drange_tombstone_fragmenter.cc150 seqnums_to_flush.end()); in FragmentTombstones()
214 return seq_it != seq_set_.end() && *seq_it <= upper; in ContainsRange()
266 pos_ = std::prev(tombstones_->end()); in SeekToLast()
275 pos_ = std::prev(tombstones_->end()); in SeekToTopLast()
304 if (pos_ == tombstones_->end()) { in SeekToCoveringTombstone()
334 while (pos_ != tombstones_->end() && in ScanForwardToVisibleTombstone()
338 if (pos_ == tombstones_->end()) { in ScanForwardToVisibleTombstone()
349 while (pos_ != tombstones_->end() && in ScanBackwardToVisibleTombstone()
372 if (pos_ == tombstones_->end()) { in TopNext()
387 if (pos_ == tombstones_->end() || in Prev()
[all …]
Dmanual_compaction_test.cc78 if (it == key_level_.end()) { in KeyLevel()
206 Slice end("7"); in TEST_F() local
208 db->CompactRange(CompactRangeOptions(), &start, &end); in TEST_F()
216 Slice end("7"); in TEST_F() local
218 db->CompactRange(CompactRangeOptions(), &start, &end); in TEST_F()
228 Slice end("0"); in TEST_F() local
230 db->CompactRange(CompactRangeOptions(), nullptr, &end); in TEST_F()
249 Slice end("2"); in TEST_F() local
251 db->CompactRange(CompactRangeOptions(), &start, &end); in TEST_F()
261 Slice end("5"); in TEST_F() local
[all …]
Dversion_edit_handler.cc145 if (cf_options == name_to_options_.end() && in OnColumnFamilyAdd()
201 assert(builder_iter != builders_.end()); in OnNonCfOperation()
289 assert(builder_iter != builders_.end()); in CheckIterationResult()
358 assert(builder_iter != builders_.end()); in DestroyCfAndCleanup()
382 assert(builder_iter != builders_.end()); in MaybeCreateVersion()
403 assert(builder_iter != builders_.end()); in LoadTables()
497 if (v_iter != versions_.end()) { in CheckIterationResult()
511 if (v_iter != versions_.end()) { in DestroyCfAndCleanup()
531 if (fiter != missing_files.end()) { in MaybeCreateVersion()
556 assert(builder_iter != builders_.end()); in MaybeCreateVersion()
[all …]
Drange_del_aggregator_test.cc51 ParsedInternalKey end; member
58 ParsedInternalKey end; member
70 Slice end; member
90 EXPECT_EQ(0, icmp.Compare(iter->end_key(), expected_range_dels[i].end)); in VerifyIterator()
105 0, icmp.Compare(iter->end_key(), reverse_expected_range_dels[i].end)); in VerifyIterator()
121 EXPECT_EQ(0, icmp.Compare(iter->end_key(), test_case.end)); in VerifySeek()
137 EXPECT_EQ(0, icmp.Compare(iter->end_key(), test_case.end)); in VerifySeekForPrev()
608 Slice end("__"); in TEST_F() local
626 Slice end("q"); in TEST_F() local
651 Slice end("e"); in TEST_F() local
[all …]
Drange_tombstone_fragmenter.h28 RangeTombstoneStack(const Slice& start, const Slice& end, size_t start_idx, in RangeTombstoneStack()
31 end_key(end), in RangeTombstoneStack()
49 std::vector<RangeTombstoneStack>::const_iterator end() const { in end() function
50 return tombstones_.end(); in end()
62 return tombstone_seqs_.end(); in seq_end()
145 pos_ = tombstones_->end(); in Invalidate()
147 pinned_pos_ = tombstones_->end(); in Invalidate()
225 if (pos_ != tombstones_->end() && seq_pos_ != tombstones_->seq_end() && in MaybePinKey()
Drange_del_aggregator.cc145 split_untruncated_iters.begin(), split_untruncated_iters.end(), in SplitBySnapshot()
253 it != iters_.end(); ++it, forward_iter_.IncUnusedIdx()) { in ShouldDelete()
264 it != iters_.end(); ++it, reverse_iter_.IncUnusedIdx()) { in ShouldDelete()
277 const Slice& end) { in IsRangeOverlapped() argument
287 ParsedInternalKey end_ikey(end, 0, static_cast<ValueType>(0)); in IsRangeOverlapped()
304 iter->SeekForPrev(end); in IsRangeOverlapped()
331 const Slice& end) { in IsRangeOverlapped() argument
333 return rep_.IsRangeOverlapped(start, end); in IsRangeOverlapped()
350 if (it == reps_.end()) { in AddTombstones()
358 assert(it != reps_.end()); in AddTombstones()
[all …]
Dtable_properties_collector_test.cc302 ASSERT_NE(user_collected.find("TablePropertiesTest"), user_collected.end()); in TestCustomizedTablePropertiesCollector()
306 ASSERT_NE(user_collected.find("Count"), user_collected.end()); in TestCustomizedTablePropertiesCollector()
313 ASSERT_NE(user_collected.find("NumPuts"), user_collected.end()); in TestCustomizedTablePropertiesCollector()
319 ASSERT_NE(user_collected.find("NumDeletes"), user_collected.end()); in TestCustomizedTablePropertiesCollector()
325 ASSERT_NE(user_collected.find("NumSingleDeletes"), user_collected.end()); in TestCustomizedTablePropertiesCollector()
331 ASSERT_NE(user_collected.find("NumSizeChanges"), user_collected.end()); in TestCustomizedTablePropertiesCollector()
452 ASSERT_NE(user_collected.find("Count"), user_collected.end()); in TestInternalKeyPropertiesCollector()
459 ASSERT_NE(user_collected.find("NumPuts"), user_collected.end()); in TestInternalKeyPropertiesCollector()
465 ASSERT_NE(user_collected.find("NumDeletes"), user_collected.end()); in TestInternalKeyPropertiesCollector()
472 user_collected.end()); in TestInternalKeyPropertiesCollector()
Dexperimental.cc16 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()
Dversion_set.cc2705 std::sort(temp->begin(), temp->end(), in SortFileByOverlappingRatio()
2917 if (end != nullptr) { in GetOverlappingInputs()
2918 user_end = end->user_key(); in GetOverlappingInputs()
2930 while (iter != index.end()) { in GetOverlappingInputs()
2938 } else if (end != nullptr && in GetOverlappingInputs()
2957 if (end != nullptr && in GetOverlappingInputs()
3045 if (end != nullptr) { in GetOverlappingInputsRangeBinarySearch()
4279 assert(builder != builders.end()); in ApplyOneVersionEditToBuilder()
4820 column_family_names.end()) { in ListColumnFamilies()
4828 column_family_names.end()) { in ListColumnFamilies()
[all …]
Dlogs_with_prep_tracker.cc15 if (UNLIKELY(it == prepared_section_completed_.end())) { in MarkLogAsHavingPrepSectionFlushed()
47 for (; it != logs_with_prep_.end();) { in FindMinLogContainingOutstandingPrep()
52 if (completed_it == prepared_section_completed_.end() || in FindMinLogContainingOutstandingPrep()
56 assert(completed_it != prepared_section_completed_.end() && in FindMinLogContainingOutstandingPrep()
/rocksdb-6.9/java/crossbuild/
DVagrantfile12 end
17 end
23 end
33 end
39 end
43 end
46 end
51 end
/rocksdb-6.9/env/
Dmock_env.cc431 if (file_map_.find(fn) == file_map_.end()) { in NewSequentialFile()
448 if (file_map_.find(fn) == file_map_.end()) { in NewRandomAccessFile()
554 result->erase(std::unique(result->begin(), result->end()), result->end()); in GetChildren()
561 if (pair != file_map_.end()) { in DeleteFileInternal()
582 if (iter == file_map_.end()) { in Truncate()
615 if (iter == file_map_.end()) { in GetFileSize()
628 if (iter == file_map_.end()) { in GetFileModificationTime()
639 if (file_map_.find(s) == file_map_.end()) { in RenameFile()
653 if (file_map_.find(s) == file_map_.end()) { in LinkFile()
669 if (iter == file_map_.end()) { in NewLogger()
[all …]
/rocksdb-6.9/memtable/
Dvectorrep.cc119 return std::find(bucket_->begin(), bucket_->end(), key) != bucket_->end(); in Contains()
151 cit_(bucket_->end()), in Iterator()
160 std::sort(bucket_->begin(), bucket_->end(), Compare(compare_)); in DoSort()
167 std::sort(bucket_->begin(), bucket_->end(), Compare(compare_)); in DoSort()
178 return cit_ != bucket_->end(); in Valid()
192 if (cit_ == bucket_->end()) { in Next()
206 cit_ = bucket_->end(); in Prev()
220 bucket_->end(), in Seek()
244 cit_ = bucket_->end(); in SeekToLast()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc127 if (paths.find(path) == paths.end()) { in FindObsoleteFiles()
236 log_recycle_files_.end()); in FindObsoleteFiles()
342 std::sort(candidate_files.begin(), candidate_files.end(), in PurgeObsoleteFiles()
345 std::unique(candidate_files.begin(), candidate_files.end()), in PurgeObsoleteFiles()
346 candidate_files.end()); in PurgeObsoleteFiles()
406 log_recycle_files_set.end())); in PurgeObsoleteFiles()
416 keep = (sst_live_map.find(number) != sst_live_map.end()) || in PurgeObsoleteFiles()
523 size_t end = in PurgeObsoleteFiles() local
525 for (unsigned int i = 0; i <= end; i++) { in PurgeObsoleteFiles()
681 std::sort(paths.begin(), paths.end()); in CleanupFilesAfterRecovery()
[all …]
/rocksdb-6.9/
DVagrantfile7 end
11 end
15 end
20 end
37 end
39 end
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader.cc68 if (hash_funs == user_props.end()) { in CuckooTableReader()
74 if (unused_key == user_props.end()) { in CuckooTableReader()
82 if (user_key_len == user_props.end()) { in CuckooTableReader()
90 if (value_length == user_props.end()) { in CuckooTableReader()
100 if (hash_table_size == user_props.end()) { in CuckooTableReader()
108 if (is_last_level == user_props.end()) { in CuckooTableReader()
116 if (identity_as_first_hash == user_props.end()) { in CuckooTableReader()
125 if (use_module_hash == user_props.end()) { in CuckooTableReader()
133 if (cuckoo_block_size == user_props.end()) { in CuckooTableReader()
285 std::sort(sorted_bucket_ids_.begin(), sorted_bucket_ids_.end(), in InitIfNeeded()
[all …]
/rocksdb-6.9/options/
Doptions_helper.cc274 if (iter != type_map.end()) { in ParseEnum()
337 start = end + 1; in ParseVectorCompressionType()
408 size_t len = (end == std::string::npos) ? end : end - start; in ParseStructOptions()
413 start = (end == std::string::npos) ? end : end + 1; in ParseStructOptions()
935 size_t end = value.find(':'); in ParseCompressionOptions() local
941 start = end + 1; in ParseCompressionOptions()
942 end = value.find(':', start); in ParseCompressionOptions()
948 start = end + 1; in ParseCompressionOptions()
958 start = end + 1; in ParseCompressionOptions()
969 start = end + 1; in ParseCompressionOptions()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader_impl.h97 char* end = EncodeVarint64(cache_key + kExtraCacheKeyPrefix, in NewDataBlockIterator() local
99 assert(end - cache_key <= in NewDataBlockIterator()
101 const Slice unique_key(cache_key, static_cast<size_t>(end - cache_key)); in NewDataBlockIterator()
169 char* end = EncodeVarint64(cache_key + kExtraCacheKeyPrefix, in NewDataBlockIterator() local
171 assert(end - cache_key <= in NewDataBlockIterator()
173 const Slice unique_key(cache_key, static_cast<size_t>(end - cache_key)); in NewDataBlockIterator()
/rocksdb-6.9/tools/
Dldb_cmd.cc339 if (itr != options.end()) { in LDBCommand()
344 if (itr != options.end()) { in LDBCommand()
349 if (itr != options.end()) { in LDBCommand()
357 if (itr != options.end()) { in LDBCommand()
531 ret.insert(ret.end(), options.begin(), options.end()); in BuildCmdLineOptions()
844 if (itr != options.end()) { in ParseBooleanOption()
875 if (itr != options.end()) {
881 if (itr != options.end()) {
910 Slice* end = nullptr; in DoCommand() local
915 end = new Slice(to_); in DoCommand()
[all …]
/rocksdb-6.9/utilities/transactions/
Dtransaction_lock_mgr.cc149 std::reverse(working.begin(), working.end()); in PrepareBuffer()
188 if (lock_maps_.find(column_family_id) == lock_maps_.end()) { in AddColumnFamily()
205 assert(lock_maps_iter != lock_maps_.end()); in RemoveColumnFamily()
231 if (lock_map_iter != lock_maps_cache->end()) { in GetLockMap()
240 if (lock_map_iter == lock_maps_.end()) { in GetLockMap()
495 std::reverse(path.begin(), path.end()); in IncrementWaiters()
531 if (stripe_iter != stripe->keys.end()) { in AcquireLocked()
597 if (stripe_iter != stripe->keys.end()) { in UnLockKey()
601 if (txn_it != txns.end()) { in UnLockKey()
605 auto last_it = txns.end() - 1; in UnLockKey()
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc320 if (db_file_state_.find(s) != db_file_state_.end()) { in RenameFile()
329 assert(tlist.find(tdn.second) == tlist.end()); in RenameFile()
339 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileClosed()
347 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileSynced()
348 if (db_file_state_.find(state.filename_) == db_file_state_.end()) { in WritableFileSynced()
358 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileAppended()
359 if (db_file_state_.find(state.filename_) == db_file_state_.end()) { in WritableFileAppended()
371 io_s.ok() && it != db_file_state_.end(); ++it) { in DropUnsyncedFileData()
384 io_s.ok() && it != db_file_state_.end(); ++it) { in DropRandomUnsyncedFileData()
400 dir_to_new_files_since_last_sync_.end()); in DeleteFilesCreatedAfterLastDirSync()

12345678910