//
// gsdptxq.cpp
//
// Copyright (c) 2002 Symbian Ltd.  All rights reserved
//

#include "gsdpserver.h"

CGsdpTransmitQueue* CGsdpTransmitQueue::NewL(CGsdpGdpAdapter& aAdapter)
	{
	CGsdpTransmitQueue* self = new (ELeave) CGsdpTransmitQueue(aAdapter);
	CleanupStack::PushL(self);;
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CGsdpTransmitQueue::CGsdpTransmitQueue(CGsdpGdpAdapter& aAdapter)
	: iAdapter(aAdapter)
	{
	}

void CGsdpTransmitQueue::Transmit(TUint32 aGameProtocol, TUint32 aToPort, const TDesC8& aFromAddress, TUint32 aFromPort, const TDesC8& aData)
	{
	// get first free packet slot - drop packet if there isn't one
	TGsdpPacket* packet=AddPacket(aGameProtocol, aToPort, aFromAddress, aFromPort, aData);
	if (!packet)
		return;
	// see if it can be sent
	if(iAdapter.CanSendPacket(*packet))
		{
		iAdapter.SendPacket(*packet);
		FreePacket(*packet);
		}
	}

void CGsdpTransmitQueue::TryToSend()
	{
	TGsdpPacket* packet = iPackets.First();
	
	if(!packet)
		return;
	if(iAdapter.CanSendPacket(*packet))
		{
		iAdapter.SendPacket(*packet);
		}
	}