--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/tsrc/VCXTestCommon/src/TestUtilConnectionWaiter.cpp Mon Jan 18 20:21:12 2010 +0200
@@ -0,0 +1,315 @@
+/*
+* 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 the License "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 FILES
+
+#include "TestUtilConnectionWaiter.h"
+#include "VCXTestLog.h"
+#include "MTestUtilConnectionObserver.h"
+
+const TInt KMillion = 1000000;
+
+// ========================== MEMBER FUNCTIONS ===============================
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::NewL()
+//
+// Constructs CTestUtilConnectionWaiter object
+// ---------------------------------------------------------------------------
+//
+EXPORT_C CTestUtilConnectionWaiter* CTestUtilConnectionWaiter::NewL(MTestUtilConnectionObserver* aObserver)
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::NewL");
+ CTestUtilConnectionWaiter* self = NewLC(aObserver);
+ CleanupStack::Pop(self);
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::NewL");
+ return self;
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::NewLC()
+//
+// Constructs CTestUtilConnectionWaiter object
+// ---------------------------------------------------------------------------
+//
+EXPORT_C CTestUtilConnectionWaiter* CTestUtilConnectionWaiter::NewLC(MTestUtilConnectionObserver* aObserver)
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::NewLC");
+ CTestUtilConnectionWaiter* self = new (ELeave) CTestUtilConnectionWaiter(aObserver);
+ CleanupStack::PushL(self);
+ self->ConstructL();
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::NewLC");
+ return self;
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::CTestUtilConnectionWaiter()
+//
+// Constructor
+// ---------------------------------------------------------------------------
+//
+EXPORT_C CTestUtilConnectionWaiter::CTestUtilConnectionWaiter(MTestUtilConnectionObserver* aObserver)
+: CActive(CActive::EPriorityHigh), iObserver(aObserver)
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::CTestUtilConnectionWaiter");
+
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::CTestUtilConnectionWaiter");
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::~CTestUtilConnectionWaiter()
+//
+// Destructor
+// ---------------------------------------------------------------------------
+//
+EXPORT_C CTestUtilConnectionWaiter::~CTestUtilConnectionWaiter()
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::~CTestUtilConnectionWaiter");
+
+ if( IsAdded() )
+ {
+ Deque(); // calls also Cancel()
+ }
+
+ iServ.Close();
+
+ iTimer.Close();
+
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::~CTestUtilConnectionWaiter");
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::ConstructL()
+//
+// Second phase constructor
+// ---------------------------------------------------------------------------
+//
+void CTestUtilConnectionWaiter::ConstructL()
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::ConstructL");
+
+ // get connection for the iap
+
+ TInt err = iServ.Connect();
+ if(err != KErrNone)
+ {
+ VCXLOGLO2("Could not connect to socket server, %d.", err);
+ User::Leave(err);
+ }
+
+ User::LeaveIfError(iTimer.CreateLocal());
+
+ CActiveScheduler::Add(this);
+
+
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::ConstructL");
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::WaitForConnection()
+//
+// Start waiting the IAP to be active
+// ---------------------------------------------------------------------------
+//
+EXPORT_C void CTestUtilConnectionWaiter::WaitForConnection(TUint32 aIapId)
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::WaitForConnection");
+
+ if (!IsActive())
+ {
+ iWaitState = EWaitingConnection;
+
+ iIapId = aIapId;
+ iTimer.After(iStatus, KMillion);
+ SetActive();
+ iCheckCount = 0;
+
+ VCXLOGLO2(">>>CTestUtilConnectionWaiter:: Waiting until connection is created for Iap: %d", aIapId);
+ }
+ else
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter:: error - already ACTIVE");
+ }
+
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::WaitForConnection");
+ }
+
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::WaitUntilConnectionIsClosed()
+//
+// Start waiting the IAP to be active
+// ---------------------------------------------------------------------------
+//
+EXPORT_C void CTestUtilConnectionWaiter::WaitUntilConnectionIsClosed(TUint32 aIapId)
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::WaitUntilConnectionIsClosed");
+
+ if (!IsActive())
+ {
+ iWaitState = EWaitingConnectionClosed;
+
+ iIapId = aIapId;
+ iTimer.After(iStatus, KMillion);
+ SetActive();
+ iCheckCount = 0;
+
+ VCXLOGLO2(">>>CTestUtilConnectionWaiter:: Waiting until connection closed for Iap: %d", aIapId);
+ }
+ else
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter:: error - already ACTIVE");
+ }
+
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::WaitUntilConnectionIsClosed");
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::RunL()
+//
+// Handle request completion events
+// ---------------------------------------------------------------------------
+//
+void CTestUtilConnectionWaiter::RunL()
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::RunL");
+
+// TInt statusCode = iStatus.Int();
+
+ if( iCheckCount++ == 30 )
+ {
+ VCXLOGLO1("CTestUtilConnectionWaiter:: Connection request timed out.");
+ iObserver->ConnectionTimeout();
+ iCheckCount = 0;
+ Cancel();
+ }
+ else
+ {
+ switch(iWaitState)
+ {
+ case EWaitingConnection:
+ {
+ if(IsConnectionActive(iIapId))
+ {
+ iObserver->ConnectionCreated();
+ iWaitState = ENoWaitState;
+ VCXLOGLO1("Connection is active!");
+ }
+ else
+ {
+ SetActive();
+ iTimer.After(iStatus, KMillion);
+ }
+ }
+ break;
+
+ case EWaitingConnectionClosed:
+ {
+ if(!IsConnectionActive(iIapId))
+ {
+ iObserver->ConnectionClosed();
+ iWaitState = ENoWaitState;
+ VCXLOGLO1("Connection is closed!");
+ }
+ else
+ {
+ SetActive();
+ iTimer.After(iStatus, KMillion);
+ }
+ }
+ break;
+
+ default:
+ break;
+ }
+ }
+
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::RunL");
+
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::DoCancel()
+//
+// Cancels ongoing requests
+// ---------------------------------------------------------------------------
+//
+void CTestUtilConnectionWaiter::DoCancel()
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::DoCancel");
+ iTimer.Cancel();
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::DoCancel");
+ }
+
+// ---------------------------------------------------------------------------
+// CTestUtilConnectionWaiter::IsConnectionActive(TUint32 aIapId)
+//
+// Checks if IAP specified in iWaitConnectionForIapId is active
+// ---------------------------------------------------------------------------
+EXPORT_C TBool CTestUtilConnectionWaiter::IsConnectionActive(TUint32 aIapId)
+ {
+ VCXLOGLO1(">>>CTestUtilConnectionWaiter::IsConnectionActive");
+
+ RConnection connection;
+
+ TUint count;
+
+ TInt err = connection.Open(iServ, KAfInet);
+
+ if(err != KErrNone)
+ {
+ iServ.Close();
+ VCXLOGLO2("CTestUtilConnectionWaiter::Could not connect to open connection: %d.", err);
+ User::Leave(err);
+ }
+
+ err = connection.EnumerateConnections(count);
+ if(err != KErrNone)
+ {
+ connection.Close();
+ iServ.Close();
+ VCXLOGLO2("CTestUtilConnectionWaiter::Could not enum connections, %d.", err);
+ User::Leave(err);
+ }
+
+ for(; count; --count)
+ {
+ TPckgBuf<TConnectionInfo> connInfo;
+
+ if(connection.GetConnectionInfo(count, connInfo) == KErrNone)
+ {
+ VCXLOGLO2("CTestUtilConnectionWaiter:: Connection IAP id: %d", connInfo().iIapId);
+
+ if(aIapId == connInfo().iIapId)
+ {
+ VCXLOGLO1("CTestUtilConnectionWaiter:: IAP is connected.");
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::IsConnectionActive");
+ connection.Close();
+ return ETrue;
+ }
+ }
+ }
+
+ connection.Close();
+
+ VCXLOGLO1("<<<CTestUtilConnectionWaiter::IsConnectionActive");
+ return EFalse;
+ }
+
+
+// End of file