#ifndef TCPQUEUE_H

#define TCPQUEUE_H

#include "common.h"

class Connection;

class TcpQueue {

public:

	enum { ALLOCATED_SIZE = TCP_BUFFER_SIZE + 1 };

public:

	Connection &connection;

private:

	unsigned char buffer[ALLOCATED_SIZE];

	int begin;

	int end;

public:

	explicit TcpQueue(Connection &connection);

	~TcpQueue();

	inline int busySize() const

		{ return end < begin ? end + ALLOCATED_SIZE - begin : end - begin; }

	inline int freeSize() const

		{ return TCP_BUFFER_SIZE - busySize(); }

	bool push(const void *data, int size);

	bool pop(void *data, int size);

	int readFromTcp();

	int writeToTcp();

};

#endif