#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