Home
last modified time | relevance | path

Searched refs:second (Results 1 – 25 of 183) sorted by relevance

12345678

/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc531 record.second.key_id = stat.second.a_key_id; in MakeStatistics()
540 if (stat.second.a_count_stats.find(record.second.access_count) == in MakeStatistics()
542 stat.second.a_count_stats[record.second.access_count] = 1; in MakeStatistics()
544 stat.second.a_count_stats[record.second.access_count]++; in MakeStatistics()
559 s = MakeStatisticCorrelation(stat.second, record.second); in MakeStatistics()
683 record.second.value_size, record.second.key_id, in MakeStatisticKeyStatsOrPrefix()
814 if (time_it.second > stat.second.a_peak_qps) { in MakeStatisticQPS()
815 stat.second.a_peak_qps = time_it.second; in MakeStatisticQPS()
854 stat.second.top_k_qps_sec.top().first < time_it.second) { in MakeStatisticQPS()
899 stat.second.top_k_qps_sec.top().second, in MakeStatisticQPS()
[all …]
Dldb_cmd.cc495 delete pair.second; in CloseDB()
509 return it->second; in GetCfHandle()
577 *value = itr->second; in ParseStringOption()
877 from_ = itr->second;
883 to_ = itr->second;
1066 path_ = itr->second;
1208 path_ = itr->second;
1413 delim_ = itr->second;
1550 from_ = itr->second;
1556 to_ = itr->second;
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer.cc322 time.second; in adjust_time_unit()
427 uint64_t access = it->second; in WriteMissRatioTimeline()
583 return b.second < a.second; in WriteSkewness()
632 UpdateFeatureVectors(it->second, caller_map.second, label, in WriteCorrelationFeatures()
834 ->second += 1; in WriteGetSpatialLocality()
837 ->second += 1; in WriteGetSpatialLocality()
840 ->second += 1; in WriteGetSpatialLocality()
972 ->second += reuse_distance.second; in WriteReuseDistance()
1223 if (block.second[start_time] && block.second[i]) { in WriteBlockReuseTimeline()
2008 naccess_type.second, percent(naccess_type.second, naccesses)); in PrintStatsSummary()
[all …]
/rocksdb-6.9/env/
Denv_chroot.cc49 encoded_paths.emplace_back(status_and_enc_path.second); in RegisterDbPaths()
62 encoded_paths.emplace_back(status_and_enc_path.second); in UnregisterDbPaths()
142 return EnvWrapper::FileExists(status_and_enc_path.second); in FileExists()
169 return EnvWrapper::DeleteFile(status_and_enc_path.second); in DeleteFile()
177 return EnvWrapper::CreateDir(status_and_enc_path.second); in CreateDir()
193 return EnvWrapper::DeleteDir(status_and_enc_path.second); in DeleteDir()
223 return EnvWrapper::RenameFile(status_and_src_enc_path.second, in RenameFile()
236 return EnvWrapper::LinkFile(status_and_src_enc_path.second, in LinkFile()
290 res.second = chroot_dir_ + path; in EncodePath()
298 res.first = Status::NotFound(res.second, strerror(errno)); in EncodePath()
[all …]
/rocksdb-6.9/utilities/transactions/
Dtransaction_base.cc149 auto& keys = key_map_iter.second; in RollbackToSavePoint()
213 curr_cf_key_iter.second; in PopSavePoint()
221 prev_keys_iter->second; in PopSavePoint()
642 if (!result.second && seq < iter->second.seq) { in TrackKey()
644 iter->second.seq = seq; in TrackKey()
651 } else if (seq < iter->second.seq) { in TrackKey()
653 iter->second.seq = seq; in TrackKey()
662 iter->second.num_reads++; in TrackKey()
664 iter->second.num_writes++; in TrackKey()
666 iter->second.exclusive |= exclusive; in TrackKey()
[all …]
Dwrite_unprepared_txn_db.cc61 const auto& batch = it->second.batch_; in RollbackRecoveredTransaction()
95 if (res.second == in RollbackRecoveredTransaction()
248 auto recovered_trx = rtxn.second; in Initialize()
264 auto first_log_number = recovered_trx->batches_.begin()->second.log_number_; in Initialize()
267 recovered_trx->batches_.begin()->second.batch_cnt_; in Initialize()
285 const auto& batch_info = batch.second; in Initialize()
311 auto cnt = seq_cnt.second; in Initialize()
332 auto recovered_trx = rtxn.second; in Initialize()
Dpessimistic_transaction.cc509 auto& cfh_keys = cf_iter.second; in LockBatch()
561 auto iter = tracked_keys_cf->second.find(key_str); in TryLock()
562 if (iter == tracked_keys_cf->second.end()) { in TryLock()
565 if (!iter->second.exclusive && exclusive) { in TryLock()
569 tracked_at_seq = iter->second.seq; in TryLock()
647 assert(tracked_keys_cf->second.count(key_str) > 0); in TryLock()
648 const auto& info = tracked_keys_cf->second.find(key_str)->second; in TryLock()
/rocksdb-6.9/db/
Dversion_edit_test.cc91 ASSERT_TRUE(new_files[0].second.marked_for_compaction); in TEST_F()
93 ASSERT_TRUE(new_files[2].second.marked_for_compaction); in TEST_F()
94 ASSERT_TRUE(new_files[3].second.marked_for_compaction); in TEST_F()
95 ASSERT_EQ(3u, new_files[0].second.fd.GetPathId()); in TEST_F()
96 ASSERT_EQ(3u, new_files[1].second.fd.GetPathId()); in TEST_F()
97 ASSERT_EQ(0u, new_files[2].second.fd.GetPathId()); in TEST_F()
98 ASSERT_EQ(0u, new_files[3].second.fd.GetPathId()); in TEST_F()
100 new_files[0].second.oldest_blob_file_number); in TEST_F()
102 new_files[1].second.oldest_blob_file_number); in TEST_F()
155 ASSERT_EQ(3u, new_files[0].second.fd.GetPathId()); in TEST_F()
[all …]
Dversion_edit_handler.cc219 const auto& missing_files = elem.second; in HasMissingFiles()
275 msg.append(cf.second); in CheckIterationResult()
404 assert(builder_iter->second != nullptr); in LoadTables()
481 delete elem.second; in ~VersionEditHandlerPointInTime()
498 assert(v_iter->second != nullptr); in CheckIterationResult()
500 version_set_->AppendVersion(cfd, v_iter->second); in CheckIterationResult()
512 delete v_iter->second; in DestroyCfAndCleanup()
529 uint64_t file_num = file.second; in MaybeCreateVersion()
537 const FileMetaData& meta = elem.second; in MaybeCreateVersion()
567 delete v_iter->second; in MaybeCreateVersion()
[all …]
Dversion_builder.cc130 UnrefFile(pair.second); in ~Rep()
153 const auto& meta = changed_it->second; in GetBlobFileMetaData()
165 const auto& meta = base_it->second; in GetBlobFileMetaData()
302 const auto& blob_file_meta = pair.second; in CheckConsistency()
373 if (level.second.size() > 0) { in CheckConsistencyForNumLevels()
441 const auto number = del_file.second; in Apply()
448 UnrefFile(exising->second); in Apply()
529 const auto& base_meta = base_it->second; in SaveBlobFilesTo()
562 const auto& base_meta = base_it->second; in SaveBlobFilesTo()
604 added_files.push_back(pair.second); in SaveTo()
[all …]
Dcuckoo_table_db_test.cc129 ASSERT_EQ(3U, ptc.begin()->second->num_entries); in TEST_F()
146 ASSERT_EQ(3U, row->second->num_entries); in TEST_F()
147 ASSERT_EQ(3U, (++row)->second->num_entries); in TEST_F()
163 ASSERT_EQ(3U, row->second->num_entries); in TEST_F()
164 ASSERT_EQ(3U, (++row)->second->num_entries); in TEST_F()
165 ASSERT_EQ(3U, (++row)->second->num_entries); in TEST_F()
186 ASSERT_EQ(2U, ptc.begin()->second->num_entries); in TEST_F()
Dlogs_with_prep_tracker.cc18 it->second += 1; in MarkLogAsHavingPrepSectionFlushed()
53 completed_it->second < it->cnt) { in FindMinLogContainingOutstandingPrep()
57 completed_it->second == it->cnt); in FindMinLogContainingOutstandingPrep()
/rocksdb-6.9/util/
Dfile_checksum_helper.cc28 checksums->push_back(i.second.first); in GetAllFileChecksums()
29 checksum_func_names->push_back(i.second.second); in GetAllFileChecksums()
45 *checksum = it->second.first; in SearchOneFileChecksum()
46 *checksum_func_name = it->second.second; in SearchOneFileChecksum()
59 it->second.first = checksum; in InsertOneFileChecksum()
60 it->second.second = checksum_func_name; in InsertOneFileChecksum()
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader.cc72 num_hash_func_ = *reinterpret_cast<const uint32_t*>(hash_funs->second.data()); in CuckooTableReader()
78 unused_key_ = unused_key->second; in CuckooTableReader()
87 user_key_len->second.data()); in CuckooTableReader()
95 value_length->second.data()); in CuckooTableReader()
105 hash_table_size->second.data()); in CuckooTableReader()
121 identity_as_first_hash->second.data()); in CuckooTableReader()
130 use_module_hash->second.data()); in CuckooTableReader()
138 cuckoo_block_size->second.data()); in CuckooTableReader()
228 bool operator()(const uint32_t first, const uint32_t second) const { in operator ()()
233 (second == kInvalidIndex) ? target_.data() : in operator ()()
[all …]
/rocksdb-6.9/options/
Doptions_parser.cc421 s = ParseVersionNumber(pair.first, pair.second, 3, db_version); in EndSection()
647 if (iter->second == kNullptrString) { in AreEqualOptions()
651 return (value1 == iter->second); in AreEqualOptions()
743 if (pair.second.verification == OptionVerificationType::kDeprecated) { in VerifyDBOptions()
751 pair.second, pair.first, nullptr)) { in VerifyDBOptions()
757 reinterpret_cast<const char*>(&base_opt) + pair.second.offset, in VerifyDBOptions()
758 pair.second.type, &base_value); in VerifyDBOptions()
761 pair.second.type, &persisted_value); in VerifyDBOptions()
789 pair.second, pair.first, persisted_opt_map)) { in VerifyCFOptions()
796 pair.second.type, &base_value); in VerifyCFOptions()
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc236 list.insert(dir_and_name.second); in NewWritableFile()
257 list.insert(dir_and_name.second); in ReopenWritableFile()
278 list.insert(dir_and_name.second); in NewRandomRWFile()
327 if (dir_to_new_files_since_last_sync_[sdn.first].erase(sdn.second) != 0) { in RenameFile()
329 assert(tlist.find(tdn.second) == tlist.end()); in RenameFile()
330 tlist.insert(tdn.second); in RenameFile()
372 FSFileState& fs_state = it->second; in DropUnsyncedFileData()
385 FSFileState& fs_state = it->second; in DropRandomUnsyncedFileData()
404 for (std::string name : pair.second) { in DeleteFilesCreatedAfterLastDirSync()
425 dir_and_name.second); in UntrackFile()
Dfault_injection_test_env.cc247 list.insert(dir_and_name.second); in NewWritableFile()
268 list.insert(dir_and_name.second); in ReopenWritableFile()
289 list.insert(dir_and_name.second); in NewRandomRWFile()
334 if (dir_to_new_files_since_last_sync_[sdn.first].erase(sdn.second) != 0) { in RenameFile()
336 assert(tlist.find(tdn.second) == tlist.end()); in RenameFile()
337 tlist.insert(tdn.second); in RenameFile()
383 const FileState& state = it->second; in DropFileData()
413 for (std::string name : pair.second) { in DeleteFilesCreatedAfterLastDirSync()
433 dir_and_name.second); in UntrackFile()
/rocksdb-6.9/table/plain/
Dplain_table_factory.cc180 const auto& opt_info = iter->second; in ParsePlainTableOptions()
198 o.first, o.second, new_table_options, input_strings_escaped); in GetPlainTableOptionsFromMap()
205 (iter->second.verification != OptionVerificationType::kByName && in GetPlainTableOptionsFromMap()
206 iter->second.verification != in GetPlainTableOptionsFromMap()
208 iter->second.verification != in GetPlainTableOptionsFromMap()
210 iter->second.verification != OptionVerificationType::kDeprecated)) { in GetPlainTableOptionsFromMap()
/rocksdb-6.9/table/block_based/
Dblock_based_table_factory.cc427 auto& opt_info = iter->second; in SerializeSingleBlockBasedTableOption()
445 if (iter->second.verification == OptionVerificationType::kDeprecated) { in GetOptionString()
537 const auto& opt_info = iter->second; in ParseBlockBasedTableOption()
569 o.first, o.second, new_table_options, input_strings_escaped, in GetBlockBasedTableOptionsFromMap()
577 (iter->second.verification != OptionVerificationType::kByName && in GetBlockBasedTableOptionsFromMap()
578 iter->second.verification != in GetBlockBasedTableOptionsFromMap()
580 iter->second.verification != in GetBlockBasedTableOptionsFromMap()
582 iter->second.verification != OptionVerificationType::kDeprecated)) { in GetBlockBasedTableOptionsFromMap()
611 if (pair.second.verification == OptionVerificationType::kDeprecated) { in VerifyBlockBasedTableFactory()
619 pair.second, pair.first, nullptr)) { in VerifyBlockBasedTableFactory()
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc103 result.second.clear(); in parseKey()
109 result.second = ""; in parseKey()
113 result.second = key_resize; in parseKey()
158 if (kv.second.compare(kFormatVersionKeyString) == 0) { in AdvanceIteratorByTime()
161 new_stats_map[kv.second] = ParseUint64(iter->value().ToString()); in AdvanceIteratorByTime()
Dthread_status_updater.cc198 iter != cf_info_map_.end() ? iter->second.db_name : "", in GetThreadList()
199 iter != cf_info_map_.end() ? iter->second.cf_name : "", op_type, in GetThreadList()
241 ConstantColumnFamilyInfo& cf_info = cf_pair->second; in EraseColumnFamilyInfo()
245 result = db_pair->second.erase(cf_key); in EraseColumnFamilyInfo()
262 for (auto cf_key : db_pair->second) { in EraseDatabaseInfo()
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc140 batch.Put(kv_it_->first, kv_it_->second); 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()
200 } else if (val.compare(kv.second) != 0) { in SimpleKeyMayExistCheck()
203 kv.second.c_str()); in SimpleKeyMayExistCheck()
223 ASSERT_EQ(values[i], kv.second); in SimpleMultiGetTest()
261 } else if (!test_compaction_change && v.compare(kv_it_->second) !=0) { in SleepCompactCheck()
264 kv_it_->second.c_str()); in SleepCompactCheck()
285 ASSERT_NE(dbiter->value().compare(kv_it_->second), 0); in SleepCompactCheckIter()
291 ASSERT_EQ(dbiter->value().compare(kv_it_->second), 0); in SleepCompactCheckIter()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc209 return it->second; in GetFile()
817 assert(ret.second == true); in CreateNewBackupWithMetadata()
1071 auto s = corrupt->second.second->Delete(); in DeleteBackupInternal()
1083 if (itr.second->refs == 0) { in DeleteBackupInternal()
1115 if (!backup.second->Empty()) { in GetBackupInfo()
1117 backup.first, backup.second->GetTimestamp(), backup.second->GetSize(), in GetBackupInfo()
1118 backup.second->GetNumberFiles(), backup.second->GetAppMetadata())); in GetBackupInfo()
1146 auto& backup = backup_itr->second; in RestoreDBFromBackup()
1714 if (ret.second) { in AddFile()
1716 itr->second->refs = 1; in AddFile()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_picker_level.cc136 assert(!level_file.second->being_compacted); in PickExpiredTtlFiles()
147 start_level_inputs_.files = {level_file.second}; in PickExpiredTtlFiles()
172 assert(!level_file.second->being_compacted); in PickFilesMarkedForPeriodicCompaction()
180 start_level_inputs_.files = {level_file.second}; in PickFilesMarkedForPeriodicCompaction()
265 assert(!level_and_file.second->being_compacted); in SetupInitialFiles()
268 start_level_inputs_.files = {level_and_file.second}; in SetupInitialFiles()
/rocksdb-6.9/table/
Dmock_table.cc77 table_reader->reset(new MockTableReader(it->second)); in NewTableReader()
125 ASSERT_EQ(file_contents, file_system_.files.begin()->second); in AssertSingleFile()
134 if (file_contents != latest->second) { in AssertLatestFile()
136 for (const auto& kv : latest->second) { in AssertLatestFile()

12345678