Method write

src/BufferedConnection.actor.cpp:230–255

}

void BufferedConnection::write(StringRef buf) {
	int remaining = buf.size();
	const uint8_t* ptr = buf.begin();

	PacketBuffer* pb = self->unsent.getWriteBuffer();

	while (remaining) {
		int writable = PacketBuffer::DATA_SIZE - pb->bytes_written;
		if (!writable) {
			pb->next = new PacketBuffer();
			self->unsent.setWriteBuffer(pb->nextPacketBuffer());
			pb = pb->nextPacketBuffer();
			writable = PacketBuffer::DATA_SIZE;
		}

		int to_write = std::min(remaining, writable);

		memcpy(pb->data + pb->bytes_written, ptr, to_write);
		pb->bytes_written += to_write;
		ptr += to_write;

		remaining -= to_write;
	}

	self->on_data_write.trigger();
}

ACTOR Future<Void> doOnBytesAvailable(BufferedConnectionData* self, int count) {
	if (count > self->desired_bytes.get()) {