Home
last modified time | relevance | path

Searched refs:stream_ (Results 1 – 8 of 8) sorted by relevance

/system/update_engine/payload_consumer/
Dbzip_extent_writer.cc28 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 …]
Dbzip_extent_writer.h39 memset(&stream_, 0, sizeof(stream_)); in BzipExtentWriter()
50 bz_stream stream_; // the libbz2 stream variable
Dxz_extent_writer.cc56 xz_dec_end(stream_); in ~XzExtentWriter()
63 stream_ = 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_, &request); in Write()
Dxz_extent_writer.h51 xz_dec* stream_{nullptr};
/system/bt/gd/packet/parser/
Dlogging.h46 stream_ << "\033[1mLine " << loc_.GetLine() << ": "; in Init()
50 stream_ << "\033[1;31m"; in Init()
51 stream_ << "ERROR: "; in Init()
52 stream_ << "\033[0m"; in Init()
54 stream_ << "\033[1;m"; in Init()
55 stream_ << "DEBUG: "; in Init()
56 stream_ << "\033[0m"; in Init()
63 std::cerr << stream_.str() << "\n"; in ~LogMessage()
78 return stream_; in stream()
82 std::ostringstream stream_;
/system/update_engine/common/
Dfile_fetcher.cc76 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()
Dfile_fetcher.h115 brillo::StreamPtr stream_; variable
/system/tools/aidl/
Doptions.h39 std::ostringstream stream_; variable
43 stream_ << t;
49 stream_ << t;
55 f(stream_);
130 bool Ok() const { return error_message_.stream_.str().empty(); } in Ok()
132 string GetErrorMessage() const { return error_message_.stream_.str(); } in GetErrorMessage()