| /rocksdb-6.9/db/ |
| D | log_reader.cc | 34 buffer_(), in Reader()
282 buffer_.clear(); in ReadMore()
286 buffer_.clear(); in ReadMore()
303 buffer_.clear(); in ReadMore()
307 buffer_.clear(); in ReadMore()
354 buffer_.clear(); in ReadPhysicalRecord()
373 buffer_.clear(); in ReadPhysicalRecord()
512 buffer_.clear(); in TryReadMore()
516 buffer_.clear(); in TryReadMore()
539 buffer_.clear(); in TryReadMore()
[all …]
|
| D | log_reader.h | 108 Slice buffer_; variable
|
| /rocksdb-6.9/file/ |
| D | sequence_file_reader.cc | 77 buffer_(), in ReadaheadSequentialFile()
80 buffer_.Alignment(alignment_); in ReadaheadSequentialFile()
81 buffer_.AllocateNewBuffer(readahead_size_); in ReadaheadSequentialFile()
113 buffer_.Clear(); in Read()
131 if (buffer_.CurrentSize() > 0) { in Skip()
149 buffer_.Clear(); in Skip()
162 buffer_.Clear(); in InvalidateCache()
192 if (n > buffer_.Capacity()) { in ReadIntoBuffer()
193 n = buffer_.Capacity(); in ReadIntoBuffer()
200 buffer_.Size(result.size()); in ReadIntoBuffer()
[all …]
|
| D | file_prefetch_buffer.cc | 48 if (buffer_.CurrentSize() > 0 && offset >= buffer_offset_ && in Prefetch()
49 offset <= buffer_offset_ + buffer_.CurrentSize()) { in Prefetch()
50 if (offset + n <= buffer_offset_ + buffer_.CurrentSize()) { in Prefetch()
60 chunk_len = buffer_.CurrentSize() - chunk_offset_in_buffer; in Prefetch()
64 buffer_offset_ + buffer_.CurrentSize()); in Prefetch()
76 if (buffer_.Capacity() < roundup_len) { in Prefetch()
77 buffer_.Alignment(alignment); in Prefetch()
78 buffer_.AllocateNewBuffer(static_cast<size_t>(roundup_len), in Prefetch()
94 buffer_.Size(static_cast<size_t>(chunk_len) + result.size()); in Prefetch()
112 if (offset + n > buffer_offset_ + buffer_.CurrentSize()) { in TryReadFromCache()
[all …]
|
| D | readahead_raf.cc | 27 buffer_(), in ReadaheadRandomAccessFile()
29 buffer_.Alignment(alignment_); in ReadaheadRandomAccessFile()
30 buffer_.AllocateNewBuffer(readahead_size_); in ReadaheadRandomAccessFile()
53 (cached_len == n || buffer_.CurrentSize() < readahead_size_)) { in Read()
100 buffer_.Clear(); in InvalidateCache()
114 offset >= buffer_offset_ + buffer_.CurrentSize()) { in TryReadFromCache()
129 if (n > buffer_.Capacity()) { in ReadIntoBuffer()
130 n = buffer_.Capacity(); in ReadIntoBuffer()
135 Status s = file_->Read(offset, n, &result, buffer_.BufferStart()); in ReadIntoBuffer()
138 buffer_.Size(result.size()); in ReadIntoBuffer()
[all …]
|
| D | file_prefetch_buffer.h | 83 AlignedBuffer buffer_;
|
| /rocksdb-6.9/table/block_based/ |
| D | block_builder.cc | 72 buffer_.clear(); in Reset()
115 PutFixed32(&buffer_, restarts_[i]); in Finish()
123 data_block_hash_index_builder_.Finish(buffer_); in Finish()
130 PutFixed32(&buffer_, block_footer); in Finish()
132 return Slice(buffer_); in Finish()
143 restarts_.push_back(static_cast<uint32_t>(buffer_.size())); in Add()
163 const size_t curr_size = buffer_.size(); in Add()
177 buffer_.append(key.data() + shared, non_shared); in Add()
182 buffer_.append(delta_value->data(), delta_value->size()); in Add()
184 buffer_.append(value.data(), value.size()); in Add()
[all …]
|
| D | block_builder.h | 57 bool empty() const { return buffer_.empty(); } in empty()
66 std::string buffer_; // Destination buffer variable
|
| /rocksdb-6.9/util/ |
| D | channel.h | 31 return buffer_.empty() && eof_; in eof()
36 return buffer_.size(); in size()
42 buffer_.emplace(std::forward<T>(elem)); in write()
51 cv_.wait(lk, [&] { return eof_ || !buffer_.empty(); }); in read()
52 if (eof_ && buffer_.empty()) { in read()
55 elem = std::move(buffer_.front()); in read()
56 buffer_.pop(); in read()
64 std::queue<T> buffer_; variable
|
| /rocksdb-6.9/tools/ |
| D | trace_analyzer_tool.cc | 577 ret = snprintf(buffer_, sizeof(buffer_), in MakeStatistics()
630 ret = snprintf(buffer_, sizeof(buffer_), in MakeStatistics()
681 ret = snprintf(buffer_, sizeof(buffer_), in MakeStatisticKeyStatsOrPrefix()
712 snprintf(buffer_, sizeof(buffer_), in MakeStatisticKeyStatsOrPrefix()
819 ret = snprintf(buffer_, sizeof(buffer_), "%u\n", 0); in MakeStatisticQPS()
831 ret = snprintf(buffer_, sizeof(buffer_), "%u\n", time_it.second); in MakeStatisticQPS()
880 ret = snprintf(buffer_, sizeof(buffer_), "%" PRIu64 " %.12f\n", in MakeStatisticQPS()
917 ret = snprintf(buffer_, sizeof(buffer_), in MakeStatisticQPS()
971 ret = snprintf(buffer_, sizeof(buffer_), "%u ", v); in MakeStatisticQPS()
973 ret = snprintf(buffer_, sizeof(buffer_), "%u\n", v); in MakeStatisticQPS()
[all …]
|
| D | trace_analyzer_tool.h | 203 char buffer_[1024]; variable
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_log_reader.cc | 24 buffer_(), in Reader()
45 Status s = ReadSlice(BlobLogHeader::kSize, &buffer_, header_buf_); in ReadHeader()
50 if (buffer_.size() != BlobLogHeader::kSize) { in ReadHeader()
54 return header->DecodeFrom(buffer_); in ReadHeader()
59 Status s = ReadSlice(BlobLogRecord::kHeaderSize, &buffer_, header_buf_); in ReadRecord()
63 if (buffer_.size() != BlobLogRecord::kHeaderSize) { in ReadRecord()
67 s = record->DecodeHeaderFrom(buffer_); in ReadRecord()
|
| D | blob_dump_tool.cc | 27 : reader_(nullptr), buffer_(nullptr), buffer_size_(0) {} in BlobDumpTool()
102 buffer_.reset(new char[buffer_size_]); in Read()
104 Status s = reader_->Read(offset, size, result, buffer_.get(), nullptr); in Read()
|
| D | blob_log_reader.h | 73 Slice buffer_; variable
|
| D | blob_dump_tool.h | 36 std::unique_ptr<char[]> buffer_; variable
|
| /rocksdb-6.9/logging/ |
| D | event_logger_test.cc | 19 vsnprintf(buffer_, sizeof(buffer_), format, ap); in Logv()
21 char* buffer() { return buffer_; } in buffer()
24 char buffer_[1000]; member in ROCKSDB_NAMESPACE::StringLogger
|
| /rocksdb-6.9/utilities/trace/ |
| D | file_trace_reader_writer.cc | 22 buffer_(new char[kBufferSize]) {} in FileTraceReader()
26 delete[] buffer_; in ~FileTraceReader()
36 Status s = file_reader_->Read(offset_, kTraceMetadataSize, &result_, buffer_, in Read()
54 DecodeFixed32(&buffer_[kTraceTimestampSize + kTraceTypeSize]); in Read()
61 s = file_reader_->Read(offset_, to_read, &result_, buffer_, nullptr); in Read()
|
| D | file_trace_reader_writer.h | 28 char* const buffer_; variable
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_fs.cc | 51 buffer_.resize(0); in DropUnsyncedData()
56 int range = static_cast<int>(buffer_.size()); in DropRandomUnsyncedData()
58 buffer_.resize(truncated_size); in DropRandomUnsyncedData()
93 state_.buffer_.append(data.data(), data.size()); in Append()
106 io_s = target_->Append(state_.buffer_, options, dbg); in Close()
108 state_.buffer_.resize(0); in Close()
134 IOStatus io_s = target_->Append(state_.buffer_, options, dbg); in Sync()
135 state_.buffer_.resize(0); in Sync()
|
| D | fault_injection_test_fs.h | 42 std::string buffer_; member
|