Lines Matching refs:input_buffer_
47 void Append(Block&& block) { input_buffer_.append(std::move(block)); } in Append()
64 IOVector input_buffer_; member
69 void Append(Block input) { input_buffer_.append(std::move(input)); } in Append()
87 IOVector input_buffer_; member
96 while (available_out > 0 && !input_buffer_.empty()) { in Decode()
97 size_t len = std::min(available_out, input_buffer_.front_size()); in Decode()
98 p = mempcpy(p, input_buffer_.front_data(), len); in Decode()
100 input_buffer_.drop_front(len); in Decode()
103 if (input_buffer_.empty()) { in Decode()
120 while (available_out > 0 && !input_buffer_.empty()) { in Encode()
121 size_t len = std::min(available_out, input_buffer_.front_size()); in Encode()
122 p = mempcpy(p, input_buffer_.front_data(), len); in Encode()
124 input_buffer_.drop_front(len); in Encode()
129 if (input_buffer_.empty()) { in Encode()
143 size_t available_in = input_buffer_.front_size(); in Decode()
144 const uint8_t* next_in = reinterpret_cast<const uint8_t*>(input_buffer_.front_data()); in Decode()
152 size_t bytes_consumed = input_buffer_.front_size() - available_in; in Decode()
153 input_buffer_.drop_front(bytes_consumed); in Decode()
192 size_t available_in = input_buffer_.front_size(); in Encode()
193 const uint8_t* next_in = reinterpret_cast<const uint8_t*>(input_buffer_.front_data()); in Encode()
209 size_t bytes_consumed = input_buffer_.front_size() - available_in; in Encode()
210 input_buffer_.drop_front(bytes_consumed); in Encode()
223 } else if (input_buffer_.empty()) { in Encode()
247 size_t available_in = input_buffer_.front_size(); in Decode()
248 const char* next_in = input_buffer_.front_data(); in Decode()
260 input_buffer_.drop_front(available_in); in Decode()
263 if (!input_buffer_.empty()) { in Decode()
273 return input_buffer_.empty() && lz4_done_ ? DecodeResult::Done in Decode()
310 size_t available_in = input_buffer_.front_size(); in Encode()
311 const char* next_in = input_buffer_.front_data(); in Encode()
341 input_buffer_.drop_front(available_in); in Encode()
396 in.src = input_buffer_.front_data(); in Decode()
397 in.size = input_buffer_.front_size(); in Decode()
413 input_buffer_.drop_front(in.pos); in Decode()
415 if (!input_buffer_.empty()) { in Decode()
425 return input_buffer_.empty() && zstd_done_ ? DecodeResult::Done in Decode()
447 in.src = input_buffer_.front_data(); in Encode()
448 in.size = input_buffer_.front_size(); in Encode()
465 input_buffer_.drop_front(in.pos); in Encode()
471 if (!input_buffer_.empty()) { in Encode()
477 return input_buffer_.empty() ? EncodeResult::NeedInput : EncodeResult::MoreOutput; in Encode()