Lines Matching refs:stream_
27 std::unique_ptr<BlockAccessCipherStream> stream_; 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()
101 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in PositionedRead()
110 std::unique_ptr<BlockAccessCipherStream> stream_; member in ROCKSDB_NAMESPACE::EncryptedRandomAccessFile
115 : file_(f), stream_(s), prefixLength_(prefixLength) { } in EncryptedRandomAccessFile()
135 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in Read()
190 std::unique_ptr<BlockAccessCipherStream> stream_; member in ROCKSDB_NAMESPACE::EncryptedWritableFile
196 : WritableFileWrapper(f), file_(f), stream_(s), prefixLength_(prefixLength) { } in EncryptedWritableFile()
211 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Append()
235 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in PositionedAppend()
310 std::unique_ptr<BlockAccessCipherStream> stream_; member in ROCKSDB_NAMESPACE::EncryptedRandomRWFile
315 : file_(f), stream_(s), prefixLength_(prefixLength) {} in EncryptedRandomRWFile()
340 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Write()
361 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in Read()