Home
last modified time | relevance | path

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

/rocksdb-6.9/utilities/persistent_cache/
Dvolatile_tier_impl.cc86 CacheData* kv; in Lookup() local
87 bool ok = index_.Find(&key, &kv); in Lookup()
90 result->reset(new char[kv->value.size()]); in Lookup()
91 memcpy(result->get(), kv->value.c_str(), kv->value.size()); in Lookup()
92 *size = kv->value.size(); in Lookup()
94 kv->refs_--; in Lookup()
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc152 std::pair<uint64_t, std::string> kv; in AdvanceIteratorByTime() local
154 kv = parseKey(iter->key(), start_time); in AdvanceIteratorByTime()
155 if (kv.first != time_) { in AdvanceIteratorByTime()
158 if (kv.second.compare(kFormatVersionKeyString) == 0) { in AdvanceIteratorByTime()
161 new_stats_map[kv.second] = ParseUint64(iter->value().ToString()); in AdvanceIteratorByTime()
Dperf_context.cc411 for (auto& kv : *level_to_perf_context) { in Reset()
412 kv.second.Reset(); in Reset()
427 for (auto& kv : *level_to_perf_context) { \
428 if (!exclude_zero_counters || (kv.second.counter > 0)) { \
429 ss << kv.second.counter << "@level" << kv.first << ", "; \
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc194 for(auto &kv : kvmap_) { in SimpleKeyMayExistCheck() local
195 bool ret = db_ttl_->KeyMayExist(ropts, kv.first, &val, &value_found); in SimpleKeyMayExistCheck()
198 " should have\n", kv.first.c_str()); in SimpleKeyMayExistCheck()
200 } else if (val.compare(kv.second) != 0) { in SimpleKeyMayExistCheck()
202 " should be %s\n", kv.first.c_str(), val.c_str(), in SimpleKeyMayExistCheck()
203 kv.second.c_str()); in SimpleKeyMayExistCheck()
215 for (auto& kv : kvmap_) { in SimpleMultiGetTest() local
216 keys.emplace_back(kv.first); in SimpleMultiGetTest()
221 for (auto& kv : kvmap_) { in SimpleMultiGetTest() local
223 ASSERT_EQ(values[i], kv.second); in SimpleMultiGetTest()
/rocksdb-6.9/db/
Dprefix_test.cc700 for (auto& kv : entry_maps[i]) { in TEST_F() local
702 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()
715 for (auto& kv : entry_maps[i]) { in TEST_F() local
717 whole_map.erase(kv.first); in TEST_F()
719 entry_maps[2][kv.first] = "delete"; in TEST_F()
726 for (auto& kv : entry_maps[i]) { in TEST_F() local
727 std::cout << "[" << i << "]" << kv.first.prefix << kv.first.sorted in TEST_F()
[all …]
Dbuilder.cc179 auto kv = tombstone.Serialize(); in BuildTable() local
180 builder->Add(kv.first.Encode(), kv.second); in BuildTable()
181 meta->UpdateBoundariesForRange(kv.first, tombstone.SerializeEndKey(), in BuildTable()
Ddb_test_util.cc1421 for (auto& kv : true_data) { in VerifyDBFromMap() local
1422 Status s = status[kv.first]; in VerifyDBFromMap()
1424 ASSERT_EQ(Get(kv.first), kv.second); in VerifyDBFromMap()
1482 for (auto kv : true_data) { in VerifyDBFromMap() local
1483 iter->Seek(kv.first); in VerifyDBFromMap()
1484 ASSERT_EQ(kv.first, iter->key().ToString()); in VerifyDBFromMap()
1485 ASSERT_EQ(kv.second, iter->value().ToString()); in VerifyDBFromMap()
1513 for (auto kv : true_data) { in VerifyDBFromMap() local
1514 iter->Seek(kv.first); in VerifyDBFromMap()
1515 ASSERT_EQ(kv.first, iter->key().ToString()); in VerifyDBFromMap()
[all …]
Dtable_properties_collector_test.cc279 for (const auto& kv : kvs) { in TestCustomizedTablePropertiesCollector() local
280 InternalKey ikey(kv.first.first, seqNum++, kv.first.second); in TestCustomizedTablePropertiesCollector()
281 builder->Add(ikey.Encode(), kv.second); in TestCustomizedTablePropertiesCollector()
Ddb_iterator_test.cc1550 auto& kv = results[i]; in TEST_P() local
1551 ASSERT_EQ(kv.first, data_iter->first); in TEST_P()
1552 ASSERT_EQ(kv.second, data_iter->second); in TEST_P()
1604 auto& kv = results[i]; in TEST_P() local
1613 ASSERT_EQ(kv.second, numbers[expected_val]); in TEST_P()
1642 for (auto& kv : true_data) { in TEST_P() local
1644 ASSERT_OK(Delete(kv.first)); in TEST_P()
1647 ASSERT_OK(Put(kv.first, new_val)); in TEST_P()
1661 auto& kv = results[i]; in TEST_P() local
1662 ASSERT_EQ(kv.first, data_iter->first); in TEST_P()
[all …]
Ddb_bloom_filter_test.cc420 for (auto& kv : (*(get_perf_context()->level_to_perf_context))) { in TEST_F()
421 if (kv.second.bloom_filter_useful > 0) { in TEST_F()
422 bloom_filter_useful_all_levels += kv.second.bloom_filter_useful; in TEST_F()
1382 for (auto& kv : (*(get_perf_context()->level_to_perf_context))) { in TEST_F()
1383 if (kv.second.bloom_filter_useful > 0) { in TEST_F()
1384 bloom_filter_useful_all_levels += kv.second.bloom_filter_useful; in TEST_F()
Dexternal_sst_file_test.cc1222 for (const auto& kv : true_data) { in TEST_F() local
1223 ASSERT_EQ(Get(kv.first), kv.second); in TEST_F()
2469 for (const auto& kv : orig_data) { in TEST_P() local
2470 ASSERT_OK(Put(cf, kv.first, kv.second)); in TEST_P()
Ddb_test.cc2580 std::string kv(ToString(i + id * kGCNumKeys)); in GCThreadBody() local
2581 ASSERT_OK(db->Put(wo, kv, kv)); in GCThreadBody()
5646 for (const auto& kv : values) { in TEST_F() local
5647 ASSERT_EQ(Get(Key(kv.first)), kv.second); in TEST_F()
/rocksdb-6.9/utilities/transactions/
Dtransaction_test.h462 for (auto& kv : committed_kvs) { in CrossCompatibilityTest()
464 s = db->Get(read_options, kv.first, &value); in CrossCompatibilityTest()
466 printf("key = %s\n", kv.first.c_str()); in CrossCompatibilityTest()
469 if (kv.second != value) { in CrossCompatibilityTest()
470 printf("key = %s\n", kv.first.c_str()); in CrossCompatibilityTest()
472 ASSERT_EQ(kv.second, value); in CrossCompatibilityTest()
Dwrite_prepared_transaction_test.cc486 for (auto& kv : data) { in VerifyKeys() local
487 auto s = db->Get(read_options, kv.first, &value); in VerifyKeys()
490 if (kv.second != value) { in VerifyKeys()
491 printf("key = %s\n", kv.first.c_str()); in VerifyKeys()
493 ASSERT_EQ(kv.second, value); in VerifyKeys()
495 ASSERT_EQ(kv.second, "NOT_FOUND"); in VerifyKeys()
501 {kv.first}, &values); in VerifyKeys()
507 ASSERT_TRUE(kv.second == values[0]); in VerifyKeys()
509 ASSERT_EQ(kv.second, "NOT_FOUND"); in VerifyKeys()
2339 KeyVersion kv = {"foo", v, seq, kTypeValue}; in TEST_P() local
[all …]
/rocksdb-6.9/java/rocksjni/
Dcompaction_job_info.cc162 kv) { in Java_org_rocksdb_CompactionJobInfo_tableProperties() argument
164 env, &(kv.first), false); in Java_org_rocksdb_CompactionJobInfo_tableProperties()
172 env, *(kv.second.get())); in Java_org_rocksdb_CompactionJobInfo_tableProperties()
Dportal.h2494 [env](const std::pair<const std::string, const std::string>& kv) { in fromCppMap()
2496 env, &(kv.first), false); in fromCppMap()
2503 env, &(kv.second), true); in fromCppMap()
2550 [env](const std::pair<const std::string, const uint32_t>& kv) { in fromCppMap()
2552 env, &(kv.first), false); in fromCppMap()
2559 env, static_cast<jint>(kv.second)); in fromCppMap()
2601 [env](const std::pair<const std::string, const uint64_t>& kv) { in fromCppMap()
2603 env, &(kv.first), false); in fromCppMap()
2610 env, static_cast<jlong>(kv.second)); in fromCppMap()
2653 env, static_cast<jint>(kv.first)); in fromCppMap()
[all …]
Drocksjni.cc3121 kv) { in Java_org_rocksdb_RocksDB_getPropertiesOfAllTables() argument
3123 env, &(kv.first), false); in Java_org_rocksdb_RocksDB_getPropertiesOfAllTables()
3131 env, *(kv.second.get())); in Java_org_rocksdb_RocksDB_getPropertiesOfAllTables()
/rocksdb-6.9/table/
Dtable_test.cc180 keys->push_back(kv.first); in Finish()
232 builder.Add(kv.first, kv.second); in FinishImpl()
362 builder->Add(kv.first, kv.second); in FinishImpl()
490 memtable_->Add(seq, kTypeValue, kv.first, kv.second); in FinishImpl()
552 batch.Put(kv.first, kv.second); in FinishImpl()
1223 table_builder_->Add(kv.first, kv.second); in WriteKVAndFlushTable()
1872 for (auto& kv : kvmap) { in TEST_P() local
1873 db_iter->Seek(kv.first); in TEST_P()
3939 for (auto& kv : kvmap) { in TEST_P() local
3940 db_iter->Seek(kv.first); in TEST_P()
[all …]
Dmock_table.cc136 for (const auto& kv : latest->second) { in AssertLatestFile() local
139 std::tie(key, value) = kv; in AssertLatestFile()
/rocksdb-6.9/db_stress_tool/
Dcf_consistency_stress.cc481 for (const KeyVersion& kv : versions) { in VerifyDb() local
483 Slice(kv.user_key).ToString(true).c_str(), kv.sequence, in VerifyDb()
484 kv.type); in VerifyDb()
/rocksdb-6.9/tools/
Dsst_dump_tool.cc751 for (const auto& kv : table_properties->user_collected_properties) { in Run() local
752 std::string prop_name = kv.first; in Run()
753 std::string prop_val = Slice(kv.second).ToString(true); in Run()
/rocksdb-6.9/docs/_posts/
D2014-04-07-rocksdb-2-8-release.markdown27 …* Added a V2 compaction filter interface. It buffers the kv-pairs sharing the same key prefix, pro…
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc1230 auto kv = tombstone.Serialize(); in FinishCompactionOutputFile() local
1232 ucmp->Compare(*lower_bound, kv.second) < 0); in FinishCompactionOutputFile()
1233 sub_compact->builder->Add(kv.first.Encode(), kv.second); in FinishCompactionOutputFile()
1234 InternalKey smallest_candidate = std::move(kv.first); in FinishCompactionOutputFile()
Dcompaction_job_test.cc141 for (auto kv : contents) { in AddMockFile() local
145 std::tie(skey, value) = kv; in AddMockFile()
/rocksdb-6.9/
DHISTORY.md1116 * Now compaction filter has a V2 interface. It buffers the kv-pairs sharing the same key prefix, pr…