Lines Matching defs:Size
21 explicit ShrinkableIOBufferWithSize(int size)
22 : IOBufferWithSize(size) {}
68 bool WebSocketInflater::AddBytes(const char* data, size_t size) {
69 if (!size)
74 input_queue_.Push(data, size);
78 int result = InflateWithFlush(data, size);
80 input_queue_.Push(&data[size - stream_->avail_in], stream_->avail_in);
89 scoped_refptr<IOBufferWithSize> WebSocketInflater::GetOutput(size_t size) {
91 new ShrinkableIOBufferWithSize(size);
94 while (num_bytes_copied < size && output_buffer_.Size() > 0) {
96 std::min(output_buffer_.Size(), size - num_bytes_copied);
177 size_t WebSocketInflater::OutputBuffer::Size() const {
178 return (tail_ + buffer_.size() - head_) % buffer_.size();
182 DCHECK_LT(tail_, buffer_.size());
184 std::min(capacity_ - Size(), buffer_.size() - tail_));
187 void WebSocketInflater::OutputBuffer::Read(char* dest, size_t size) {
188 DCHECK_LE(size, Size());
192 size_t num_bytes_to_copy = std::min(size, buffer_.size() - head_);
193 DCHECK_LT(head_, buffer_.size());
199 if (num_bytes_copied == size)
202 size_t num_bytes_to_copy = size - num_bytes_copied;
204 DCHECK_LT(head_, buffer_.size());
208 DCHECK_EQ(size, num_bytes_copied);
213 DCHECK_LE(advance, Size());
214 head_ = (head_ + advance) % buffer_.size();
218 DCHECK_LE(advance + Size(), capacity_);
219 tail_ = (tail_ + advance) % buffer_.size();
229 if (buffers_.size() == 1) {
237 void WebSocketInflater::InputQueue::Push(const char* data, size_t size) {
238 if (!size)
243 num_copied_bytes += PushToLastBuffer(data, size);
245 while (num_copied_bytes < size) {
251 PushToLastBuffer(&data[num_copied_bytes], size - num_copied_bytes);
255 void WebSocketInflater::InputQueue::Consume(size_t size) {
257 DCHECK_LE(size + head_of_first_buffer_, capacity_);
259 head_of_first_buffer_ += size;
264 if (buffers_.size() == 1 && head_of_first_buffer_ == tail_of_last_buffer_) {
272 size_t size) {
274 size_t num_bytes_to_copy = std::min(size, capacity_ - tail_of_last_buffer_);
