Searched refs:CurrentSize (Results 1 – 8 of 8) sorted by relevance
| /rocksdb-6.9/file/ |
| D | writable_file_writer.cc | 41 if (buf_.Capacity() - buf_.CurrentSize() < left) { in Append()
48 if (desired_capacity - buf_.CurrentSize() >= left || in Append()
58 if (buf_.CurrentSize() > 0) { in Append()
64 assert(buf_.CurrentSize() == 0); in Append()
85 assert(buf_.CurrentSize() == 0); in Append()
100 size_t cap = buf_.Capacity() - buf_.CurrentSize(); in Pad()
115 cap = buf_.Capacity() - buf_.CurrentSize(); in Pad()
173 if (buf_.CurrentSize() > 0) { in Flush()
181 s = WriteBuffered(buf_.BufferStart(), buf_.CurrentSize()); in Flush()
375 size_t leftover_tail = buf_.CurrentSize() - file_advance; in WriteDirect()
[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()
112 if (offset + n > buffer_offset_ + buffer_.CurrentSize()) { in TryReadFromCache()
|
| D | sequence_file_reader.cc | 98 (cached_len == n || buffer_.CurrentSize() < readahead_size_)) { in Read()
131 if (buffer_.CurrentSize() > 0) { in Skip()
133 if (read_offset_ + n >= buffer_offset_ + buffer_.CurrentSize()) { in Skip()
135 n -= buffer_offset_ + buffer_.CurrentSize() - read_offset_; in Skip()
136 read_offset_ = buffer_offset_ + buffer_.CurrentSize(); in Skip()
175 read_offset_ >= buffer_offset_ + buffer_.CurrentSize()) { in TryReadFromCache()
181 buffer_.CurrentSize() - static_cast<size_t>(offset_in_buffer), n); in TryReadFromCache()
|
| D | random_access_file_reader.cc | 47 while (buf.CurrentSize() < read_size) { in Read()
51 buf.Capacity() - buf.CurrentSize(), buf.Alignment(), in Read()
54 assert(buf.CurrentSize() == 0); in Read()
63 orig_offset = aligned_offset + buf.CurrentSize(); in Read()
67 s = file_->Read(aligned_offset + buf.CurrentSize(), allowed, in Read()
76 buf.Size(buf.CurrentSize() + tmp.size()); in Read()
82 if (s.ok() && offset_advance < buf.CurrentSize()) { in Read()
83 res_len = std::min(buf.CurrentSize() - offset_advance, n); in Read()
|
| D | readahead_raf.cc | 53 (cached_len == n || buffer_.CurrentSize() < readahead_size_)) { in Read()
114 offset >= buffer_offset_ + buffer_.CurrentSize()) { in TryReadFromCache()
120 buffer_.CurrentSize() - static_cast<size_t>(offset_in_buffer), n); in TryReadFromCache()
|
| D | writable_file_writer.h | 158 bool TEST_BufferIsEmpty() { return buf_.CurrentSize() == 0; } in TEST_BufferIsEmpty()
|
| /rocksdb-6.9/env/ |
| D | env_encryption.cc | 211 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Append()
215 dataToAppend = Slice(buf.BufferStart(), buf.CurrentSize()); in Append()
235 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in PositionedAppend()
239 dataToAppend = Slice(buf.BufferStart(), buf.CurrentSize()); in PositionedAppend()
340 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Write()
344 dataToWrite = Slice(buf.BufferStart(), buf.CurrentSize()); in Write()
482 prefixSlice = Slice(prefixBuf.BufferStart(), prefixBuf.CurrentSize()); in NewWritableFile()
529 prefixSlice = Slice(prefixBuf.BufferStart(), prefixBuf.CurrentSize()); in ReopenWritableFile()
571 prefixSlice = Slice(prefixBuf.BufferStart(), prefixBuf.CurrentSize()); in ReuseWritableFile()
627 prefixSlice = Slice(prefixBuf.BufferStart(), prefixBuf.CurrentSize()); in NewRandomRWFile()
|
| /rocksdb-6.9/util/ |
| D | aligned_buffer.h | 105 size_t CurrentSize() const { in CurrentSize() function
|