Method advance

src/BufferedConnection.actor.cpp:195–213

}

void BufferedConnection::advance(int count) {
	ASSERT(count <= self->total_bytes.get());

	while (count) {
		int to_remove = std::min(count, BCBlock::DATA_SIZE - self->buffer_begin_offset);

		self->desired_bytes.set(self->desired_bytes.get() - to_remove);
		self->total_bytes.set(self->total_bytes.get() - to_remove);

		self->buffer_begin_offset += to_remove;
		if (self->buffer_begin_offset == BCBlock::DATA_SIZE) {
			self->deadlist.push_back(self->buffer.front());
			self->buffer.pop_front();
			self->buffer_begin_offset = 0;
		}

		count -= to_remove;
	}
}

void BufferedConnection::pop(int count) {
	while (count) {