#ifndef UDPSENDQUEUE_H

#define UDPSENDQUEUE_H

#include "common.h"

class Connection;

class UdpSendQueue {

public:

	struct Entry {

		Entry *prev, *next;

		Time resendTime;

		unsigned int index;

		unsigned short size;

		unsigned char data[PACKET_SIZE];

	};

public:

	Connection &connection;

private:

	Time nextSendTime;

	Time nextPartialSendTime;

	bool finalEntryAdded;

	unsigned int nextIndex;

	Entry *freeFirst;

	Entry *busyFirst, *busyLast;

	Entry entries[PACKETS_COUNT];

	Entry* allocEntry();

	void moveToEnd(Entry *e);

	void freeEntry(Entry *e);

public:

	explicit UdpSendQueue(Connection &connection);

	~UdpSendQueue();

	void confirm(unsigned int index, const unsigned char *bits, unsigned int bitsCount);

	bool sendUdpSingle();

	int sendUdp();

	bool canSentToUdp() const;

	void whenWriteToUdp(Time &t) const;

};

#endif