| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_test.cc | 40 struct Entry { struct
50 Entry e; in PutCF()
59 Entry e; in MergeCF()
68 Entry e; in DeleteCF()
109 auto write_entry = iter->Entry(); in TestValueAsSecondaryIndexHelper()
146 auto write_entry = iter->Entry(); in TestValueAsSecondaryIndexHelper()
188 auto write_entry = iter->Entry(); in TestValueAsSecondaryIndexHelper()
210 auto write_entry = iter->Entry(); in TestValueAsSecondaryIndexHelper()
277 Entry entries[] = { in TEST_F()
296 Entry new_entries[] = { in TEST_F()
[all …]
|
| D | write_batch_with_index.cc | 109 if (comparator_->Equal(delta_iterator_->Entry().key, in Next()
145 if (comparator_->Equal(delta_iterator_->Entry().key, in Prev()
157 : delta_iterator_->Entry().key; in key()
162 : delta_iterator_->Entry().value; in value()
205 assert(delta_iterator_->Entry().type != kMergeRecord && in AssertInvariants()
206 delta_iterator_->Entry().type != kLogDataRecord); in AssertInvariants()
207 int compare = comparator_->Compare(delta_iterator_->Entry().key, in AssertInvariants()
266 delta_entry = delta_iterator_->Entry(); in UpdateCurrent()
402 WriteEntry Entry() const override { in Entry() function in ROCKSDB_NAMESPACE::WBWIIteratorImpl
502 if (comparator.CompareKey(column_family_id, key, iter.Entry().key) != 0) { in UpdateExistingEntryWithCfId()
|
| D | write_batch_with_index_internal.cc | 172 const WriteEntry entry = iter->Entry(); in GetFromBatch()
193 const WriteEntry entry = iter->Entry(); in GetFromBatch()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | object_registry.h | 29 class Entry {
31 virtual ~Entry() {} in ~Entry()
32 Entry(const std::string& name) : name_(std::move(name)) {} in Entry() function
46 class FactoryEntry : public Entry {
49 : Entry(name), pattern_(std::move(name)), factory_(std::move(f)) {} in FactoryEntry()
66 const Entry* FindEntry(const std::string& type,
75 std::unique_ptr<Entry> entry(new FactoryEntry<T>(pattern, factory)); in Register()
84 void AddEntry(const std::string& type, std::unique_ptr<Entry>& entry);
87 std::unordered_map<std::string, std::vector<std::unique_ptr<Entry>>> entries_;
196 const ObjectLibrary::Entry* FindEntry(const std::string& type,
|
| D | write_batch_with_index.h | 74 virtual WriteEntry Entry() const = 0;
|
| /rocksdb-6.9/db/ |
| D | write_batch_test.cc | 670 ASSERT_EQ("bar8", iter->Entry().value.ToString()); in TEST_F()
687 ASSERT_EQ("twofoo", iter->Entry().key.ToString()); in TEST_F()
688 ASSERT_EQ("bar2", iter->Entry().value.ToString()); in TEST_F()
705 ASSERT_EQ("omom", iter->Entry().key.ToString()); in TEST_F()
706 ASSERT_EQ("nom", iter->Entry().value.ToString()); in TEST_F()
717 ASSERT_EQ("foo", iter->Entry().key.ToString()); in TEST_F()
718 ASSERT_EQ("bar", iter->Entry().value.ToString()); in TEST_F()
724 ASSERT_EQ("foo", iter->Entry().key.ToString()); in TEST_F()
725 ASSERT_EQ("bar", iter->Entry().value.ToString()); in TEST_F()
731 ASSERT_EQ("omom", iter->Entry().key.ToString()); in TEST_F()
[all …]
|
| D | db_iter_stress_test.cc | 43 struct Entry { struct
52 bool operator<(const Entry& e) const { in operator <() argument
59 std::vector<Entry> entries;
134 Entry& e = data->entries[idx]; in MaybeMutate()
155 Entry& e = data->entries[idx]; in MaybeMutate()
272 [&](const Entry& e) { in FindNextKey()
301 [&](const Entry& e) { in FindValueForCurrentKey()
313 Entry& e = *it; in FindValueForCurrentKey()
334 Entry& e = *it; in FindValueForCurrentKey()
459 Entry e; in TEST_F()
[all …]
|
| /rocksdb-6.9/utilities/ |
| D | object_registry.cc | 16 const ObjectLibrary::Entry *ObjectLibrary::FindEntry( in FindEntry()
30 std::unique_ptr<Entry> &entry) { in AddEntry()
69 const ObjectLibrary::Entry *ObjectRegistry::FindEntry( in FindEntry()
|
| /rocksdb-6.9/util/ |
| D | thread_local.cc | 17 struct Entry { struct
18 Entry() : ptr(nullptr) {} in Entry() function
19 Entry(const Entry& e) : ptr(e.ptr.load(std::memory_order_relaxed)) {} in Entry() function
46 std::vector<Entry> entries;
|
| /rocksdb-6.9/table/block_based/ |
| D | index_builder.cc | 179 Entry& last_entry = entries_.front(); in Finish()
211 Entry& entry = entries_.front(); in Finish()
|
| D | index_builder.h | 419 struct Entry { struct
423 std::list<Entry> entries_; // list of partitioned indexes and their keys argument
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | TransactionDBTest.java | 144 final Set<Map.Entry<Long, TransactionDB.KeyLockInfo>> entrySet = lockStatus.entrySet(); in lockStatusData()
145 final Map.Entry<Long, TransactionDB.KeyLockInfo> entry = entrySet.iterator().next(); in lockStatusData()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | MemoryUtil.java | 52 for(Map.Entry<Byte, Long> longEntry : byteOutput.entrySet()) { in getApproximateMemoryUsageByType()
|
| D | AbstractMutableOptions.java | 87 for (final Map.Entry<K, MutableOptionValue<?>> option : options.entrySet()) { in build()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | BytewiseComparatorTest.java | 392 private final List<Map.Entry<K, V>> entries;
|
| /rocksdb-6.9/java/rocksjni/ |
| D | write_batch_with_index.cc | 813 const ROCKSDB_NAMESPACE::WriteEntry& we = it->Entry(); in Java_org_rocksdb_WBWIRocksIterator_entry1()
|
| /rocksdb-6.9/ |
| D | HISTORY.md | 902 * WBWIIterator::Entry() now returns WriteEntry instead of `const WriteEntry&`
|