#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()); }

void Connection::whenWriteToUdp(Time &t) const {

	if (timeLess(lastUdpOutputTime + tunnel.udpKeepAliveDuration, t))

		t = lastUdpOutputTime + tunnel.udpKeepAliveDuration;

	udpSendQueue.whenWriteToUdp(t);

	udpRecvQueue.whenWriteToUdp(t);

}