// gsdprxq.cpp
//
// Receive queue for the GSDP server
//
// Copyright (c) 2000-2002 Symbian Ltd.  All rights reserved.

#include "gsdpserver.h"

/*
	CGsdpReceiveQueue
*/

// construct/destruct
CGsdpReceiveQueue* CGsdpReceiveQueue::NewL(CGsdpServer& aServer)
	{
	CGsdpReceiveQueue* self = new (ELeave) CGsdpReceiveQueue(aServer);
	CleanupStack::PushL(self);;
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CGsdpReceiveQueue::CGsdpReceiveQueue(CGsdpServer& aServer)
	: iServer(aServer)
	{
	}

// functions

void CGsdpReceiveQueue::Receive(TUint32 aGameProtocol, TUint32 aToPort, const TDesC8& aFromAddress, TUint32 aFromPort, const TDesC8& aData)
	{
	TGsdpPacket* packet=AddPacket(aGameProtocol, aToPort, aFromAddress, aFromPort, aData);
	if (!packet)
		return;
	CGsdpSession* session=iServer.SessionForPacket(*packet);
	if (!session)
		return;
	session->ReceivePacket(*packet);
	}

void CGsdpReceiveQueue::CheckPackets(CGsdpSession* aSession)
	{
	TSglQueIter<TGsdpPacket> packetIter(iPackets);
	for (TGsdpPacket* packet=packetIter++; packet; packet=packetIter++)
		{
		if (aSession->CanReceivePacket(*packet))
			{
			aSession->ReceivePacket(*packet);
			break;
			}
		}
	}