Class BufferedConnectionData

src/BufferedConnection.actor.cpp:40–70

};

struct BufferedConnectionData {
	explicit BufferedConnectionData(Reference<IConnection> connection);
	~BufferedConnectionData() {
		// Free left over buffers.
		for (auto blk : deadlist) {
			delete blk;
		}
		for (auto blk : buffer) {
			delete blk;
		}

		conn.cancel();
		connection->close();
	}

	Reference<IConnection> connection;
	Future<Void> conn;

	// Blocks that have been advance()d away but not fully popped.  memory needs to be held, but that's it
	std::list<BCBlock*> deadlist;
	int deadlist_begin_offset;
	std::list<BCBlock*> buffer;
	int buffer_begin_offset, buffer_end_offset;
	AsyncVar<int> total_bytes;
	AsyncVar<int> desired_bytes;

	AsyncTrigger on_data_write;
	UnsentPacketQueue unsent;

	void copyInto(uint8_t* buf, int count);
};

ACTOR Future<Void> reader(BufferedConnectionData* self) {
	loop {