| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_reader.cc | 79 delete rep_; in ~BlockBasedTable()
743 rep_->footer, rep_->ioptions, table_properties, in TryReadPropertiesWithGlobalSeqno()
1043 if (rep_->filter) { in ApproximateMemoryUsage()
1066 rep_->file.get(), prefetch_buffer, rep_->footer, ReadOptions(), in ReadMetaIndexBlock()
1067 rep_->footer.metaindex_handle(), &metaindex, rep_->ioptions, in ReadMetaIndexBlock()
1153 &contents, rep_->table_options.format_version, rep_->ioptions, in GetDataBlockFromCache()
1295 auto& rep = rep_; in CreateFilterBlockReader()
1431 rep_->file.get(), prefetch_buffer, rep_->footer, ro, handle, in MaybeReadBlockAndLoadToCache()
1812 StopWatch sw(rep_->ioptions.env, rep_->ioptions.statistics, in RetrieveBlock()
2059 rep_->fragmented_range_dels, rep_->internal_comparator, snapshot); in NewRangeTombstoneIterator()
[all …]
|
| D | block_based_table_builder.cc | 502 delete rep_; in ~BlockBasedTableBuilder()
506 Rep* r = rep_; in Add()
586 Rep* r = rep_; in Flush()
608 Rep* r = rep_; in WriteBlock()
724 Rep* r = rep_; in WriteRawBlock()
805 Rep* r = rep_; in InsertBlockInCache()
925 rep_->props.column_family_id = rep_->column_family_id; in WritePropertiesBlock()
926 rep_->props.column_family_name = rep_->column_family_name; in WritePropertiesBlock()
971 rep_->props.creation_time = rep_->creation_time; in WritePropertiesBlock()
972 rep_->props.oldest_key_time = rep_->oldest_key_time; in WritePropertiesBlock()
[all …]
|
| D | block_based_table_reader_impl.h | 39 if (rep_->uncompression_dict_reader) { in NewDataBlockIterator()
76 (!block.GetValue()->own_bytes() && rep_->immortal_table); in NewDataBlockIterator()
81 if (!ro.fill_cache && rep_->cache_key_prefix_size != 0) { in NewDataBlockIterator()
94 assert(rep_->cache_key_prefix_size != 0); in NewDataBlockIterator()
95 assert(rep_->cache_key_prefix_size <= kExtraCacheKeyPrefix); in NewDataBlockIterator()
96 memcpy(cache_key, rep_->cache_key_prefix, rep_->cache_key_prefix_size); in NewDataBlockIterator()
148 (!block.GetValue()->own_bytes() && rep_->immortal_table); in NewDataBlockIterator()
153 if (!ro.fill_cache && rep_->cache_key_prefix_size != 0) { in NewDataBlockIterator()
166 assert(rep_->cache_key_prefix_size != 0); in NewDataBlockIterator()
167 assert(rep_->cache_key_prefix_size <= kExtraCacheKeyPrefix); in NewDataBlockIterator()
[all …]
|
| D | block_based_table_reader.h | 218 Rep* get_rep() { return rep_; } in get_rep()
219 const Rep* get_rep() const { return rep_; } in get_rep()
245 Rep* rep_;
247 : rep_(rep), block_cache_tracer_(block_cache_tracer) {} in BlockBasedTable()
|
| D | partitioned_index_reader.cc | 61 const BlockBasedTable::Rep* rep = table()->rep_; in NewIterator()
108 const BlockBasedTable::Rep* rep = table()->rep_; in CacheDependencies()
|
| D | block_based_table_builder.h | 138 Rep* rep_; variable
|
| /rocksdb-6.9/db/ |
| D | write_batch.cc | 264 rep_(rep), in WriteBatch()
270 rep_(std::move(rep)), in WriteBatch()
277 rep_(src.rep_), in WriteBatch()
290 rep_(std::move(src.rep_)), in WriteBatch()
323 rep_.clear(); in Clear()
526 if (begin > wb->rep_.size() || end > wb->rep_.size() || end < begin) { in Iterate()
740 EncodeFixed32(&b->rep_[8], n); in SetCount()
748 EncodeFixed64(&b->rep_[0], seq); in SetSequence()
775 PutVarint32(&b->rep_, in Put()
1159 rep_.resize(savepoint.size); in RollbackToSavePoint()
[all …]
|
| D | dbformat.h | 230 std::string rep_;
254 return ParseInternalKey(Slice(rep_), &parsed); in Valid()
259 assert(!rep_.empty()); in Encode()
260 return rep_; in Encode()
263 Slice user_key() const { return ExtractUserKey(rep_); } in user_key()
264 size_t size() { return rep_.size(); } in size()
271 rep_.clear(); in SetFrom()
272 AppendInternalKey(&rep_, p); in SetFrom()
275 void Clear() { rep_.clear(); } in Clear()
279 std::string* rep() { return &rep_; } in rep()
[all …]
|
| D | db_memtable_test.cc | 26 : MemTableRep(allocator), rep_(rep), num_insert_with_hint_(0) {} in MockMemTableRep()
29 return rep_->Allocate(len, buf); in Allocate()
32 void Insert(KeyHandle handle) override { rep_->Insert(handle); } in Insert()
38 rep_->InsertWithHint(handle, hint); in InsertWithHint()
42 bool Contains(const char* key) const override { return rep_->Contains(key); } in Contains()
46 rep_->Get(k, callback_args, callback_func); in Get()
50 return rep_->ApproximateMemoryUsage(); in ApproximateMemoryUsage()
54 return rep_->GetIterator(arena); in GetIterator()
62 std::unique_ptr<MemTableRep> rep_; member in ROCKSDB_NAMESPACE::MockMemTableRep
|
| D | write_batch_internal.h | 135 return Slice(batch->rep_); in Contents()
139 return batch->rep_.size(); in ByteSize()
232 if (batch_->max_bytes_ && batch_->rep_.size() > batch_->max_bytes_) { in commit()
233 batch_->rep_.resize(savepoint_.size); in commit()
|
| D | range_del_aggregator.h | 359 rep_(icmp, upper_bound, 0 /* lower_bound */) {} in ReadRangeDelAggregator()
370 if (rep_.IsEmpty()) { in ShouldDelete()
378 void InvalidateRangeDelMapPositions() override { rep_.Invalidate(); } in InvalidateRangeDelMapPositions()
380 bool IsEmpty() const override { return rep_.IsEmpty(); } in IsEmpty()
383 StripeRep rep_;
|
| D | version_builder.cc | 750 : rep_(new Rep(file_options, info_log, table_cache, base_vstorage)) {} in VersionBuilder()
755 return rep_->CheckConsistencyForNumLevels(); in CheckConsistencyForNumLevels()
758 Status VersionBuilder::Apply(VersionEdit* edit) { return rep_->Apply(edit); } in Apply()
761 return rep_->SaveTo(vstorage); in SaveTo()
768 return rep_->LoadTableHandlers(internal_stats, max_threads, in LoadTableHandlers()
|
| D | dbformat.cc | 105 if (ParseInternalKey(rep_, &parsed)) { in DebugString()
109 result.append(EscapeString(rep_)); in DebugString()
|
| D | range_del_aggregator.cc | 320 rep_.AddTombstones( in AddTombstones()
327 return rep_.ShouldDelete(parsed, mode); in ShouldDeleteImpl()
333 return rep_.IsRangeOverlapped(start, end); in IsRangeOverlapped()
|
| D | c.cc | 3072 const FilterPolicy* rep_; in rocksdb_filterpolicy_create_bloom_format() member
3073 ~Wrapper() override { delete rep_; } in rocksdb_filterpolicy_create_bloom_format()
3077 return rep_->CreateFilter(keys, n, dst); in rocksdb_filterpolicy_create_bloom_format()
3080 return rep_->KeyMayMatch(key, filter); in rocksdb_filterpolicy_create_bloom_format()
3086 return rep_->GetBuilderWithContext(context); in rocksdb_filterpolicy_create_bloom_format()
3090 return rep_->GetFilterBitsReader(contents); in rocksdb_filterpolicy_create_bloom_format()
3562 const SliceTransform* rep_; member
3563 ~Wrapper() override { delete rep_; } in ~Wrapper()
3566 return rep_->Transform(src); in Transform()
3569 return rep_->InDomain(src); in InDomain()
[all …]
|
| D | version_builder.h | 46 std::unique_ptr<Rep> rep_; variable
|
| /rocksdb-6.9/memtable/ |
| D | skiplistrep.cc | 165 rep_(rep), iter_(&rep_.skip_list_), prev_(iter_) {} in LookaheadIterator()
181 auto k1 = rep_.UserKey(prev_.key()); in Next()
182 auto k2 = rep_.UserKey(iter_.key()); in Next()
187 } else if (rep_.transform_) { in Next()
189 auto t1 = rep_.transform_->Transform(k1); in Next()
190 auto t2 = rep_.transform_->Transform(k2); in Next()
212 if (prev_.Valid() && rep_.cmp_(encoded_key, prev_.key()) >= 0) { in Seek()
218 while (cur++ <= rep_.lookahead_ && iter_.Valid()) { in Seek()
219 if (rep_.cmp_(encoded_key, iter_.key()) <= 0) { in Seek()
253 const SkipListRep& rep_; member in ROCKSDB_NAMESPACE::__anon1cbf76c00111::SkipListRep::LookaheadIterator
|
| /rocksdb-6.9/table/ |
| D | sst_file_writer.cc | 169 rep_->file_info.file_size = 0; in SstFileWriter()
173 if (rep_->builder) { in ~SstFileWriter()
176 rep_->builder->Abandon(); in ~SstFileWriter()
181 Rep* r = rep_.get(); in Open()
262 return rep_->Add(user_key, value, ValueType::kTypeValue); in Add()
266 return rep_->Add(user_key, value, ValueType::kTypeValue); in Put()
270 return rep_->Add(user_key, value, ValueType::kTypeMerge); in Merge()
274 return rep_->Add(user_key, Slice(), ValueType::kTypeDeletion); in Delete()
279 return rep_->DeleteRange(begin_key, end_key); in DeleteRange()
283 Rep* r = rep_.get(); in Finish()
[all …]
|
| D | sst_file_reader.cc | 36 SstFileReader::SstFileReader(const Options& options) : rep_(new Rep(options)) {} in SstFileReader()
41 auto r = rep_.get(); in Open()
66 auto r = rep_.get(); in NewIterator()
81 return rep_->table_reader->GetTableProperties(); in GetTableProperties()
85 return rep_->table_reader->VerifyChecksum(read_options, in VerifyChecksum()
|
| /rocksdb-6.9/util/ |
| D | compression_context_cache.cc | 88 CompressionContextCache::CompressionContextCache() : rep_(new Rep()) {} in CompressionContextCache()
99 return rep_->GetZSTDUncompressData(); in GetCachedZSTDUncompressData()
103 rep_->ReturnZSTDUncompressData(idx); in ReturnCachedZSTDUncompressData()
106 CompressionContextCache::~CompressionContextCache() { delete rep_; } in ~CompressionContextCache()
|
| D | compression_context_cache.h | 44 Rep* rep_; variable
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.h | 383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b()
403 rep_ = (ps << format.PAD_BITS) & ~format.COMMIT_FILTER; in CommitEntry64b()
404 rep_ = rep_ | delta; in CommitEntry64b()
410 uint64_t delta = rep_ & format.COMMIT_FILTER; in Parse()
418 uint64_t prep_up = rep_ & ~format.COMMIT_FILTER; in Parse()
428 uint64_t rep_;
|
| /rocksdb-6.9/include/rocksdb/ |
| D | write_batch.h | 281 const std::string& Data() const { return rep_; } in Data()
284 size_t GetDataSize() const { return rep_.size(); } in GetDataSize()
371 std::string rep_; // See comment in write_batch.cc for the format of rep_
|
| D | sst_file_reader.h | 42 std::unique_ptr<Rep> rep_; variable
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_internal.cc | 42 Slice input = Slice(rep_.data() + data_offset, rep_.size() - data_offset); in GetEntryFromDataOffset()
|