Home
last modified time | relevance | path

Searched refs:key_str (Results 1 – 14 of 14) sorted by relevance

/rocksdb-6.9/db_stress_tool/
Dbatched_ops_stress.cc37 std::string key_str = Key(rand_keys[0]); in TestPut() local
39 keys[i] += key_str; in TestPut()
72 std::string key_str = Key(rand_keys[0]); in TestDelete() local
74 keys[i] += key_str; in TestDelete()
125 std::string key_str = Key(rand_keys[0]); in TestGet() local
126 Slice key = key_str; in TestGet()
187 std::vector<std::string> key_str; in TestMultiGet() local
188 key_str.reserve(num_prefixes); in TestMultiGet()
195 key_slices.emplace_back(key_str.back()); in TestMultiGet()
253 std::string key_str = Key(rand_keys[0]); in TestPrefixScan() local
[all …]
Dcf_consistency_stress.cc25 std::string key_str = Key(rand_keys[0]); in TestPut() local
26 Slice key = key_str; in TestPut()
56 std::string key_str = Key(rand_keys[0]); in TestDelete() local
57 Slice key = key_str; in TestDelete()
84 std::string key_str = Key(rand_key); in TestDeleteRange() local
85 Slice key = key_str; in TestDeleteRange()
120 Slice key = key_str; in TestGet()
207 std::vector<std::string> key_str; in TestMultiGet() local
210 key_str.reserve(num_keys); in TestMultiGet()
217 keys.emplace_back(key_str.back()); in TestMultiGet()
[all …]
Dno_batched_ops_stress.cc144 std::string key_str = Key(rand_keys[0]); in TestGet() local
145 Slice key = key_str; in TestGet()
167 std::vector<std::string> key_str; in TestMultiGet() local
169 key_str.reserve(num_keys); in TestMultiGet()
194 keys.emplace_back(key_str.back()); in TestMultiGet()
268 Slice key = key_str; in TestPrefixScan()
320 std::string key_str = Key(rand_key); in TestPut() local
321 Slice key = key_str; in TestPut()
402 std::string key_str = Key(rand_key); in TestDelete() local
403 Slice key = key_str; in TestDelete()
[all …]
Ddb_stress_test_base.cc350 std::string key_str = Key(k); in PreloadDbAndReopenAsReadOnly() local
351 Slice key = key_str; in PreloadDbAndReopenAsReadOnly()
862 std::vector<std::string> key_str; in TestIterate() local
865 key_str = GetWhiteBoxKeys(thread, db_, cfh, rand_keys.size()); in TestIterate()
867 if (key_str.empty()) { in TestIterate()
871 key_str.push_back(Key(rkey)); in TestIterate()
878 for (const std::string& skey : key_str) { in TestIterate()
1228 std::string key_str = Key(rand_keys[i]); in TestBackupRestore() local
1229 Slice key = key_str; in TestBackupRestore()
1351 std::string key_str = Key(rand_keys[i]); in TestCheckpoint() local
[all …]
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc474 std::string key_str = key.ToString(); in LockBatch() local
477 auto iter = cfh_keys.find(key_str); in LockBatch()
480 cfh_keys.insert({std::move(key_str)}); in LockBatch()
549 std::string key_str = key.ToString(); in TryLock() local
561 auto iter = tracked_keys_cf->second.find(key_str); in TryLock()
576 s = txn_db_impl_->TryLock(this, cfh_id, key_str, exclusive); in TryLock()
619 s = txn_db_impl_->TryLock(this, cfh_id, key_str, in TryLock()
644 TrackKey(cfh_id, key_str, tracked_at_seq, read_only, exclusive); 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()
Doptimistic_transaction.cc154 std::string key_str = key.ToString(); in TryLock() local
156 TrackKey(cfh_id, key_str, seq, read_only, exclusive); in TryLock()
Dtransaction_base.cc735 std::string key_str = key.ToString(); in UndoGetForUpdate() local
743 auto savepoint_iter = cf_savepoint_keys.find(key_str); in UndoGetForUpdate()
767 auto key_iter = cf_tracked_keys.find(key_str); in UndoGetForUpdate()
Dwrite_prepared_transaction_test.cc2229 std::string key_str = "key" + ToString(ikey); in TEST_P() local
2234 ASSERT_OK(db->Put(woptions, key_str, "initvalue1")); in TEST_P()
2237 ASSERT_OK(db->Merge(woptions, key_str, "initvalue2")); in TEST_P()
2240 ASSERT_OK(db->Delete(woptions, key_str)); in TEST_P()
2243 ASSERT_OK(db->SingleDelete(woptions, key_str)); in TEST_P()
Dtransaction_test.cc2841 std::vector<std::string> key_str; in TEST_P() local
2843 key_str.emplace_back(std::to_string(i)); in TEST_P()
2872 batch.Put(handles[1], key_str[i], val); in TEST_P()
2895 keys.emplace_back(key_str[i]); in TEST_P()
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc98 std::string key_str = key.ToString(); in parseKey() local
99 std::string::size_type pos = key_str.find("#"); in parseKey()
105 uint64_t parsed_time = ParseUint64(key_str.substr(0, pos)); in parseKey()
112 std::string key_resize = key_str.substr(pos + 1); in parseKey()
/rocksdb-6.9/db/
Ddb_compaction_filter_test.cc115 char key_str[100]; in FilterV2() local
116 snprintf(key_str, sizeof(key_str), "%010d", i / 10 * 10 + 10); in FilterV2()
117 *skip_until = key_str; in FilterV2()
Ddb_basic_test.cc1749 std::string key_str = Key(static_cast<int>(i)); in TEST_F() local
1752 ASSERT_OK(Put(static_cast<int>(cf), key_str, value_str)); in TEST_F()
1769 std::string key_str = Key(static_cast<int>(i)); in TEST_F() local
1772 ASSERT_EQ(expected_value_str, Get(static_cast<int>(cf), key_str)); in TEST_F()
Dinternal_stats.cc1091 auto key_str = in DumpCFMapStats() local
1094 (*cf_stats)[key_str] = std::to_string(stat_ent.second); in DumpCFMapStats()
/rocksdb-6.9/table/block_based/
Dblock_based_filter_block.cc52 std::string key_str = ROCKSDB_NAMESPACE::ToString(key); in AppendItem() local
53 AppendItem(props, key_str, value); in AppendItem()