Method peekExact

src/BufferedConnection.actor.cpp:168–193

}

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

	if (self->buffer_begin_offset + count <= BCBlock::DATA_SIZE) {
		/* requested byte range is in a single block */
		return {self->buffer.front()->data + self->buffer_begin_offset, count};
	} else {
		/* find the _last_ block containing data for this range */
		int remaining = count - (BCBlock::DATA_SIZE - self->buffer_begin_offset);

		auto it = ++(self->buffer.begin());

		while (remaining > BCBlock::DATA_SIZE) {
			++it;
			remaining -= BCBlock::DATA_SIZE;
		}

		/* Allocate memory in the arena of the last block from which we are copying, and copy the requested range into
		 * the newly allocated memory */
		auto* buf = new ((*it)->arena) uint8_t[count];

		self->copyInto(buf, count);

		return {buf, count};
	}
}

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