// Copyright (c) 2004-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:
// prt.cpp - Packet Probe Hook
//

#include <e32std.h>
#include <e32base.h>
#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS
#include <es_prot_internal.h>
#endif

#include "family.h"
#include "prt.h"
#include "sap.h"
#include "inet6log.h"


CProtocolProbe::CProtocolProbe(TUint aId) : iId(aId)
	{
	LOG(Log::Printf(_L("Probe::CProtocolProbe()\r\n"));)
	}

void CProtocolProbe::InitL(TDesC& aTag)
	{
	LOG(Log::Printf(_L("Probe::InitL()\r\n"));)
	CProtocolBase::InitL(aTag);
	}


void CProtocolProbe::StartL()
	{
	//	__ASSERT_DEBUG(iProtocol != NULL, User::Leave(KErrGeneral));
	}

CProtocolProbe::~CProtocolProbe()
	{
	LOG(Log::Printf(_L("Probe::~CProtocolProbe()\r\n"));)
	}


CProtocolProbe *CProtocolProbe::NewL(TUint aId)
	{
	return new (ELeave) CProtocolProbe(aId);
	}

void CProtocolProbe::FillIdentification(TServerProtocolDesc& anEntry, TUint aId)
	{
	anEntry.iName=_S("probe");
	if (aId > 1)
		anEntry.iName.AppendNum(aId-1);
	anEntry.iAddrFamily = KAfProbe;
	anEntry.iSockType = KSockDatagram;
	anEntry.iProtocol = aId;
	anEntry.iVersion = TVersion(1, 0, 0);
	anEntry.iByteOrder = EBigEndian;
	anEntry.iServiceInfo = KSIDatagram | KSIConnectionLess;
	anEntry.iNamingServices = 0;
	anEntry.iSecurity = KSocketNoSecurity;
	anEntry.iMessageSize = 0xffff;
	anEntry.iServiceTypeInfo = ESocketSupport;
	anEntry.iNumSockets = KUnlimitedSockets;
	}

void CProtocolProbe::Identify(TServerProtocolDesc *aDesc) const
	{
	FillIdentification(*aDesc, iId);
	}


CServProviderBase* CProtocolProbe::NewSAPL(TUint aProtocol)
	{
	LOG(Log::Printf(_L("Probe::NewSAPL(%d)\r\n"), aProtocol);)

	if (aProtocol != KSockDatagram)
		User::Leave(KErrNotSupported);
	CProviderProbe* sap = new (ELeave) CProviderProbe(this);
	sap->iNext = iList;
	iList = sap;
	return sap;
	}

//
// CProtocolProbe::CancelSAP
// *************************
// Disconnect SAP from the protocol
//
void CProtocolProbe::CancelSAP(const CServProviderBase* aSAP)
	{
	CProviderProbe **h, *sap;
	for (h = &iList; (sap = *h) != NULL; h = &sap->iNext)
		if (sap == aSAP)
			{
			*h = sap->iNext;
			break;
			}
	}


// CProtocolProbe::NetworkAttachedL
// ********************************
// When network becomes available, do the hooking!
//
void CProtocolProbe::NetworkAttachedL()
	{
	NetworkService()->BindL(this, MIp6Hook::BindPostHook());
	NetworkService()->BindL(this, MIp6Hook::BindPostHook()+1);
	}

//
//	CProtocolProbe::Deliver
//	***********************
//	Generate a copy of the packet to every bound provider
//
void CProtocolProbe::Deliver(RMBufChain &aPacket)
	{
	const RMBufPktInfo *const info = RMBufPacketBase::PeekInfoInChain(aPacket);

	for (CProviderProbe* sap = iList; sap != NULL; sap = sap->iNext)
		{
		if (sap->IsReceiving(*info))
			{
			RMBufPacketBase copy;
			TRAPD(err, copy.CopyPackedL(aPacket));
			if (err == KErrNone)
				sap->Process(copy, this);
			else
				copy.Free();
			}
		}
	}


TInt CProtocolProbe::Send(RMBufChain &aPacket, CProtocolBase* aSrc)
	{
	Deliver(aPacket);
	return CProtocolPosthook::Send(aPacket, aSrc);
	}

void CProtocolProbe::Process(RMBufChain &aPacket, CProtocolBase* aSrc)
	{
	Deliver(aPacket);
	CProtocolPosthook::Process(aPacket, aSrc);
	}