Searched refs:current_buffer (Results 1 – 1 of 1) sorted by relevance
51 data_buffer_t *current_buffer; member133 if (reader->current_buffer) in eager_reader_free()134 reader->allocator->free(reader->current_buffer); in eager_reader_free()184 if (!reader->current_buffer) in eager_reader_read()185 reader->current_buffer = fixed_queue_dequeue(reader->buffers); in eager_reader_read()187 size_t bytes_to_copy = reader->current_buffer->length - reader->current_buffer->offset; in eager_reader_read()191 …memcpy(&buffer[bytes_consumed], &reader->current_buffer->data[reader->current_buffer->offset], byt… in eager_reader_read()193 reader->current_buffer->offset += bytes_to_copy; in eager_reader_read()195 if (reader->current_buffer->offset >= reader->current_buffer->length) { in eager_reader_read()196 reader->allocator->free(reader->current_buffer); in eager_reader_read()[all …]