Home
last modified time | relevance | path

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

12

/rocksdb-6.9/utilities/
Dobject_registry.cc20 for (const auto &entry : entries->second) { in FindEntry() local
21 if (entry->matches(name)) { in FindEntry()
22 return entry.get(); in FindEntry()
30 std::unique_ptr<Entry> &entry) { in AddEntry() argument
32 entries.emplace_back(std::move(entry)); in AddEntry()
72 const auto *entry = iter->get()->FindEntry(type, name); in FindEntry() local
73 if (entry != nullptr) { in FindEntry()
74 return entry; in FindEntry()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DWBWIRocksIterator.java12 private final WriteEntry entry = new WriteEntry(); field in WBWIRocksIterator
32 public WriteEntry entry() { in entry() method in WBWIRocksIterator
36 entry.type = WriteType.fromId((byte)ptrs[0]); in entry()
37 entry.key.resetNativeHandle(ptrs[1], ptrs[1] != 0); in entry()
38 entry.value.resetNativeHandle(ptrs[2], ptrs[2] != 0); in entry()
40 return entry; in entry()
87 entry.close(); in close()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_internal.cc172 const WriteEntry entry = iter->Entry(); in GetFromBatch() local
173 if (cmp->CompareKey(cf_id, entry.key, key) != 0) { in GetFromBatch()
193 const WriteEntry entry = iter->Entry(); in GetFromBatch() local
194 if (cmp->CompareKey(cf_id, entry.key, key) != 0) { in GetFromBatch()
199 switch (entry.type) { in GetFromBatch()
202 entry_value = entry.value; in GetFromBatch()
207 merge_context->PushOperand(entry.value); in GetFromBatch()
223 ToString(entry.type)); in GetFromBatch()
/rocksdb-6.9/db/
Derror_handler.cc175 auto entry = ErrorSeverityMap.find(std::make_tuple(reason, bg_err.code(), in SetBGError() local
177 if (entry != ErrorSeverityMap.end()) { in SetBGError()
178 sev = entry->second; in SetBGError()
184 auto entry = DefaultErrorSeverityMap.find(std::make_tuple(reason, in SetBGError() local
186 if (entry != DefaultErrorSeverityMap.end()) { in SetBGError()
187 sev = entry->second; in SetBGError()
193 auto entry = DefaultReasonMap.find(std::make_tuple(reason, paranoid)); in SetBGError() local
194 if (entry != DefaultReasonMap.end()) { in SetBGError()
195 sev = entry->second; in SetBGError()
Dmemtable.cc626 static bool SaveValue(void* arg, const char* entry) { in SaveValue() argument
645 const char* key_ptr = GetVarint32Ptr(entry, entry + 5, &key_length); in SaveValue()
959 const char* entry = iter->key(); in Update() local
961 const char* key_ptr = GetVarint32Ptr(entry, entry + 5, &key_length); in Update()
981 assert((unsigned)((p + value.size()) - entry) == in Update()
1018 const char* entry = iter->key(); in UpdateCallback() local
1020 const char* key_ptr = GetVarint32Ptr(entry, entry + 5, &key_length); in UpdateCallback()
1089 const char* entry = iter->key(); in CountSuccessiveMergeEntries() local
1091 const char* iter_key_ptr = GetVarint32Ptr(entry, entry + 5, &key_length); in CountSuccessiveMergeEntries()
1112 bool (*callback_func)(void* arg, const char* entry)) { in Get() argument
Dexternal_sst_file_test.cc111 for (const auto& entry : data) { in GenerateOneExternalFile() local
112 s = sst_file_writer.Put(entry.first, entry.second); in GenerateOneExternalFile()
124 true_data->insert({entry.first, entry.second}); in GenerateOneExternalFile()
166 for (auto& entry : data) { in GenerateAndAddExternalFile() local
167 s = sst_file_writer.Put(entry.first, entry.second); in GenerateAndAddExternalFile()
189 for (auto& entry : data) { in GenerateAndAddExternalFile() local
190 (*true_data)[entry.first] = entry.second; in GenerateAndAddExternalFile()
241 for (auto& entry : data) { in GenerateAndAddExternalFile() local
242 file_data.emplace_back(Key(entry.first), entry.second); in GenerateAndAddExternalFile()
1759 ASSERT_OK(Put(entry.first, entry.second)); in TEST_P()
[all …]
/rocksdb-6.9/table/block_based/
Ddata_block_hash_index.cc45 for (auto& entry : hash_and_restart_pairs_) { in Finish() local
46 uint32_t hash_value = entry.first; in Finish()
47 uint8_t restart_index = entry.second; in Finish()
Dindex_builder.cc211 Entry& entry = entries_.front(); in Finish() local
213 entry.value->seperator_is_key_plus_seq_ = seperator_is_key_plus_seq_; in Finish()
214 auto s = entry.value->Finish(index_blocks); in Finish()
Dindex_builder.h173 IndexValue entry(block_handle, current_block_first_internal_key_); in AddIndexEntry()
176 entry.EncodeTo(&encoded_entry, include_first_key_, nullptr); in AddIndexEntry()
178 entry.EncodeTo(&delta_encoded_entry, include_first_key_, in AddIndexEntry()
Dblock.cc285 uint8_t entry = in SeekForGetImpl() local
288 if (entry == kCollision) { in SeekForGetImpl()
294 if (entry == kNoEntry) { in SeekForGetImpl()
310 entry = static_cast<uint8_t>(num_restarts_ - 1); in SeekForGetImpl()
313 uint32_t restart_index = entry; in SeekForGetImpl()
Dfull_filter_block_test.cc59 bool MayMatch(const Slice& entry) override { in MayMatch() argument
60 uint32_t h = Hash(entry.data(), entry.size(), 1); in MayMatch()
Dblock_test.cc549 IndexValue entry(block_handles[i], first_keys[i]); in TEST_P() local
552 entry.EncodeTo(&encoded_entry, includeFirstKey(), nullptr); in TEST_P()
554 entry.EncodeTo(&delta_encoded_entry, includeFirstKey(), in TEST_P()
557 last_encoded_handle = entry.handle; in TEST_P()
Dblock.h527 IndexValue entry; in value() local
530 entry.DecodeFrom(&v, have_first_key_, nullptr); in value()
532 return entry; in value()
Ddata_block_hash_index_test.cc26 uint8_t entry = index.Lookup(data, map_offset, key); in SearchForOffset() local
27 if (entry == kCollision) { in SearchForOffset()
31 if (entry == kNoEntry) { in SearchForOffset()
35 return entry == restart_point; in SearchForOffset()
Dfull_filter_block.cc160 const Slice& entry, bool no_io, GetContext* get_context, in MayMatch() argument
176 if (filter_bits_reader->MayMatch(entry)) { in MayMatch()
Dblock_based_filter_block.cc247 const Slice& entry, uint64_t block_offset, bool no_io, in MayMatch() argument
279 const bool may_match = policy->KeyMayMatch(entry, filter); in MayMatch()
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_pysim.py975 entry = CacheEntry(
1142 def pqinsert(self, entry): argument
1150 self.table[entry.key] = entry
1151 heapq.heappush(self.pq, entry)
1157 if not entry.is_removed:
1159 return entry
1164 entry = self.pq[0]
1165 if not entry.is_removed:
1166 return entry
1287 entry = self.table[key]
[all …]
/rocksdb-6.9/cache/
Dlru_cache.cc136 for (auto entry : last_reference_list) { in EraseUnRefEntries() local
137 entry->Free(); in EraseUnRefEntries()
261 for (auto entry : last_reference_list) { in SetCapacity() local
262 entry->Free(); in SetCapacity()
410 for (auto entry : last_reference_list) { in Insert() local
411 entry->Free(); in Insert()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchWithIndexTest.java223 final WBWIRocksIterator.WriteEntry entry = it.entry(); in iterator() local
224 assertThat(entry).isEqualTo(expected[testOffset]); in iterator()
237 assertThat(it.entry()).isEqualTo(expected[i++]); in iterator()
243 assertThat(it.entry()).isEqualTo(expected[i--]); in iterator()
266 final WBWIRocksIterator.WriteEntry actual = it.entry(); in zeroByteTests()
268 assertThat(it.entry().hashCode() == expected.hashCode()).isTrue(); in zeroByteTests()
DTransactionDBTest.java145 final Map.Entry<Long, TransactionDB.KeyLockInfo> entry = entrySet.iterator().next(); in lockStatusData() local
146 final long columnFamilyId = entry.getKey(); in lockStatusData()
148 final TransactionDB.KeyLockInfo keyLockInfo = entry.getValue(); in lockStatusData()
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.h385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b()
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
408 bool Parse(const uint64_t indexed_seq, CommitEntry* entry, in Parse()
421 entry->prep_seq = prep_up | prep_low; in Parse()
423 entry->commit_seq = entry->prep_seq + delta - 1; in Parse()
603 CommitEntry* entry) const;
/rocksdb-6.9/include/rocksdb/utilities/
Dobject_registry.h75 std::unique_ptr<Entry> entry(new FactoryEntry<T>(pattern, factory)); in Register()
76 AddEntry(T::Type(), entry); in Register()
84 void AddEntry(const std::string& type, std::unique_ptr<Entry>& entry);
/rocksdb-6.9/memtable/
Dvectorrep.cc44 bool (*callback_func)(void* arg, const char* entry)) override;
251 bool (*callback_func)(void* arg, const char* entry)) { in Get() argument
Dhash_skiplist_rep.cc38 bool (*callback_func)(void* arg, const char* entry)) override;
290 bool (*callback_func)(void* arg, const char* entry)) { in Get() argument
Dmemtablerep_bench.cc296 static bool callback(void* arg, const char* entry) { in callback() argument
300 const char* key_ptr = GetVarint32Ptr(entry, entry + 5, &key_length); in callback()

12