// 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:

// in_net.cpp - network layer protocol

//

#include "in6_if.h"

#include "inet.h"

#include "in_net.h"

#include "tcpip_ini.h"

#include "inet6log.h"

void CProtocolInet6Network::StartL()

	{

	CProtocolInet6Base::StartL();

	//

	// Get the default value for the provider receive queue limiter

	// (use the protocol name as section name)

	TServerProtocolDesc info;

	Identify(&info);

	TInt value;

	if (iNetwork->Interfacer()->FindVar(info.iName, TCPIP_INI_RECV_BUF, value))

		iQueueLimit = value;

	else

		iQueueLimit = KNetDefaultRecvBuf;

	}

CProtocolInet6Network::~CProtocolInet6Network()

	{

	}

//

//	CProtocolInet6Network::Deliver

//	******************************

//	Generate a copy of the packet to every bound provider

//

void CProtocolInet6Network::Deliver(/*const*/ RMBufPacketBase &aPacket)

	// .. cannot use "const", because CopyInfoL is not const! -- msa */

	{

	CProviderInet6Network* provider;

	TInet6SAPIter iter(this);

	const RMBufPktInfo *const info = aPacket.Info();

	while (provider = (CProviderInet6Network *)iter++, provider != NULL)

		{

		if (provider->IsReceiving(*info))

			{

			RMBufRecvPacket copy;

			TRAPD(err, aPacket.CopyL(copy);aPacket.CopyInfoL(copy));

			if (err == KErrNone)

				{

				copy.Pack();

				provider->Process(copy);

				}

			else

				copy.Free();

			}

		}

	}

//

// Shared provider methods (defaults)

//

CProviderInet6Network::~CProviderInet6Network()

	{

	iProtocol->UnbindProvider(this);

	iRecvQ.Free();

	}

void CProviderInet6Network::InitL()

	{

	//

	// Set initial value for the iQueueLimit

	//

	iQueueLimit = ((CProtocolInet6Network*)iProtocol)->QueueLimit();

	CProviderInet6Base::InitL();

	iProtocol->UnbindProvider(this);

	iProtocol->BindProvider(this);

	}

TInt CProviderInet6Network::SetLocalName(TSockAddr &aAddr)

	{

	iProtocol->UnbindProvider(this);

	// Note: a non-zero port in aAddr is significant!

	iFlow.SetLocalAddr(aAddr);

	iProtocol->BindProvider(this);

	return 0;

	}

void CProviderInet6Network::AutoBind()

	{

	// TInetAddr() is assumed to be KAFUnspec & port=0

	iFlow.SetLocalAddr(TInetAddr());

	}

void CProviderInet6Network::Shutdown(TCloseType aOption)

	{

	switch(aOption)

		{

		case EStopInput:

			iInputStopped = 1;

			iProtocol->UnbindProvider(this);	// We don't need any incoming data

			iRecvQ.Free();

			iSocket->Error(KErrNone,MSocketNotify::EErrorClose); // Complete KErrNone

//			Nif::SetSocketState(ENifSocketConnected, this); // Reset CSocket state to ESStateConnected

			break;

		case EStopOutput:

			iSocket->Error(KErrNone,MSocketNotify::EErrorClose); // Complete KErrNone

//			Nif::SetSocketState(ENifSocketConnected, this); // Reset CSocket state to ESStateConnected

			break;

		default:

	        iProtocol->UnbindProvider(this);

	        if (aOption!=EImmediate)

				iSocket->CanClose();

		}

	}

//

// CProviderInet6Network::Process()

// ********************************

//	Process incoming data from the protocol object.

//

void CProviderInet6Network::Process(RMBufChain& aPacket, CProtocolBase * /*aSourceProtocol*/)

	{

	// iInputStopped is set at ShutDown() and no packets should be coming

	// from the protocol after that. However, without knowing the exact

	// details of the process model/threads, it could be possible that

	// a Process() call has been initiated by the protocol and interrupted

	// before the shutdown, thus there may be a need for this iInputStopped

	// flag, although I would prefer to do without... NEED TO VERIFY IF

	// iInputStopped is really needed!!! -- msa

	//

	if(!(iInputStopped ||

		(iErrorMask & (MSocketNotify::EErrorFatal|MSocketNotify::EErrorConnect|MSocketNotify::EErrorRecv))))

		{

		iQueueLimit -= RMBufPacketBase::PeekInfoInChain(aPacket)->iLength;

		iRecvQ.Append(aPacket);

		LOG(Log::Printf(_L("\t%S SAP[%u] Packet Queued, calling NewData(1), limit=%d"), &ProtocolName(), (TInt)this, iQueueLimit));

		iSocket->NewData(1);

		}

	else

		{

		LOG(Log::Printf(_L("\t%S SAP[%u] Packet Dropped"), &ProtocolName(), (TInt)this));

		aPacket.Free();

		}

	}

// CProviderInet6Network::IsReceiving

// **********************************

//

TBool CProviderInet6Network::IsReceiving(const RMBufPktInfo &aInfo)

	{

	if (!HasNetworkServices() && (aInfo.iFlags & KIpLoopbackPacket) == 0)

		return FALSE;	// No network services and packet is external.

	const TInt port = iFlow.FlowContext()->LocalPort();

	if (iQueueLimit < 0)

		{

		// Receive Queue limit is full, cannot receive this packet

		LOG(Log::Printf(_L("\t%S SAP[%u] Not receiving packets, limit=%d"), &ProtocolName(), (TInt)this, iQueueLimit));

		iPacketsDropped++;

		return FALSE;

		}

	return port == 0 || port == aInfo.iProtocol;

	}

// CProviderInet6Network::GetData

// ******************************

TInt CProviderInet6Network::GetData(RMBufChain& aData, TUint aLength, TUint aOptions, TSockAddr* aAddr)

	{

	RMBufRecvPacket packet;

	const RMBufRecvInfo *info;

	if (!iRecvQ.Remove(packet))

		{

		LOG(Log::Printf(_L("GetData\t%S SAP[%u] No Data Available (0)"), &ProtocolName(), (TInt)this));

		return 0;	// No Data Available

		}

	info = packet.Unpack();

	if (aAddr != NULL)

		*aAddr = info->iSrcAddr;

#ifdef _LOG

	TBuf<70> tmp(_L("NULL"));

	if (aAddr)

		TInetAddr::Cast(*aAddr).OutputWithScope(tmp);

#endif

	const TInt offset = ((aOptions & KIpHeaderIncluded) != 0 || iRawMode) ? 0 : info->iOffset;

	if (aOptions & KSockReadPeek)

		{

		//

		// Oops, peek needs to keep the original packet intact in the queue

		//

		TInt len = info->iLength - offset;

		if (len > (TInt)aLength)

			len = aLength;

		TInt err = packet.Copy(aData, offset, len);

		packet.Pack();

		iRecvQ.Prepend(packet);

		LOG(Log::Printf(_L("GetData\t%S SAP[%u] Peek len=%d err=%d from=%S, calling NewData(1)"), &ProtocolName(), (TInt)this, len, err, &tmp));

		iSocket->NewData(1);

		// Any failure to create the RMBufChain is signalled as KErrNoMBufs!

		return err != KErrNone ? KErrNoMBufs : len;

		}

	iQueueLimit += info->iLength; // Allow more packets in..

	packet.TrimStart(offset);

	aData.Assign(packet);

	if ((TUint)info->iLength > aLength)

		aData.TrimEnd(aLength);

	packet.Free();	// (Releases info block)

	LOG(Log::Printf(_L("GetData\t%S SAP[%u] length=%d from=%S"), &ProtocolName(), (TInt)this, aLength, &tmp));

	return aLength;

	}

void CProviderInet6Network::GetData(TDes8 &aDesc, TUint aOptions, TSockAddr *anAddr)

	{

	RMBufRecvPacket packet;

	const RMBufRecvInfo *info;

	if (!iRecvQ.Remove(packet))

		Panic(EInet6Panic_NoData);

	info = packet.Unpack();

	const TInt offset = ((aOptions & KIpHeaderIncluded) != 0 || iRawMode) ? 0 : info->iOffset;

	packet.CopyOut(aDesc, offset);

	if (anAddr!=NULL)

		*anAddr = info->iSrcAddr;

#ifdef _LOG

	TBuf<70> tmp(_L("NULL"));

	if (anAddr)

		TInetAddr::Cast(*anAddr).OutputWithScope(tmp);

#endif

	if (aOptions & KSockReadPeek)

		{

		packet.Pack();

		iRecvQ.Prepend(packet);

		LOG(Log::Printf(_L("GetData\t%S SAP[%u] peek aDesc = %d from %S, calling NewData(1)"), &ProtocolName(), (TInt)this, aDesc.Length(), &tmp));

		iSocket->NewData(1);

		}

	else

		{

		iQueueLimit += info->iLength; // Allow more packets in..

		packet.Free();

		LOG(Log::Printf(_L("GetData\t%S SAP[%u] aDesc = %d from=%S"), &ProtocolName(), (TInt)this, aDesc.Length(), &tmp));

		}

	}