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

/system/update_engine/payload_consumer/
H A Dbzip_extent_writer.cc31 int rc = BZ2_bzDecompressInit(&stream_,
53 stream_.next_in = reinterpret_cast<char*>(const_cast<uint8_t*>(input));
54 stream_.avail_in = input_end - input;
57 stream_.next_out = reinterpret_cast<char*>(output_buffer.data());
58 stream_.avail_out = output_buffer.size();
60 int rc = BZ2_bzDecompress(&stream_);
63 if (stream_.avail_out == output_buffer.size())
68 output_buffer.size() - stream_.avail_out));
71 CHECK_EQ(stream_.avail_in, 0u);
72 if (stream_
[all...]
H A Dbzip_extent_writer.h39 memset(&stream_, 0, sizeof(stream_));
51 bz_stream stream_; // the libbz2 stream member in class:chromeos_update_engine::BzipExtentWriter
H A Dxz_extent_writer.cc54 xz_dec_end(stream_);
60 stream_ = xz_dec_init(XZ_DYNALLOC, kXzMaxDictSize);
61 TEST_AND_RETURN_FALSE(stream_ != nullptr);
87 xz_ret ret = xz_dec_run(stream_, &request);
H A Dxz_extent_writer.h52 xz_dec* stream_{nullptr};
/system/update_engine/common/
H A Dfile_fetcher.cc71 stream_ =
77 if (!stream_) {
88 stream_->SetPosition(offset_, nullptr);
118 ongoing_read_ = stream_->ReadAsync(
172 if (stream_) {
173 stream_->CancelPendingAsyncOperations();
174 stream_->CloseBlocking(nullptr);
175 stream_.reset();
177 // Destroying the |stream_| releases the callback, so we don't have any
H A Dfile_fetcher.h85 // Called from the main loop when a single read from |stream_| succeeds or
97 // the |buffer_| is being used by the |stream_|.
109 brillo::StreamPtr stream_; member in class:chromeos_update_engine::FileFetcher
/system/extras/perfprofd/quipper/base/
H A Dlogging.cc68 stream_ << "Check failed: " << *result;
76 stream_ << "Check failed: " << *result;
81 stream_ << std::endl;
82 std::string str_newline(stream_.str());
H A Dlogging.h472 std::ostream& stream() { return stream_; }
478 std::ostringstream stream_; member in class:logging::LogMessage

Completed in 463 milliseconds