telephonyprotocols/pdplayer/src/pdpservices.cpp
changeset 0 3553901f7fa8
child 24 6638e7f4bd8f
child 42 3adadc800673
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/telephonyprotocols/pdplayer/src/pdpservices.cpp	Tue Feb 02 01:41:59 2010 +0200
@@ -0,0 +1,550 @@
+// 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 <comms-infras/ss_log.h>
+#include <comms-infras/ss_corepractivities.h> // TODO is this needed?
+#include <comms-infras/coretiermanagerstates.h> // TODO is this needed?
+#include <comms-infras/coretiermanageractivities.h> // TODO is this needed?
+#include "pdpservices.h"
+#include "pdptiermanager.h"
+#include <pcktcs.h>
+#include <comms-infras/es_connectionserv.h>
+
+#ifdef __CFLOG_ACTIVE
+#define KPDPTierMgrTag KESockMetaConnectionTag
+_LIT8(KMBMSObjectTag, "MBMSObject");
+#endif
+
+using namespace Messages;
+using namespace MeshMachine; // TODO is this needed?
+using namespace ESock;
+using namespace NetStateMachine; // TODO is this needed?
+using namespace ConnectionServ;
+
+
+//Constructor for CMBMSServiceRequest
+CMBMSServiceRequest::CMBMSServiceRequest(
+		CMBMSEngine& aMBMSEngine,
+		const TNodeId& aMBMSTMCommsId,
+		const Messages::TNodeSignal::TMessageId& aRequestType,
+		CRefCountOwnedParameterBundle* aRequestBundleOwner,
+		const XMBMSServiceQuerySet::TQueryType aQueryType
+		)
+	:CActive(EPriorityStandard),
+	iMBMSEngine(aMBMSEngine),
+	iMBMSTMCommsId(aMBMSTMCommsId),
+	iRequestType(aRequestType),
+	iObjectBundleOwner(aRequestBundleOwner),
+	iQueryType(aQueryType)
+	{
+	CActiveScheduler::Add(this);
+	}
+
+/**
+The NewL factory function for CMBMSServiceRequest.
+@param aMBMSTMCommsId comms Id.
+@param aClientId Node Channel Id.
+@param aRequestType Message Id
+@param aRequestBundleOwner Parameter Bundle.
+@return CMBMSServiceRequest*
+*/
+CMBMSServiceRequest* CMBMSServiceRequest::NewL(
+		CMBMSEngine& aMBMSEngine,
+		const TNodeId& aMBMSTMCommsId,
+		RNodeInterface* aOriginatorInterface,
+		const TRuntimeCtxId& aOriginator,
+		const Messages::TNodeSignal::TMessageId& aRequestType,
+		CRefCountOwnedParameterBundle* aRequestBundleOwner,
+		const XMBMSServiceQuerySet::TQueryType aQueryType
+		)
+	{
+	CMBMSServiceRequest* self = new(ELeave) CMBMSServiceRequest(
+													aMBMSEngine,
+													aMBMSTMCommsId,
+													aRequestType,
+													aRequestBundleOwner,
+													aQueryType
+													);
+
+	CleanupStack::PushL(self);
+	self->ConstructL(aOriginatorInterface, aOriginator);
+	CleanupStack::Pop(self);
+
+	return self;
+	}
+/**
+ConstructL for CMBMSEngine.
+*/
+void CMBMSServiceRequest::ConstructL(RNodeInterface* aOriginatorInterface, const TRuntimeCtxId& aOriginator)
+	{
+
+	if (iRequestOriginator.Open(*aOriginatorInterface, aOriginator) != KErrNone)
+		{
+		// Fix the code - looks like this originator already has an outstanding request
+		User::Leave(KErrArgument);
+		}
+	}
+
+/**
+Destructor for CMBMSServiceRequest.
+*/
+CMBMSServiceRequest::~CMBMSServiceRequest()
+	{
+	Cancel();
+	iObjectBundleOwner->Close();
+	delete iRetrievePcktMbms;
+	}
+
+/**
+This function is used to cancel the notification message sent by the client
+@param aError const TInt
+@return void
+*/
+void CMBMSServiceRequest::CancelMessage(const TInt aError)
+	{
+	__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::CancelMessage(%d)"), this, aError));
+	if (iRequestType == TCFTierStatusProvider::TTierNotificationRegistration::Id())
+		{
+		iRequestOriginator.PostMessage(
+				iMBMSTMCommsId,
+				TEBase::TError(TCFTierStatusProvider::TTierNotificationRegistration::Id(), aError).CRef()
+				);
+		}
+	}
+
+/**
+This function is used to process the MBMS requests.The RunL() function of CMBMSServiceRequest is called
+based on the state machines.
+@param aError const TInt
+@return void
+*/
+void CMBMSServiceRequest::StartRequest()
+	{
+	iScanEngineState = EChecking;
+
+	SetActive();
+	TRequestStatus* status = &iStatus;
+	User::RequestComplete(status, KErrNone);
+	}
+
+/**
+This function is used to return the client id.
+@param None
+@return TCFNodeChannelId
+*/
+const TNodeId& CMBMSServiceRequest::GetClientId()
+	{
+	return iRequestOriginator.Node().RecipientId();
+	}
+
+/**
+This is CActive overloaded function.Cancel all outstanding requests.
+@param None
+@return Void
+*/
+void CMBMSServiceRequest::DoCancel()
+	{
+     switch (iScanEngineState)
+		{
+		case ENotifyService:
+		case ERemoveAllComplete:
+			iMBMSEngine.GetRPacketService().CancelAsyncRequest(EPacketUpdateMbmsMonitorServiceList);
+		break;
+		case ERetrieveBearerAvailability:
+			iMBMSEngine.GetRPacketService().CancelAsyncRequest(EPacketGetMbmsNetworkServiceStatus);
+		break;
+		case EStartMonitor:
+			iMBMSEngine.GetRPacketService().CancelAsyncRequest(EPacketNotifyMbmsServiceAvailabilityChange);
+		break;
+		case EResultCount:
+			if(iQueryType == XMBMSServiceQuerySet::ECountMonitorList)
+			   {
+			   iMBMSEngine.GetRPacketService().CancelAsyncRequest(EPacketEnumerateMbmsMonitorServiceList);
+			   }
+			else if(iQueryType == XMBMSServiceQuerySet::ECountActiveServiceList)
+			   {
+			   iMBMSEngine.GetRPacketService().CancelAsyncRequest(EPacketEnumerateMbmsActiveServiceList);
+			   }
+		break;
+		case EGetMonitorList:
+			if(iRetrievePcktMbms != NULL)
+			iRetrievePcktMbms->Cancel();
+		break;
+		}
+	}
+
+/**
+This is CActive overloaded function.
+@param None
+@return TInt
+*/
+TInt CMBMSServiceRequest::RunError(TInt aError)
+	{
+	__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::RunError(%d)"), this, aError));
+
+	// Stop the ScanEngine components
+	Cancel();
+
+	if (iRequestType == TCFTierStatusProvider::TTierNotificationRegistration::Id())
+		{
+		iRequestOriginator.PostMessage(
+						iMBMSTMCommsId,
+						TEBase::TError(TCFTierStatusProvider::TTierNotificationRegistration::Id(), aError).CRef()
+						);
+		}
+	return KErrNone;
+	}
+
+/**
+This is CActive overloaded function.
+@param None
+@return Void
+*/
+void CMBMSServiceRequest::RunL()
+	{
+    TRequestStatus* status = &iStatus;
+	if (iStatus == KErrNone)
+		{
+		switch(iScanEngineState)
+			{
+			case EChecking:
+				__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In EChecking State"), this));
+				User::LeaveIfError(iMBMSEngine.GetRPacketService().GetStatus(iPsdStatus)); // get initial status
+
+				//check the query type
+				if(iQueryType == XMBMSServiceQuerySet::EBearerAvailability)
+					iScanEngineState = EBearerAvailable;
+				else if (iQueryType == XMBMSServiceQuerySet::EAddService)
+					iScanEngineState = EServiceAdd;
+				else if (iQueryType == XMBMSServiceQuerySet::ERemoveService)
+					iScanEngineState = EServiceRemove;
+				else if (iQueryType == XMBMSServiceQuerySet::ERemoveAllService)
+					iScanEngineState = EServiceRemoveAll;
+				else if (iQueryType == XMBMSServiceQuerySet::ECountMonitorList)
+					iScanEngineState = EGetCountMonitorList;
+				else if (iQueryType == XMBMSServiceQuerySet::ECountActiveServiceList)
+					iScanEngineState = EGetCountServiceList;
+
+				SetActive();
+				User::RequestComplete(status, KErrNone);
+			break;
+
+			case EBearerAvailable:
+				//get MBMS bearer availability.
+				 __CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In EBearerAvailable State"), this));
+				 iMBMSEngine.GetRPacketService().GetMbmsNetworkServiceStatus(iStatus,ETrue,iNetworkServiceStatus);
+			 	 iScanEngineState = ERetrieveBearerAvailability;
+				 SetActive();
+			break;
+
+		   	case ERetrieveBearerAvailability:
+				__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In ERetrieveBearerAvailability State"), this));
+			    //create a parameter bundle and send the results to the client.
+			    SendResultBundleL();
+
+			    iScanEngineState = EBearerAvailable;
+			    SetActive();
+			    User::RequestComplete(status, KErrNone);
+			break;
+
+			case EServiceAdd:
+				{
+				CPcktMbmsMonitoredServiceList* mbmsServiceList = UpdateMonitorServiceListL();
+			    CleanupStack::PushL(mbmsServiceList);
+			    iMBMSEngine.GetRPacketService().UpdateMbmsMonitorServiceListL(iStatus,EAddEntries,mbmsServiceList);
+			    CleanupStack::PopAndDestroy(mbmsServiceList);
+
+				SetActive();
+				iScanEngineState = ENotifyService;
+				}
+			break;
+
+			case EServiceRemoveAll:
+			    {
+			    iMBMSEngine.GetRPacketService().UpdateMbmsMonitorServiceListL (iStatus,ERemoveAllEntries);
+
+				SetActive();
+				iScanEngineState = ERemoveAllComplete;
+			    }
+			break;
+
+			case ERemoveAllComplete:
+				SendResultBundleL();
+			break;
+
+			case EServiceRemove:
+				{
+				CPcktMbmsMonitoredServiceList* mbmsSeriveList = UpdateMonitorServiceListL();
+			    CleanupStack::PushL(mbmsSeriveList);
+			    iMBMSEngine.GetRPacketService().UpdateMbmsMonitorServiceListL (iStatus,ERemoveEntries,mbmsSeriveList);
+			    CleanupStack::PopAndDestroy(mbmsSeriveList);
+
+				SetActive();
+				iScanEngineState = ENotifyService;
+				}
+			break;
+
+			case EGetCountMonitorList:
+				{
+				__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In ECountActiveServiceList State"), this));
+				iMBMSEngine.GetRPacketService().EnumerateMbmsMonitorServiceList(iStatus,iCount,iMaxCount);
+
+				SetActive();
+				iScanEngineState = EResultCount;
+				}
+			break;
+
+			case EGetCountServiceList:
+				{
+				__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In ECountActiveServiceList State"), this));
+				iMBMSEngine.GetRPacketService().EnumerateMbmsActiveServiceList(iStatus,iCount,iMaxCount);
+
+				SetActive();
+				iScanEngineState = EResultCount;
+				}
+			break;
+
+			case EResultCount:
+				SendResultBundleL();
+			break;
+
+			case ENotifyService:
+				//notify for MBMS Services.
+				__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In ENotifyService State"), this));
+				iMBMSEngine.GetRPacketService().NotifyMbmsServiceAvailabilityChange(iStatus);
+			    SetActive();
+				iScanEngineState = EStartMonitor;
+			break;
+
+			case EStartMonitor:
+				__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In EStartMonitor State"), this));
+				iRetrievePcktMbms = CRetrievePcktMbmsMonitoredServices::NewL(iMBMSEngine.GetRPacketService());
+			    iRetrievePcktMbms->Start(iStatus);
+
+			    SetActive();
+				iScanEngineState = EGetMonitorList;
+			break;
+
+			case EGetMonitorList:
+				SendResultBundleL();
+
+			    SetActive();
+			    User::RequestComplete(status, KErrNone);
+			    iScanEngineState = ENotifyService;
+			break;
+
+		  }
+		}
+	else if(((iStatus.Int() == KErrMbmsImpreciseServiceEntries))||((iStatus.Int() == KErrNotFound)))
+		 {
+		  __CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::RunL() KErrMbmsImpreciseServiceEntries || KErrNotFound"), this));
+		  CancelMessage(iStatus.Int());
+		  iMBMSEngine.RemoveFromRequestListL(GetClientId());
+		 }
+	else
+		{
+		 __CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::RunL() ERROR: Incorrect status, Aborting"), this));
+		 User::Leave(iStatus.Int());
+		}
+
+	}
+
+/**
+This function is used to update Mbms Monitored Service List
+@param None
+@return Void
+*/
+CPcktMbmsMonitoredServiceList* CMBMSServiceRequest::UpdateMonitorServiceListL()
+	{
+	__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In UpdateMonitorServiceListL()"), this));
+
+	//Read the entries in the parameter bundle and pass them to Etel.
+	CPcktMbmsMonitoredServiceList* serviceList= CPcktMbmsMonitoredServiceList::NewL();
+	CleanupStack::PushL(serviceList);
+
+	if((iScanEngineState == EServiceAdd) || (iScanEngineState == EServiceRemove))
+	   {
+		const ConnectionServ::CConnectionServParameterBundle* objectBundle1 = static_cast<const CConnectionServParameterBundle*>(iObjectBundleOwner->Ptr());
+	    ConnectionServ::CConnectionServParameterBundle* objectBundle = const_cast<CConnectionServParameterBundle *>(objectBundle1);
+
+	    TUint numObjectPSCs = objectBundle->CountParamSetContainers();
+
+		for(TUint i = 0; i < numObjectPSCs; i++)
+			{
+			CParameterSetContainer* objectPSC = objectBundle->GetParamSetContainer(i);
+			XMBMSServiceParameterSet* objectMPS = XMBMSServiceParameterSet::FindInParamSetContainer(*objectPSC);
+			RPacketService::TMbmsServiceAvailabilityV1 mbmsService;
+			mbmsService.iTmgi.SetServiceId(objectMPS->GetChannelInfo()->GetTmgi().GetServiceId());
+			mbmsService.iTmgi.SetMCC(objectMPS->GetChannelInfo()->GetTmgi().GetMCC());
+
+			mbmsService.iTmgi.SetMNC(objectMPS->GetChannelInfo()->GetTmgi().GetMNC());
+			mbmsService.iMbmsServiceMode = objectMPS->GetServiceMode();
+			mbmsService.iMbmsAccessBearer = objectMPS->GetChannelInfo()->GetScope();
+			serviceList->AddEntryL(mbmsService);
+			}
+	   }
+	CleanupStack::Pop(serviceList);
+	return serviceList;
+	}
+
+/**
+This function is used to send result parameter bundle to the client
+@param None
+@return Void
+*/
+void CMBMSServiceRequest::SendResultBundleL()
+	{
+	CConnectionServParameterBundle* returnBundle = NULL;
+	if(iScanEngineState == EGetMonitorList)
+	   returnBundle = PrepareMonitorResultBundleL();
+	else if(iScanEngineState == ERetrieveBearerAvailability)
+	   returnBundle = PrepareBearerResultBundleL();
+	else if (iScanEngineState == ERemoveAllComplete)
+	   returnBundle = PrepareRemoveAllBundleL();
+	else if (iScanEngineState == EResultCount)
+	   returnBundle = PrepareCountBundleL();
+
+	CleanupStack::PushL(returnBundle);// Ownership of the bundle passes to the Server
+	CRefCountOwnedParameterBundle* returnBundleOwner = new (ELeave) CRefCountOwnedParameterBundle(returnBundle);
+	returnBundleOwner->Open(); // Open the initial reference
+	CleanupClosePushL(*returnBundleOwner);
+
+	if (iRequestType == TCFTierStatusProvider::TTierNotificationRegistration::Id())
+		{
+		iRequestOriginator.PostMessage(
+						iMBMSTMCommsId,
+						TCFTierStatusProvider::TTierNotification(returnBundleOwner).CRef()
+						);
+		}
+	CleanupStack::Pop(returnBundleOwner);
+	CleanupStack::Pop(returnBundle);
+	}
+
+/**
+This function is used to prepare result bundle.
+@param None
+@return CConnectionServParameterBundle*
+*/
+CConnectionServParameterBundle* CMBMSServiceRequest::PrepareMonitorResultBundleL() const
+	{
+	CConnectionServParameterBundle* returnBundle = CConnectionServParameterBundle::NewL();
+	CleanupStack::PushL(returnBundle);
+
+	__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In PrepareMonitorResultBundleL function"), this));
+	//read the MBMS Service list from Etel after receiving the MBMS Service Availability Notification.
+
+	CPcktMbmsMonitoredServiceList* serviceList = iRetrievePcktMbms->RetrieveListL();
+	TInt count = serviceList->Enumerate();
+	CleanupStack::PushL(serviceList);
+
+	//Read the monitor list from  Etel and send the list to client as parameter bundle.
+    for(TUint i = 0; i < count; i++)
+		{
+		RPacketService::TMbmsServiceAvailabilityV1 serviceAvailability;
+		CParameterSetContainer* returnPSC = CParameterSetContainer::NewL(*returnBundle);
+		CleanupStack::PushL(returnPSC);
+		serviceAvailability = serviceList->GetEntryL(i);
+
+		TTmgi tmgi;
+		tmgi.SetMCC(serviceAvailability.iTmgi.GetMCC());
+		tmgi.SetMNC(serviceAvailability.iTmgi.GetMNC());
+		tmgi.SetServiceId(serviceAvailability.iTmgi.GetServiceId());
+												 			
+		XMBMSServiceParameterSet* returnPS = XMBMSServiceParameterSet::NewL(*returnPSC);
+		TMBMSChannelInfoV1* serviceInfo = returnPS->GetChannelInfo();
+
+		serviceInfo->SetTmgi(tmgi);
+		serviceInfo->SetScope(serviceAvailability.iMbmsAccessBearer);
+		
+	    returnPS->SetServiceMode(serviceAvailability.iMbmsServiceMode);
+	    returnPS->SetMBMSServiceAvailability(serviceAvailability.iMbmsAvailabilityStatus);
+
+	    CleanupStack::Pop(returnPSC);
+	    }
+
+	CleanupStack::PopAndDestroy(serviceList);
+	CleanupStack::Pop(returnBundle);
+
+	return returnBundle;
+	}
+
+/**
+This function is used to prepare result bundle containing bearer availability.
+@param None
+@return CConnectionServParameterBundle*
+*/
+CConnectionServParameterBundle* CMBMSServiceRequest::PrepareBearerResultBundleL() const
+	{
+	__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In PrepareBearerResultBundleL function"), this));
+
+	CConnectionServParameterBundle* returnBundle = CConnectionServParameterBundle::NewL();
+	CleanupStack::PushL(returnBundle);
+
+	CParameterSetContainer* returnPSC = CParameterSetContainer::NewL(*returnBundle);
+	CleanupStack::PushL(returnPSC);
+
+	XMBMSServiceQuerySet* returnQuery = XMBMSServiceQuerySet::NewL(*returnPSC);
+	returnQuery->SetMBMSBearerAvailability(iNetworkServiceStatus);
+
+	CleanupStack::Pop(returnPSC);
+	CleanupStack::Pop(returnBundle);
+
+	return returnBundle;
+	}
+
+/**
+This function is used to prepare result bundle containing current and max count of entries
+in Monitor/Serice list table.
+@param None
+@return CConnectionServParameterBundle*
+*/
+CConnectionServParameterBundle* CMBMSServiceRequest::PrepareCountBundleL() const
+	{
+	__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In PrepareCountBundleL function"), this));
+
+	CConnectionServParameterBundle* returnBundle = CConnectionServParameterBundle::NewL();
+	CleanupStack::PushL(returnBundle);
+
+	CParameterSetContainer* returnPSC = CParameterSetContainer::NewL(*returnBundle);
+	CleanupStack::PushL(returnPSC);
+
+	XMBMSServiceQuerySet* returnQuery = XMBMSServiceQuerySet::NewL(*returnPSC);
+	returnQuery->SetListCount(iCount);
+	returnQuery->SetListMaxCount(iMaxCount);
+
+	CleanupStack::Pop(returnPSC);
+	CleanupStack::Pop(returnBundle);
+
+	return returnBundle;
+	}
+
+/**
+This function creates an empty bundle.
+@param None
+@return CConnectionServParameterBundle*
+*/
+CConnectionServParameterBundle* CMBMSServiceRequest::PrepareRemoveAllBundleL() const
+	{
+	//pass empty bundle
+	__CFLOG_VAR((KPDPTierMgrTag, KMBMSObjectTag, _L8("CMBMSServiceRequest[%08x]::In PrepareRemoveAllBundleL function"), this));
+
+	CConnectionServParameterBundle* returnBundle = CConnectionServParameterBundle::NewL();
+	return returnBundle;
+	}