| /rocksdb-6.9/table/plain/ |
| D | plain_table_builder.cc | 145 assert(offset_ <= std::numeric_limits<uint32_t>::max()); in Add()
146 auto prev_offset = static_cast<uint32_t>(offset_); in Add()
148 io_status_ = encoder_.AppendKey(key, file_, &offset_, meta_bytes_buf, in Add()
167 offset_ += value_size + meta_bytes_buf_size; in Add()
184 key, value, offset_, table_properties_collectors_, ioptions_.info_log); in Add()
192 properties_.data_size = offset_; in Finish()
236 WriteBlock(index_finish_result, file_, &offset_, &index_block_handle); in Finish()
261 IOStatus s = WriteBlock(property_block_builder.Finish(), file_, &offset_, in Finish()
270 io_status_ = WriteBlock(meta_index_builer.Finish(), file_, &offset_, in Finish()
286 offset_ += footer_encoding.size(); in Finish()
[all …]
|
| D | plain_table_reader.cc | 87 uint32_t offset_; member in ROCKSDB_NAMESPACE::PlainTableIterator
640 next_offset_ = offset_ = table_->file_info_.data_end_offset; in PlainTableIterator()
647 return offset_ < table_->file_info_.data_end_offset && in Valid()
648 offset_ >= table_->data_start_offset_; in Valid()
655 next_offset_ = offset_ = table_->file_info_.data_end_offset; in SeekToFirst()
664 next_offset_ = offset_ = table_->file_info_.data_end_offset; in SeekToLast()
677 offset_ = next_offset_ = table_->file_info_.data_end_offset; in Seek()
733 offset_ = table_->file_info_.data_end_offset; in Seek()
741 offset_ = next_offset_ = table_->file_info_.data_end_offset; in SeekForPrev()
745 offset_ = next_offset_; in Next()
[all …]
|
| D | plain_table_builder.h | 107 uint64_t offset_ = 0; variable
|
| /rocksdb-6.9/utilities/trace/ |
| D | file_trace_reader_writer.cc | 21 offset_(0), in FileTraceReader()
36 Status s = file_reader_->Read(offset_, kTraceMetadataSize, &result_, buffer_, in Read()
51 offset_ += kTraceMetadataSize; in Read()
61 s = file_reader_->Read(offset_, to_read, &result_, buffer_, nullptr); in Read()
70 offset_ += to_read; in Read()
|
| D | file_trace_reader_writer.h | 27 size_t offset_; variable
|
| /rocksdb-6.9/table/ |
| D | format.h | 45 uint64_t offset() const { return offset_; } in offset()
46 void set_offset(uint64_t _offset) { offset_ = _offset; } in set_offset()
61 bool IsNull() const { return offset_ == 0 && size_ == 0; } in IsNull()
69 uint64_t offset_;
342 : offset_(_offset), size_(_size) {} in BlockHandle()
|
| D | format.cc | 52 assert(offset_ != ~static_cast<uint64_t>(0)); in EncodeTo()
54 PutVarint64Varint64(dst, offset_, size_); in EncodeTo()
58 if (GetVarint64(input, &offset_) && GetVarint64(input, &size_)) { in DecodeFrom()
62 offset_ = 0; in DecodeFrom()
70 offset_ = _offset; in DecodeSizeFrom()
74 offset_ = 0; in DecodeSizeFrom()
|
| /rocksdb-6.9/db/blob/ |
| D | blob_index.h | 78 return offset_; in offset()
104 if (GetVarint64(&slice, &file_number_) && GetVarint64(&slice, &offset_) && in DecodeFrom()
120 oss << "[blob ref] file:" << file_number_ << " offset:" << offset_ in DebugString()
173 uint64_t offset_ = 0; variable
|
| /rocksdb-6.9/file/ |
| D | file_prefetch_buffer.cc | 31 size_t offset_ = static_cast<size_t>(offset); in Prefetch() local
32 uint64_t rounddown_offset = Rounddown(offset_, alignment); in Prefetch()
33 uint64_t roundup_end = Roundup(offset_ + n, alignment); in Prefetch()
|
| D | readahead_raf.cc | 83 size_t offset_ = static_cast<size_t>(offset); in Prefetch() local
84 size_t prefetch_offset = TruncateToPageBoundary(alignment_, offset_); in Prefetch()
89 Roundup(offset_ + n, alignment_) - prefetch_offset); in Prefetch()
|
| D | sequence_file_reader.cc | 29 size_t offset = offset_.fetch_add(n); in Read()
58 offset_ += static_cast<size_t>(n); in Skip()
|
| D | sequence_file_reader.h | 26 std::atomic<size_t> offset_{0}; // read offset
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 534 : data_(data), offset_(0), read_count_(read_count) {} in SeqStringSource()
538 if (offset_ < data_.size()) { in Read()
539 n = std::min(data_.size() - offset_, n); in Read()
540 memcpy(scratch, data_.data() + offset_, n); in Read()
541 offset_ += n; in Read()
551 if (offset_ >= data_.size()) { in Skip()
556 offset_ += static_cast<size_t>(n); in Skip()
562 size_t offset_; variable
|
| /rocksdb-6.9/env/ |
| D | mock_env.cc | 106 size_t offset_ = static_cast<size_t>(offset); in Read() local
115 memcpy(scratch, &(data_[offset_]), n); in Read()
118 *result = Slice(&(data_[offset_]), n); in Read()
125 size_t offset_ = static_cast<size_t>(offset); in Write() local
127 data_.resize(offset_ + data.size()); in Write()
129 data_.replace(offset_, data.size(), data.data(), data.size()); in Write()
|
| D | env_encryption.cc | 28 uint64_t offset_; member in ROCKSDB_NAMESPACE::EncryptedSequentialFile
35 : file_(f), stream_(s), offset_(prefixLength), prefixLength_(prefixLength) { in EncryptedSequentialFile()
52 status = stream_->Decrypt(offset_, (char*)result->data(), result->size()); in Read()
53 …offset_ += result->size(); // We've already ready data from disk, so update offset_ even if decryp… in Read()
69 offset_ += n; in Skip()
100 offset_ = offset + result->size(); in PositionedRead()
|
| /rocksdb-6.9/tools/ |
| D | trace_analyzer_tool.h | 202 size_t offset_; variable
|
| D | trace_analyzer_tool.cc | 279 offset_ = 0; in TraceAnalyzer()
|