--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/locationmgmt/networklocationmgr/src/lbsnetlocmanrequesthandler.cpp	Tue Feb 02 01:50:39 2010 +0200
@@ -0,0 +1,229 @@
+// Copyright (c) 2006-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:
+// Includes
+// Component
+// 
+//
+
+#include "lbsnetlocmanrequesthandler.h"
+#include "lbsnetlocmanlogic.h"
+#include "lbsdevloggermacros.h"
+
+
+//****************************************************************
+// Class CNetLocManRequestHandler
+//****************************************************************
+/** Static constructor.
+@param aChannel A reference to the channel identifier
+@param aNetLocMan A reference to the parent class
+@released
+@internalComponent
+*/
+CNetLocManRequestHandler* CNetLocManRequestHandler::NewL(const RLbsPositionUpdateRequests::TChannelIdentifer& aChannel, CNetLocManLogic& aNetLocMan)
+	{
+	CNetLocManRequestHandler* self = new(ELeave) CNetLocManRequestHandler (aChannel, aNetLocMan);
+
+	CleanupStack::PushL(self);
+
+	self->ConstructL();
+	CleanupStack::Pop();
+	
+	return self;
+	}
+	
+
+/** Constructor.
+@param aChannel A reference to the channel identifier
+@param aNetLocMan A reference to the parent class
+@released
+@internalComponent
+*/
+CNetLocManRequestHandler::CNetLocManRequestHandler(const RLbsPositionUpdateRequests::TChannelIdentifer& aChannel, CNetLocManLogic& aNetLocMan) : 
+CActive(CActive::EPriorityStandard), iChannel(aChannel), iNetLocMan(aNetLocMan), iTimer(NULL)
+	{
+	}
+
+
+/** 
+@see CActive::DoCancel
+@released
+@internalComponent
+*/
+void CNetLocManRequestHandler::DoCancel()
+	{
+	// cancel RLbsPositionUpdateRequests async request
+	iPosUpdateReq.CancelNotifyPositionUpdateRequestChange();
+	}
+
+
+/** Second phase constructor.
+@released
+@internalComponent
+*/
+void CNetLocManRequestHandler::ConstructL()
+	{
+	iPosUpdateReq.OpenL(iChannel);
+	iLocationReq.OpenL(KLbsNetLocManagerUid);
+	iTimer = CLbsCallbackTimer::NewL(*this);
+	CActiveScheduler::Add(this);
+	}
+
+
+/** Destructor
+@released
+@internalComponent
+*/
+CNetLocManRequestHandler::~CNetLocManRequestHandler()
+	{
+	Cancel();
+	iPosUpdateReq.Close();
+	iLocationReq.Close();
+	if(iTimer)
+		{
+		iTimer->Cancel();
+		delete iTimer;	
+		}
+	}
+ 
+
+/** Subscribe to the position update request property
+@released
+@internalComponent
+*/
+void CNetLocManRequestHandler::StartGettingRequests()
+	{
+	LBSLOG(ELogP2, "CNetLocManRequestHandler::StartGettingRequests:");
+
+	Cancel();
+	// subscribe to property from Network Location Manager -> Network Gateway
+	iPosUpdateReq.NotifyPositionUpdateRequestChange(iStatus);
+	SetActive();	
+	}
+
+
+/** 
+@see CActive::RunError
+@param aError An error code
+@released
+@internalComponent
+*/
+TInt CNetLocManRequestHandler::RunError(TInt aError)
+	{
+	// handle RunL leaving - in our case we do nothing 
+	// as this means we have had encountered a program inconsistency
+	// By doing nothing here  causes the main manager thread to exit
+	// and the Lbs root process resolves any issues - by stopping and restarting
+	// lbs components
+ 	return aError;
+	}
+
+
+/** Handle requests from the LocServer
+This function handles the incomming position requests from the LocServer,
+and pass them on to the NetworkGateway
+@see CActive::RunL
+@released
+@internalComponent
+*/
+void CNetLocManRequestHandler::RunL()
+	{
+	TInt status = iStatus.Int();
+
+	StartGettingRequests(); // we want further location requests!
+	
+	switch (status)
+		{
+		case KErrNone:
+			{
+			TLbsPositionUpdateRequestBase updateRequest; 
+			User::LeaveIfError(iPosUpdateReq.GetPositionUpdateRequest(updateRequest));
+			
+			// when there is a new request forwarded, increase session ID by one
+			TLbsNetSessionIdInt sessionId;
+			iNetLocMan.GetSessionId(sessionId);
+			
+			switch(updateRequest.Type())
+				{
+				case TLbsPositionUpdateRequestBase::ECancel:
+					{
+					iTimer->Cancel();
+					TLbsNetLocNetworkLocationCancelMsg locCancel(sessionId, 0);
+					User::LeaveIfError(iLocationReq.SetNetworkLocationRequest(locCancel));
+					break;
+					}
+		
+				case TLbsPositionUpdateRequestBase::EUpdateRequest:
+					{
+					// only increment when new update request comes in
+					iNetLocMan.IncrementSessionId();
+					TLbsPositionUpdateRequest* request = 
+						(reinterpret_cast<TLbsPositionUpdateRequest*>(&updateRequest));
+					
+					TTime target = request->TargetTime();
+					TTime now;
+					now.UniversalTime();
+					
+					TTimeIntervalMicroSeconds timeout;
+					timeout = target.MicroSecondsFrom(now);
+					
+					if (timeout < 0)
+						timeout = 0;
+					
+					iTimer->Cancel();
+					iTimer->EventAfter(timeout ,0);
+					break;
+					}
+				}
+			break;
+			}
+		default:
+			{
+			User::LeaveIfError(status);
+			break;
+			}
+		}
+	}
+	
+
+void CNetLocManRequestHandler::OnTimerEventL(TInt /*aTimerId*/)
+	{
+	TLbsPositionUpdateRequestBase updateRequest; 
+	User::LeaveIfError(iPosUpdateReq.GetPositionUpdateRequest(updateRequest));
+
+	TLbsNetSessionIdInt sessionId;
+	iNetLocMan.GetSessionId(sessionId);
+	
+	TLbsPositionUpdateRequest* request = 
+		(reinterpret_cast<TLbsPositionUpdateRequest*>(&updateRequest));
+	
+	TLbsNetPosRequestQualityInt quality; 
+	quality.SetMaxFixTime(request->RequestQuality().MaxFixTime());
+	
+	quality.SetMinHorizontalAccuracy(request->RequestQuality().MinHorizontalAccuracy());
+	quality.SetMinVerticalAccuracy(request->RequestQuality().MinVerticalAccuracy());										
+
+	// Set device status to EDeviceActive
+	iNetLocMan.UpdateDeviceStatus(TPositionModuleStatus::EDeviceActive);
+	
+	TLbsNetLocNetworkLocationRequestMsg locRequest(sessionId, ETrue, quality);
+	User::LeaveIfError(iLocationReq.SetNetworkLocationRequest(locRequest));
+	}
+	
+	
+TInt CNetLocManRequestHandler::OnTimerError(TInt /*aTimerId*/, TInt aError)
+	{
+	return aError;
+	}
+
+