Lines Matching refs:offset
86 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache() argument
87 return file_->InvalidateCache(offset + prefixLength_, length); in InvalidateCache()
92 Status PositionedRead(uint64_t offset, size_t n, Slice* result, in PositionedRead() argument
95 offset += prefixLength_; // Skip prefix in PositionedRead()
96 auto status = file_->PositionedRead(offset, n, result, scratch); in PositionedRead()
100 offset_ = offset + result->size(); in PositionedRead()
101 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in PositionedRead()
127 Status Read(uint64_t offset, size_t n, Slice* result, in Read() argument
130 offset += prefixLength_; in Read()
131 auto status = file_->Read(offset, n, result, scratch); in Read()
135 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in Read()
140 Status Prefetch(uint64_t offset, size_t n) override { in Prefetch() argument
142 return file_->Prefetch(offset + prefixLength_, n); in Prefetch()
179 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache() argument
180 return file_->InvalidateCache(offset + prefixLength_, length); in InvalidateCache()
203 auto offset = file_->GetFileSize(); // size including prefix in Append() local
211 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Append()
224 Status PositionedAppend(const Slice& data, uint64_t offset) override { in PositionedAppend() argument
228 offset += prefixLength_; in PositionedAppend()
235 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in PositionedAppend()
241 status = file_->PositionedAppend(dataToAppend, offset); in PositionedAppend()
277 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache() argument
278 return file_->InvalidateCache(offset + prefixLength_, length); in InvalidateCache()
287 Status RangeSync(uint64_t offset, uint64_t nbytes) override { in RangeSync() argument
288 return file_->RangeSync(offset + prefixLength_, nbytes); in RangeSync()
296 void PrepareWrite(size_t offset, size_t len) override { in PrepareWrite() argument
297 file_->PrepareWrite(offset + prefixLength_, len); in PrepareWrite()
301 Status Allocate(uint64_t offset, uint64_t len) override { in Allocate() argument
302 return file_->Allocate(offset + prefixLength_, len); in Allocate()
329 Status Write(uint64_t offset, const Slice& data) override { in Write() argument
333 offset += prefixLength_; in Write()
340 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Write()
346 status = file_->Write(offset, dataToWrite); in Write()
353 Status Read(uint64_t offset, size_t n, Slice* result, in Read() argument
356 offset += prefixLength_; in Read()
357 auto status = file_->Read(offset, n, result, scratch); in Read()
361 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in Read()