| /system/update_engine/payload_consumer/ |
| D | bzip_extent_writer.cc | 28 TEST_AND_RETURN(BZ2_bzDecompressEnd(&stream_) == BZ_OK); in ~BzipExtentWriter()
35 int rc = BZ2_bzDecompressInit(&stream_, in Init()
57 stream_.next_in = reinterpret_cast<char*>(const_cast<uint8_t*>(input)); in Write()
58 stream_.avail_in = input_end - input; in Write()
61 stream_.next_out = reinterpret_cast<char*>(output_buffer.data()); in Write()
62 stream_.avail_out = output_buffer.size(); in Write()
64 int rc = BZ2_bzDecompress(&stream_); in Write()
67 if (stream_.avail_out == output_buffer.size()) in Write()
71 output_buffer.data(), output_buffer.size() - stream_.avail_out)); in Write()
74 CHECK_EQ(stream_.avail_in, 0u); in Write()
[all …]
|
| D | bzip_extent_writer.h | 39 memset(&stream_, 0, sizeof(stream_)); in BzipExtentWriter()
49 bz_stream stream_; // the libbz2 stream variable
|
| D | xz_extent_writer.cc | 56 xz_dec_end(stream_); in ~XzExtentWriter()
62 stream_ = xz_dec_init(XZ_DYNALLOC, kXzMaxDictSize); in Init()
63 TEST_AND_RETURN_FALSE(stream_ != nullptr); in Init()
89 xz_ret ret = xz_dec_run(stream_, &request); in Write()
|
| D | xz_extent_writer.h | 50 xz_dec* stream_{nullptr};
|
| /system/bt/gd/packet/parser/ |
| D | logging.h | 46 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/ |
| 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 | 115 brillo::StreamPtr stream_; variable
|
| /system/core/fs_mgr/libsnapshot/ |
| D | inspect_cow.cpp | 49 size_t old_size = stream_.size(); in GetBuffer()
50 stream_.resize(old_size + requested, '\0'); in GetBuffer()
52 return stream_.data() + old_size; in GetBuffer()
55 void Reset() { stream_.clear(); } in Reset()
57 std::string& stream() { return stream_; } in stream()
60 std::string stream_; member in android::snapshot::StringSink
|
| D | cow_decompress.h | 48 void set_stream(IByteStream* stream) { stream_ = stream; } in set_stream()
52 IByteStream* stream_ = nullptr;
|
| D | cow_decompress.cpp | 34 size_t stream_remaining = stream_->Size(); in Decompress()
48 if (!stream_->Read(buffer_pos, bytes_to_read, &read)) { in Decompress()
96 stream_remaining_ = stream_->Size(); in Decompress()
102 if (!stream_->Read(chunk, read, &read)) { in Decompress()
|
| D | make_cow_from_ab_ota.cpp | 289 PuffOutputStream(std::vector<uint8_t>& stream) : stream_(stream), pos_(0) {} in PuffOutputStream()
292 *size = stream_.size(); in GetSize()
300 if (offset > stream_.size()) { in Seek()
307 if (stream_.size() - pos_ < length) { in Read()
310 memcpy(buffer, &stream_[0] + pos_, length); in Read()
315 auto remaining = stream_.size() - pos_; in Write()
317 stream_.resize(stream_.size() + (length - remaining)); in Write()
319 memcpy(&stream_[0] + pos_, buffer, length); in Write()
326 std::vector<uint8_t>& stream_; member in android::snapshot::PuffOutputStream
|
| D | cow_api_test.cpp | 51 size_t old_size = stream_.size(); in GetBuffer()
52 stream_.resize(old_size + requested, '\0'); in GetBuffer()
54 return stream_.data() + old_size; in GetBuffer()
57 void Reset() { stream_.clear(); } in Reset()
59 std::string& stream() { return stream_; } in stream()
62 std::string stream_; member in android::snapshot::StringSink
|
| /system/tools/aidl/ |
| D | options.h | 40 std::ostringstream stream_; variable
44 stream_ << t;
50 stream_ << t;
56 f(stream_);
150 bool Ok() const { return error_message_.stream_.str().empty(); } in Ok()
152 string GetErrorMessage() const { return error_message_.stream_.str(); } in GetErrorMessage()
|