// Copyright (c) 2002-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:

// Implements the CRawIPNifMain class, which provides a central point for the NIF

// to communicate with NifMan and the BCA controllers. This class creates an interface

// to the IPv4 protocol when it is required.

// 

//

/**

 @file

*/

#include <f32file.h>

#include <nifman.h>

#include <nifmbuf.h>

#include <in_iface.h>

#include <nifvar.h>

#include "IPv4ProtocolIf.h"

#include "IPv6ProtocolIf.h"

#include "RawIPNifMain.h"

#ifdef __FLOG_ACTIVE

//These variables are used only if flog is active.

_LIT8(KTcpDumpFirstTag,"TcpDump");

static const TUint16 KTcpDumpLinkType = 12;

#endif

CRawIPNifMain::CRawIPNifMain(CNifIfFactory& aFactory, MNifIfNotify* aNotify, CBttLogger* aTheLogger)

/**

 * Constructor.

 *

 * @param aFactory Reference to the factory which created this object.

 * @param aTheLogger The logging object, ownership is passed to this object

 */

	: CNifIfLink(aFactory), 

	  iTheLogger(aTheLogger),

	  iInitError(KErrNone), 

	  iState(EIfDown)

	{

	// To aid debugging.

	iNotify = aNotify;

	}

void CRawIPNifMain::Info(TNifIfInfo& aInfo) const

/**

 * Provides information about the NIF.

 *

 * @param aInfo Information structure to be filled in

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::Info"));

	aInfo.iVersion = TVersion(KNifMajorVersionNumber, KNifMinorVersionNumber,

		KNifBuildVersionNumber);

	aInfo.iFlags = KNifIfIsBase | 

				   KNifIfUsesNotify | 

				   KNifIfIsLink |

	               KNifIfCreatedByFactory |

				   KNifIfCreatesBinder;

	aInfo.iName = KRawIPNifName;

	aInfo.iProtocolSupported = KProtocolUnknown;

	}

void CRawIPNifMain::ConstructL(const TDesC& /*aName*/)

/**

 * Second-phase constructor. Creates the Etel

 * control engine

 *

 * @param aName The name of the NIF (unused)

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::ConstructL"));

	iBcaController = CBcaIoController::NewL(*this, iTheLogger);

	}

CRawIPNifMain::~CRawIPNifMain()

/**

 * Destructor. Cancels and deletes all owned active objects.

 */

	{

	// Note that we don't delete iProtocolIf because it's not owned by us.

	delete iBcaController;

	// This class also deletes the logging object

	delete iTheLogger;

	// Cleanup when stop was not called - harmless as it null's the pointer

	__PACKETLOG_DELETE;

	}

TInt CRawIPNifMain::Control(TUint /*aLevel*/, TUint /*aName*/,

                             TDes8& /*aOption*/, TAny* /*aSource*/)

/**

 * Method to set up NIF parameters. This is unused; instead, the Control()

 * method on the IPv4 interface will be called to configure the NIF.

 *

 * @param aLevel The network level of the parameter to be set (unused)

 * @param aName The name of the parameter to be set (unused)

 * @param aOption The parameter to be written to (unused)

 * @param aSource The source of the method call (unused)

 * @return Always KErrNotSupported

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::Control"));

	return KErrNotSupported;

	}

TInt CRawIPNifMain::State()

/**

 * Returns the current state of the NIF. This will be one of EIfUp or EIfDown.

 *

 * @return The state of the NIF

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::State"));

	return iState;

	}

TInt CRawIPNifMain::Start()

/**

 * Starts the NIF up. This process involves connecting to the BCA.  When startup is

 * complete, LinkLayerUp() will be called.

 *

 * @return Allways KErrNone

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::Start"));

	TRAPD(err1,InitialiseL(MControllerObserver::EStart, KErrNone));

	if (err1)

		{

		return err1;

		}

	//the name calculation should be done only if logging is enabled

#ifdef __FLOG_ACTIVE

	const TUint KModemNameLen = KCommsDbSvrMaxColumnNameLength + 10;  // need enough for ppp-XXX.txt - e.g. ppp-comm-1.txt, ppp-btcomm-10.txt etc

	TBuf8<KModemNameLen> modemName;

	//first add modem name

	_LIT(KModemPortName, "ModemBearer\\PortName");

	_LIT8(KStupidCharacters, "::");

	iNotify->ReadDes(KModemPortName, modemName);

	const TInt pos = modemName.FindC((const TDesC8&)KStupidCharacters);

	if(pos != KErrNotFound)

		{

		modemName.Delete(pos, 2);

		}

	//append time stamp

	const TUint KTimeStampLen = 8;

	TBuf8<KTimeStampLen> logFileName;

	_LIT8(KTimeFormat, "%08X");

	TUint32 counter = User::FastCounter();

	logFileName.Format(KTimeFormat, counter);

	TRAPD(err,__PACKETLOG_NEWL(KTcpDumpFirstTag, logFileName, CPacketLogger::ETcpDump, KTcpDumpLinkType));

	if (err)

		{

		_LOG_L1C1(_L8("Trapped leave from __PACKETLOG_NEWL"));

		}

	const TUint KLogTextLen = KModemNameLen+KTimeStampLen+30;

	TBuf8<KLogTextLen> logText;

	_LIT8(KLogTimeText, "TcpDump log file time stamp:");

	_LIT8(KLogModemText, " for modem:");

	logText.Append(KLogTimeText);

	logText.Append(logFileName);

	logText.Append(KLogModemText);

	logText.Append(modemName);

	_LOG_L1C1(logText);

#endif

	return KErrNone;

	}

void CRawIPNifMain::LinkLayerUp()

/**

 * This function is called when initialisation is complete and the NIF is

 * ready to send/receive data. It notifies NifMan and the IP interface that it's

 * ready to go.

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::LinkLayerUp"));

	iState = EIfUp;

	iNotify->LinkLayerUp();

	iNotify->IfProgress(KLinkLayerOpen, KErrNone);

	iProtocolIf->StartSending(reinterpret_cast<CProtocolBase*>(this));

	}

void CRawIPNifMain::LinkLayerDown(TInt aError)

/**

 * This function is called when the context has been deactivated and the NIF

 * is ready to be deleted, or if there is an error on startup. Its job is to

 * notify NifMan that the link has gone down, so it can delete the NIF.

 *

 * @param aError An error code to propagate to NifMan

 */

	{

	_LOG_L1C2(_L8("CRawIPNifMain::LinkLayerDown [aError=%d]"), aError);

	iState = EIfDown;

	iNotify->IfProgress(KLinkLayerClosed, aError);

	iNotify->LinkLayerDown(aError, MNifIfNotify::EDisconnect);

	}

void CRawIPNifMain::Stop(TInt aError, MNifIfNotify::TAction /*aAction*/)

/**

 * This function is called by NifMan to bring down the link. It starts

 * the asynchronous context deactivation process; LinkLayerDown() will be

 * called when the context has been deactivated.

 *

 * @param aError A code specifying why the link is to be brought down

 * @param aAction The action to take: disconnect or reconnect

 */

	{

	_LOG_L1C2(_L8("CRawIPNifMain::Stop [aError=%d]"), aError);

	__PACKETLOG_DELETE;

	ShutDown(MControllerObserver::EInitialised, aError);

	}

void CRawIPNifMain::Restart(CNifIfBase* /*aIf*/)

/**

 * This is just an empty implementation of the CNifIfLink derived method.

 * It is used as part of functionality to allow a NIF to specify that

 * one of its binders has gone down but the link layer has not.

 *

 * @param Pointer to the protocol interface object

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::Restart called"));

	}

TInt CRawIPNifMain::Send(RMBufChain& /*aPdu*/, TAny* /*aProtocol*/)

/**

 * Unused. The Send() method on the IPv4 protocol interface should be used

 * to send IPv4 packets.

 *

 * @return Always KErrNotSupported

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::Send"));

	// Only the bearers' Send functions should be called.

	return KErrNotSupported;

	}

TInt CRawIPNifMain::SendPacket(RMBufChain& aPdu, TAny* /*aProtocol*/,

							   TUint16 /*aType*/)

/**

 * Sends a packet, via the BCA controller. This method is protocol-agnostic,

 * and is called by the IPv4 protocol interface to actually send packets.

 *

 * @param aPdu The packet to send

 * @return A standard error code

 */

	{

	_LOG_L1C2(_L8("CRawIPNifMain::SendPacket [length=%d]"),

		aPdu.Length() - aPdu.First()->Length());

	__PACKETLOG_WRITE_PACKET(aPdu, 0);

	TInt ret = iBcaController->Send(aPdu);

	return ret;

	}

void CRawIPNifMain::Process(RMBufChain& aPdu, TUint16 aProtocolCode)

/**

 * Handles incoming packets which have been passed up from the BCA controller.

 * If the IPv4 interface wants to process the packet, it hands it on; otherwise,

 * the packet is binned.

 *

 * @param aPdu The incoming packet

 */

	{

	_LOG_L1C2(_L8("CRawIPNifMain::Process [aPdu length=%d]"),

		aPdu.Length() - aPdu.First()->Length());

	// If the packet has zero or negative length, bin it.

	if ((aPdu.Length() - aPdu.First()->Length()) <= 0)

		{

		_LOG_L1C1(_L8("Dumped packet: illegal length"));

		aPdu.Free();

		return;

		}

	// See if the protocol interface wants the packet.

	if (iProtocolIf->WantsProtocol(aProtocolCode)) 

		{

		__PACKETLOG_WRITE_PACKET(aPdu, 0);

		iProtocolIf->Process(aPdu);

		}

	else

		{

		// The protocol didn't want the packet, so bin it.

		_LOG_L1C2(_L8("Packet was not processed: freeing (protocol code: %X)"),

			aProtocolCode);

		aPdu.Free();

		}

	}

void CRawIPNifMain::ResumeSending()

/**

 * Notifies the protocol interface that it can resume sending packets.

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::ResumeSending"));

	iProtocolIf->StartSending(reinterpret_cast<CProtocolBase*>(this));

	}

void CRawIPNifMain::AuthenticateComplete(TInt /*aResult*/)

/**

 * Notifies NifMan when authentication is complete. This function is never

 * actually called.

 *

 * @param aResult The result of the authentication (unused)

 */

	{

	_LOG_L1C1(_L8("CRawIPNifMain::AuthenticateComplete"));

	}

TInt CRawIPNifMain::Notification(TAgentToNifEventType aEvent,

								  void* aInfo)

/**

 * Provides a mechanism for the notification of events. 

 *

 * @param aEvent The event type (unused)

 * @param aInfo Event information (unused)

 */

	{

	_LOG_L1C2(_L8("CRawIPNifMain::Notification [%d]"), aEvent);

	switch (aEvent)

	{

	case (EAgentToNifEventTypeDisableTimers) : //GPRS suspension

		{

		_LOG_L1C1(_L8("CRawIPNifMain::Received Suspend from Agent..."));

		// Let the BCA controller know that data can no longer be sent over

		// the PDP context.

		iBcaController->UpdateContextStateFlag(EFalse);

		break;

		}

	case (EAgentToNifEventTypeEnableTimers) : //GPRS resumption

		{

		_LOG_L1C1(_L8("CRawIPNifMain::Received Resume from Agent..."));

		iBcaController->UpdateContextStateFlag(ETrue);

		break;

		}

	case (EAgentToNifEventTsyConfig) : 

		{

		_LOG_L1C1(_L8("CRawIPNifMain::Received context config from Agent..."));

		RPacketContext::TContextConfigGPRS* localPtr = (reinterpret_cast<RPacketContext::TContextConfigGPRS*>(aInfo));

		TRAPD(err, GetProtocolIf()->UpdateContextConfigL(*localPtr));

		if (err)

			{

			_LOG_L1C1(_L8("Trapped leave from UpdateContextConfigL"));

			}

		break;

		}

	case (EAgentToNifEventTsyConnectionSpeed) : 

		{

		TUint connectionSpeed = reinterpret_cast<TUint>(aInfo);

		_LOG_L1C2(_L8("CRawIPNifMain::Connection Speed Received [%d]"), connectionSpeed);

		GetProtocolIf()->UpdateConnectionSpeed(connectionSpeed);

		break;

		}

	case (EAgentToNifEventTypeDisableConnection) :

		{

		// This is handled by NIFMAN and passed to NifMain as a Stop() call

		_LOG_L1C1(_L8("CRawIPNifMain::Received Disable connection from Agent..."));

		break;

		}

	case (EAgentToNifEventTypeGetDataTransfer) :

		{

		_LOG_L1C1(_L8("CRawIPNifMain::Received Get Data Transfer from Agent..."));

		break;

		}

	default : 

		{

		_LOG_L1C2(_L8("CRawIPNifMain::Received Notification [%d] from Agent..."), aEvent);

		break;

		}

	}

	return KErrNone;

	}

void CRawIPNifMain::BindL(TAny *aId)

/**

 * Called by NifMan to bind the NIF to a specific protocol. This is never

 * actually called; instead, the BindL() function of the IPv4 interface is used.

 *

 * @param aId A pointer to the protocol to be bound to

 * @leave KErrAlreadyExists when already bound

 */

	{

	_LOG_L1C2(_L8("CRawIPNifMain::BindL [aId=%X]"), aId);

	if (iProtocol)

		{

		User::Leave(KErrAlreadyExists);

		}

	iProtocol = reinterpret_cast<CProtocolBase*>(aId);

	}

CNifIfBase* CRawIPNifMain::GetBinderL(const TDesC& aName)

/**

 * Creates a new protocol interface, for supported protocols. This is currently

 * only IPv4 and ICMP, both of which use the IPv4 protocol interface class.

 *

 * @param aName The name of the protocol

 * @return A newly created protocol interface object

 * @leave KErrNotSupported if protocol is not supported

 */

	{

#ifdef __BTT_LOGGING__

	TBuf8<256> debugBuffer;

	debugBuffer.Copy(aName);

	_LOG_L1C2(_L8("CRawIPNifMain::GetBinderL [aName=%S]"), &debugBuffer);

#endif

	// IPv4 and ICMP Protocols.

	if (!aName.CompareF(KDescIp) || !aName.CompareF(KDescIcmp))

		{

		if (!iProtocolIf)

			{

			iProtocolIf = new (ELeave) CIPv4ProtocolIf(*this, iTheLogger);

#ifdef RAWIP_HEADER_APPENDED_TO_PACKETS			

			iBcaController->SetType(KIp4FrameType);

#endif // RAWIP_HEADER_APPENDED_TO_PACKETS

			}

		}

	// IPv6 Protocol

	else if (!aName.CompareF(KDescIp6))

		{

		if (!iProtocolIf)

			{

			iProtocolIf = new (ELeave) CIPv6ProtocolIf(*this, iTheLogger);

#ifdef RAWIP_HEADER_APPENDED_TO_PACKETS			

			iBcaController->SetType(KIp6FrameType);

#endif // RAWIP_HEADER_APPENDED_TO_PACKETS

			}

		}		

	else

		{

		User::Leave(KErrNotSupported);

		}

    return iProtocolIf;

	}

void CRawIPNifMain::InitialiseL(TInitialisationState aState, TInt aError)

/**

 * This method controls the initialisation sequence of the different modules

 * in the NIF. When a module completes all the initialisation tasks it will 

 * call again this method with the new state. If an error occurs then the 

 * ShutDown() method will be called.

 *  

 * @param aState The current initialisation step

 * @param aError A possible error

 */	

	{

	_LOG_L1C3(_L8("CRawIPNifMain::InitialiseL [aState=%d ,aError=%d]"),

		aState, aError);

	if (aError != KErrNone)

		{

		_LOG_L2C2(_L8("  *** FAILED to initialise NIF *** Error =%d"),aError);

		// Initialise shutdown sequence

		switch (aState)

		{

		case MControllerObserver::EBcaController:

			ShutDown(MControllerObserver::EInitialised, aError);

			break;

		default:

			_LOG_L2C3(_L8("ERROR CRawIPNifMain: Unknown state:%d in NIF: %S"), aState, &KNifName);

			User::Leave(KErrUnknown);	

			break;

			}

		return;

		}

	switch (aState)

		{

	case MControllerObserver::EStart:

		{

		_LOG_L1C1(_L8("Calling Agent for TSY Config"));

		GetAgent()->Notification(ENifToAgentEventTsyConfig, NULL);

		_LOG_L1C1(_L8("Calling Agent for TSY Connection Speed"));

		GetAgent()->Notification(ENifToAgentEventTsyConnectionSpeed, NULL);