--- a/telephonyprotocols/pdplayer/src/pdpservices.cpp Mon May 03 13:37:20 2010 +0300
+++ b/telephonyprotocols/pdplayer/src/pdpservices.cpp Thu May 06 15:10:38 2010 +0100
@@ -1,550 +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;
- }
+// 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;
+ }