| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | AbstractTransactionTest.java | 114 txn.put(k1, v1); in commit()
131 txn.put(k1, v1); in rollback()
154 txn.put(k1, v1); in savePoint()
202 txn.put(k1, v1); in getPut()
273 txn.put(k1, v1); in getForUpdate()
332 txn.put(k1, v1); in getIterator()
413 txn.put(k1, v1); in delete()
416 txn.delete(k1); in delete()
589 txn.put(k1, v1); in deleteUntracked()
674 txn.put(k1, v1); in numKeys()
[all …]
|
| D | OptimisticTransactionTest.java | 22 final byte k1[] = "key1".getBytes(UTF_8); in getForUpdate_cf_conflict()
30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
40 txn2.put(testCf, k1, v12); in getForUpdate_cf_conflict()
60 final byte k1[] = "key1".getBytes(UTF_8); in getForUpdate_conflict()
67 txn.put(k1, v1); in getForUpdate_conflict()
77 txn2.put(k1, v12); in getForUpdate_conflict()
196 txn.put(testCf, k1, v1); in undoGetForUpdate_cf_conflict()
209 txn2.put(testCf, k1, v12); in undoGetForUpdate_cf_conflict()
230 txn.put(k1, v1); in undoGetForUpdate_conflict()
240 txn3.undoGetForUpdate(k1); in undoGetForUpdate_conflict()
[all …]
|
| D | WriteBatchWithIndexTest.java | 42 db.put(k1, v1); in readYourOwnWrites()
48 it.seek(k1); in readYourOwnWrites()
76 wbwi.delete(k1); in readYourOwnWrites()
77 it.seek(k1); in readYourOwnWrites()
82 wbwi.put(k1, v1Other); in readYourOwnWrites()
83 it.seek(k1); in readYourOwnWrites()
117 wbwi.put(k1, v1); in writeBatchWithIndex()
142 wbwi.put(k1, v1); in write_writeBatchWithIndexDirect()
162 final String k1 = "key1"; in iterator() local
479 wbwi.put(k1, v1); in getFromBatch()
[all …]
|
| D | TransactionTest.java | 22 final byte k1[] = "key1".getBytes(UTF_8); in getForUpdate_cf_conflict()
30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
31 assertThat(txn.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf_conflict()
37 assertThat(txn3.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf_conflict()
41 txn2.put(testCf, k1, v12); // should cause an exception! in getForUpdate_cf_conflict()
56 final byte k1[] = "key1".getBytes(UTF_8); in getForUpdate_conflict()
63 txn.put(k1, v1); in getForUpdate_conflict()
64 assertThat(txn.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
70 assertThat(txn3.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
74 txn2.put(k1, v12); // should cause an exception! in getForUpdate_conflict()
|
| /rocksdb-6.9/memtable/ |
| D | skiplistrep.cc | 181 auto k1 = rep_.UserKey(prev_.key()); in Next() local
184 if (k1.compare(k2) == 0) { in Next()
189 auto t1 = rep_.transform_->Transform(k1); in Next()
|
| /rocksdb-6.9/util/ |
| D | crc32c_arm64.cc | 72 uint32_t k0 = 0xe417f38a, k1 = 0x8f158014; in crc32c_arm64() local
96 t1 = (uint64_t)vmull_p64(crc1, k1); in crc32c_arm64()
|
| D | xxhash.cc | 818 xxh_u64 const k1 = XXH64_round(0, XXH_get64bits(ptr)); \ in XXH64_finalize()
820 h64 ^= k1; \ in XXH64_finalize()
|
| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend_test.cc | 147 std::string k1("k1"); in TEST_F() local
150 for (it->Seek(k1); it->Valid(); it->Next()) { in TEST_F()
164 for (it->Seek(k1); it->Valid(); it->Next()) { in TEST_F()
178 for (it->Seek(k1); it->Valid(); it->Next()) { in TEST_F()
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim_test.py | 129 k1 = TraceRecord(
225 sequence = [k1, k1, k2, k3, k3, k3]
|
| D | block_cache_pysim.sh | 152 cat "$fn" | sort -t ',' -k1,1 -k4,4n > "$tmp_file"
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 3083 InternalKey k1(range.start, kMaxSequenceNumber, kValueTypeForSeek); in GetApproximateMemTableStats() local
3086 sv->mem->ApproximateStats(k1.Encode(), k2.Encode()); in GetApproximateMemTableStats()
3088 sv->imm->ApproximateStats(k1.Encode(), k2.Encode()); in GetApproximateMemTableStats()
3110 InternalKey k1(range[i].start, kMaxSequenceNumber, kValueTypeForSeek); in GetApproximateSizes() local
3115 options, v, k1.Encode(), k2.Encode(), /*start_level=*/0, in GetApproximateSizes()
3119 sizes[i] += sv->mem->ApproximateStats(k1.Encode(), k2.Encode()).size; in GetApproximateSizes()
3120 sizes[i] += sv->imm->ApproximateStats(k1.Encode(), k2.Encode()).size; in GetApproximateSizes()
|
| /rocksdb-6.9/db/ |
| D | memtable.cc | 237 Slice k1 = GetLengthPrefixedSlice(prefix_len_key1); in operator ()() local
239 return comparator.CompareKeySeq(k1, k2); in operator ()()
|
| D | db_test2.cc | 2363 std::string k1 = Key(6); in TEST_F() local
2365 Slice k1s(k1); in TEST_F()
|
| D | version_set.cc | 1353 InternalKey k1(range[i].start, kMaxSequenceNumber, kValueTypeForSeek); in GetPropertiesOfTablesInRange() local
1356 storage_info_.GetOverlappingInputs(level, &k1, &k2, &files, -1, nullptr, in GetPropertiesOfTablesInRange()
|