Lines Matching refs:n
25 Status SequentialFileReader::Read(size_t n, Slice* result, char* scratch) { in Read() argument
29 size_t offset = offset_.fetch_add(n); in Read()
33 size_t size = Roundup(offset + n, alignment) - aligned_offset; in Read()
44 std::min(tmp.size() - offset_advance, n)); in Read()
49 s = file_->Read(n, IOOptions(), result, scratch, nullptr); in Read()
55 Status SequentialFileReader::Skip(uint64_t n) { in Skip() argument
58 offset_ += static_cast<size_t>(n); in Skip()
62 return file_->Skip(n); in Skip()
88 IOStatus Read(size_t n, const IOOptions& opts, Slice* result, char* scratch, in Read() argument
97 if (TryReadFromCache(n, &cached_len, scratch) && in Read()
98 (cached_len == n || buffer_.CurrentSize() < readahead_size_)) { in Read()
103 n -= cached_len; in Read()
107 if (n + alignment_ >= readahead_size_) { in Read()
108 s = file_->Read(n, opts, result, scratch + cached_len, dbg); in Read()
121 TryReadFromCache(n, &remaining_len, scratch + cached_len); in Read()
127 IOStatus Skip(uint64_t n) override { in Skip() argument
133 if (read_offset_ + n >= buffer_offset_ + buffer_.CurrentSize()) { in Skip()
135 n -= buffer_offset_ + buffer_.CurrentSize() - read_offset_; in Skip()
139 read_offset_ += n; in Skip()
140 n = 0; in Skip()
143 if (n > 0) { in Skip()
145 s = file_->Skip(n); in Skip()
147 read_offset_ += n; in Skip()
154 IOStatus PositionedRead(uint64_t offset, size_t n, const IOOptions& opts, in PositionedRead() argument
157 return file_->PositionedRead(offset, n, opts, result, scratch, dbg); in PositionedRead()
173 bool TryReadFromCache(size_t n, size_t* cached_len, char* scratch) { in TryReadFromCache() argument
181 buffer_.CurrentSize() - static_cast<size_t>(offset_in_buffer), n); in TryReadFromCache()
190 IOStatus ReadIntoBuffer(size_t n, const IOOptions& opts, in ReadIntoBuffer() argument
192 if (n > buffer_.Capacity()) { in ReadIntoBuffer()
193 n = buffer_.Capacity(); in ReadIntoBuffer()
195 assert(IsFileSectorAligned(n, alignment_)); in ReadIntoBuffer()
197 IOStatus s = file_->Read(n, opts, &result, buffer_.BufferStart(), dbg); in ReadIntoBuffer()