// Copyright (c) 2005-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:

//

/**

 @file

*/

#include "Te_SimPacketNotify2ThreadTest.h"

CSimPacketNotify2ThreadTest::CSimPacketNotify2ThreadTest() 

	{ 

	SetTestStepName(_L("Notify2ThreadTest"));

	}

TVerdict CSimPacketNotify2ThreadTest::doTestStepL()

	{

	INFO_PRINTF1(_L("BeginPacketNotify2ThreadTest"));

	CreateConfigFileL(_L("c:\\config3.txt"));

 	SetTestNumberL(6);

	const TInt KStackSize=0x8000;

	const TInt KHeapSize=0x8000;

	const TInt KMaxHeapSize=0x80000;

	_LIT(KGprsThreadName,"GprsThread");

	_LIT(KRel99ThreadName,"Rel99Thread");

	RThread gprs;

	RThread rel99;

	iGprsMutex.CreateLocal();

	gprs.Create(KGprsThreadName,GprsThreadEntry,

					KStackSize,KHeapSize,KMaxHeapSize,this);

	rel99.Create(KRel99ThreadName,Rel99ThreadEntry,

					KStackSize,KHeapSize,KMaxHeapSize,this);

	//start the threads

	gprs.Resume();

	rel99.Resume();

	while (iMainFlag==EFalse) //loop until threads have finished.

		User::After(5000);	

	iGprsMutex.Close();

	gprs.Close();

	rel99.Close();

	return TestStepResult();

	}

TInt CSimPacketNotify2ThreadTest::GprsThreadEntry(TAny* aThreadData)

	{

	CSimPacketNotify2ThreadTest* thisptr = static_cast<CSimPacketNotify2ThreadTest*>(aThreadData);

	thisptr->GprsNotifyFunction();

	ASSERT(RThread().RequestCount()==0);

	return(KErrNone);

	}

TInt CSimPacketNotify2ThreadTest::Rel99ThreadEntry(TAny* aThreadData)

	{

	CSimPacketNotify2ThreadTest* thisptr = static_cast<CSimPacketNotify2ThreadTest*>(aThreadData);

	thisptr->Rel99NotifyFunction();

	ASSERT(RThread().RequestCount()==0);

	return(KErrNone);

	}

void CSimPacketNotify2ThreadTest::GprsNotifyFunction()

	{

	TRequestStatus gprsReqStatus;

	TRequestStatus gprsNotifyStatus;

	RTelServer gprsServer;

	RMobilePhone gprsPhone;

	CTrapCleanup* cleanup;

	if ((cleanup=CTrapCleanup::New())==NULL)

		return;

	// Open Etel

	TESTL(gprsServer.Connect()==KErrNone);

	TESTL(gprsServer.LoadPhoneModule(KSimtsyName)==KErrNone);

	// Open phone

	TESTL(gprsPhone.Open(gprsServer,KPhoneName)==KErrNone); 

	// Open GPRS packet service

	TESTL(iGPRSPacketService.Open(gprsPhone)==KErrNone);

	// Open GPRS context

	TName gprsContextName;

	TName gprsContextNameCompare;

	TESTL(iGPRSPacketContext.OpenNewContext(iGPRSPacketService, gprsContextName)==KErrNone);

    iNewContextOpened = ETrue;

	gprsContextNameCompare.Append(KSimPrimaryPacketContextName);

	gprsContextNameCompare.AppendNum(1);

	TESTL(gprsContextName.Compare(gprsContextNameCompare)==KErrNone);

	// Configure GPRS context.

	RPacketContext::TContextConfigGPRS gprsContextConfig;

	TESTL(gprsContextConfig.ExtensionId()==TPacketDataConfigBase::KConfigGPRS);

	TPckg<RPacketContext::TContextConfigGPRS> contextConfigPckgGPRS(gprsContextConfig);

	gprsContextConfig.iAccessPointName = DPCKTTSY_ACCESS_POINT1;

	gprsContextConfig.iAnonymousAccessReqd = DPCKTTSY_ANONYMOUS_ACCESS1;

	gprsContextConfig.iPdpAddress = DPCKTTSY_PDP_ADDRESS1;

	gprsContextConfig.iPdpCompression = DPCKTTSY_COMPRESSION1;

	gprsContextConfig.iPdpType = DPCKTTSY_PDP_TYPE1;

	gprsContextConfig.iUseEdge = ETrue;

	gprsContextConfig.iProtocolConfigOption.iAuthInfo.iProtocol = SIM_PACKET_CONTEXT_PROTOCOL1;

	gprsContextConfig.iProtocolConfigOption.iAuthInfo.iUsername = SIM_PACKET_CONTEXT_USERNAME1;

	gprsContextConfig.iProtocolConfigOption.iAuthInfo.iPassword = SIM_PACKET_CONTEXT_PASSWORD1;

	gprsContextConfig.iProtocolConfigOption.iChallenge = SIM_PACKET_CONTEXT_CHALLENGE1;

	gprsContextConfig.iProtocolConfigOption.iResponse = SIM_PACKET_CONTEXT_RESPONSE1;

	gprsContextConfig.iProtocolConfigOption.iDnsAddresses.iPrimaryDns = SIM_PACKET_CONTEXT_PRIMARYSERVER1;

	gprsContextConfig.iProtocolConfigOption.iDnsAddresses.iSecondaryDns = SIM_PACKET_CONTEXT_SECONDARYSERVER1;

	gprsContextConfig.iProtocolConfigOption.iId = SIM_PACKET_CONTEXT_ID1;

	iGPRSPacketContext.NotifyConfigChanged(gprsNotifyStatus, contextConfigPckgGPRS);

	User::After(500000);

	iGprsMutex.Wait();

	iGPRSPacketContext.SetConfig(gprsReqStatus, contextConfigPckgGPRS);

	User::WaitForRequest(gprsNotifyStatus);

	User::WaitForRequest(gprsReqStatus);

	iGprsMutex.Signal();

	// Close

	iGPRSPacketContext.Close();

	iGPRSPacketService.Close();

	gprsPhone.Close();

	gprsServer.UnloadPhoneModule(KSimtsyName);

	gprsServer.Close();	// disconnect from etel

	delete cleanup;

	iThreadFlag=ETrue;//marks that this thread has finished

	ASSERT(RThread().RequestCount()==0);

	}

void CSimPacketNotify2ThreadTest::Rel99NotifyFunction()

	{

	TRequestStatus rel99ReqStatus;

	TRequestStatus rel99NotifyStatus;

	RTelServer rel99Server;

	RMobilePhone rel99Phone;

	CTrapCleanup* cleanup;

	if ((cleanup=CTrapCleanup::New())==NULL)

		return;

	// Open Etel

		TESTL(rel99Server.Connect()==KErrNone);

		TESTL(rel99Server.LoadPhoneModule(KSimtsyName)==KErrNone);

	// Open phone

		TESTL(rel99Phone.Open(rel99Server,KPhoneName)==KErrNone); 

  // Open GPRS packet service

	TESTL(iRel99PacketService.Open(rel99Phone)==KErrNone);

 //Open Rel99 Context

	TName rel99ContextNameCompare;

	rel99ContextNameCompare.Append(KSimPrimaryPacketContextName);

	rel99ContextNameCompare.AppendNum(1);

	while(iNewContextOpened==EFalse)

		User::After(50000);		

	TESTL(iRel99PacketContext.OpenExistingContext(iRel99PacketService, rel99ContextNameCompare)==KErrNone);

	RDebug::Print(_L("ThreadEntry9"));

	//Configure Rel99 Context	

	RPacketContext::TContextConfigR99_R4 rel99ContextConfig;

	TESTL(rel99ContextConfig.ExtensionId()==TPacketDataConfigBase::KConfigRel99Rel4);

	TPckg<RPacketContext::TContextConfigR99_R4> contextConfigPckgRel99(rel99ContextConfig);

	rel99ContextConfig.iAccessPointName = DPCKTTSY_ACCESS_POINT1;

	rel99ContextConfig.iPdpAddress = DPCKTTSY_PDP_ADDRESS1;

	rel99ContextConfig.iPdpType = DPCKTTSY_PDP_TYPE1;

	rel99ContextConfig.iUseEdge = DPCKTTSY_EGPRS_REQUIRED;

	rel99ContextConfig.iProtocolConfigOption.iAuthInfo.iProtocol = SIM_PACKET_CONTEXT_PROTOCOL2;

	rel99ContextConfig.iProtocolConfigOption.iAuthInfo.iUsername = SIM_PACKET_CONTEXT_USERNAME2;

	rel99ContextConfig.iProtocolConfigOption.iAuthInfo.iPassword = SIM_PACKET_CONTEXT_PASSWORD2;

	rel99ContextConfig.iProtocolConfigOption.iChallenge = SIM_PACKET_CONTEXT_CHALLENGE2;

	rel99ContextConfig.iProtocolConfigOption.iResponse = SIM_PACKET_CONTEXT_RESPONSE2;

	rel99ContextConfig.iProtocolConfigOption.iDnsAddresses.iPrimaryDns = SIM_PACKET_CONTEXT_PRIMARYSERVER2;

	rel99ContextConfig.iProtocolConfigOption.iDnsAddresses.iSecondaryDns = SIM_PACKET_CONTEXT_SECONDARYSERVER2;

	rel99ContextConfig.iProtocolConfigOption.iId = SIM_PACKET_CONTEXT_ID2;

	iRel99PacketContext.NotifyConfigChanged(rel99ReqStatus, contextConfigPckgRel99);

	RDebug::Print(_L("ThreadEntry8"));

	iGprsMutex.Wait();	

	iRel99PacketContext.SetConfig(rel99ReqStatus, contextConfigPckgRel99);

	User::WaitForRequest(rel99NotifyStatus);

	User::WaitForRequest(rel99ReqStatus);	

	iGprsMutex.Signal();

	// Close

	iRel99PacketContext.Close();

	iRel99PacketService.Close();

	while(iThreadFlag==EFalse)	//wait until the other thread has finished.

		User::After(50000);

	rel99Phone.Close();

	rel99Server.UnloadPhoneModule(KSimtsyName);

	rel99Server.Close();	// disconnect from etel

	delete cleanup;

	iMainFlag=ETrue; //mark to say this thread (and hence the test) has finished.

	ASSERT(RThread().RequestCount()==0);

	}