| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | AbstractWriteBatch.java | 49 delete(nativeHandle_, key, key.length); in remove()
61 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
63 key.position(key.limit()); in put()
71 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
73 key.position(key.limit()); in put()
79 delete(nativeHandle_, key, key.length); in delete()
91 singleDelete(nativeHandle_, key, key.length); in singleDelete()
114 removeDirect(nativeHandle_, key, key.position(), key.remaining(), 0); in remove()
115 key.position(key.limit()); in remove()
122 nativeHandle_, key, key.position(), key.remaining(), columnFamilyHandle.nativeHandle_); in remove()
[all …]
|
| D | Transaction.java | 673 put(nativeHandle_, key, key.length, value, value.length, in put()
705 put(nativeHandle_, key, key.length, value, value.length, in put()
734 put(nativeHandle_, key, key.length, value, value.length); in put()
988 delete(nativeHandle_, key, key.length); in delete()
1083 singleDelete(nativeHandle_, key, key.length, in singleDelete()
1115 singleDelete(nativeHandle_, key, key.length, in singleDelete()
1143 singleDelete(nativeHandle_, key, key.length); in singleDelete()
1375 deleteUntracked(nativeHandle_, key, key.length, in deleteUntracked()
1399 deleteUntracked(nativeHandle_, key, key.length); in deleteUntracked()
1655 undoGetForUpdate(nativeHandle_, key, key.length); in undoGetForUpdate()
[all …]
|
| D | AbstractMutableOptions.java | 97 final K key, final double value) { in setDouble() argument
106 protected double getDouble(final K key) in getDouble() argument
116 final K key, final long value) { in setLong() argument
125 protected long getLong(final K key) in getLong() argument
135 final K key, final int value) { in setInt() argument
144 protected int getInt(final K key) in getInt() argument
173 final K key, final int[] value) { in setIntArray() argument
192 final K key, final N value) { in setEnum() argument
223 switch(key.getValueType()) { in fromString()
249 return setIntArray(key, value); in fromString()
[all …]
|
| D | RocksDB.java | 784 key.position(key.limit()); in put()
808 key.position(key.limit()); in put()
873 delete(nativeHandle_, key, 0, key.length); in delete()
1101 key.position(key.limit()); in get()
1134 key.position(key.limit()); in get()
1161 singleDelete(nativeHandle_, key, key.length); in singleDelete()
1189 singleDelete(nativeHandle_, key, key.length, in singleDelete()
1497 key.position(key.limit()); in delete()
1519 key.position(key.limit()); in delete()
1886 return get(nativeHandle_, key, 0, key.length, in get()
[all …]
|
| D | SstFileWriter.java | 74 public void add(final Slice key, final Slice value) in add() argument
133 assert key.isDirect() && value.isDirect(); in put()
134 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
136 key.position(key.limit()); in put()
150 put(nativeHandle_, key, value); in put()
163 public void merge(final Slice key, final Slice value) in merge() argument
178 public void merge(final byte[] key, final byte[] value) in merge() argument
180 merge(nativeHandle_, key, value); in merge()
207 delete(nativeHandle_, key.getNativeHandle()); in delete()
219 delete(nativeHandle_, key.getNativeHandle()); in delete()
[all …]
|
| D | WriteBatchWithIndex.java | 174 key, key.length, columnFamilyHandle.nativeHandle_); in getFromBatch()
190 public byte[] getFromBatch(final DBOptions options, final byte[] key) in getFromBatch() argument
192 return getFromBatch(nativeHandle_, options.nativeHandle_, key, key.length); in getFromBatch()
221 options.nativeHandle_, key, key.length, in getFromBatchAndDB()
248 final byte[] key) throws RocksDBException { in getFromBatchAndDB() argument
250 options.nativeHandle_, key, key.length); in getFromBatchAndDB()
255 @Override final native void put(final long handle, final byte[] key, in put() argument
257 @Override final native void put(final long handle, final byte[] key, in put() argument
309 final byte[] key, final int keyLen); in getFromBatch() argument
311 final byte[] key, final int keyLen, final long cfHandle); in getFromBatch() argument
[all …]
|
| /rocksdb-6.9/util/ |
| D | bloom_test.cc | 192 for (int key = 0; key < 87; key++) { in TEST_F() local
199 for (int key = 0; key < 87; key++) { in TEST_F() local
206 for (int key = 0; key < 87; key++) { in TEST_F() local
213 for (int key = 0; key < 87; key++) { in TEST_F() local
236 for (int key = 1; key < 88; key++) { in TEST_F() local
243 for (int key = 1; key < 88; key++) { in TEST_F() local
532 for (int key = 0; key < 2087; key++) { in TEST_P() local
546 for (int key = 0; key < 2087; key++) { in TEST_P() local
560 for (int key = 0; key < 2087; key++) { in TEST_P() local
574 for (int key = 0; key < 2087; key++) { in TEST_P() local
[all …]
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | WriteBatchGetter.java | 12 private final byte[] key; field in WriteBatchGetter
16 this.key = key; in WriteBatchGetter()
26 if(Arrays.equals(this.key, key)) { in put()
34 if(Arrays.equals(this.key, key)) { in put()
42 if(Arrays.equals(this.key, key)) { in merge()
50 if(Arrays.equals(this.key, key)) { in merge()
57 if(Arrays.equals(this.key, key)) { in delete()
65 if(Arrays.equals(this.key, key)) { in delete()
72 if(Arrays.equals(this.key, key)) { in singleDelete()
80 if(Arrays.equals(this.key, key)) { in singleDelete()
[all …]
|
| D | CapturingWriteBatchHandler.java | 36 public void put(final byte[] key, final byte[] value) { in put() argument
37 events.add(new Event(Action.PUT, key, value)); in put()
48 events.add(new Event(Action.MERGE, key, value)); in merge()
57 public void delete(final byte[] key) { in delete() argument
64 columnFamilyId, key, (byte[])null)); in singleDelete()
68 public void singleDelete(final byte[] key) { in singleDelete() argument
125 public final byte[] key; field in CapturingWriteBatchHandler.Event
129 this(action, 0, key, value); in Event()
136 this.key = key; in Event()
151 ((key == null && event.key == null) in equals()
[all …]
|
| /rocksdb-6.9/third-party/folly/folly/hash/ |
| D | Hash.h | 17 inline uint64_t twang_mix64(uint64_t key) noexcept { in twang_mix64() argument
18 key = (~key) + (key << 21); // key *= (1 << 21) - 1; key -= 1; in twang_mix64()
19 key = key ^ (key >> 24); in twang_mix64()
20 key = key + (key << 3) + (key << 8); // key *= 1 + (1 << 3) + (1 << 8) in twang_mix64()
21 key = key ^ (key >> 14); in twang_mix64()
22 key = key + (key << 2) + (key << 4); // key *= 1 + (1 << 2) + (1 << 4) in twang_mix64()
23 key = key ^ (key >> 28); in twang_mix64()
24 key = key + (key << 31); // key *= 1 + (1 << 31) in twang_mix64()
25 return key; in twang_mix64()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_base.h | 126 return Put(nullptr, key, value); in Put()
133 return Put(nullptr, key, value); in Put()
139 return Merge(nullptr, key, value); in Merge()
144 Status Delete(const Slice& key) override { return Delete(nullptr, key); } in Delete() argument
147 Status Delete(const SliceParts& key) override { return Delete(nullptr, key); } in Delete() argument
152 return SingleDelete(nullptr, key); in SingleDelete()
157 return SingleDelete(nullptr, key); in SingleDelete()
163 return PutUntracked(nullptr, key, value); in PutUntracked()
181 return DeleteUntracked(nullptr, key); in DeleteUntracked()
186 return DeleteUntracked(nullptr, key); in DeleteUntracked()
[all …]
|
| D | transaction_base.cc | 106 for (int i = 0; i < key.num_parts; ++i) { in TryLock()
107 key_size += key.parts[i].size(); in TryLock()
113 for (int i = 0; i < key.num_parts; ++i) { in TryLock()
114 str.append(key.parts[i].data(), key.parts[i].size()); in TryLock()
154 const std::string& key = key_iter.first; in RollbackToSavePoint() local
223 const std::string& key = key_iter.first; in PopSavePoint() local
227 auto prev_info = prev_keys.find(key); in PopSavePoint()
640 auto result = cf_key_map.try_emplace(key, seq); in TrackKey()
647 auto iter = cf_key_map.find(key); in TrackKey()
683 const std::string& key = key_iter.first; in GetTrackedKeysSinceSavePoint() local
[all …]
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index.cc | 155 Slice key() const override { in key() function in ROCKSDB_NAMESPACE::BaseDeltaIterator
306 comparator_->Compare(delta_entry.key, base_iterator_->key()); in UpdateCurrent()
498 iter.Seek(key); in UpdateExistingEntryWithCfId()
502 if (comparator.CompareKey(column_family_id, key, iter.Entry().key) != 0) { in UpdateExistingEntryWithCfId()
538 Slice key; in AddNewEntry() local
547 key.data() - wb_data.data(), key.size()); in AddNewEntry()
1005 KeyContext& key = *iter; in MultiGetFromBatchAndDB() local
1006 if (key.s->ok() || key.s->IsNotFound()) { // DB Get Succeeded in MultiGetFromBatchAndDB()
1018 if (key.s->ok()) { in MultiGetFromBatchAndDB()
1026 merge_operator, *key.key, merge_data, in MultiGetFromBatchAndDB()
[all …]
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | RocksIteratorTest.java | 42 assertThat(iterator.key(key)).isEqualTo(4); in rocksIterator()
51 key.get(tmp); in rocksIterator()
58 assertThat(iterator.key(key)).isEqualTo(4); in rocksIterator()
66 key.get(tmp); in rocksIterator()
90 key.clear(); in rocksIterator()
91 key.put("key1".getBytes()); in rocksIterator()
92 key.flip(); in rocksIterator()
93 iterator.seek(key); in rocksIterator()
99 key.clear(); in rocksIterator()
101 key.flip(); in rocksIterator()
[all …]
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | transaction.h | 198 auto s = Get(options, key, pinnable_val->GetSelf()); in Get()
344 virtual Status Delete(const Slice& key) = 0;
346 const SliceParts& key,
348 virtual Status Delete(const SliceParts& key) = 0;
351 const Slice& key,
353 virtual Status SingleDelete(const Slice& key) = 0;
355 const SliceParts& key,
371 const SliceParts& key,
373 virtual Status PutUntracked(const SliceParts& key,
464 const Slice& key) = 0;
[all …]
|
| /rocksdb-6.9/memtable/ |
| D | skiplist.h | 60 void Insert(const Key& key);
85 const Key& key() const;
171 Key const key;
208 return new (mem) Node(key);
230 return node_->key;
297 return (n != nullptr) && (compare_(n->key, key) < 0);
319 ? 1 : compare_(next->key, key);
390 assert(x == head_ || compare_(x->key, key) < 0);
392 if (next == nullptr || compare_(next->key, key) >= 0) {
456 assert(prev_[0]->Next(0) == nullptr || !Equal(key, prev_[0]->Next(0)->key));
[all …]
|
| D | inlineskiplist_test.cc | 70 keys_.insert(key); in Insert()
77 keys_.insert(key); in InsertWithHint()
94 ASSERT_EQ(key, Decode(iter.key())); in Validate()
110 Key key = 10; in TEST_F() local
117 key = 100; in TEST_F()
118 iter.Seek(Encode(&key)); in TEST_F()
222 Key key = i; in TEST_F() local
342 static uint64_t key(Key key) { return (key >> 40); } in key() function in ROCKSDB_NAMESPACE::ConcurrentTest
343 static uint64_t gen(Key key) { return (key >> 8) & 0xffffffffu; } in gen() argument
344 static uint64_t hash(Key key) { return key & 0xff; } in hash() argument
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | write_batch.h | 72 return Put(nullptr, key, value); in Put()
81 return Put(nullptr, key, value); in Put()
87 Status Delete(const Slice& key) override { return Delete(nullptr, key); } in Delete() argument
92 Status Delete(const SliceParts& key) override { return Delete(nullptr, key); } in Delete() argument
99 return SingleDelete(nullptr, key); in SingleDelete()
106 return SingleDelete(nullptr, key); in SingleDelete()
132 return Merge(nullptr, key, value); in Merge()
193 Put(key, value); in PutCF()
203 Delete(key); in DeleteCF()
213 SingleDelete(key); in SingleDeleteCF()
[all …]
|
| /rocksdb-6.9/db/ |
| D | db_iter_stress_test.cc | 44 std::string key; member
53 if (key != e.key) return key < e.key; in operator <()
274 return e.key < key; in FindNextKey()
276 return e.key <= key; in FindNextKey()
281 key = it->key; in FindNextKey()
287 key = it->key; in FindNextKey()
302 if (e.key != key) { in FindValueForCurrentKey()
303 return e.key < key; in FindValueForCurrentKey()
314 if (e.key != key) { in FindValueForCurrentKey()
335 if (e.key != key) { in FindValueForCurrentKey()
[all …]
|
| D | db_iter_test.cc | 191 Slice key() const override { in key() function in ROCKSDB_NAMESPACE::TestIterator
2422 std::string key; in TEST_F() local
2423 key.resize(9); in TEST_F()
2425 key[0] = 'b'; in TEST_F()
2428 internal_iter->AddPut(key, "0"); in TEST_F()
2429 internal_iter->AddPut(key, "1"); in TEST_F()
2430 internal_iter->AddPut(key, "2"); in TEST_F()
2431 internal_iter->AddPut(key, "3"); in TEST_F()
2432 internal_iter->AddPut(key, "4"); in TEST_F()
2444 ASSERT_EQ(db_iter->key().ToString(), key); in TEST_F()
[all …]
|
| D | db_tailing_iter_test.cc | 57 Slice key(buf, 16); in TEST_F() local
60 iter->Seek(key); in TEST_F()
62 ASSERT_EQ(iter->key().compare(key), 0); in TEST_F()
81 Slice key(buf1, 20); in TEST_F() local
92 ASSERT_EQ(iter->key().compare(key), 0); in TEST_F()
99 ASSERT_EQ(itern->key().compare(key), 0); in TEST_F()
108 Slice key(buf1, 20); in TEST_F() local
119 ASSERT_EQ(iter->key().compare(key), 0); in TEST_F()
203 ASSERT_EQ(iter->key().compare(key), 0); in TEST_F()
211 ASSERT_EQ(itern->key().compare(key), 0); in TEST_F()
[all …]
|
| D | write_batch.cc | 152 AssignTimestamp(key); in PutCF()
158 AssignTimestamp(key); in DeleteCF()
164 AssignTimestamp(key); in SingleDeleteCF()
178 AssignTimestamp(key); in MergeCF()
219 void AssignTimestamp(const Slice& key) { in AssignTimestamp() argument
223 char* ptr = const_cast<char*>(key.data() + key.size() - ts_sz); in AssignTimestamp()
534 Slice key, value, blob, xid; in Iterate() local
777 b->rep_.append(key.data(), key.size()); in Put()
911 PutLengthPrefixedSlice(&b->rep_, key); in Delete()
957 PutLengthPrefixedSlice(&b->rep_, key); in SingleDelete()
[all …]
|
| /rocksdb-6.9/cache/ |
| D | clock_cache.cc | 180 Slice key; member
203 key = a.key; in operator =()
210 Slice key, size_t charge, in CalcTotalCharge()
233 Slice key; member
239 key = k; in CacheKey()
244 return a.hash_value == b.hash_value && a.key == b.key; in equal()
431 handle->key.clear(); in RecycleHandle()
445 delete[] key; in Cleanup()
591 handle->key = key; in Insert()
619 memcpy(key_data, key.data(), key.size()); in Insert()
[all …]
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim.py | 142 self.key = key
222 if self.table[index][i].hash == hash and self.table[index][i].key == key:
279 and self.table[index][i].key == key
304 and self.table[index][i].key == key
508 def delete(self, key): argument
919 key,
957 key=hash_entry.key, max_size=self.table.elements
1115 self.key = key
1245 self.key = key
1393 if key in self.t1:
[all …]
|
| /rocksdb-6.9/tools/rdb/ |
| D | API.md | 26 # Get the value of a given key.
28 # key (string) - Which key to get the value of.
35 db_obj.get(key, column_family = { default })
39 # Associate a value with a key.
41 # key (string) - Which key to associate the value with.
49 db_obj.put(key, value, column_family = { default })
53 # Delete a value associated with a given key.
55 # key (string) - Which key to delete the value of..
65 db_obj.delete(key, column_family = { default })
143 The following key-value pair is optional:
[all …]
|