/*+
−
* Copyright (c) 2002-2006 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: Packet probe hook+
−
*+
−
*/+
−
+
−
#include "sap.h"+
−
+
−
+
−
CProviderProbe::CProviderProbe(CProtocolProbe* aProtocol) : iProtocol(aProtocol)+
−
	{+
−
//	__DECLARE_NAME(_S("CProviderProbe"));+
−
	iQueueLimit = 8000;+
−
	}+
−
+
−
CProviderProbe::~CProviderProbe()+
−
	{+
−
	if (iProtocol)+
−
		iProtocol->CancelSAP(this);+
−
	}+
−
+
−
void CProviderProbe::Start()+
−
	{+
−
	}+
−
+
−
TInt CProviderProbe::GetOption(TUint /*aLevel*/, TUint /*aName*/, TDes8& /*aOption*/) const+
−
	{+
−
	return KErrNotSupported;+
−
	}+
−
+
−
TInt CProviderProbe::SetOption(TUint /*aLevel*/, TUint /*aName*/, const TDesC8& /*aOption*/)+
−
	{+
−
//	return KErrNotSupported;+
−
	return KErrNone;+
−
	}+
−
+
−
void CProviderProbe::Ioctl(TUint /*level*/,TUint /*name*/,TDes8* /*anOption*/)+
−
	{+
−
	Panic(EProbePanic_NotSupported);+
−
	}+
−
+
−
void CProviderProbe::CancelIoctl(TUint /*aLevel*/,TUint /*aName*/)+
−
	{+
−
	Panic(EProbePanic_NotSupported);+
−
	}+
−
+
−
+
−
TUint CProviderProbe::Write(const TDesC8 &/*aDesc*/, TUint /*aOptions*/, TSockAddr* /*aAddr*/)+
−
	{+
−
	// For now, Write does nothing on probe socket+
−
	return 1;+
−
	}+
−
+
−
void CProviderProbe::Shutdown(TCloseType /*option*/,const TDesC8& /*aDisconnectionData*/)+
−
	{+
−
	Panic(EProbePanic_NotSupported);+
−
	}+
−
+
−
void CProviderProbe::Shutdown(TCloseType aOption)+
−
	{+
−
	switch(aOption)+
−
		{+
−
		case EStopInput:+
−
			iInputStopped = ETrue;+
−
			iRecvQ.Free();+
−
			iSocket->Error(KErrNone,MSocketNotify::EErrorClose); // Complete KErrNone+
−
			break;+
−
+
−
		case EStopOutput:+
−
			iSocket->Error(KErrNone,MSocketNotify::EErrorClose); // Complete KErrNone+
−
			break;+
−
+
−
		default:+
−
	        if (aOption != EImmediate)+
−
				iSocket->CanClose();+
−
		}+
−
	}+
−
+
−
TInt CProviderProbe::SetLocalName(TSockAddr &/*aAddr*/)+
−
	{+
−
	return 0;	// Ignore silently+
−
	}+
−
+
−
void CProviderProbe::AutoBind()+
−
	{+
−
	// Ignore silently+
−
	}+
−
+
−
// CProviderProbe::Error+
−
// *********************+
−
// Soft errors are not immediately reported to the socket server.+
−
// A soft error is indicated by a zero aOperationMask.+
−
//+
−
// The socket error can be cleared by calling this routing with+
−
// aError == KErrNone.+
−
//+
−
void CProviderProbe::Error(TInt aError, TUint aOperationMask)+
−
	{+
−
	if (aError <= KErrNone && !FatalState())+
−
		{+
−
		if (aError == KErrNone)+
−
			iErrorMask = aOperationMask;+
−
		else+
−
			iErrorMask |= aOperationMask;+
−
	    if (iSocket && aOperationMask)+
−
			iSocket->Error(aError, aOperationMask);+
−
		}+
−
	}+
−
+
−
//+
−
// CProviderProbe::Process()+
−
// *************************+
−
// Process incoming data from the protocol object.+
−
//+
−
void CProviderProbe::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);+
−
		iSocket->NewData(1);+
−
		}+
−
	else+
−
		aPacket.Free();+
−
	}+
−
+
−
// CProviderProbe::IsReceiving+
−
// ***************************+
−
//+
−
TBool CProviderProbe::IsReceiving(const RMBufPktInfo & /*aInfo*/)+
−
	{+
−
	if (iQueueLimit < 0)+
−
		{+
−
		// Receive Queue limit is full, cannot receive this packet+
−
		iPacketsDropped++;+
−
		return FALSE;+
−
		}+
−
	return TRUE;+
−
	}+
−
+
−
+
−
// CProviderProbe::GetData+
−
// ***********************+
−
void CProviderProbe::GetData(TDes8 &aDesc, TUint aOptions, TSockAddr *anAddr)+
−
	{+
−
	RMBufPacketBase packet;+
−
	if (!iRecvQ.Remove(packet))+
−
		Panic(EProbePanic_NoData);+
−
+
−
	const RMBufPktInfo *const info = packet.Unpack();+
−
+
−
	packet.CopyOut(aDesc, 0);+
−
+
−
	if (anAddr!=NULL)+
−
		*anAddr = info->iSrcAddr;+
−
+
−
	if (aOptions & KSockReadPeek)+
−
		{+
−
		packet.Pack();+
−
		iRecvQ.Prepend(packet);+
−
		iSocket->NewData(1);+
−
		}+
−
	else+
−
		{+
−
		iQueueLimit += info->iLength; // Allow more packets in..+
−
		packet.Free();+
−
		}+
−
	}+
−