#ifndef CONNECTION_H

#define CONNECTION_H

#include "socket.h"

class Server;

class Connection: public Socket {

public:

	struct Task {

		void *data;

		size_t size;

		size_t completion;

		Task *next;

		inline explicit Task(

			void *data = nullptr,

			size_t size = 0,

			size_t completion = 0,

			Task *next = nullptr

		):

			data(data), size(size), completion(completion), next(next)

			{ assert(!!data == !!size); }

	};

	typedef CounteredQueueMISO<task, &task::next=""> TaskQueue;</task,>

private:

	friend class Protocol;

	friend class Server;

	Server *server;

	Connection *srvPrev, *srvNext;

	bool errorLocal;

	TaskQueue readQueue;

	TaskQueue writeQueue;

	bool open(Protocol &protocol, void *address, size_t addressSize, int sockId, Server *server);

public:

	Connection();

	~Connection();

	bool open(Protocol &protocol, void *address, size_t addressSize);

	bool read(Task &task);

	bool write(Task &task);

private:

	void handleState() override;

	void handleEvents(unsigned int events) override;

protected:

	virtual void onReadReady(Task &task, bool error);

	virtual void onWriteReady(Task &task, bool error);

};

#endif