// Copyright (c) 2006-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 <nifman.h>
#include <comms-infras/nifif.h>
#include <in_iface.h>

#include "qos_if.h"
#include "qos_prot.h"
#include "modules.h"
#include "interface.h"


CInterface* CInterface::NewL(CProtocolQoS& aProt, CNifIfBase* aNif)
	{
	CInterface* iface = new (ELeave) CInterface(aProt, aNif);
	CleanupStack::PushL(iface);
	iface->ConstructL();
	CleanupStack::Pop();
	//coverity[leave_without_push]
	LOG(Log::Printf(_L("\t\tIF [%S] '%S' created"), &iface->iName, &iface->iInterfaceName));
	return iface;
	}


CInterface::CInterface(CProtocolQoS& aProt, CNifIfBase* aNif) : iProtocol(aProt), iNif(aNif)
	{
	LOG(Log::Printf(_L("new\tqos IF for NIF[%u] size=%d"), (TInt)aNif, sizeof(CInterface)));
	iIapId = 0;
	}


CInterface::~CInterface()
	{
	LOG(Log::Printf(_L("~\tqos IF [%S] destructor -- start"), &iName));
	
	if (iTrafficControl)
		{
		iTrafficControl->Module()->InterfaceDetached(iInterfaceName, iNif);
		delete iTrafficControl;
		}

	LOG(Log::Printf(_L("~\tqos IF [%S] destructor -- end"), &iName));
	}

void CInterface::ConstructL()
	{
	iTrafficControl = NULL;
	iIapId = 0;
	GetInterfaceInfo();
	// If the control module is not available, for some reason,
	// then this status will cause all channel
	// negotiations for this interface to fail, but does not
	// prevent normal packet flow.
	iTrafficControlStatus = LoadControlModule();
	}


void CInterface::GetInterfaceInfo()
	{
	TNifIfInfo info;
	iNif->Info(info);
	iName = info.iName;

	TInt aPlace;
	TChar aMark('.');
	aPlace = iName.LocateReverse(aMark);
	if (aPlace > 0)
		iInterfaceName.Set(iName.Left(aPlace));
	else
		iInterfaceName.Set(iName);

	// Get NetworkId and IapId
	TSoIfConnectionInfo netinfo;
	TPckg<TSoIfConnectionInfo> option(netinfo);
	if (iNif->Control(KSOLInterface, KSoIfGetConnectionInfo, option) == KErrNone)
		iIapId = netinfo.iIAPId;
	LOG(Log::Printf(_L("\t\tIF [%S] '%S' NET=%d IAP=%d"), &iName, &iInterfaceName, netinfo.iNetworkId, iIapId));
	}


TInt CInterface::GetPlugIn(TSoIfControllerInfo& aPluginInfo)
	{
	TPckg<TSoIfControllerInfo> opt(aPluginInfo);
	TInt ret;

	ret = iNif->Control(KSOLInterface, KSoIfControllerPlugIn, opt);
	if (!ret)
		{
		_LIT(KDescPrt, ".prt");
		TInt aPlace;
		aPlace = aPluginInfo.iPlugIn.Match(KDescPrt);
		if (aPlace == KErrNotFound)
			aPluginInfo.iPlugIn.Append(KDescPrt);
		}
	return ret;
	}


// Load technology-specific control module
TInt CInterface::LoadControlModule()
	{
	TInt ret;
	TSoIfControllerInfo aPluginInfo;
	ret = GetPlugIn(aPluginInfo);
	if (ret == KErrNone)
		{
		RModule* module = NULL;
		TRAP(ret, module = iProtocol.ModuleMgr()->LoadModuleL(iProtocol.NetworkService()->Protocol(), aPluginInfo.iPlugIn, aPluginInfo.iProtocolId));
		if (ret == KErrNone)
			{
			SetTrafficControl(module);
			LOG(Log::Printf(_L("\t\tCalling module[%S]::InterfaceAttached(IF [%S])"), &aPluginInfo.iPlugIn, &iName));
			module->Module()->InterfaceAttached(iInterfaceName, iNif);
			}
		else
			{
			LOG(Log::Printf(_L("\t\tFailed to load module[%S] for IF [%S] , err=%d"), &aPluginInfo.iPlugIn, &iName, ret));
			}
		}
	return ret;
	}

CInterfaceManager* CInterfaceManager::NewL(CProtocolQoS& aProtocol)
	{
	return new (ELeave) CInterfaceManager(aProtocol);
	}

CInterfaceManager::CInterfaceManager(CProtocolQoS& aProtocol) : iProtocol(aProtocol)
	{
	LOG(Log::Printf(_L("new\tqos Interface Manager[%u] size=%d"), (TInt)this, sizeof(CInterfaceManager)));
	iInterfaces.SetOffset(_FOFF(CInterface, iLink));
	}

CInterfaceManager::~CInterfaceManager()
	{
	LOG(Log::Printf(_L("~\tqos Interface Manager[%u] -- start"), (TInt)this));
	while (!iInterfaces.IsEmpty())
		{
		CInterface* iface = iInterfaces.First();
		iInterfaces.Remove(*iface);
		delete iface;
		}
	iInterfaces.Reset();
	LOG(Log::Printf(_L("~\tqos Interface Manager[%u] -- done"), (TInt)this));
	}

CInterface* CInterfaceManager::AddInterfaceL(CNifIfBase* aNif)
	{
	CInterface* iface = CInterface::NewL(iProtocol, aNif);
	iInterfaces.AddLast(*iface);
	return iface;
	}

void CInterfaceManager::RemoveInterface(CInterface* aInterface)
	{
	iInterfaces.Remove(*aInterface);
	delete aInterface;
	}


CInterface* CInterfaceManager::FindInterface(CNifIfBase* aNif)
	{
	TSglQueIter<CInterface> iter(iInterfaces);
	CInterface* i;

	while ((i = iter++) != NULL)
		{
		if (i->Nif() == aNif)
			return i;
		}
	return NULL;
	}