// 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 <in_iface.h>

#include "context.h"
#include "async_request.h"
#include "iface.h"
#include "tc.h"
#include "guqos.h"
#include "guqos_log.h"

CNif* CNif::NewL(CNifIfBase& aInterface, CModuleGuqos& aModule)
	{
	CNif* nif = new (ELeave) CNif(aInterface, aModule);
	CleanupStack::PushL(nif);
	nif->ConstructL();
	CleanupStack::Pop();
	return nif;
	}

//	XNifTimeoutLinkage
//	******************
//	Glue to bind timeout callback from the timeout manager into Timeout() call
//	on the CPdpContext
//
//	*NOTE*
//		This kludgery is all static and compile time, and only used in the constructor
//		of CPdpContext.
//

// This ungainly manoevure is forced on us because the offset is not evaluated early enough by GCC3.4 to be
// passed as a template parameter
#if defined(__X86GCC__) || defined(__GCCE__)
#define KNifTimeoutOffset 2144
__ASSERT_COMPILE(KNifTimeoutOffset == _FOFF(CNif, iTimeout));
#else
#define KNifTimeoutOffset _FOFF(CNif, iTimeout)
#endif

class XNifTimeoutLinkage : public TimeoutLinkage<CNif, KNifTimeoutOffset>
	{
public:
	static void Timeout(RTimeout &aLink, const TTime & /*aNow*/, TAny * /*aPtr*/)
		{
		Object(aLink)->RunPendingRequests();
		}
	};

CNif::CNif(CNifIfBase& aNif, CModuleGuqos& aModule) : iNif(aNif), iModule(aModule), iTimeout(XNifTimeoutLinkage::Timeout)
	{
	LOG(Log::Printf(_L("new\tCNif[%u] size=%d"), (TInt)this, sizeof(*this)));
	iContexts.SetOffset(_FOFF(CPdpContext, iNext));
	iPending.SetOffset(_FOFF(CRequestBase, iLink));
	}

void CNif::ConstructL()
	{
	// The instance for the primary context exists always for CNif
	iPrimary = CPdpContext::NewL(*this, EPrimaryContext, 0);
	AddContext(*iPrimary);

	User::LeaveIfError(RegisterEventHandler());

	// Get IapId from Nif
	TSoIfConnectionInfo netinfo;
	TPckg<TSoIfConnectionInfo> option(netinfo);
	if (iNif.Control(KSOLInterface, KSoIfGetConnectionInfo, option) == KErrNone)
		iIapId = netinfo.iIAPId;
	}

CNif::~CNif()
	{
	LOG(Log::Printf(_L("~\tCNif[%u] Start"), (TInt)this));
	// No upcalls from NIF, we are in destructor!
	CloseInterface();

	// Unconditionallly terminate all request activities

	// Note: CompleteAndDestruct ends up calling "CloseRequest",
	// which may attempt to activate the next request in queue. To avoid
	// this, set iCurrentRequest to NULL.
	iCurrentRequest = NULL;
	while (!iPending.IsEmpty())
		{
		CRequestBase* request = iPending.First();
		request->CompleteAndDestruct(KErrDied, NULL);
		}

	// Remove all PDP Contexts from NIF and GUQOS
	while (!iContexts.IsEmpty())
		{
		CPdpContext *context = iContexts.First();
		// Remove context from iContexts list before
		// giving control out (to NIF) After this
		// the context instance is no more "reachable"
		// from anywhere else.
		RemoveContext(*context);
		context->Delete();	// Delete context from NIF
		delete context;
		}
	iContexts.Reset();
	iTimeout.Cancel();
	LOG(Log::Printf(_L("\tCNif[%u] Destruction Completed"), (TInt)this));
	}

// Initialize the iParameters and return reference
TContextParameters& CNif::ContextParameters()
	{
	//?? Hope this doesn't generate a memory leak?
	//?? is iParameters.iContextConfig.Reset() required instead?
	iParameters = TContextParameters();
	return iParameters;
	}


CPdpContext* CNif::FindContext(TInt aContextId)
	{
	TContextIter iter(iContexts);
	CPdpContext *context;

	while ((context = iter++) != NULL)
		if (context->ContextId() == aContextId)
			return context;
	return NULL;
	}
	
CPdpContext* CNif::FindChannel(TInt aChannelId)
	{
	TContextIter iter(iContexts);
	CPdpContext *context;

	while ((context = iter++) != NULL)
		if (context->ChannelId() == aChannelId)
			return context;
	return NULL;
	}


// Choose new default Pdp context with the highest QoS profile (according to TS 23.107).
//
// *Note*
//		Because in 3GPP there can be only ONE Context without any TFT's, this code
//		assumes that the lower layer (NIF) has already deleted the current primary
//		context. If this is not true, the TFT removal will fail at 3GPP level!
void CNif::SelectNewDefaultContext()
	{
	TContextIter iter(iContexts);
	CPdpContext* context;
	CPdpContext* highestQoS=NULL;

	while ((context = iter++) != NULL)
		{
		if (context == DefaultPdpContext())
			continue;	// Exclude the current default from the search.

		//lint -e{961} would want terminating 'else' (we don't)
		if (!highestQoS)
			highestQoS = context;
		else if (context->GetQoSRanking() < highestQoS->GetQoSRanking())
			highestQoS = context;
		}
	if (highestQoS == NULL)
		{
		// No other contexts available, cannot delete or change the primary!
		LOG(Log::Printf(_L("\tOnly primary context available -- cannot be deleted")));
		return;
		}
	//
	// Assign the new default context!
	// (iPrimary pointer is only additional reference, it does not "own" the
	// pointed object, thus just overwriting it is ok -- all contexts are in
	// iContexts list).
	iPrimary = highestQoS;
	LOG(Log::Printf(_L("\tContext %d (channel=%d) is the new default context"), iPrimary->ContextId(), iPrimary->ChannelId()));
	// Use the CClose request to clean out all TFT filters
	// from the context (when context is primary, the RemoveFilters
	// removes all, regardless of how many flows are connected).
	CClose* request = CClose::New(*highestQoS);
	if (request)
		{
		highestQoS->Nif().AddRequest(*request);
		}
	else
		{
		// If allocation of the request fails, there is not much that can
		// be done, the filters will be left there and packets not matching
		// them will be dropped. However, the cleanup will be attempted
		// again any time the context is modified in such way that filters
		// need to be removed.
		LOG(Log::Printf(_L("\tCould not remove TFTs from new default context -- no room for request")));
		}
	}

// delete PDP context, and bind flows using this context to default PDP context
void CNif::DeletePdpContext(CPdpContext* aContext)
	{

	if (DefaultPdpContext() == aContext)
		{
		// Attempt to select a new default context (may fail)
		SelectNewDefaultContext();
		}

	CPdpContext *pdpDefault = DefaultPdpContext();
	if (pdpDefault != aContext)
		{
		while (!aContext->Flows().IsEmpty())
			{
			CFlowData* flow = aContext->Flows().First();
			// The SetContext will remove the flow from old
			// context, and eventually the aContext->Flows()
			// *MUST* become empty
			// (because aContext != pdpContext)
			flow->SetContext(pdpDefault);
			}
		RemoveContext(*aContext);
		delete aContext;
		}
	else
		{
		// Cannot delete the default context, just block flows (as the
		// context is not actually existing any more).
		aContext->Block();
		}
	}

TInt CNif::RegisterEventHandler()
	{
	TPckgBuf<TEvent> opt;
	opt().iEvent = this;
	LOG(Log::Printf(_L("\tcall NIF Control(KRegisterEventHandler)")));
	return iNif.Control(KSOLInterface, KRegisterEventHandler, opt);
	}

TInt CNif::SetEvents(TBool aValue)
	{
	TPckgBuf<TBool> opt;
	opt() = aValue;
	LOG(Log::Printf(_L("\tcall NIF Control(KContextSetEvents. %d)"), aValue));
	return iNif.Control(KSOLInterface, KContextSetEvents, opt);
	}


// event received from Nif when the Network status changes
TInt CNif::NetworkStatusEvent(const TNetworkParameters& aNetworkEvent)
	{
	switch(aNetworkEvent.iNetworkEventCode)
		{

	case KNetworkConnectionLost:
		break;

	case KNetworkInterfaceDown:
		iModule.IfManager()->DeleteNif(this);
		break;

	default:
		return KErrNotSupported;
		}

	return KErrNone;
	}


// Receive events from umtsnif
TInt CNif::Event(CProtocolBase* aProtocol, TUint aName, TDes8& aOption, TAny* /*aSource*/)
	{
	LOG(Log::Printf(_L("")));	// just make empty line into log
#ifdef _LOG
	TBuf<40> name;

	switch(aName)
		{
		case KContextDeleteEvent:				name.Append(_L("KContextDeleteEvent"));				break;
		case KContextActivateEvent:				name.Append(_L("KContextActivateEvent"));			break;
		case KContextParametersChangeEvent:		name.Append(_L("KContextParametersChangeEvent"));	break;
		case KContextBlockedEvent:				name.Append(_L("KContextBlockedEvent"));			break;
		case KContextUnblockedEvent:			name.Append(_L("KContextUnblockedEvent"));			break;
		case KNetworkStatusEvent:				name.Append(_L("KNetworkStatusEvent"));				break;
		case KContextQoSSetEvent:				name.Append(_L("KContextQoSSetEvent"));				break;
		case KContextTFTModifiedEvent:			name.Append(_L("KContextTFTModifiedEvent"));		break;
		case KPrimaryContextCreated:			name.Append(_L("KPrimaryContextCreated"));			break;
		case KSecondaryContextCreated:			name.Append(_L("KSecondaryContextCreated"));		break;
		case KContextModifyActiveEvent:			name.Append(_L("KContextModifyActiveEvent"));		break;
		case KGetNegQoSEvent:					name.Append(_L("KGetNegQoSEvent"));					break;
		default:								name.Append(_L("error"));							break;
		}

	LOG(Log::Printf(_L("CNif::Event,aName: %d, name: {%S}"), aName, &name));
#else
	LOG(Log::Printf(_L("CNif::Event(name=%d)"), aName));
#endif

#ifndef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY
//PREQ399 had to disable this check because in the new architecture, in order to
//plug UmtsIf capable CFProtos (formerly Nifs) they need to be below IProto,
//and hence aProtocol will never match the iNif reference that we have here.
	if ((CNifIfBase *)aProtocol != &iNif)
		{
		LOG(Log::Printf(_L("\tThe CNifIfBase[%u] parameter does not match my CNifIBase[%u]"), (TInt)aProtocol, (TInt)&iNif));
		return KErrNotFound;	// Not called from what we expect! (invalid use of API)
		}
#else
    (void)aProtocol;
#endif
	// Handle KNetworkStatusEvent first.
	if (aName == KNetworkStatusEvent)
		{
		if (aOption.Length() >= (TInt)sizeof(TNetworkParameters))
			{
			const TNetworkParameters& opt = *(TNetworkParameters*)aOption.Ptr();
			NetworkStatusEvent(opt);
			return KErrNone;
			}
		LOG(Log::Printf(_L("\tThe aOption length=%d is too short for TNetworkParameters (size=%d)"),
			aOption.Length(), (TInt)sizeof(TNetworkParameters)));
		return KErrArgument;
		}

	// All remaining valid events use TContextParameters, do the shared
	// checking and preprocess before the switch...
	if (aOption.Length() != (TInt)sizeof(TContextParameters))
		{
		LOG(Log::Printf(_L("\tThe aOption length=%d does not match TContextParamaters (size=%d)"),
			aOption.Length(), (TInt)sizeof(TContextParameters)));
		return KErrArgument;
		}
	const TContextParameters& opt = *(TContextParameters*)aOption.Ptr();

	// PrimaryContextCreated/SecondaryContextCreated do not have the context
	// id in opt yet, handle those separately here (because searching PDP
	// context by id would fail.
	if (aName == KPrimaryContextCreated)
		{
		return PrimaryContextCreated(opt);
		}
	else if (aName == KSecondaryContextCreated)
		{
		SecondaryContextCreated(opt);
		return KErrNone;
		}

	// Even if the aOption is not TContextParameters, nothing bad happens.
	// In that case teh context is searced with random id, which either is
	// found or not.
	CPdpContext *context = FindContext(opt.iContextInfo.iContextId);
	if (context == NULL)
		{
		return KErrNotFound;	// Context does not exist any more
		}

	switch (aName)
		{
	case KContextUnblockedEvent:
		// independent of any request pending
		// NOTE: NIF *MUST* always provide the correct context status for Unblock
		context->SetContextStatus(opt.iContextInfo.iStatus);
		context->UnBlock();
		return KErrNone;

	case KContextBlockedEvent:
		// independent of any request pending
		// NOTE: NIF *MUST* always provide the correct context status for Block
		context->SetContextStatus(opt.iContextInfo.iStatus);
		context->Block();
		return KErrNone;

	case KContextDeleteEvent:
		// independent of any request pending
		context->SetContextStatus(opt.iContextInfo.iStatus);
				
		// qos framework has to be notified!!!
		context->DeleteEvent(opt);
		DeletePdpContext(context);
		return KErrNone;

	case KContextParametersChangeEvent:
		// independent of any request pending
		context->ParametersChangedEvent(opt);
		return KErrNone;

	case KContextQoSSetEvent:
		context->SetQoSReply(iCurrentRequest, opt);
		return KErrNone;

	case KContextTFTModifiedEvent:
		context->ModifyTftReply(iCurrentRequest, opt);
		return KErrNone;


	case KContextActivateEvent:
		context->ActivateReply(iCurrentRequest, opt);
		return KErrNone;

	case KContextModifyActiveEvent:
		context->ModifyActiveReply(iCurrentRequest, opt);
		return KErrNone;

	default:
		break;
		}
	return KErrNotSupported;
	}


void CNif::SetDefaultQoS()
	{
	LOG(Log::Printf(_L("\tSetDefaultQoS -- begin")));
	TQoSRequested policy;
	TInt ret = iModule.GetDefaultParameters(policy, iIapId);
	if (ret == KErrNone)
		{
		TContextParameters& parameters(ContextParameters());
		parameters.iContextConfig.SetUMTSQoSReq(policy);
		TPckg<TContextParameters> opt(parameters);
		LOG(Log::Printf(_L("\tcall NIF Control(KNifSetDefaultQoS)")));
		iNif.Control(KSOLInterface, KNifSetDefaultQoS, opt);
		}
	LOG(Log::Printf(_L("\tSetDefaultQoS -- end")));
	}

void CNif::AddContext(CPdpContext& aContext)
	{
	iContexts.AddLast(aContext);
	}

TInt CNif::PrimaryContextCreated(const TContextParameters& aParams)
	{
	TNifIfInfo info;
	iNif.Info(info);
	LOG(Log::Printf(_L("CNif::PrimaryContextCreated [Nif=%S]"),&info.iName));
	
	iPrimary->SetContextStatus(aParams.iContextInfo.iStatus);

	SetStatus(EReady);
	IssueRequest();
	return KErrNone;
	}

void CNif::SecondaryContextCreated(const TContextParameters& aParams)
	{
	if (iCurrentRequest)
		{
		SetStatus(EReady);
		CPdpContext* context=NULL;
		TRAPD(err, context = CPdpContext::NewL(*this, ESecondaryContext, aParams.iContextInfo.iContextId));
		if (err == KErrNone)
			{
			//coverity[leave_without_push]
			context->SetContextStatus(aParams.iContextInfo.iStatus);
			AddContext(*context);
			iCurrentRequest->Run(EPendingCreate, context, aParams);
			return;	// Do not fall to context destruction.		
			}
		else
			{
			iCurrentRequest->CompleteAndDestruct(err, NULL);
			// Fall to context destruction...
			}
		}
	// Either there was no request to receive this, or running low on memory
	LOG(Log::Printf(_L("CNif::SecondaryContextCreated -- but, GUGOS cannot use it, deleting context")));
	TPckg<TContextParameters> options(aParams);
	iNif.Control(KSOLInterface, KContextDelete, options);
	}

// Issue the creation of secondary PDP context
TInt CNif::NewPdpContext()
	{
	LOG(Log::Printf(_L("\t\tCNif::NewPdpContext -- request creation of secondary context")));
	TPckg<TContextParameters> opt(ContextParameters());
	opt().iContextType = ESecondaryContext;
	const TInt ret(iNif.Control(KSOLInterface, KContextCreate, opt));
	return (ret == KErrNone) ? opt().iReasonCode : ret;
	}


// Turn off events
TInt CNif::CloseInterface()
	{
	return SetEvents(EFalse);
	}

void CNif::AddRequest(CRequestBase& aRequest)
	{
	iPending.AddLast(aRequest);
	++iPendingSequence;	// iPending Modified
	LOG(Log::Printf(_L("\trequest %S[%u] -- Queued for activation on IAP=%u"), aRequest.iName, (TInt)&aRequest, iIapId));
	IssueRequest();
	}

void CNif::CancelPendingRequest(CFlowData* aFlowData)
	{
	LOG(Log::Printf(_L("\tCancelPendingRequest for FLOW -- BEGIN")));
	TUint32 mark;
	do
		{
		mark = iPendingSequence;
		TSglQueIter<CRequestBase> iter(iPending);
		CRequestBase* request;
		while (iPendingSequence == mark && (request = iter++) != NULL)
			request->Cancel(aFlowData);
		}
	while (mark != iPendingSequence);
	LOG(Log::Printf(_L("\tCancelPendingRequest FLOW -- END")));
	}


void CNif::CancelPendingRequest(CPdpContext* aContext)
	{
	LOG(Log::Printf(_L("\tCancelPendingRequest for PDP -- BEGIN")));

	TUint32 mark;
	do
		{
		mark = iPendingSequence;
		TSglQueIter<CRequestBase> iter(iPending);
		CRequestBase* request;
		while (iPendingSequence == mark && (request = iter++) != NULL)
			request->Cancel(aContext);
		}
	while (mark != iPendingSequence);

	LOG(Log::Printf(_L("\tCancelPendingRequest for PDP -- END")));
	}

void CNif::IssueRequest()
	{
	// Request a callback with delay 0, calls RunPendingRequests as soon as possible.
	iTimeout.Set(Module().TimeoutManager(), 0);
	};

void CNif::RunPendingRequests()
	{
	LOG(Log::Printf(_L("")));
	if (Status() != EReady)
		return;

	while (!iPending.IsEmpty() && iCurrentRequest == NULL)
		{
		iCurrentRequest = iPending.First();
		iCurrentRequest->Start();
		}
	}

// Recompute evaluation precedences in use from the current state of PDP contexts.
void CNif::RecomputeEvaluationPrecedences()
	{
	// This is called every time NIF returns the current set of filters.
	//
	// When new packet filters are added for the PDP Context, the
	// precedence indexes must be selected for each of them and
	// marked as used in the current table. Removal of filter must
	// release the index, however at the time of TFT removal request,
	// it is not yet known whether it will succeed.
	//
	// Eventually, NIF reports back what filters
	// and indexes are actually used. Just recomputing the used
	// status by scanning all (few) PDP Contexts and their current
	// filters is the simplest solution to keep the information in
	// in synch with NIF/network view of things.

	Mem::FillZ(iEvaluationPrecedenceMap, sizeof(iEvaluationPrecedenceMap));
	TContextIter iter(iContexts);
	CPdpContext* context;
	while ((context = iter++) != NULL)
		{
		for (TInt i = 0; i < context->iNumFilters; ++i)
			{
			const TInt p = context->iFilters[i].iEvaluationPrecedenceIndex;
			if (p >= 0 && p < KMaxEvaluationPrecedences)
				iEvaluationPrecedenceMap[p] = 1;
			}
		}
	}

// Evaluation precedence must be unique amongst all packet filters related to 
// same APN. 
TInt CNif::FindEvaluationPrecedence()
	{
	TUint i;
	for (i=0; i < KMaxEvaluationPrecedences; i++)
		{
		if (iEvaluationPrecedenceMap[i] == 0)
			{
			iEvaluationPrecedenceMap[i] = 1;
			return i;
			}
		}
	return KErrNotFound;
	}

void CNif::CloseRequest(CRequestBase* aRequest)
	{
	LOG(Log::Printf(_L("\t\tCNif::CloseRequest")));
	iPending.Remove(*aRequest);
	++iPendingSequence;
	// Note: If current request is already NULL, then this does not
	// activate a new request from queue, even if there would be some.
	// This is intentional -- see ~CNif() destructor!
	if (iCurrentRequest != aRequest)
		return;
	iCurrentRequest = NULL;
	IssueRequest();
	}
//
CNifManager* CNifManager::NewL()
	{
	CNifManager* manager = new (ELeave) CNifManager();
	CleanupStack::PushL(manager);
	manager->ConstructL();
	CleanupStack::Pop();
	return manager;
	}

CNifManager::~CNifManager()
	{
	while (!iNifs.IsEmpty())
		{
		CNif* nif = iNifs.First();
		iNifs.Remove(*nif);
		delete nif;
		}
	iNifs.Reset();
	}


CNifManager::CNifManager()
	{
	iNifs.SetOffset(_FOFF(CNif, iNext));
	}

void CNifManager::ConstructL()
	{
	}

CNif* CNifManager::CreateNifL(CNifIfBase& aInterface, CModuleGuqos& aModule)
	{
	CNif* nif = CNif::NewL(aInterface, aModule);
	iNifs.AddLast(*nif);
	nif->SetEvents(ETrue);
	nif->SetDefaultQoS();
	return nif;
	}

void CNifManager::DeleteNif(CNifIfBase* aInterface)
	{
	CNif* nif = FindInterface(aInterface);
	if (nif)
		DeleteNif(nif);
	}

void CNifManager::DeleteNif(CNif* aInterface)
	{
	iNifs.Remove(*aInterface);
	delete aInterface;
	}

CNif* CNifManager::FindInterface(const CNifIfBase *aIface)
	{
	TNifIter iter(iNifs);
	CNif* nif;
	while ((nif = iter++) != NULL)
		if (&nif->Interface() == aIface)
			return nif;
	return NULL;
	}
	
CPdpContext* CNifManager::FindChannel(TInt aChannelId)
	{
	TNifIter iter(iNifs);
	CNif* nif;
	while ((nif = iter++) != NULL)
		{
		CPdpContext* context = nif->FindChannel(aChannelId);
		if (context)
			return context;
		}
	return NULL;
	}


// delete all pending requests related to this flow
void CNifManager::CancelPendingRequests(CFlowData* aFlowData)
	{
	__ASSERT_ALWAYS(aFlowData!=NULL, User::Panic(_L("CNifManager::CancelPendingRequests"), 0));
	TNifIter iter(iNifs);
	CNif *nif;
	while ((nif = iter++) != NULL)
		nif->CancelPendingRequest(aFlowData);
	}