| /rocksdb-6.9/options/ |
| D | options_parser.cc | 419 for (const auto& pair : opt_map) { in EndSection() local
420 if (pair.first == "rocksdb_version") { in EndSection()
421 s = ParseVersionNumber(pair.first, pair.second, 3, db_version); in EndSection()
426 s = ParseVersionNumber(pair.first, pair.second, 2, opt_file_version); in EndSection()
742 for (const auto& pair : db_options_type_info) { in VerifyDBOptions() local
751 pair.second, pair.first, nullptr)) { 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 …]
|
| D | options_settable_test.cc | 42 typedef std::vector<std::pair<size_t, size_t>> OffsetGap;
47 for (auto& pair : blacklist) { in FillWithSpecialChar() local
48 std::memset(start_ptr + offset, kSpecialChar, pair.first - offset); in FillWithSpecialChar()
49 offset = pair.first + pair.second; in FillWithSpecialChar()
58 for (auto& pair : blacklist) { in NumUnsetBytes() local
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/tools/ |
| D | trace_analyzer_tool.h | 64 std::vector<std::pair<int, int>> correlation_list;
100 std::priority_queue<std::pair<uint64_t, std::string>,
101 std::vector<std::pair<uint64_t, std::string>>,
104 std::priority_queue<std::pair<uint64_t, std::string>,
108 std::priority_queue<std::pair<double, std::string>,
109 std::vector<std::pair<double, std::string>>,
110 std::greater<std::pair<double, std::string>>>
112 std::priority_queue<std::pair<uint32_t, uint32_t>,
113 std::vector<std::pair<uint32_t, uint32_t>>,
114 std::greater<std::pair<uint32_t, uint32_t>>>
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | memory_util.cc | 75 const std::pair<ROCKSDB_NAMESPACE::MemoryUtil::UsageType, in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType()
76 uint64_t> &pair) { in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType() argument
80 pair.first)); in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType()
83 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType()
87 ROCKSDB_NAMESPACE::LongJni::valueOf(env, pair.second); in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType()
90 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType()
93 return std::unique_ptr<std::pair<jobject, jobject>>( in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType()
94 new std::pair<jobject, jobject>(jusage_type, in Java_org_rocksdb_MemoryUtil_getApproximateMemoryUsageByType()
|
| D | sst_file_manager.cc | 152 [env](const std::pair<const std::string, const uint64_t>& pair) { in Java_org_rocksdb_SstFileManager_getTrackedFiles() argument
154 env->NewStringUTF(pair.first.c_str()); in Java_org_rocksdb_SstFileManager_getTrackedFiles()
157 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_SstFileManager_getTrackedFiles()
160 ROCKSDB_NAMESPACE::LongJni::valueOf(env, pair.second); in Java_org_rocksdb_SstFileManager_getTrackedFiles()
163 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_SstFileManager_getTrackedFiles()
165 return std::unique_ptr<std::pair<jobject, jobject>>( in Java_org_rocksdb_SstFileManager_getTrackedFiles()
166 new std::pair<jobject, jobject>(jtracked_file_path, in Java_org_rocksdb_SstFileManager_getTrackedFiles()
|
| D | compaction_job_info.cc | 159 [env](const std::pair< in Java_org_rocksdb_CompactionJobInfo_tableProperties()
167 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_CompactionJobInfo_tableProperties()
176 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_CompactionJobInfo_tableProperties()
179 return std::unique_ptr<std::pair<jobject, jobject>>( in Java_org_rocksdb_CompactionJobInfo_tableProperties()
180 new std::pair<jobject, jobject>(static_cast<jobject>(jkey), in Java_org_rocksdb_CompactionJobInfo_tableProperties()
|
| D | transaction_db.cc | 340 [env](const std::pair<const int32_t, in Java_org_rocksdb_TransactionDB_getLockStatusData()
341 const ROCKSDB_NAMESPACE::KeyLockInfo>& pair) { in Java_org_rocksdb_TransactionDB_getLockStatusData() argument
343 ROCKSDB_NAMESPACE::LongJni::valueOf(env, pair.first); in Java_org_rocksdb_TransactionDB_getLockStatusData()
346 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_TransactionDB_getLockStatusData()
349 ROCKSDB_NAMESPACE::KeyLockInfoJni::construct(env, pair.second); in Java_org_rocksdb_TransactionDB_getLockStatusData()
352 return std::unique_ptr<std::pair<jobject, jobject>>(nullptr); in Java_org_rocksdb_TransactionDB_getLockStatusData()
354 return std::unique_ptr<std::pair<jobject, jobject>>( in Java_org_rocksdb_TransactionDB_getLockStatusData()
355 new std::pair<jobject, jobject>(jlong_column_family_id, in Java_org_rocksdb_TransactionDB_getLockStatusData()
|
| /rocksdb-6.9/monitoring/ |
| D | statistics_test.cc | 24 auto pair = TickersNameMap[static_cast<size_t>(t)]; in TEST_F() local
25 ASSERT_EQ(pair.first, t) << "Miss match at " << pair.second; in TEST_F()
36 auto pair = HistogramsNameMap[static_cast<size_t>(h)]; in TEST_F() local
37 ASSERT_EQ(pair.first, h) << "Miss match at " << pair.second; in TEST_F()
|
| D | persistent_stats_history.cc | 95 std::pair<uint64_t, std::string> parseKey(const Slice& key, in parseKey()
97 std::pair<uint64_t, std::string> result; in parseKey()
152 std::pair<uint64_t, std::string> kv; in AdvanceIteratorByTime()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_test.cc | 126 for (auto pair : data_map) { in TestValueAsSecondaryIndexHelper() local
142 for (auto pair = data_map.rbegin(); pair != data_map.rend(); ++pair) { in TestValueAsSecondaryIndexHelper() local
143 for (auto v = pair->second.rbegin(); v != pair->second.rend(); v++) { in TestValueAsSecondaryIndexHelper()
167 for (auto pair : index_map) { in TestValueAsSecondaryIndexHelper() local
184 for (auto pair = index_map.rbegin(); pair != index_map.rend(); ++pair) { in TestValueAsSecondaryIndexHelper() local
185 for (auto v = pair->second.rbegin(); v != pair->second.rend(); v++) { in TestValueAsSecondaryIndexHelper()
205 for (auto pair = data_map.rbegin(); pair != data_map.rend(); ++pair) { in TestValueAsSecondaryIndexHelper() local
206 iter->Seek(pair->first); in TestValueAsSecondaryIndexHelper()
208 for (auto v : pair->second) { in TestValueAsSecondaryIndexHelper()
227 for (auto pair = index_map.rbegin(); pair != index_map.rend(); ++pair) { in TestValueAsSecondaryIndexHelper() local
[all …]
|
| /rocksdb-6.9/util/ |
| D | hash_map.h | 28 std::array<autovector<std::pair<K, V>, 1>, size> table_;
35 [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()
|
| D | timer_queue.h | 74 std::function<std::pair<bool, int64_t>(bool)> handler) { in add()
170 std::pair<bool, Clock::time_point> calcWaitTime_lock() { in calcWaitTime_lock()
217 std::function<std::pair<bool, int64_t>(bool)> handler;
|
| D | core_local.h | 33 std::pair<T*, size_t> AccessElementAndIndex() const;
65 std::pair<T*, size_t> CoreLocalArray<T>::AccessElementAndIndex() const { in AccessElementAndIndex()
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_stats_fetcher.py | 188 pair = pair_string.split(',')
189 first = int(pair[0].strip())
190 second = float(pair[1].strip())
238 value = {pair[0]: pair[1] for pair in list_of_lists}
|
| /rocksdb-6.9/db/ |
| D | version_builder.cc | 129 for (auto& pair : added) { in ~Rep() local
130 UnrefFile(pair.second); in ~Rep()
236 auto pair = std::make_pair(&f1, &f2); in CheckConsistency() local
237 TEST_SYNC_POINT_CALLBACK("VersionBuilder::CheckConsistency", &pair); in CheckConsistency()
301 for (const auto& pair : blob_files) { in CheckConsistency() local
302 const auto& blob_file_meta = pair.second; in CheckConsistency()
603 for (const auto& pair : unordered_added_files) { in SaveTo() local
604 added_files.push_back(pair.second); in SaveTo()
677 std::vector<std::pair<FileMetaData*, int>> files_meta; in LoadTableHandlers()
|
| D | version_set.h | 303 const autovector<std::pair<int, FileMetaData*>>& FilesMarkedForCompaction() in FilesMarkedForCompaction()
311 const autovector<std::pair<int, FileMetaData*>>& ExpiredTtlFiles() const { in ExpiredTtlFiles()
318 const autovector<std::pair<int, FileMetaData*>>&
330 const autovector<std::pair<int, FileMetaData*>>&
496 autovector<std::pair<int, FileMetaData*>> files_marked_for_compaction_;
498 autovector<std::pair<int, FileMetaData*>> expired_ttl_files_;
500 autovector<std::pair<int, FileMetaData*>>
509 autovector<std::pair<int, FileMetaData*>> bottommost_files_;
510 autovector<std::pair<int, FileMetaData*>>
|
| D | external_sst_file_test.cc | 93 [&](const std::pair<std::string, std::string>& e1, in GenerateOneExternalFile()
99 [&](const std::pair<std::string, std::string>& e1, in GenerateOneExternalFile()
100 const std::pair<std::string, std::string>& e2) { in GenerateOneExternalFile()
147 [&](const std::pair<std::string, std::string>& e1, in GenerateAndAddExternalFile()
153 [&](const std::pair<std::string, std::string>& e1, in GenerateAndAddExternalFile()
154 const std::pair<std::string, std::string>& e2) { in GenerateAndAddExternalFile()
240 std::vector<std::pair<std::string, std::string>> file_data; in GenerateAndAddExternalFile()
257 std::vector<std::pair<std::string, std::string>> file_data; in GenerateAndAddExternalFile()
1128 std::vector<std::pair<int, int>> key_ranges; in TEST_F()
1780 std::vector<std::pair<std::string, std::string>> file_data; in TEST_P()
[all …]
|
| D | version_set_test.cc | 1848 const std::vector<std::pair<int, uint64_t>>& deleted_files) { in WriteFileAdditionAndDeletionToManifest()
1887 std::vector<std::pair<int, FileMetaData>> added_files; in TEST_F()
1900 /*cf=*/0, added_files, std::vector<std::pair<int, uint64_t>>()); in TEST_F()
1901 std::vector<std::pair<int, uint64_t>> deleted_files; in TEST_F()
1904 /*cf=*/0, std::vector<std::pair<int, FileMetaData>>(), deleted_files); in TEST_F()
1935 std::vector<std::pair<int, FileMetaData>> added_files; in TEST_F()
1940 /*cf=*/0, added_files, std::vector<std::pair<int, uint64_t>>()); in TEST_F()
1955 /*cf=*/0, added_files, std::vector<std::pair<int, uint64_t>>()); in TEST_F()
1995 std::vector<std::pair<int, FileMetaData>> added_files; in TEST_F()
2000 /*cf=*/0, added_files, std::vector<std::pair<int, uint64_t>>()); in TEST_F()
[all …]
|
| /rocksdb-6.9/tools/rdb/ |
| D | API.md | 43 # column_family (string) - Which column family to put the key-value pair
47 # Returns true if the key-value pair was successfully stored in the
143 The following key-value pair is optional:
161 # with the value '2'. Additionally, adds the key-value pair
162 # 'name' => 'Saghm Rossi' to the column family 'user1' and the pair
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl.h | 280 std::pair<bool, int64_t> SanityCheck(bool aborted);
284 std::pair<bool, int64_t> DeleteObsoleteFiles(bool aborted);
288 std::pair<bool, int64_t> EvictExpiredFiles(bool aborted);
293 std::pair<bool, int64_t> ReclaimOpenFiles(bool aborted);
295 std::pair<bool, int64_t> RemoveTimerQ(TimerQueue* tq, bool aborted);
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_factory.cc | 610 for (auto& pair : block_based_table_type_info) { in VerifyBlockBasedTableFactory() local
611 if (pair.second.verification == OptionVerificationType::kDeprecated) { in VerifyBlockBasedTableFactory()
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/memory/ |
| D | arena.cc | 219 std::pair<size_t*, size_t*> pair(&allocated_size, &block_bytes); in AllocateNewBlock() local
220 TEST_SYNC_POINT_CALLBACK("Arena::AllocateNewBlock:0", &pair); in AllocateNewBlock()
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | format.cc | 376 for (auto& pair: merged_columns) { in Merge() local
380 if (pair.second->Timestamp() <= tombstone_timestamp) { in Merge()
383 last_modified_time = std::max(last_modified_time, pair.second->Timestamp()); in Merge()
384 columns.push_back(std::move(pair.second)); in Merge()
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_fs.cc | 43 std::pair<std::string, std::string> TestFSGetDirAndName( in TestFSGetDirAndName()
403 for (auto& pair : map_copy) { in DeleteFilesCreatedAfterLastDirSync() local
404 for (std::string name : pair.second) { in DeleteFilesCreatedAfterLastDirSync()
405 IOStatus io_s = DeleteFile(pair.first + "/" + name, options, dbg); in DeleteFilesCreatedAfterLastDirSync()
|
| D | fault_injection_test_env.cc | 80 std::pair<std::string, std::string> GetDirAndName(const std::string& name) { in GetDirAndName()
412 for (auto& pair : map_copy) { in DeleteFilesCreatedAfterLastDirSync() local
413 for (std::string name : pair.second) { in DeleteFilesCreatedAfterLastDirSync()
414 Status s = DeleteFile(pair.first + "/" + name); in DeleteFilesCreatedAfterLastDirSync()
|