// Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of "Eclipse Public License v1.0"

// which accompanies this distribution, and is available

// at the URL "http://www.eclipse.org/legal/epl-v10.html".

//

// Initial Contributors:

// Nokia Corporation - initial contribution.

//

// Contributors:

//

// Description:

//

#include <es_ini.h>

#include <flow.h>

#include "iface.h"

#include "context.h"

#include "async_request.h"

#include "tc.h"

#include "guqos_log.h"

#include "guqos.h"

#ifdef _LOG

// Ugly use of function from another module (context.cpp), but this debugging only!

extern void LogPacketFilter(const TPacketFilter& aFilter);

#endif

CFlowData* CFlowData::NewL(CFlowContext& aHandle, CNif& aNif, CFlowData *aNext)

	{

	CFlowData* flowData = new (ELeave) CFlowData(aHandle, aNif);

	CleanupStack::PushL(flowData);

	flowData->ConstructL();

	CleanupStack::Pop();

	flowData->iNext = aNext;

	return flowData;

	}

CFlowData* CFlowData::Find(const CFlowContext* aHandle, CFlowData *aList)

	{

	while (aList)

		{

		if (&aList->iFlowContext == aHandle)

			break;

		aList = aList->iNext;

		}

	return aList;

	}

CFlowData* CFlowData::Remove(const CFlowContext* aHandle, CFlowData **aList)

	{

	CFlowData* p = NULL;

	for ( ; (p = *aList) != NULL; aList = &p->iNext)

		{

		if (&p->iFlowContext == aHandle)

			{

			*aList = p->iNext;

			break;

			}

		}

	return p;

	}

void CFlowData::SetContext(CPdpContext *aContext)

	/**

	* Associate the flow with a new context (or none).

	*

	* Move the flow from one context to another. The

	* internal CClose reuqest is not triggered. (It's

	* only used in destructor).

	*

	* @param aContext The new context (or NULL)

	*/

	{

	if (iContext == aContext)

		{

		// Already attache to this context (or NONE) -- nothing to do.

		return;

		}

	if (iContext)

		{

		// Remove from previous context.

		iLink.Deque();

		iContext->FlowDetached();

		}

	iContext = aContext;

	if (iContext)

		{

		// Add to new context.

		iContext->Flows().AddLast(*this);

		iContext->FlowAttached();

		}

	MEventInterface *notifier = Nif().Module().QoSEvent();

	if (notifier)

		{

		// Determine the blocked or unblocked status for the flow

		// and notify upwards accordingly...

		// Throw away "const". The MEventInterface is misdeclared to

		// use non-const reference parameter, when const reference

		// would be the correct way...

		if (iContext == NULL || iContext->IsFlowBlocked())

			notifier->BlockFlow((CFlowContext &)iFlowContext);

		else

			notifier->UnBlockFlow((CFlowContext &)iFlowContext);

		}

	}

CFlowData::CFlowData(CFlowContext& aHandle, CNif& aNif) : 

	iNif(aNif), iFlowContext(aHandle)

	{

	iContext = NULL;

	// Initialize constant filter values from TPacketHead.

	const TPacketHead& h = aHandle.iHead;

	Mem::Copy(iPacketFilter.iSrcAddr, h.ip6.DstAddr().u.iAddr8, sizeof(iPacketFilter.iSrcAddr));

	Mem::Fill(iPacketFilter.iSrcAddrSubnetMask, sizeof(iPacketFilter.iSrcAddrSubnetMask), 0xFF);

	iPacketFilter.iProtocolNumberOrNextHeader = h.iProtocol;

	iPacketFilter.iSrcPortMin = h.iDstPort;

	iPacketFilter.iSrcPortMax = h.iDstPort;

	iPacketFilter.iDestPortMin = h.iSrcPort;

	iPacketFilter.iDestPortMax = h.iSrcPort;

	iPacketFilter.iTOSorTrafficClass = 0;

	LOG(Log::Printf(_L("new\tflow[%u] size=%d"), (TInt)this, sizeof(*this)));

	LOG(LogPacketFilter(iPacketFilter));

	// The filter is for the *INCOMING* traffic! Predicting the values

	// of the following fields from the *OUTGOING* flow would be

	// dubious!!

	/* iPacketFilter.iIPSecSPI = ??? */

	/* iPacketFilter.iTOSorTrafficClass = h.ip6.TrafficClass() ? */

	/* iPacketFilter.iFlowLabel = h.ip6.FlowLabel() ? */

	}

CFlowData::~CFlowData()

	{

	if (iContext)

		{

		// The flow is still attached to a contex.

		iLink.Deque();

		iContext->FlowDetached();

		}

	LOG(Log::Printf(_L("~\tflow[%u]"), (TInt)this));

	}

void CFlowData::ConstructL()

	{

	}

TInt CFlowData::Send(RMBufChain& aPacket, RMBufSendInfo& aInfo)

	{

	// Note: the fact that we are here, means that the CFlowContex in the aInfo

	// is same as CFlowContext associated with CFlowData. ASSERT is only a

	// remainder of this and never expect to fire.

	ASSERT(aInfo.iFlow.FlowContext() == &iFlowContext);

	if (iContext)

		{

		aInfo.iDstAddr.SetPort(iContext->ContextId());

		// Note: this assumes that the Send below does to come back

		// and delete structures from under us! If this becomes

		// possible, then at least CFlowData and possibly CPdpContext

		// need to be protected against destruction...

		const TInt ret = aInfo.iFlow.FlowContext()->Send(aPacket);

		if (ret <= 0)

			{

			// Packet accepted, but cannot send any more packets

			// to this context, until it is unblocked.

			LOG(Log::Printf(_L("Send\tflow[%u] returns %d, blocking PDP context id = %d"), (TInt)this, ret, iContext->ContextId()));

			iContext->Block();

			}

		}

	else

		{

		LOG(Log::Printf(_L("Send\tflow[%u] has no PDP context -- packet dropped"), (TInt)this));

		aInfo.iFlow.Close();

		aPacket.Free();

		}

	// Always eat the packet!

	return 1;

	}