--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/nettools/conntest/probe/inc/sap.h	Thu Dec 17 08:39:25 2009 +0200
@@ -0,0 +1,95 @@
+/*
+* 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