--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/test/protocols/ptestinternalsocket/src/protocolfamily.cpp	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,164 @@
+// 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:
+//
+
+#include <es_prot.h>
+#include <e32test.h>
+#include "es_ptestinternalsocket.h"
+#include <comms-infras/nifif.h>
+#include <comms-infras/eintsock.h>
+#include <comms-infras/ss_roles.h>
+#include <nifman_internal.h>
+#include <es_mbuf.h>
+#include <ss_std.h>
+#include <ss_pman.h>
+#include <ss_glob.h>
+#include <e32math.h>
+#include <dns_qry.h>
+#include <agenterrors.h>
+#include <e32property.h>
+
+#include "proxyprotocol.h"
+
+#include "protocolfamily.h"
+
+extern "C"
+	{
+	IMPORT_C CProtocolFamilyBase* InstallProxy(void);	// Force export 
+
+	EXPORT_C CProtocolFamilyBase * InstallProxy(void)
+	//
+	// Create a new protocol family
+	//
+		{
+		return CTestIntSocketProtocolFamily::NewL();
+		}
+	}
+
+CTestIntSocketProtocolFamily* CTestIntSocketProtocolFamily::NewL()
+//
+//
+//
+	{
+	CTestIntSocketProtocolFamily* pf=new(ELeave) CTestIntSocketProtocolFamily();
+	CleanupStack::PushL(pf);
+	pf->ConstructL();
+	CleanupStack::Pop();
+	return pf;
+	}
+
+void CTestIntSocketProtocolFamily::ConstructL()
+//
+//
+//
+	{
+	// Force a fail on Memory tests
+	char* ptr=new(ELeave) char;
+	delete ptr;
+
+	}
+
+CTestIntSocketProtocolFamily::CTestIntSocketProtocolFamily() : CProtocolFamilyBase()
+	{
+	iProtocolDescs[0].iAddrFamily=KProxyAddrFamily;
+	iProtocolDescs[0].iSockType=KSockDatagram; // not important whether datagram or stream for proxy
+	iProtocolDescs[0].iProtocol=KProxy;
+	iProtocolDescs[0].iVersion=TVersion(KPTestIntSocketMajor,KPTestIntSocketMinor,KPTestIntSocketBuild);
+	iProtocolDescs[0].iByteOrder=EBigEndian;
+	iProtocolDescs[0].iServiceInfo=kDDatagramServiceInfo|KSIPeekData;
+	iProtocolDescs[0].iSecurity=KSocketNoSecurity;
+	iProtocolDescs[0].iMessageSize=0x300;
+	iProtocolDescs[0].iName=KProxyName;
+	iProtocolDescs[0].iServiceTypeInfo=ESocketSupport|ECantProcessMBufChains;
+	iProtocolDescs[0].iNamingServices=KNSNameResolution|KNSServiceResolution|KNSInfoDatabase;
+	iProtocolDescs[0].iNumSockets=100;
+/*
+	iProtocolDescs[1].iAddrFamily=KProxyAddrFamily;
+	iProtocolDescs[1].iSockType=KSockDatagram;
+	iProtocolDescs[1].iProtocol=KTargetDatagram;
+	iProtocolDescs[1].iVersion=TVersion(KPTestIntSocketMajor,KPTestIntSocketMinor,KPTestIntSocketBuild);
+	iProtocolDescs[1].iByteOrder=EBigEndian;
+	iProtocolDescs[1].iServiceInfo=kDDatagramServiceInfo|KSIPeekData;
+	iProtocolDescs[1].iSecurity=KSocketNoSecurity;
+	iProtocolDescs[1].iMessageSize=0x300;
+	iProtocolDescs[1].iName=KTargetDatagramName;
+	iProtocolDescs[1].iServiceTypeInfo=ESocketSupport|ECantProcessMBufChains;
+	iProtocolDescs[1].iNamingServices=KNSNameResolution|KNSServiceResolution|KNSInfoDatabase;
+	iProtocolDescs[1].iNumSockets=100;
+
+	iProtocolDescs[2].iAddrFamily=KProxyAddrFamily;
+	iProtocolDescs[2].iSockType=KSockStream;
+	iProtocolDescs[2].iProtocol=KTargetStream;
+	iProtocolDescs[2].iVersion=TVersion(KPTestIntSocketMajor,KPTestIntSocketMinor,KPTestIntSocketBuild);
+	iProtocolDescs[2].iByteOrder=EBigEndian;
+	iProtocolDescs[2].iServiceInfo=KDStreamServiceInfo;
+	iProtocolDescs[2].iSecurity=KSocketNoSecurity;
+	iProtocolDescs[2].iMessageSize=KSocketMessageSizeIsStream;
+	iProtocolDescs[2].iName=KTargetStreamName;
+	iProtocolDescs[2].iServiceTypeInfo=ESocketSupport|ECantProcessMBufChains;
+	iProtocolDescs[2].iNamingServices=0;
+	iProtocolDescs[2].iNumSockets=100;
+*/
+	__DECLARE_NAME(_S("CTestIntSocketProtocolFamily"));
+	}
+
+#pragma warning( disable : 4100 )
+
+TInt CTestIntSocketProtocolFamily::Install()
+	{
+	// Force a fail on Memory tests
+	char* ptr=new char;
+	if (!ptr)
+		return KErrNoMemory;
+	delete ptr;
+	return KErrNone;
+	}
+
+TInt CTestIntSocketProtocolFamily::Remove()
+	{
+	return KErrNone;
+	}
+
+TUint CTestIntSocketProtocolFamily::ProtocolList(TServerProtocolDesc *& aProtocolDescPointer)
+	{
+	// Make sure we don't register the proxy protocol twice when testing two worker threads.
+	// We only need one instance and if we try to register a second, ESockSvr will panic the
+	// second worker thread with a misconfiguration error.
+	if(SockManGlobals::Get()->SelfWorker()->WorkerId() == KProxyWorkerTwoId)
+		{
+		aProtocolDescPointer = NULL;
+		
+		return 0;
+		}
+ 
+  	aProtocolDescPointer=new TServerProtocolDesc[KPTestIntSocketNumProtocols];
+  	if (!aProtocolDescPointer)
+  		return 0;
+
+	Mem::Copy(aProtocolDescPointer, iProtocolDescs, sizeof(TServerProtocolDesc)*KPTestIntSocketNumProtocols);
+
+	TRAP_IGNORE(Nif::CheckInstalledMBufManagerL();)
+
+	return KPTestIntSocketNumProtocols;
+	};
+
+CProtocolBase * CTestIntSocketProtocolFamily::NewProtocolL(TUint /* aSockType */,TUint aProtocol)
+	{
+
+	CProtocolBase* p=CProxyProtocol::NewL(aProtocol, &iProtocolDescs[aProtocol-1]);	
+	return p;
+	}
+
+
+