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

// rawip_sap.cpp - Raw IP socket

//

#include "rawip.h"

#include <in_pkt.h>

#include <in_chk.h>

#include "in_net.h"

//

class CProtocolRawBinder;

class CProviderRawIp : public CProviderInet6Network

	{

public:

	CProviderRawIp(CProtocolInet6Base* aProtocol);

	~CProviderRawIp();

	virtual TInt SetLocalName(TSockAddr &aAddr);

	virtual TInt DoWrite(RMBufSendPacket &aPacket, RMBufSendInfo &aInfo, TUint aOptions, TUint aOffset);

	virtual TInt SecurityCheck(MProvdSecurityChecker *aChecker);

	virtual void InitL();

private:

	CProtocolRawBinder *iBinder;

	};

class CProtocolRawBinder : public CProtocolBase

	{

public:

	CProtocolRawBinder(CProviderRawIp &aProvider) : iProvider(aProvider) {}

	virtual void Identify(TServerProtocolDesc *) const;

	virtual void Process(RMBufChain&, CProtocolBase* aSourceProtocol=NULL);

private:

	CProviderRawIp &iProvider;

	};

CServProviderBase *RAWIP::NewSAPL(TUint aSockType, CProtocolInet6Base *aProtocol)

	{

	LOG(Log::Printf(_L("NewSAPL\t%S SockType=%d"), &aProtocol->ProtocolName(), aSockType));

	if (aSockType != KSockRaw)

		User::Leave(KErrNotSupported);

	CProviderRawIp *provider = new (ELeave) CProviderRawIp(aProtocol);

	CleanupStack::PushL(provider);

	provider->InitL();

	CleanupStack::Pop();

	LOG(Log::Printf(_L("NewSAPL\t%S SAP[%u] OK"), &aProtocol->ProtocolName(), (TInt)provider));

	return provider;

	}

//

CProviderRawIp::CProviderRawIp(CProtocolInet6Base* aProtocol) :

	CProviderInet6Network(aProtocol)

	{

	}

void CProviderRawIp::InitL()

	{

	iBinder = new (ELeave) CProtocolRawBinder(*this);

	CProviderInet6Network::InitL();	

	}

CProviderRawIp::~CProviderRawIp()

	{

	iProtocol->NetworkService()->Protocol()->Unbind(iBinder);

	delete iBinder;

	}

// SetLocalName (Bind() in application) with non-zero port activates

// the incoming path for packets of the specific protocol. 

TInt CProviderRawIp::SetLocalName(TSockAddr &aAddr)

	{

	const TInt id = aAddr.Port();

	// Only bind as real upper layer protocol, limit the value...

	if (id < 0 || id > 255)

		return KErrNotSupported;

	if (iProtocol == NULL || iProtocol->NetworkService() == NULL)

		return KErrNotReady;	// Should never really happen...

	iProtocol->NetworkService()->Protocol()->Unbind(iBinder);

	if (id > 0)

		{

		// Only non-zero protocol is bound.

		TRAPD(err, iProtocol->NetworkService()->BindL(iBinder, id));

		if (err != KErrNone)

			return err;

		}

	// iProtocolId is used to fill in the protocol number

	// for outgoing packets, if non-zero (if zero, then

	// the port of the destination address is used as protocol).

	iProtocolId = id;

	// Do the default SetLocalName without the port!

	aAddr.SetPort(0);

	return CProviderInet6Network::SetLocalName(aAddr);

	}

TInt CProviderRawIp::DoWrite(RMBufSendPacket & /*aPacket*/, RMBufSendInfo &aInfo, TUint /*aOptions*/, TUint /*aOffset*/)

	{

	iFlow.SetIcmpType(0, 0);

	iFlow.SetNotify(this);

	if (aInfo.iSrcAddr.Family())

		iFlow.SetLocalAddr(aInfo.iSrcAddr);

	if (aInfo.iDstAddr.Family())

		iFlow.SetRemoteAddr(aInfo.iDstAddr);

	return aInfo.iFlow.Open(iFlow, &aInfo);

	}

// Require network control for raw ip sockets

TInt CProviderRawIp::SecurityCheck(MProvdSecurityChecker *aChecker)

	{

	const TInt res = CProviderInet6Network::SecurityCheck(aChecker);

	if (res == KErrNone)

		return CheckPolicy(KPolicyNetworkControl, "TCPIP RAWIP SAP");

	return res;

	}

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

	{

	for (;;)	// LOOP ONLY FOR EASY BREAK EXITS!

		{

		RMBufRecvInfo *const info = (RMBufRecvInfo *)RMBufPacketBase::PeekInfoInChain(aPacket);

		if (info == NULL)		

			break;

		if (info->iIcmp)

			{

			// For now, ignore ICMP error reports.

			// Could do the save icmp error to support the "Last ICMP" error feature,

			// in socket. That would require translating ICMP error codes into Symbian

			// error codes (which is done in udp.cpp for example -- should have some

			// shared code for this ICMP handling).

			break;

			}

		iProvider.Process(aPacket);

		// ALWAYS TERMINATE THE LOOP

		break;

		}

	aPacket.Free();

	}

void CProtocolRawBinder::Identify(TServerProtocolDesc *aInfo) const

	{

	// If asked, the binder returns the same info as the "rawip" protocol.

	RAWIP::Identify(*aInfo);

	}