servicediscoveryandcontrol/pnp/test/upnp/unittests/udpserver/src/protocolfamily.cpp
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/servicediscoveryandcontrol/pnp/test/upnp/unittests/udpserver/src/protocolfamily.cpp Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,158 @@
+/*
+* Copyright (c) 2008 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_ptest.h"
+#include <comms-infras/nifif.h>
+#include <es_mbuf.h>
+#include "ss_std.h"
+#include <ss_pman.h>
+#include <ss_glob.h>
+#include <es_mbman.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
+ //
+ {
+ CTestIntSocketProtocolFamily* protocolFamily = NULL;
+ TRAP_IGNORE(protocolFamily = CTestIntSocketProtocolFamily::NewL());
+ return protocolFamily;
+ }
+ }
+
+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;
+// TAppProtIntfMessage::RegisterL ();
+ return KErrNone;
+ }
+
+TInt CTestIntSocketProtocolFamily::Remove()
+ {
+ //TAppProtIntfMessage::DeRegister ();
+ return KErrNone;
+ }
+
+TUint CTestIntSocketProtocolFamily::ProtocolList(TServerProtocolDesc *& aProtocolDescPointer)
+ {
+
+ 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;
+ }
+
+