#include "tunnel.h"
#include "connection.h"



Connection::Connection(const Args &args):
	tunnel(args.tunnel),
	id(args.id),
	tcpSockId(args.tcpSockId),
	udpActive(true),
	lastUdpInputTime(tunnel.time),
	lastUdpOutputTime(tunnel.time),
	tcpSendQueue(*this),
	tcpRecvQueue(*this),
	udpSendQueue(*this),
	udpRecvQueue(*this)
	{ }


Connection::~Connection() { }


bool Connection::wantReadFromTcp() const
	{ return tcpSockId >= 0 && udpActive && tcpRecvQueue.freeSize() > 0; }


bool Connection::wantWriteToTcp() const
	{ return tcpSockId >= 0 && (tcpSendQueue.busySize() > 0 || udpRecvQueue.canSentToTcp()); }


Time Connection::whenWriteToUdp() const {
	Time t = lastUdpOutputTime + tunnel.udpKeepAliveDuration;
	udpSendQueue.whenWriteToUdp(t);
	udpRecvQueue.whenWriteToUdp(t);
	return t;
}