// 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;
	}