--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/common/tools/ats/smoketest/lbs/lbsclient/src/ctlbsclientpostp256.cpp Tue Nov 10 13:50:58 2009 +0000
@@ -0,0 +1,291 @@
+// 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 the License "Symbian Foundation License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.symbianfoundation.org/legal/sfl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+//
+
+
+
+// INCLUDES
+#include <EPos_CPosModules.h>
+#include <EPos_CPosModuleIdList.h>
+#include "ctlbsclientpostp256.h"
+#include <e32std.h>
+
+// CONSTANTS
+const TInt KNoMultipleClients=2;
+const TUint KMaxHeapSize=0x80000;
+
+// Structure for passing parameters to threads
+struct MyThreadData
+ {
+ TBool iTestFlag;
+ };
+
+// ================= MEMBER FUNCTIONS =======================
+
+// ---------------------------------------------------------
+// Constructor.
+// ---------------------------------------------------------
+CT_LbsClientPosTp256::CT_LbsClientPosTp256(CT_LbsServer& aParent): CT_LbsPortedStepBase(aParent)
+ {
+ _LIT(KTestName, "Tp256 - Location Settings and Multiple Clients");
+ SetTestStepName(KTestName);
+ }
+
+// ---------------------------------------------------------
+// Destructor.
+// ---------------------------------------------------------
+CT_LbsClientPosTp256::~CT_LbsClientPosTp256()
+ {
+ }
+
+// ---------------------------------------------------------
+// CT_LbsClientPosTp256::StartL
+//
+// (other items were commented in a header).
+// ---------------------------------------------------------
+//
+void CT_LbsClientPosTp256::StartL()
+ {
+ _LIT(KMultipleErr, "Error %d when multiple clients access the CPosModules, err from client:%d");
+ _LIT(KSuccess, "Client %d is successful");
+ _LIT(KAllErr, "All clients gets error when multiple clients access the CPosModules");
+ _LIT(KPanicErr, "Panic when multiple clients access the CPosModules, Thread: %d panics");
+
+ TFixedArray<TRequestStatus, KNoMultipleClients> statuses;
+ //make a request just to make sure att all databases are created.
+
+ SetupPsyL(iUidMultiPsy);
+
+ //synchronous request
+ ConnectL();
+
+ User::LeaveIfError(OpenPositionerByName(iUidMultiPsy));
+
+ TPositionInfo info = TPositionInfo();
+
+ RequestL(info);
+
+ //potenial memory leak if above function leav
+ ClosePositioner();
+ Disconnect();
+
+ //End first request.
+
+
+ TInt errorsFound = KErrNone;
+ CreateThreadsL();
+
+ for (TInt i=0; i<iThreads.Count(); i++)
+ {
+ iThreads[i].Logon(statuses[i]);
+ iThreads[i].Resume();
+ }
+
+ for (TInt t=0; t<iThreads.Count(); t++)
+ {
+ TInt exitReason = iThreads[t].ExitReason();
+
+ TBuf<150> buf;
+ if (exitReason != KErrNone)
+ {
+ buf.Format(KMultipleErr, exitReason, t);
+ INFO_PRINTF1(buf);
+
+ errorsFound++;
+ }
+ else
+ {
+ buf.Format(KSuccess, t);
+ INFO_PRINTF1(buf);
+ }
+ AssertTrueL(iThreads[t].ExitType() != EExitPanic, KPanicErr, t);
+ }
+
+ AssertTrueL(errorsFound < KNoMultipleClients, KAllErr, KErrGeneral);
+
+ _LIT(KPass, "CT_LbsClientPosTp256 passed!!!");
+ INFO_PRINTF1(KPass);
+ }
+
+// ---------------------------------------------------------
+// CT_LbsClientPosTp256::CloseTest
+//
+// (other items were commented in a header).
+// ---------------------------------------------------------
+//
+void CT_LbsClientPosTp256::CloseTest()
+ {
+ for (TInt i=0; i<iThreads.Count(); i++)
+ {
+ iThreads[i].Close();
+ }
+
+ iThreads.Close();
+ iNames.ResetAndDestroy();
+ }
+
+// ---------------------------------------------------------
+// void RunTestL
+//
+// (other items were commented in a header).
+// ---------------------------------------------------------
+//
+void RunTestL(TAny* aData)
+ {
+ const TInt KNrOfRounds = 50;
+
+ CPosModules* db = CPosModules::OpenL();
+ CleanupStack::PushL(db);
+
+ TInt nrOfModules = 0;
+
+ // Read parameters from TAny*
+ MyThreadData* info = (MyThreadData*) aData;
+ TInt i = 0;
+ for (i=0;i<KNrOfRounds; i++)
+ {
+ //db->ResetAllModulesL();
+ CPosModuleIdList* myDebugList = db->ModuleIdListLC();
+
+ nrOfModules = myDebugList->Count();
+ TPositionModuleInfo debugModuleInfo;
+ TBuf<40> moduleName;
+ TPositionQuality quality;
+
+ for (TInt i=0;i<nrOfModules;i++)
+ {
+ db->GetModuleInfoL(myDebugList->At(i), debugModuleInfo);
+ moduleName.Zero();
+ debugModuleInfo.GetModuleName(moduleName);
+ debugModuleInfo.GetPositionQuality(quality);
+ }
+ CleanupStack::PopAndDestroy(myDebugList);
+ }
+
+ for (i=0;i<KNrOfRounds; i++)
+ {
+ // The first thread does this
+ if (info->iTestFlag)
+ {
+ for (TInt j=0;j<nrOfModules;j++)
+ {
+ // Just change priority
+ db->SetModulePriorityL(nrOfModules-j-1, j);
+ }
+ }
+ // And all the other thread does this
+ else
+ {
+ CPosModuleIdList* myDebugList = db->ModuleIdListLC();
+
+ TInt debugCount = myDebugList->Count();
+ TPositionModuleInfo debugModuleInfo;
+ TBuf<20> moduleName;
+ TPositionQuality quality;
+
+ for (TInt i=0;i<debugCount;i++)
+ {
+ db->GetModuleInfoL(myDebugList->At(i), debugModuleInfo);
+ moduleName.Zero();
+ debugModuleInfo.GetModuleName(moduleName);
+ debugModuleInfo.GetPositionQuality(quality);
+ }
+ CleanupStack::PopAndDestroy(myDebugList);
+ }
+ }
+
+
+ CleanupStack::PopAndDestroy(db);
+ }
+
+// ---------------------------------------------------------
+// LOCAL_C TInt ThreadFunction
+//
+// (other items were commented in a header).
+// ---------------------------------------------------------
+//
+LOCAL_C TInt ThreadFunction(TAny* aData)
+ {
+ __UHEAP_MARK;
+ CTrapCleanup* cleanup=CTrapCleanup::New(); // get clean-up stack
+
+ if (cleanup == NULL)
+ {
+ return KErrNoMemory;
+ }
+ // we need an ActiveScheduler
+ CActiveScheduler scheduler;
+ CActiveScheduler::Install(&scheduler);
+
+ TRAPD(err, RunTestL(aData));
+
+ delete cleanup; // destroy clean-up stack
+ __UHEAP_MARKEND;
+ return err;
+ }
+
+// ---------------------------------------------------------
+// CT_LbsClientPosTp256::CreateThreadsL
+//
+// (other items were commented in a header).
+// ---------------------------------------------------------
+//
+void CT_LbsClientPosTp256::CreateThreadsL()
+ {
+ _LIT(KThreadName, "TP256 test thread%d");
+ _LIT(KCreateThreadErr, "Create thread failed with %d");
+
+ for (TInt i=0; i<KNoMultipleClients; i++)
+ {
+ // Introduce parameters for each thread.
+ MyThreadData info;
+
+ if (i == 0) info.iTestFlag = ETrue;
+ else info.iTestFlag = EFalse;
+
+ RThread thread;
+ TBuf<32> name;
+ name.Format(KThreadName, 1+iThreads.Count());
+
+ TInt err;
+ err = thread.Create(name, ThreadFunction, KDefaultStackSize, KMinHeapSize, KMaxHeapSize, reinterpret_cast<TAny*>(&info));
+ AssertTrueL(err == KErrNone, KCreateThreadErr, err);
+
+ iThreads.Append(thread);
+ }
+ }
+
+
+void CT_LbsClientPosTp256::RequestL(TPositionInfoBase& aInfoBase)
+ {
+ _LIT(KService, "service");
+ TInt err = PerformSyncRequest(KService, &aInfoBase);
+
+ if (err != KErrNone)
+ {
+ _LIT(KErrorRequest, "The request was not completed with KErrorNone, errCode = %d");
+ TBuf<100> buf;
+ buf.Format(KErrorRequest, err);
+ LogErrorAndLeaveL(buf);
+ }
+
+ _LIT(KIncorrectPsySyncRequestError,
+ "TP2. Position from wrong PSY received (sync request).");
+ if (iUidMultiPsy != aInfoBase.ModuleId())
+ {
+ LogErrorAndLeaveL(KIncorrectPsySyncRequestError);
+ }
+ }
+
+// End of File