--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/applayerprotocols/httptransportfw/Test/testhook/testhook.cpp	Tue Feb 02 01:09:52 2010 +0200
@@ -0,0 +1,256 @@
+// 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:
+// testhook.cpp - Outbound plugin test
+// When the ip.etesthook.esk is put in c:/system/data this
+// plugin is bound to the IP. All outgoing messages will pass
+// through this. The name "ip.etesthook.esk" is important, since this
+// must be processed before any other ip.*.esk files.
+// Based on Nokia's exout plugin
+// 
+//
+
+
+#include <e32svr.h>	
+#include "testhook.h"
+#include <httpsocketconstants.h>
+
+const TUint16 KTestProtocol	= 0xfb5;	//likewise
+
+//
+// Entrypoint
+//
+#ifdef __SECURE_API__
+GLDEF_C TInt E32Dll()
+#else
+GLDEF_C TInt E32Dll(TDllReason /*aReason*/)
+#endif
+{
+	return KErrNone;
+}
+
+class CTestProtocolFamily : public CProtocolFamilyBase
+{
+public:
+	CTestProtocolFamily();
+	~CTestProtocolFamily();
+	TInt Install();
+	TInt Remove();
+	TUint ProtocolList(TServerProtocolDesc *& aProtocolList);
+	CProtocolBase* NewProtocolL(TUint aSockType, TUint aProtocol);
+};
+
+extern "C" { IMPORT_C CProtocolFamilyBase* Install(void); }
+EXPORT_C CProtocolFamilyBase* Install()
+{
+	return new (ELeave) CTestProtocolFamily;
+}
+
+//----------------------------------------------------------------------
+// Dummy protocol family declaration. Required for DLL's
+//
+
+CTestProtocolFamily::CTestProtocolFamily()
+	{
+	__DECLARE_NAME(_S("CTestProtocolFamily"));
+	}
+
+CTestProtocolFamily::~CTestProtocolFamily()
+	{
+	}
+
+TInt CTestProtocolFamily::Install()
+	{
+	return KErrNone;
+	}
+
+TInt CTestProtocolFamily::Remove()
+	{
+	return KErrNone;
+	}
+
+TUint CTestProtocolFamily::ProtocolList(TServerProtocolDesc *& aProtocolList)
+	{
+	// This function should be a leaving fn
+	// apparently it is OK for it to leave
+	TServerProtocolDesc *p = new (ELeave) TServerProtocolDesc[1]; // Esock catches this leave
+	
+	CTestProtocol::FillIdentification(p[0]);
+	aProtocolList = p;
+	return 1;
+	}
+
+CProtocolBase* CTestProtocolFamily::NewProtocolL(TUint /*aSockType*/, TUint aProtocol)
+	{
+	if (aProtocol != KTestProtocol)
+		{
+		User::Leave(KErrNotSupported);
+		}
+
+	return new (ELeave) CTestProtocol;
+	}
+
+
+//-------------------------------------
+
+const TInt CTestFlowInfo::iOffset = _FOFF(CTestFlowInfo, iDLink);
+
+CTestProtocol::CTestProtocol() : iFlowList(CTestFlowInfo::iOffset), iSessionId(KErrNotFound)
+	{
+	}
+
+void CTestProtocol::InitL(TDesC& aTag)
+	{
+	CProtocolBase::InitL(aTag);
+	}
+
+void CTestProtocol::StartL()
+{
+//	__ASSERT_DEBUG(iProtocol != NULL, User::Leave(KErrGeneral));
+}
+
+CTestProtocol::~CTestProtocol()
+	{
+	if (iIPProtocol != NULL)
+		{
+		iIPProtocol->Unbind(this);
+		}
+	}
+
+void CTestProtocol::BindL(CProtocolBase* aProtocol, TUint aId)
+	{
+	if ((aId != KProtocolInet6Ip) || (aProtocol == this))
+		{
+		User::Leave(KErrGeneral);
+		}
+	
+	TUint ourId;
+	TServerProtocolDesc info;
+	Identify(&info);
+	ourId = info.iProtocol;
+	
+	if (aId == ourId)
+		{
+		User::Leave(KErrGeneral);
+		}
+
+	aProtocol->BindL((CProtocolBase*)this, BindFlowHook());
+	
+	iIPProtocol = (CProtocolInet6Binder*)aProtocol;
+	}
+
+void CTestProtocol::Unbind(CProtocolBase* aProtocol, TUint /*aId*/)
+	{
+	if (iIPProtocol == aProtocol) 
+		{
+		iIPProtocol = 0;
+		}
+
+	// All the FlowContexts in iFlowList must be deleted as well
+	if(!iFlowList.IsEmpty())
+		{
+		CTestFlowInfo* temp = iFlowList.First();
+		while (temp != NULL)
+			{
+			temp->iDLink.Deque();
+			delete temp;
+			temp = iFlowList.First();
+			}
+		}
+	}
+
+void CTestProtocol::FillIdentification(TServerProtocolDesc& anEntry)
+	{
+	anEntry.iName=_S("TestHook");
+	anEntry.iAddrFamily=KAfInet;
+	anEntry.iSockType=KSockDatagram;
+	anEntry.iProtocol=KTestProtocol;
+	anEntry.iVersion=TVersion(1, 0, 0);
+	anEntry.iByteOrder=EBigEndian;
+	anEntry.iServiceInfo=KSIDatagram | KSIConnectionLess;
+	anEntry.iNamingServices=0;
+	anEntry.iSecurity=KSocketNoSecurity;
+	anEntry.iMessageSize=0xffff;
+	anEntry.iServiceTypeInfo=0;
+	anEntry.iNumSockets=KUnlimitedSockets;
+	}
+
+void CTestProtocol::Identify(TServerProtocolDesc *aDesc) const
+	{
+	FillIdentification(*aDesc);
+	}
+
+void CTestProtocol::BindToL(CProtocolBase* /*aProtocol*/)
+	{
+	User::Panic(_L("TestHook"), 0);
+	}
+
+
+//----------------------------------------------------------------------
+MFlowHook *CTestProtocol::OpenL(TPacketHead& /*aHead*/, CFlowContext* aFlow)
+	{
+	CTestFlowInfo* info = new (ELeave) CTestFlowInfo;
+	info->iMgr = this;
+	iFlowList.AddLast(*info);	//Save the flow info for later use
+
+	if( iSessionId > 0 )
+		{
+		RDebug::Print(_L("Opening session with id = %i\n"),iSessionId);
+		}
+
+	info->iFlow = aFlow;
+
+	return info;
+	}
+
+
+
+TInt CTestProtocol::SetFlowOption(TUint aLevel, TUint aName, const TDesC8 &aOption, CFlowContext& aFlow)
+	{
+	(void) aFlow;
+	if((aLevel== KSOLHttpSessionInfo) && (aName == KSOHttpSessionId)) 
+		{
+		TPckgBuf<TInt> option; 
+		option.Copy(aOption);
+		iSessionId = option();
+		return KErrNone;
+		}
+	return KErrNotSupported;
+	}
+		
+TInt CTestFlowInfo::ReadyL(TPacketHead& /*aHead*/)
+{
+	return EFlow_READY;
+}
+
+//
+// Applies all the remaining modifications needed for every outgoing packet
+//
+TInt CTestFlowInfo::ApplyL(RMBufSendPacket& /*aPacket*/, RMBufSendInfo& /*aInfo*/)
+	{
+	return 0;
+	}
+
+void CTestFlowInfo::Close()
+	{
+	if (--iRefs < 0)
+		{
+		iDLink.Deque();
+		delete this;
+		}
+	}
+
+void CTestFlowInfo::Open()
+	{
+	iRefs++;
+	}