Searched refs:stream_ (Results 1 – 9 of 9) sorted by relevance
| /system/update_engine/payload_consumer/ |
| D | bzip_extent_writer.cc | 29 TEST_AND_RETURN(BZ2_bzDecompressEnd(&stream_) == BZ_OK); in ~BzipExtentWriter()
36 int rc = BZ2_bzDecompressInit(&stream_, in Init()
58 stream_.next_in = reinterpret_cast<char*>(const_cast<uint8_t*>(input)); in Write()
59 stream_.avail_in = input_end - input; in Write()
62 stream_.next_out = reinterpret_cast<char*>(output_buffer.data()); in Write()
63 stream_.avail_out = output_buffer.size(); in Write()
65 int rc = BZ2_bzDecompress(&stream_); in Write()
68 if (stream_.avail_out == output_buffer.size()) in Write()
72 output_buffer.data(), output_buffer.size() - stream_.avail_out)); in Write()
75 CHECK_EQ(stream_.avail_in, 0u); in Write()
[all …]
|
| D | bzip_extent_writer.h | 38 memset(&stream_, 0, sizeof(stream_)); in BzipExtentWriter()
48 bz_stream stream_{}; // the libbz2 stream
|
| D | xz_extent_writer.cc | 57 stream_.reset(); in ~XzExtentWriter()
63 stream_.reset(xz_dec_init(XZ_DYNALLOC, kXzMaxDictSize)); in Init()
64 TEST_AND_RETURN_FALSE(stream_ != nullptr); in Init()
90 xz_ret ret = xz_dec_run(stream_.get(), &request); in Write()
|
| D | xz_extent_writer.h | 54 std::unique_ptr<xz_dec, xz_deleter> stream_{nullptr};
|
| /system/update_engine/common/ |
| D | file_fetcher.cc | 76 stream_ = brillo::FileStream::FromFileDescriptor(fd, false, nullptr); in BeginTransfer()
79 stream_ = in BeginTransfer()
86 if (!stream_) { in BeginTransfer()
97 stream_->SetPosition(offset_, nullptr); in BeginTransfer()
127 ongoing_read_ = stream_->ReadAsync( in ScheduleRead()
182 if (stream_) { in CleanUp()
183 stream_->CancelPendingAsyncOperations(); in CleanUp()
184 stream_->CloseBlocking(nullptr); in CleanUp()
185 stream_.reset(); in CleanUp()
|
| D | file_fetcher.h | 114 brillo::StreamPtr stream_; variable
|
| /system/tools/aidl/ |
| D | options.h | 58 std::ostringstream stream_; variable
62 stream_ << t;
68 stream_ << t;
74 f(stream_);
220 bool Ok() const { return error_message_.stream_.str().empty(); } in Ok()
222 string GetErrorMessage() const { return error_message_.stream_.str(); } in GetErrorMessage()
|
| /system/core/fs_mgr/libsnapshot/libsnapshot_cow/ |
| D | cow_decompress.h | 64 void set_stream(IByteStream* stream) { stream_ = stream; } in set_stream()
67 IByteStream* stream_ = nullptr;
|
| D | cow_decompress.cpp | 99 stream_remaining_ = stream_->Size(); in Decompress()
107 ssize_t read = stream_->Read(chunk, max_read); in Decompress()
283 std::string input_buffer(stream_->Size(), '\0'); in Decompress()
284 ssize_t streamed_in = stream_->ReadFully(input_buffer.data(), input_buffer.size()); in Decompress()
288 CHECK_EQ(streamed_in, stream_->Size()); in Decompress()
362 input_buffer.resize(stream_->Size()); in Decompress()
363 size_t bytes_read = stream_->Read(input_buffer.data(), input_buffer.size()); in Decompress()
|