--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/supl/supltiapiimplementation/src/lbssupltirequestmanager.cpp	Tue Feb 02 01:06:48 2010 +0200
@@ -0,0 +1,242 @@
+/*
+* Copyright (c) 2005 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:  CCLbsSuplTiRequestManager Class Implementation
+*
+*/
+
+#include <lbs/supltiapi.h>
+
+#include "lbssupltirequestmanager.h"
+#include "lbssupltiapirequestor.h"
+#include "epos_tiapiimpltrace.h"
+
+
+_LIT(KTraceFileName,"lbssupltiapirequestmanager.cpp");
+
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::CCLbsSuplTiRequestManager
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+CCLbsSuplTiRequestManager::CCLbsSuplTiRequestManager(MLbsSuplTiObserver& aObserver):CActive(EPriorityStandard), iObserver(aObserver)
+    {
+    // No implementation required
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::~CCLbsSuplTiRequestManager
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+CCLbsSuplTiRequestManager::~CCLbsSuplTiRequestManager()
+    {
+    CloseSession();
+    iRequestorCollection.Close();
+    if(iTrace)
+        {
+        delete iTrace;
+        iTrace = NULL;
+        }
+   if (IsActive())      
+      	Cancel();
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::NewLC
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+CCLbsSuplTiRequestManager* CCLbsSuplTiRequestManager::NewLC(MLbsSuplTiObserver& aObserver)
+    {
+    CCLbsSuplTiRequestManager* self =
+            new (ELeave) CCLbsSuplTiRequestManager(aObserver);
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    return self;
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::NewL
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+CCLbsSuplTiRequestManager* CCLbsSuplTiRequestManager::NewL(MLbsSuplTiObserver& aObserver)
+    {
+    CCLbsSuplTiRequestManager* self = CCLbsSuplTiRequestManager::NewLC(aObserver);
+    CleanupStack::Pop(); // self;
+    return self;
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::ConstructL
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+void CCLbsSuplTiRequestManager::ConstructL()
+    {
+	CActiveScheduler::Add(this);
+    iTrace = COMASuplTrace::NewL(); 
+    iTrace->Trace(_L("CCLbsSuplTiRequestManager::ConstructL()"), KTraceFileName, __LINE__); 
+
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::RequestLocation
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+void CCLbsSuplTiRequestManager::RequestLocation(const TLbsNetSessionId& aSessionId, const TLbsNetPosRequestOptionsBase& aOptions, const TLbsNetPosRequestMethod& aMethod)
+    {
+    iTrace->Trace(_L("CCLbsSuplTiRequestManager::RequestLocation()"), KTraceFileName, __LINE__);
+    
+     if(!iServer.Handle())
+    	{
+    	iTrace->Trace(_L("Invalid Server Handle. Opening new connection"), KTraceFileName, __LINE__);
+    	TInt err = iServer.Connect(iStatus);  
+    	if(err != KErrNone)
+    	  {
+    	  iTrace->Trace(_L("Opening new connection failed"), KTraceFileName, __LINE__);
+    	  iObserver.RequestComplete(err,aSessionId);
+    	  return;
+    	  }
+    	iSessionId = aSessionId;
+     	iOptions = aOptions;
+     	iMethod = aMethod;
+    	SetActive();
+    	}
+    else
+    	{
+    	iTrace->Trace(_L("Valid Server Handle exist.Using same one..."), KTraceFileName, __LINE__);	
+    	iSessionId = aSessionId;
+     	iOptions = aOptions;
+     	iMethod = aMethod;
+    	InitiateLocationRequest();
+    	}
+    
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::CancelRequest
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+TInt CCLbsSuplTiRequestManager::CancelRequest(const TLbsNetSessionId& aSessionId)
+    {
+    iTrace->Trace(_L("CCLbsSuplTiRequestManager::CancelRequest"), KTraceFileName, __LINE__);
+    TInt index = FindSessionId(aSessionId);
+    if(index != KErrNotFound)
+        {
+        iTrace->Trace(_L("session found calling cancel"), KTraceFileName, __LINE__);
+        iRequestorCollection[index]->Cancel();
+        delete iRequestorCollection[index];
+        iRequestorCollection.Remove(index);
+        return KErrNone;
+        }
+    iTrace->Trace(_L("session not found "), KTraceFileName, __LINE__);
+    return KErrNotFound;
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::GetPosition
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+TInt CCLbsSuplTiRequestManager::GetPosition(const TLbsNetSessionId& aSessionId, TPositionInfoBase& aPositionInfo)
+    {
+    iTrace->Trace(_L("CCLbsSuplTiRequestManager::GetPosition"), KTraceFileName, __LINE__);
+    TInt index = FindSessionId(aSessionId);
+    if(index != KErrNotFound)
+        {
+        iTrace->Trace(_L("session found calling getposition"), KTraceFileName, __LINE__);
+        return iRequestorCollection[index]->GetPosition(aPositionInfo);
+        }
+    iTrace->Trace(_L("session not found found for getposition"), KTraceFileName, __LINE__);
+    return KErrNotFound;
+    }
+
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::CloseSession
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+void CCLbsSuplTiRequestManager::CloseSession()
+    {
+    iTrace->Trace(_L("CCLbsSuplTiRequestManager::CloseSession() start"), KTraceFileName, __LINE__);
+    iRequestorCollection.ResetAndDestroy(); //cancels all active requests
+    iServer.Close();
+    iTrace->Trace(_L("CCLbsSuplTiRequestManager::CloseSession() end"), KTraceFileName, __LINE__);
+    }
+// -----------------------------------------------------------------------------
+// CCLbsSuplTiRequestManager::FindSessionId
+// Other items were commented in a header
+// -----------------------------------------------------------------------------
+//
+TInt CCLbsSuplTiRequestManager::FindSessionId(const TLbsNetSessionId& aSessionId)
+    {
+    TInt count = iRequestorCollection.Count();
+    for ( TInt index = 0; index < count; index++ )
+        {
+        if ( iRequestorCollection[index]->GetSessionId().SessionNum() == aSessionId.SessionNum() )
+            {
+            return index;
+            }
+        }
+    return KErrNotFound;
+    }
+
+void CCLbsSuplTiRequestManager::RunL()
+	{
+	if(iStatus.Int() == KErrNone) // if server connect was successful
+	{
+		iTrace->Trace(_L("CCLbsSuplTiRequestManager::RunL called successfully..."), KTraceFileName, __LINE__);
+		iTrace->Trace(_L("Putting new request..."), KTraceFileName, __LINE__);
+		InitiateLocationRequest();
+	}	
+	else //opening connection failed
+		{
+		iTrace->Trace(_L("Opening new connection failed"), KTraceFileName, __LINE__);
+    iObserver.RequestComplete(iStatus.Int(),iSessionId);
+		}
+	}
+
+   // For cancelling Ashnchronous requests
+void CCLbsSuplTiRequestManager::DoCancel()
+	{
+	
+	}
+
+   // Override to handle leaves from RunL().
+TInt CCLbsSuplTiRequestManager::RunError(TInt aError)
+	{
+	return aError;
+	}
+   
+void CCLbsSuplTiRequestManager::InitiateLocationRequest()
+	{
+	if(FindSessionId(iSessionId) == KErrNotFound) // no request exists with this session id so make a new request
+		{
+		iTrace->Trace(_L("Session Id not found creating new requestor"), KTraceFileName, __LINE__);
+		//Create a new requestor object
+		CCLbsSuplTiApiRequestor* newRequestor = NULL;
+		TRAPD(err,newRequestor = CCLbsSuplTiApiRequestor::NewL(iObserver,iServer));
+		if(err != KErrNone)
+			{
+			iTrace->Trace(_L("Creating New Requestor Failed"), KTraceFileName, __LINE__);
+			iObserver.RequestComplete(err,iSessionId);
+			return;
+			}
+		//add to requestor collection, ownership is transferred to the collection array
+		iRequestorCollection.Append(newRequestor);
+		//ask requestor to make location request
+		newRequestor->RequestLocation(iSessionId,iOptions,iMethod);
+		}
+	else //request was already made with this session id
+		{
+		iTrace->Trace(_L("Session Id already exits"), KTraceFileName, __LINE__);
+		iObserver.RequestComplete(KErrAlreadyExists,iSessionId);
+		}
+	}