Home | History | Annotate | Download | only in payload_consumer

Lines Matching refs:stream_

31   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_.avail_in == 0)
77 if (stream_.avail_in || !input_buffer_.empty()) {
78 brillo::Blob new_input_buffer(input_end - stream_.avail_in, input_end);
87 TEST_AND_RETURN_FALSE(BZ2_bzDecompressEnd(&stream_) == BZ_OK);