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

// EtelPacketTestMultipleClients.cpp

// This file tests the scenario of Multiple Clients using the Packet API simultaneously.

// It is primarily used to exercise the mutex in the methods RPacketContext::OpenNewContext()

// and RPacketContext::OpenNewSecondaryContext().

// 

//

// Symbian OS includes

#include <e32base.h>

#include <e32std.h>

#include <etelpckt.h>

#include <pcktcs.h>

#include "Te_EtelPacketTestStepBase.h"

#include "testdef.h"

#include "Te_EtelPacketTestMultipleClients.h"

#include "Te_etelpckt_defs.h"

// constructor

CEtelPacketTestMultipleClients::CEtelPacketTestMultipleClients()

{

	// store the name of this test case

	SetTestStepName(_L("Multiple_Clients"));

}

// destructor

CEtelPacketTestMultipleClients::~CEtelPacketTestMultipleClients()

{

}

enum TVerdict CEtelPacketTestMultipleClients::doTestStepL( void )

/**

 * Test step Multiple_Clients tests simultaneous use of the API by Multiple clients.

 */

{

// Allocate the size of the stack and heap objects

	const TInt KStackSize=0x8000;

	const TInt KHeapSize=0x8000;

	const TInt KMaxHeapSize=0x80000;

// Create 2 RThread objects

	_LIT(KClientApp1ThreadName,"ClientApp1");

	_LIT(KClientApp2ThreadName,"ClientApp2");

	RThread thread1;

	RThread thread2;

	TInt res1=thread1.Create(KClientApp1ThreadName,ContextCreationFunction,

					    KStackSize,KHeapSize,KMaxHeapSize,this);

	TInt res2=thread2.Create(KClientApp2ThreadName,ContextCreationFunction,

					    KStackSize,KHeapSize,KMaxHeapSize,this);

	TRequestStatus thread1Status;

	TRequestStatus thread2Status;

	TBool req1Complete=EFalse;

	TBool req2Complete=EFalse;

// If both threads have been created successfully, start their execution

	if (res1==KErrNone && res2==KErrNone)

		{

		thread1.Logon(thread1Status);

		thread2.Logon(thread2Status);

		thread1.Resume();

		thread2.Resume();

		while ( req1Complete==EFalse || req2Complete==EFalse)

			{

			User::WaitForAnyRequest();

			if (thread1Status != KRequestPending && req1Complete==EFalse)

				{

				CHECKPOINT(thread1Status.Int(),KErrNone,CHP_CNTXT_CASE("A.MC2"));

				req1Complete=ETrue;

				}

			if (thread2Status != KRequestPending && req2Complete==EFalse)

				{

				CHECKPOINT(thread2Status.Int(),KErrNone,CHP_CNTXT_CASE("A.MC3"));

				req2Complete=ETrue;

				}

			} // while statement

		} // if statement

	thread1.Close();

	thread2.Close();

	return TestStepResult();

}

TInt CEtelPacketTestMultipleClients::ContextCreationFunction(TAny* /*aThread*/ )

/**

 * Static thread function. A primary and secondary context are created in this function.

 * The following sequence is carried out in order to create a secondary context:

 * Connect to the Telephony server, Load the Telephony module, open handles to a phone,

 * packet service and primary context object. 

 * Once the secondary context is created, all the handles are closed. Context 

 * functionality is exercised in other test modules and is not repeated here.

 * Note that logging is done explicitly in this function to the generated test result

 * file. This is to enable a tester examine the behaviour of this test without having to 

 * resort to checking the dummy TSY logs.

 *

 * Note The logging code has been temporarily commented out. This is because the logging

 * used by the test harness, scheduletest is not thread safe for multithreaded calls.

 * When the test harness has been modified (either by making it thread safe for multithreaded

 * calls or by using FLOGGER, the logging for this test case should be updated.

 * - 16/05/02

 */

{

	// Create a cleanup stack object

	CTrapCleanup* cleanup=CTrapCleanup::New();

	if (cleanup==NULL)

		return KErrNoMemory;

// Use the 'this' pointer to access functionality available to the test step class.

	//CEtelPacketTestMultipleClients* ptr = (CEtelPacketTestMultipleClients*) aThreadData;

	//ptr->INFO_PRINTF1(_L("Thread %d finished Wait()."), RThread().Id());

// Establish a connection to the ETel Server and open handles for this thread.

// An arbitrary value of 20 is assigned for the buffer size for the context names.

// Using a TName object would incur a significant load on the stack, which is 

// unnecessary for this test code.

	RTelServer server;

	RPhone pcktPhone;

	RPacketService wcdmaService;

	RPacketContext primaryContext;

	RPacketContext wcdmaContext;

	TBuf<20>  contextName;

	TBuf<20> secondaryContextName;

	TInt ret= KErrNone;

	if ( (ret=server.Connect())==KErrNone)

		{

		//ptr->INFO_PRINTF1(_L("Thread %d: Connect to ETel server - Pass."), RThread().Id());

		if ( (ret=server.LoadPhoneModule(DPCKTTSY_MODULE_NAME))==KErrNone)

			{

			//ptr->INFO_PRINTF1(_L("Thread %d: Load phone module - Pass."), RThread().Id());

			if ( (ret=pcktPhone.Open(server,DPCKTTSY_PHONE_NAME))==KErrNone)

				{

				//ptr->INFO_PRINTF1(_L("Thread %d: Open Packet phone - Pass."), RThread().Id());

				if ( (ret=wcdmaService.Open(pcktPhone))==KErrNone)

					{

					//ptr->INFO_PRINTF1(_L("Thread %d: Open Packet service - Pass."), RThread().Id());

					if ( (ret=primaryContext.OpenNewContext(wcdmaService, contextName))==KErrNone)

						{

						//ptr->INFO_PRINTF1(_L("Thread %d: Open Primary context - Pass."), RThread().Id());

						if ( (ret=wcdmaContext.OpenNewSecondaryContext(wcdmaService, contextName, secondaryContextName))==KErrNone)

							{

							//ptr->INFO_PRINTF1(_L("Thread %d: Open Secondary context - Pass."), RThread().Id());

							wcdmaContext.Close();

							//ptr->INFO_PRINTF1(_L("Thread %d: Close Secondary context - Pass."), RThread().Id());

							}

						primaryContext.Close();

						//ptr->INFO_PRINTF1(_L("Thread %d: Close Primary context - Pass."), RThread().Id());

						}

					wcdmaService.Close();

					//ptr->INFO_PRINTF1(_L("Thread %d: Close Packet service - Pass."), RThread().Id());

					}

				pcktPhone.Close();

				//ptr->INFO_PRINTF1(_L("Thread %d: Close Packet phone - Pass."), RThread().Id());

				}

			server.UnloadPhoneModule(DPCKTTSY_MODULE_NAME);

			//ptr->INFO_PRINTF1(_L("Thread %d: Unload phone module - Pass."), RThread().Id());

			}

		server.Close();

		//ptr->INFO_PRINTF1(_L("Thread %d: Close ETel server - Pass."), RThread().Id());

		}

	delete cleanup;

	return ret;	

}