/*

* 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

*

*/

#ifndef __PROBE_SAP_H

#define __PROBE_SAP_H

#include "prt.h"

#include "family.h"

class CProviderProbe : public CServProviderBase

{

	friend class CProtocolProbe;

public:

	CProviderProbe(CProtocolProbe* aProtocol);

	virtual ~CProviderProbe();

	//These might be useful

	virtual void Start();

	virtual TInt GetOption(TUint level,TUint name,TDes8& anOption) const;

	virtual TInt SetOption(TUint level,TUint name,const TDesC8 &anOption);

	virtual void Ioctl(TUint level,TUint name,TDes8* anOption);

	virtual void CancelIoctl(TUint aLevel,TUint aName);

	virtual TUint Write(const TDesC8& aDesc,TUint options, TSockAddr* aAddr=NULL);

	virtual void GetData(TDes8& aDesc,TUint options,TSockAddr* anAddr=NULL);

	void Process(RMBufChain& aPacket, CProtocolBase *aSourceProtocol);

	//These do nothing

	virtual void LocalName(TSockAddr& /*anAddr*/) const

		{ Panic(EProbePanic_NotSupported); }

	inline virtual void RemName(TSockAddr& /*anAddr*/) const

		{ Panic(EProbePanic_NotSupported); }

	inline virtual void ActiveOpen()

		{ Panic(EProbePanic_NotSupported); }

	inline virtual void ActiveOpen(const TDesC8& /*aConnectionData*/)

		{ Panic(EProbePanic_NotSupported); }

	virtual void Shutdown(TCloseType aOption);

	virtual void Shutdown(TCloseType aOption, const TDesC8& aDisconnectionData);

	virtual void AutoBind();

	virtual TInt SetLocalName(TSockAddr& /*anAddr*/);

	inline virtual TInt SetRemName(TSockAddr& /*anAddr*/)

		{ Panic(EProbePanic_NotSupported); return 0; }

	inline virtual TInt PassiveOpen(TUint /*aQueSize*/)

		{ Panic(EProbePanic_NotSupported); return 0; }

	inline virtual TInt PassiveOpen(TUint /*aQueSize*/,const TDesC8& /*aConnectionData*/)

		{ Panic(EProbePanic_NotSupported); return 0; }

	void Error(TInt aError, TUint aOperationMask);

	inline TBool FatalState() { return (iErrorMask & (MSocketNotify::EErrorFatal|MSocketNotify::EErrorConnect)) != 0; }

protected:

	CProtocolProbe *const iProtocol;

	CProviderProbe *iNext;

	//

	// IsReceiving is intended for the protocol side. It is can be used by

	// the protocol side "Deliver" method to ask if this SAP is willing to

	// receive packets associated with the specified id.

	virtual TBool IsReceiving(const RMBufPktInfo &info);

	RMBufPktQ iRecvQ;

	//

	// iQueueLimit is used to control how much buffered data is allowed

	// to be in the iRecvQ, before "congestion" control hits. The value counts

	// bytes in iRecvQ in following way

	// - if iQueueLimit < 0, then incoming packet is dropped (= "congestion")

	// - if iQueueLimit >= 0, then incoming packet is added into iRecvQ, and

	//   the length of the packet is subtracted from the iQueueLimit. When

	//   GetData removes the packet from the queue, the length is added back

	//   to iQueueLimit.

	// Thus, if left as initial value (= 0), only one packet at time can be

	// queued. If initialized to 8000, then at most 8000 bytes and 1 packet

	// can be queued at any point.

	TInt iQueueLimit;

	TInt iPacketsDropped;	// Count packets dropped due "congestion"

	TBool iInputStopped:1;

	TUint iErrorMask;

	};

#endif