Home
last modified time | relevance | path

Searched refs:first (Results 1 – 25 of 168) sorted by relevance

1234567

/rocksdb-6.9/env/
Denv_chroot.cc47 return status_and_enc_path.first; in RegisterDbPaths()
60 return status_and_enc_path.first; in UnregisterDbPaths()
72 return status_and_enc_path.first; in NewSequentialFile()
83 return status_and_enc_path.first; in NewRandomAccessFile()
94 return status_and_enc_path.first; in NewWritableFile()
106 return status_and_enc_path.first; in ReuseWritableFile()
122 return status_and_enc_path.first; in NewRandomRWFile()
132 return status_and_enc_path.first; in NewDirectory()
140 return status_and_enc_path.first; in FileExists()
149 return status_and_enc_path.first; in GetChildren()
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer.cc421 uint64_t time = num_miss.first; in WriteMissRatioTimeline()
471 std::string row(label.first); in WriteMissRatioTimeline()
498 uint64_t time = num_miss.first; in WriteMissTimeline()
537 std::string row(label.first); in WriteMissTimeline()
630 caller_map.first); in WriteCorrelationFeatures()
933 std::string row(label.first); in WriteAccessTimeline()
988 header += label_it.first; in WriteReuseDistance()
1054 header += label_it.first; in WriteStatsToFile()
1307 header += cf_name.first; in WritePercentAccessSummaryStats()
1351 header += cf_name.first; in WriteDetailedPercentAccessSummaryStats()
[all …]
/rocksdb-6.9/utilities/merge_operators/string_append/
Dstringappend_test.cc149 bool first = true; in TEST_F() local
152 if (first) { in TEST_F()
154 first = false; in TEST_F()
163 first = true; in TEST_F()
166 if (first) { in TEST_F()
177 first = true; in TEST_F()
180 if (first) { in TEST_F()
191 if (first) { in TEST_F()
202 first = true; in TEST_F()
206 if (first) { in TEST_F()
[all …]
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc140 batch.Put(kv_it_->first, kv_it_->second); in MakePutWriteBatch()
143 batch.Delete(kv_it_->first); in MakePutWriteBatch()
165 ? db_ttl_->Put(wopts, kv_it_->first, kv_it_->second) in PutValues()
166 : db_ttl_->Put(wopts, cf, kv_it_->first, kv_it_->second)); in PutValues()
195 bool ret = db_ttl_->KeyMayExist(ropts, kv.first, &val, &value_found); in SimpleKeyMayExistCheck()
198 " should have\n", kv.first.c_str()); in SimpleKeyMayExistCheck()
202 " should be %s\n", kv.first.c_str(), val.c_str(), in SimpleKeyMayExistCheck()
216 keys.emplace_back(kv.first); in SimpleMultiGetTest()
245 Status s = (cf == nullptr) ? db_ttl_->Get(ropts, kv_it_->first, &v) in SleepCompactCheck()
248 fprintf(stderr, "key=%s ", kv_it_->first.c_str()); in SleepCompactCheck()
[all …]
/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc247 correlation_map[it.first][it.second] = sequence; in SparseCorrelationInput()
579 record.first, record.second); in MakeStatistics()
598 stat.second.a_key_mid = record.first; in MakeStatistics()
603 record.first, record.second); in MakeStatistics()
808 if (time_it.first >= duration) { in MakeStatisticQPS()
812 type_qps[time_it.first][type] += time_it.second; in MakeStatisticQPS()
818 while (time_line < time_it.first) { in MakeStatisticQPS()
841 if (time_line == time_it.first) { in MakeStatisticQPS()
1007 uint32_t cf_id = cf_it.first; in ReProcessing()
1849 stat.top_k_prefix_ave.top().first); in PrintStatistics()
[all …]
/rocksdb-6.9/docs/_posts/
D2014-09-12-cuckoo.markdown50 …mpute hashes of the key _h1(k), ..., __hn__(k)_. We insert the key in the first hash location that…
56 …f lookups is 1.8 and maximum is 3. Around 44% of keys are accommodated in first hash location and …
64 …* If the key is not present in first hash location, we jump to second hash location which may not …
67 …first cuckoo block, we couldn't have an optimal prefetching strategy - prefetching all hash locati…
71 …first location. In case of collision in the first hash location - _h1(k)_, we try to insert it in …
74 …lization, we found that 85% of keys are accommodated in first Cuckoo Block. Prefetching the first …
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc102 result.first = port::kMaxUint64; in parseKey()
108 result.first = port::kMaxUint64; in parseKey()
111 result.first = parsed_time; in parseKey()
142 time_ = parseKey(iter->key(), start_time).first; in AdvanceIteratorByTime()
155 if (kv.first != time_) { in AdvanceIteratorByTime()
Dstatistics.cc360 assert(t.first < TICKER_ENUM_MAX); in ToString()
363 t.second.c_str(), getTickerCountLocked(t.first)); in ToString()
367 assert(h.first < HISTOGRAM_ENUM_MAX); in ToString()
370 getHistogramImplLocked(h.first)->Data(&hData); in ToString()
396 assert(t.first < TICKER_ENUM_MAX); in getTickerMap()
397 (*stats_map)[t.second.c_str()] = getTickerCountLocked(t.first); in getTickerMap()
/rocksdb-6.9/util/
Dfile_checksum_helper.cc27 file_numbers->push_back(i.first); in GetAllFileChecksums()
28 checksums->push_back(i.second.first); in GetAllFileChecksums()
45 *checksum = it->second.first; in SearchOneFileChecksum()
59 it->second.first = checksum; in InsertOneFileChecksum()
Dhash_map.h35 [key](const std::pair<K, V>& p) { return p.first == key; }); in Contains()
48 [key](const std::pair<K, V>& p) { return p.first == key; }); in Delete()
62 [key](const std::pair<K, V>& p) { return p.first == key; }); in Get()
/rocksdb-6.9/db/
Dprefix_test.cc702 PutKey(db.get(), write_options, kv.first, kv.second); in TEST_F()
703 type_map[kv.first] = "value"; in TEST_F()
705 MergeKey(db.get(), write_options, kv.first, kv.second); in TEST_F()
706 type_map[kv.first] = "merge"; in TEST_F()
717 whole_map.erase(kv.first); in TEST_F()
718 DeleteKey(db.get(), write_options, kv.first); in TEST_F()
719 entry_maps[2][kv.first] = "delete"; in TEST_F()
727 std::cout << "[" << i << "]" << kv.first.prefix << kv.first.sorted in TEST_F()
728 << " " << kv.second + " " + type_map[kv.first] << std::endl; in TEST_F()
747 << " | map: " << it->first.prefix << it->first.sorted << " | " in TEST_F()
[all …]
Ddeletefile_test.cc199 std::string first("0"), last("999999"); in TEST_F() local
203 Slice first_slice(first), last_slice(last); in TEST_F()
228 std::string first("0"), last("999999"); in TEST_F() local
232 Slice first_slice(first), last_slice(last); in TEST_F()
334 std::string first("0"), last("999999"); in TEST_F() local
338 Slice first_slice(first), last_slice(last); in TEST_F()
374 std::string first("0"), last("999999"); in TEST_F() local
378 Slice first_slice(first), last_slice(last); in TEST_F()
Ddb_test_util.cc927 bool first = true; in AllEntriesFor() local
936 if (!first) { in AllEntriesFor()
939 first = false; in AllEntriesFor()
961 if (!first) { in AllEntriesFor()
1422 Status s = status[kv.first]; in VerifyDBFromMap()
1424 ASSERT_EQ(Get(kv.first), kv.second); in VerifyDBFromMap()
1483 iter->Seek(kv.first); in VerifyDBFromMap()
1484 ASSERT_EQ(kv.first, iter->key().ToString()); in VerifyDBFromMap()
1514 iter->Seek(kv.first); in VerifyDBFromMap()
1515 ASSERT_EQ(kv.first, iter->key().ToString()); in VerifyDBFromMap()
[all …]
Dexternal_sst_file_test.cc95 return options.comparator->Compare(e1.first, e2.first) < 0; in GenerateOneExternalFile()
101 return options.comparator->Compare(e1.first, e2.first) == 0; in GenerateOneExternalFile()
149 return options.comparator->Compare(e1.first, e2.first) < 0; in GenerateAndAddExternalFile()
155 return options.comparator->Compare(e1.first, e2.first) == 0; in GenerateAndAddExternalFile()
1141 int range_start = key_ranges[i].first; in TEST_F()
1223 ASSERT_EQ(Get(kv.first), kv.second); in TEST_F()
2433 const std::string& key = elem.first; in TEST_P()
2555 const std::string& key = elem.first; in TEST_P()
2627 const std::string& key = elem.first; in TEST_P()
2697 const std::string& key = elem.first; in TEST_P()
[all …]
/rocksdb-6.9/options/
Doptions_parser.cc420 if (pair.first == "rocksdb_version") { in EndSection()
421 s = ParseVersionNumber(pair.first, pair.second, 3, db_version); in EndSection()
425 } else if (pair.first == "options_file_version") { in EndSection()
426 s = ParseVersionNumber(pair.first, pair.second, 2, opt_file_version); in EndSection()
748 if (DBOptionSanityCheckLevel(pair.first) <= sanity_check_level) { in VerifyDBOptions()
751 pair.second, pair.first, nullptr)) { in VerifyDBOptions()
766 pair.first.c_str(), base_value.c_str(), in VerifyDBOptions()
786 if (CFOptionSanityCheckLevel(pair.first) <= sanity_check_level) { in VerifyCFOptions()
789 pair.second, pair.first, persisted_opt_map)) { in VerifyCFOptions()
804 pair.first.c_str(), base_value.c_str(), in VerifyCFOptions()
Doptions_helper.cc286 *value = pair.first; in SerializeEnum()
797 auto iter = cf_options_type_info.find(o.first); in GetMutableOptionsFromStrings()
809 o.first.c_str()); in GetMutableOptionsFromStrings()
816 return Status::InvalidArgument("Error parsing " + o.first); in GetMutableOptionsFromStrings()
834 auto iter = db_options_type_info.find(o.first); in GetMutableDBOptionsFromStrings()
1145 iter->first.c_str()); in GetStringFromStruct()
1267 unsupported_options_names->push_back(o.first); in GetColumnFamilyOptionsFromMapInternal()
1319 auto s = ParseDBOption(o.first, o.second, in GetDBOptionsFromMapInternal()
1327 unsupported_options_names->push_back(o.first); in GetDBOptionsFromMapInternal()
1367 if (ParseDBOption(o.first, o.second, &new_db_options).ok()) { in GetOptionsFromString()
[all …]
Doptions_settable_test.cc48 std::memset(start_ptr + offset, kSpecialChar, pair.first - offset); in FillWithSpecialChar()
49 offset = pair.first + pair.second; in FillWithSpecialChar()
59 for (char* ptr = start_ptr + offset; ptr < start_ptr + pair.first; ptr++) { in NumUnsetBytes()
64 offset = pair.first + pair.second; in NumUnsetBytes()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_test.cc121 iter->second.first); in AddToCompactionFiles()
523 file_map_[2].first->being_compacted = true; in TEST_F()
553 file_map_[5].first->being_compacted = true; in TEST_F()
579 file_map_[5].first->being_compacted = true; in TEST_F()
609 file_map_[2].first->being_compacted = true; in TEST_F()
1075 file_map_[1U].first->being_compacted = true; in TEST_F()
1122 file_map_[6U].first->being_compacted = true; in TEST_F()
1153 file_map_[4u].first->being_compacted = true; in TEST_F()
1215 file_map_[4u].first->being_compacted = true; in TEST_F()
1608 file_map_[1U].first->being_compacted = true; in TEST_F()
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc235 auto& list = dir_to_new_files_since_last_sync_[dir_and_name.first]; in NewWritableFile()
256 auto& list = dir_to_new_files_since_last_sync_[dir_and_name.first]; in ReopenWritableFile()
277 auto& list = dir_to_new_files_since_last_sync_[dir_and_name.first]; in NewRandomRWFile()
327 if (dir_to_new_files_since_last_sync_[sdn.first].erase(sdn.second) != 0) { in RenameFile()
328 auto& tlist = dir_to_new_files_since_last_sync_[tdn.first]; in RenameFile()
405 IOStatus io_s = DeleteFile(pair.first + "/" + name, options, dbg); in DeleteFilesCreatedAfterLastDirSync()
424 dir_to_new_files_since_last_sync_[dir_and_name.first].erase( in UntrackFile()
Dfault_injection_test_env.cc246 auto& list = dir_to_new_files_since_last_sync_[dir_and_name.first]; in NewWritableFile()
267 auto& list = dir_to_new_files_since_last_sync_[dir_and_name.first]; in ReopenWritableFile()
288 auto& list = dir_to_new_files_since_last_sync_[dir_and_name.first]; in NewRandomRWFile()
334 if (dir_to_new_files_since_last_sync_[sdn.first].erase(sdn.second) != 0) { in RenameFile()
335 auto& tlist = dir_to_new_files_since_last_sync_[tdn.first]; in RenameFile()
414 Status s = DeleteFile(pair.first + "/" + name); in DeleteFilesCreatedAfterLastDirSync()
432 dir_to_new_files_since_last_sync_[dir_and_name.first].erase( in UntrackFile()
/rocksdb-6.9/utilities/blob_db/
Dblob_log_format.cc26 PutFixed64(dst, expiration_range.first); in EncodeTo()
55 if (!GetFixed64(&src, &expiration_range.first) || in DecodeFrom()
68 PutFixed64(dst, expiration_range.first); in EncodeTo()
87 !GetFixed64(&src, &expiration_range.first) || in DecodeFrom()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc683 latest_backup_id_ = backup_iter->first; in Initialize()
698 std::make_pair(backup_iter->first, in Initialize()
707 backup_iter->first, in Initialize()
719 backups_.erase(backups_.find(corrupt.first)); in Initialize()
818 auto& new_backup = ret.first->second; in CreateNewBackupWithMetadata()
1016 to_delete.push_back(itr->first); in PurgeOldBackups()
1087 to_delete.push_back(itr.first); in DeleteBackupInternal()
1129 corrupt_backup_ids->push_back(backup.first); in GetCorruptedBackups()
1140 return corrupt_itr->second.first; in RestoreDBFromBackup()
1261 return corrupt_itr->second.first; in VerifyBackup()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_table_factory.cc452 &single_output, table_options_, iter->first, delimiter); in GetOptionString()
569 o.first, o.second, new_table_options, input_strings_escaped, in GetBlockBasedTableOptionsFromMap()
572 const auto iter = block_based_table_type_info.find(o.first); in GetBlockBasedTableOptionsFromMap()
586 o.first + " " + error_message); in GetBlockBasedTableOptionsFromMap()
616 if (BBTOptionSanityCheckLevel(pair.first) <= sanity_check_level) { in VerifyBlockBasedTableFactory()
619 pair.second, pair.first, nullptr)) { in VerifyBlockBasedTableFactory()
623 pair.first); in VerifyBlockBasedTableFactory()
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn.cc23 if (it.first <= seq && seq < it.first + it.second) { in IsVisibleFullCheck()
594 wpt_db_->RemovePrepared(seq.first, seq.second); in CommitInternal()
633 wpt_db_->RemovePrepared(seq.first, seq.second); in CommitInternal()
670 const auto cfid = cfkey.first; in WriteRollbackKeys()
673 auto s = WriteRollbackKey(pair.first, cfid); in WriteRollbackKeys()
681 const auto cfid = cfkey.first; in WriteRollbackKeys()
750 wpt_db_->RemovePrepared(seq.first, seq.second); in RollbackInternal()
781 wpt_db_->RemovePrepared(seq.first, seq.second); in RollbackInternal()
Dtransaction_base.cc148 uint32_t column_family_id = key_map_iter.first; in RollbackToSavePoint()
154 const std::string& key = key_iter.first; in RollbackToSavePoint()
211 uint32_t column_family_id = curr_cf_key_iter.first; in PopSavePoint()
223 const std::string& key = key_iter.first; in PopSavePoint()
641 auto iter = result.first; in TrackKey()
650 iter = result.first; in TrackKey()
677 uint32_t column_family_id = key_map_iter.first; in GetTrackedKeysSinceSavePoint()
683 const std::string& key = key_iter.first; in GetTrackedKeysSinceSavePoint()

1234567