#ifndef PROTOCOL_H

#define PROTOCOL_H

#include <thread></thread>

#include "utils.h"

#include "connection.h"

#include "server.h"

class Protocol {

public:

	enum State {

		STATE_NONE,

		STATE_OPENING,

		STATE_INITIALIZING,

		STATE_OPEN,

		STATE_CLOSE_REQ,

		STATE_CLOSING,

		STATE_CLOSED,

		STATE_FINISHED

	};

private:

	friend class Server;

	friend class Connection;

	std::thread *thread;

	int epollFd;

	int eventFd;

	std::atomic<state> state;</state>

	std::atomic<state> stateWanted;</state>

	ReadProtector stateProtector;

	std::atomic<int> closeWaiters;</int>

	std::atomic<int> finishWaiters;</int>

	std::condition_variable closeCondition;

	Connection *connFirst, *connLast;

	Connection::Queue connQueue;

	Server *srvFirst, *srvLast;

	Server::Queue srvQueue;

	void wakeup();

	void updateEvents(Connection &connection);

	void initSocket(int sockId);

	void wantState(State state);

	void threadConnQueue();

	void threadConnEvents(Connection &connection, unsigned int events);

	void threadSrvDisconnect(Server &server, Connection &connection, bool error);

	void threadSrvQueue();

	void threadSrvEvents(Server &server, unsigned int events);

	void threadRun();

public:

	Protocol();

	virtual ~Protocol();

	bool open();

	void closeReq();

	void close();

	void closeWait(unsigned long long timeoutUs = 0, bool withReq = true);

};

#endif