diff -r a2efdd544abf -r b47902b73a93 datasourcemodules/gpspositioningmodule/lbsagpspsy/src/responsehandler/cagpsdatabus.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datasourcemodules/gpspositioningmodule/lbsagpspsy/src/responsehandler/cagpsdatabus.cpp	Fri Jun 04 10:34:15 2010 +0100
@@ -0,0 +1,151 @@
+// Copyright (c) 2008-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:
+//
+
+/**
+ @file
+ @InternalComponent
+*/
+
+#include "cagpsdatabus.h"
+#include "lbsdevloggermacros.h"
+#include "mdatabusobserver.h"
+#include <lbs/lbsextendedsatellite.h>
+
+#ifdef _DEBUG
+_LIT(KLocDataBus, "CAgpsDataBus");
+#endif
+
+/**
+Create a location data bus, this should be called from the location cache
+
+@return The pointer to the location data bus
+@see CLocationCache
+*/
+CAgpsDataBus* CAgpsDataBus::NewL(MDataBusObserver& aObserver, const TUid& aModuleId)	
+	{
+	CAgpsDataBus* self = new (ELeave) CAgpsDataBus(aObserver, aModuleId);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop(self);
+	return self;
+	} 
+	
+/**
+constructor, note the location data bus is owned by location cache and used by CRequestQ, and it is a module-based CActive object.
+Set the data bus as standard priority by default.
+Add itself to Active Scheduler
+
+@param aModuleId Position module Id
+@see CRequestQ
+@see CLocationCache
+*/
+CAgpsDataBus::CAgpsDataBus(MDataBusObserver& aObserver, const TUid& aModuleId) : CActive(CActive::EPriorityStandard), iModuleId(aModuleId), iObs(aObserver)
+	{
+	CActiveScheduler::Add(this);
+	}
+
+/**
+Open the RProperty object wrappered by the data bus.
+Location data bus is implemented as Publish & Subscribe mechanism.
+*/
+void CAgpsDataBus::ConstructL()
+	{
+	iAGPSDataBus.OpenL(iModuleId);
+	}
+
+/**
+Cancel any outstanding request to the CActive object.
+Close the RProperty.
+*/
+CAgpsDataBus::~CAgpsDataBus()
+	{
+	Cancel();
+	iAGPSDataBus.Close();
+	}
+
+/**
+Subscribe to the data bus. It will be called by objects which listen to the data bus.
+It will eventually call RProperty::Subscribe()
+Set active the data bus active object
+Panic if there are no data bus observers already set.
+*/
+void CAgpsDataBus::Subscribe()
+	{
+	if(!IsActive())
+		{
+		iAGPSDataBus.NotifyPositionUpdate(iStatus);
+		SetActive();
+		}
+	}
+
+/**
+Cancel the subscribe to the data bus. Cancel any outstanding request to the CActive object.
+Panic if there are no data bus observers already set.
+*/
+void CAgpsDataBus::UnSubscribe()
+	{
+	Cancel();
+	}
+
+/**
+Get the last position from the bus 
+ 
+ */
+TInt CAgpsDataBus::GetLastPositionInfo(TPositionSatelliteInfo& aSatelliteInfo, TTime& aActualTime, TUint& aAttributes, TUint& aMode)
+	{
+	TBool conflictControl;
+	TTime targetTime;
+
+	TInt error = iAGPSDataBus.GetPositionInfo(conflictControl, &aSatelliteInfo, aSatelliteInfo.PositionClassSize(), targetTime, aActualTime, aAttributes, aMode);
+	
+	return error;
+	}
+
+
+/**
+from CActive, the main event processing loop
+Whenever there is a new event, i.e. the position info data is published to the data bus, notify the data bus observer by LocationDataAvailableL()
+*/
+void CAgpsDataBus::RunL()
+	{
+	TTime actualTime;
+	TPositionExtendedSatelliteInfo satelliteInfo;
+	TUint attributes = 0;
+	TUint mode = 0;
+	
+	TInt error = GetLastPositionInfo(satelliteInfo, actualTime, attributes, mode);	
+
+	iObs.DataUpdate(satelliteInfo, iStatus.Int(), error, actualTime, attributes, mode);
+
+	}
+	
+/**
+from CActive
+Cancels the request for position update notification
+It will eventually cancel an outstanding subscription request for this property handle.
+*/
+void CAgpsDataBus::DoCancel()
+	{
+	iAGPSDataBus.CancelNotifyPositionUpdate();
+	}
+	
+/**
+from CActive
+Simply fwds any errors to the observers
+*/
+TInt CAgpsDataBus::RunError(TInt aError)
+	{
+	return iObs.DataError(aError, iStatus.Int());
+	}