sl@0: // Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include "mmrcservercontroller.h"
sl@0: #include "mmrcerrorcodes.h"
sl@0: #include "mmrcserversession.h"
sl@0: #include "mmrcserverinfo.h"
sl@0: #include "mmrcserverrulemanager.h"
sl@0: #include "mmrcadaptationproxy.h"
sl@0: #include "mlogicalchain.h"
sl@0: #include <a3f/audioprocessingunittypeuids.h>
sl@0: 
sl@0: /**
sl@0: @internalComponent
sl@0: 
sl@0: This class implements a timer. 
sl@0: */	
sl@0: class CARNNotificationObject : public CActive
sl@0: 	{
sl@0: 	
sl@0: public:
sl@0: 	static CARNNotificationObject* NewL(const TInt aPriority, CMMRCServerInfo& aMMRCServerInfo);
sl@0: 	~CARNNotificationObject();
sl@0: 	void After(TTimeIntervalMicroSeconds32 aInterval);
sl@0: 	void Initialize();
sl@0: 	
sl@0: protected:
sl@0: 	void RunL();
sl@0: 	void DoCancel();
sl@0: 
sl@0: private:
sl@0: 	CARNNotificationObject(const TInt aPriority);
sl@0: 	void ConstructL(CMMRCServerInfo& aMMRCServerInfo);
sl@0: 
sl@0: public:
sl@0: 	TInt iIndex;
sl@0: 	
sl@0: protected:
sl@0: 	RTimer	iTimer;
sl@0: 	CMMRCServerInfo*  iMMRCServerInfo;
sl@0: 	};
sl@0: 	
sl@0: //------------------------------------------------------------------------------------
sl@0: //
sl@0: //------------------------------------------------------------------------------------
sl@0: 
sl@0: /**
sl@0:  * Constructor
sl@0:  */
sl@0: CMMRCServerController::CMMRCServerController()
sl@0: 	{
sl@0: 	TRACE_CREATE();
sl@0: 	DP_CONTEXT(----> CMMRCServerController::CMMRCServerController *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Destructor
sl@0:  */
sl@0: CMMRCServerController::~CMMRCServerController()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::~CMMRCServerController *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	delete iMMRCServerInfo;
sl@0: 	delete iMMRCServerRuleManager;
sl@0: 	delete iARNNotificationObject;
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Constructs, and returns a pointer to, a new CMMRCServerController object.
sl@0:  * Leaves on failure.
sl@0:  * @return CMMRCServerController* A pointer to newly created utlitly object.
sl@0:  */		
sl@0: CMMRCServerController* CMMRCServerController::NewL()
sl@0: 	{
sl@0: 	DP_STATIC_CONTEXT(----> CMMRCServerController::NewL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	CMMRCServerController* self = NewLC();
sl@0: 	CleanupStack::Pop(self);
sl@0: 	
sl@0: 	DP0_RET(self, "self = 0x%x");
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0:  * Constructs, leaves object on the cleanup stack, and returns a pointer
sl@0:  * to, a new CMMRCServerController object.
sl@0:  * Leaves on failure.
sl@0:  * @return CMMRCServerController* A pointer to newly created utlitly object.
sl@0:  */	
sl@0: CMMRCServerController* CMMRCServerController::NewLC()
sl@0: 	{
sl@0: 	DP_STATIC_CONTEXT(----> CMMRCServerController::NewLC *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	CMMRCServerController* self = new(ELeave) CMMRCServerController();
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL();
sl@0: 	
sl@0: 	DP0_RET(self, "self = 0x%x");
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0:  * CMMRCServerController::ConstructL
sl@0:  * Symbian 2nd phase constructor can leave.
sl@0:  */
sl@0: void CMMRCServerController::ConstructL()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::ConstructL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	iMMRCServerInfo = CMMRCServerInfo::NewL(*this);
sl@0: 	iMMRCServerRuleManager = CMMRCServerRuleManager::NewL(*this);
sl@0: 	iARNNotificationObject = CARNNotificationObject::NewL(0, *iMMRCServerInfo); //Check the value
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: * Process the request pointer by a specific session
sl@0: * @param CMMRCServerSession& aServerSession
sl@0: * @return KerrNone in case of success of the process
sl@0: */
sl@0: TInt CMMRCServerController::EnqueueRequestL(CMMRCServerSession& aServerSession)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::ProcessRequestL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	//add the request to the queue
sl@0: 	iMMRCServerInfo->PushRequestL(aServerSession);
sl@0: 	TInt err = ProcessNextRequestL();
sl@0: 	
sl@0: 	DP0_RET(err, "err=%d");
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Process the first request with the highest priority from the FIFO queue
sl@0:  * @return KerrNone in case of success of the process
sl@0:  */
sl@0:  TInt CMMRCServerController::ProcessNextRequestL()
sl@0: 	{
sl@0: 	DP_CONTEXT(--------> CMMRCServerController::ProcessNextRequestL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TInt err = KErrNone;
sl@0: 
sl@0: 	TUint64 contextId;
sl@0: 	TMMRCServerState serverState;
sl@0: 	iMMRCServerInfo->ServerState(serverState, contextId);
sl@0: #ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING
sl@0: 		RDebug::Print(_L("serverState    = %d"),  serverState);
sl@0: 		RDebug::Print(_L("size of message queue    = %d"),  iMMRCServerInfo->RequestsCount());
sl@0: 		RDebug::Print(_L("size of inprocess queue = %d"),  iMMRCServerInfo->AllocatedResourceContextsCount());
sl@0: 		RDebug::Print(_L("size of paused queue = %d"),  iMMRCServerInfo->AllocatedPausedContextsCount());
sl@0: #endif
sl@0: 	if(EMMRCServerStateIdle != serverState)
sl@0: 		{
sl@0: 		DP0_RET(KErrNone, "%d");
sl@0: 		}
sl@0: 	
sl@0: 	CMMRCServerSession* serverSession = iMMRCServerInfo->PopAndRemoveFirstRequest(); //PopAndRemoveRequestFirstHighestPriority();
sl@0: 	//Pop the next next commited message with the highest priority
sl@0: 	if( NULL == serverSession )
sl@0: 		{
sl@0: 		DP0_RET(KErrNone, "%d");
sl@0: 		}
sl@0: 	
sl@0: 	if (!serverSession->HasUserEnvironmentCapability())
sl@0: 		{
sl@0: 		/* Check to see if it's a record use case and in IDLE, Active, or PRIME.
sl@0: 		// in which case you should refuse the request for reasons 
sl@0: 		KErrPermissionDenied
sl@0: 		*/
sl@0: 		MLogicalChain* requestedChange = serverSession->LogicalChainRequestedStack();
sl@0: 		if ((requestedChange!=NULL) && (requestedChange->StreamState() > EInitialized)) // trying to play
sl@0: 			{
sl@0: 			TInt count = requestedChange->AudioProcessingUnitsCount();
sl@0: 			for (TInt i=0; i<count; ++i)
sl@0: 				{
sl@0: 				if (KUidAudioDeviceSource == requestedChange->AudioProcessingUnitUid(i))
sl@0: 					{		
sl@0: 					serverSession->NotifyClientOfError(KErrPermissionDenied);
sl@0: 					// The following return value, doesn't actually make it back to the client
sl@0: 					// We do however Notify the client above using NotifyClientOfError()
sl@0: 					DP0_RET(KErrPermissionDenied, "%d");
sl@0: 					}
sl@0: 				}			
sl@0: 			}
sl@0: 
sl@0: 		}
sl@0: 	
sl@0: 	//Pop the last commited message in process = the current resource in use
sl@0: 	CMMRCServerSession* serverSessionAllocatedResource = iMMRCServerInfo->PopFirstAllocatedResourceContext();
sl@0: 	//If no resource locked...
sl@0: 	if( NULL == serverSessionAllocatedResource )
sl@0: 		{
sl@0: 		
sl@0: 		err = SendResourceRequest ( *serverSession );
sl@0: 		}
sl@0: 	else //If a resource has been allocated or is used, possibly preemption
sl@0: 		{
sl@0: 		TAudioContextId contextId = serverSession->ContextId( );
sl@0: 		TAudioContextId contextIdAllocatedResource = serverSessionAllocatedResource->ContextId( );
sl@0: 	#ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 			RDebug::Print(_L("contextId          = %d"),  contextId.Id());
sl@0: 			RDebug::Print(_L("contextIdAllocatedResource = %d"),  contextIdAllocatedResource.Id());
sl@0: 	#endif
sl@0: 
sl@0: 		//in case of processing the same context, remove the last committed request from the queue
sl@0: 		// of in-process request to avoid preemption within the same context.
sl@0: 		if(contextId == contextIdAllocatedResource)
sl@0: 			{
sl@0: 			err = SendResourceRequest ( *serverSession );
sl@0: 			}
sl@0: 		else // maybe preemption
sl@0: 			{
sl@0: 			//Pop the rule
sl@0: 			
sl@0: 			MLogicalChain* logicalChainUsingResource = serverSessionAllocatedResource->LogicalChainLastCommited();
sl@0: 			MLogicalChain* logicalChainNew = serverSession->LogicalChainRequestedStack();
sl@0: 			//Should not/cannot be null! 
sl@0: 			if( NULL==logicalChainUsingResource || NULL==logicalChainNew )
sl@0: 				{
sl@0: 			#ifdef _DEBUG	
sl@0: 					RDebug::Print(_L("!!!!CMMRCServerController::ProcessNextRequestL - logicalChainUsingResource or logicalChainNew NULL"));
sl@0: 					ASSERT(0);
sl@0: 			#endif
sl@0: 				User::Leave(EMMRCErrorLogicalChainNull);
sl@0: 				}
sl@0: 			
sl@0: 			TAudioState audioStateAllocatedResource = logicalChainUsingResource->StreamState();
sl@0: 			TAudioState audioStateNew = logicalChainNew->StreamState ( );
sl@0: 			TMMRCRule rule = DecisionRule(audioStateAllocatedResource, audioStateNew);
sl@0: 			//Process according to the rule
sl@0: 			if( rule == EAlwaysProcess )
sl@0: 				{
sl@0: 				err = SendResourceRequest( *serverSession );
sl@0: 				}
sl@0: 			else // process only in case of higher priority
sl@0: 				{
sl@0: 				TInt currentClientPriority = logicalChainUsingResource->Priority();
sl@0: 				TInt newClientPriority = logicalChainNew->Priority();
sl@0: 				TBool currentClient_HasMMDD = serverSessionAllocatedResource->HasMultimediaCapability();
sl@0: 				TBool newClient_HasMMDD = serverSession->HasMultimediaCapability();
sl@0: 
sl@0: 				// If new client has multimedia capability and current doesn't have, 
sl@0: 				// priorities don't matter preempt the current client
sl@0: 				
sl@0: 				// But if both are equal competitors (both has MMDD capability or both hasn't)
sl@0: 				// and the newcomer has higher priority preempt too
sl@0: 				if ( (!currentClient_HasMMDD && newClient_HasMMDD)  || 
sl@0: 					( (currentClient_HasMMDD == newClient_HasMMDD) && 
sl@0: 					  (newClientPriority > currentClientPriority) ) )
sl@0: 					{
sl@0: 					//The process is delayed. First we have to preempt the current inprocess resource
sl@0: 					// so puch back the request (its session)
sl@0: 					iMMRCServerInfo->PushRequestL(*serverSession);
sl@0: 					//
sl@0: 					//send a premption message to the last commited message session
sl@0: 					err = SendPreemptionRequest ( *serverSessionAllocatedResource );
sl@0: 					}
sl@0: 				else 
sl@0: 					{
sl@0: 					// Deny the resource
sl@0: 					TAudioContextId iId = serverSession->ContextId( );
sl@0: 					TBool iIsOnPauseList = iMMRCServerInfo->IsOnPauseList(iId);
sl@0: 					if(!iIsOnPauseList)
sl@0: 						{
sl@0: 						iMMRCServerInfo->PushPausedContextL(*serverSession);
sl@0: 						}
sl@0: // nothing pending, deny resources, and notify client.						
sl@0: 					serverSession->AdaptationRequestAcknowledgment(EMMRCAdaptationToServerResourceIncomplete, KErrInUse);
sl@0: // Server is back to idle.
sl@0: 					iMMRCServerInfo->SwitchServerState(EMMRCServerStateIdle, 0);
sl@0: 					}
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 	
sl@0: #ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 	if(err != KErrNone)
sl@0: 		{
sl@0: 		RDebug::Print(_L("!!!!CMMRCServerController::ProcessNextRequestL - error = %d"), err);
sl@0: 		}
sl@0: #endif
sl@0: 	
sl@0: 	DP0_RET(err, "err=%d");
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Pop the decision rule on the base of the current in-process request and a new committed request
sl@0:  * @param TAudioState aAudioStateAllocatedResource
sl@0:  * @param TAudioState aAudioStateRequiringProcess
sl@0:  * @return TMMRCRule
sl@0:  */
sl@0: TMMRCRule CMMRCServerController::DecisionRule(TAudioState aAudioStateAllocatedResource, TAudioState aAudioStateRequiringProcess)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::DecisionRule *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TMMRCRule rule = iMMRCServerRuleManager->DecisionRule(aAudioStateAllocatedResource, aAudioStateRequiringProcess);
sl@0: 	
sl@0: 	DP0_RET(rule, "rule=%d");
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Pop the action reason on the base of the last committed request and the current one
sl@0:  * @param TAudioState aAudioStateLastCommitted
sl@0:  * @param TAudioState aAudioStateRequested
sl@0:  * @return TReason
sl@0:  */
sl@0: TReason CMMRCServerController::ActionReason(TAudioState aAudioStateLastCommitted, TAudioState aAudioStateRequested)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::ActionReason *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TReason reason = iMMRCServerRuleManager->ActionReason(aAudioStateLastCommitted, aAudioStateRequested);
sl@0: 	
sl@0: 	DP0_RET(reason, "reason=%d");
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Send a resource request to the adaptation
sl@0:  * @param MLogicalChain* aOldChain
sl@0:  * @param MLogicalChain* aNewChain
sl@0:  * @return KerrNone in case of success of the process
sl@0:  */
sl@0: TInt CMMRCServerController::SendResourceRequest( CMMRCServerSession& aServerSession )
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::SendResourceRequest *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	iMMRCServerInfo->SwitchServerState( EMMRCServerStateWaitResourceResponseFromAdaptation, aServerSession.ContextId() );
sl@0: 
sl@0: // if entering APR state, remove from Paused list.
sl@0: 	TRAPD(err, aServerSession.StartProcessL());
sl@0: 	{
sl@0: 	MLogicalChain* logicalChainNew = aServerSession.LogicalChainRequested();
sl@0: 	if (logicalChainNew)
sl@0: 		{
sl@0: 		TAudioState audioStateNew = logicalChainNew->StreamState();
sl@0: 		if ( 
sl@0: 			(audioStateNew == EActive ) || 
sl@0: 			(audioStateNew == EPrimed) || 
sl@0: 			(audioStateNew == EIdle) 
sl@0: 			
sl@0: 			)
sl@0: 			{
sl@0: 			TInt contextId = aServerSession.ContextId( );
sl@0: 			iMMRCServerInfo->PopAndRemovePausedContext(contextId);
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 	if(err == KErrNone)
sl@0: 		{
sl@0: 		//Send request
sl@0: 		if (!aServerSession.SendRequestToAdaptation(ENormalRequest))
sl@0: 			{
sl@0: // TBD fail at current task.
sl@0: // return server shutting down			
sl@0: 			}
sl@0: 		}
sl@0: 	
sl@0: #ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 	if(err != KErrNone)
sl@0: 		{
sl@0: 		RDebug::Print(_L("!!!!CMMRCServerController::SendResourceRequest - error = %d"), err);
sl@0: 		}
sl@0: #endif
sl@0: 	
sl@0: 	DP0_RET(err, "err=%d");
sl@0: 	}
sl@0: 
sl@0: /** 
sl@0:  * Send a preemption request to the adaptation
sl@0:  * @param MLogicalChain* aOldChain
sl@0:  * @param MLogicalChain* aNewChain
sl@0:  * @return KerrNone in case of success of the process
sl@0:  */
sl@0: TInt CMMRCServerController::SendPreemptionRequest( CMMRCServerSession& aServerSession )
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::SendPreemptionRequest *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	iMMRCServerInfo->SwitchServerState( EMMRCServerStateWaitPreemptionResponse, aServerSession.ContextId() );
sl@0: 
sl@0: 	//Update logical chains
sl@0: 	TRAPD(err, aServerSession.StartPreemptionL());
sl@0: 		
sl@0: 	
sl@0: 	if(err == KErrNone)
sl@0: 		{
sl@0: 	//Send request
sl@0: 		if (!aServerSession.SendRequestToAdaptation(EPreemptionRequest))
sl@0: 			{
sl@0: 	// TBD fail at current task.
sl@0: 	// return server shutting down/low memory where necessary			
sl@0: 			}
sl@0: 		}
sl@0: 	
sl@0: #ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 	if(err != KErrNone)
sl@0: 		{
sl@0: 		RDebug::Print(_L("!!!!CMMRCServerController::SendPreemptionRequest - error = %d"), err);
sl@0: 		}
sl@0: #endif
sl@0: 
sl@0: 	DP0_RET(err, "err=%d");
sl@0: 	}
sl@0: 
sl@0: /** 
sl@0:  * Callback from the adaptation
sl@0:  * @param MLogicalChain* aOldChain
sl@0:  * @param MLogicalChain* aNewChain
sl@0:  * @param TMMRCAdaptationToServerRequestResults aResult
sl@0:  */
sl@0: void CMMRCServerController::AdaptationRequestAcknowledgment(CMMRCServerSession& aServerSession, TMMRCAdaptationToServerRequestResults aResult, TInt /*aError*/)
sl@0: 	{
sl@0: 	DP_CONTEXT(--------> CMMRCServerController::AdaptationRequestAcknowledgment *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: #ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 		RDebug::Print(_L("size of message queue    = %d"),  iMMRCServerInfo->RequestsCount());
sl@0: 		RDebug::Print(_L("size of inprocess queue = %d"),  iMMRCServerInfo->AllocatedResourceContextsCount());
sl@0: 		RDebug::Print(_L("size of paused queue = %d"),  iMMRCServerInfo->AllocatedPausedContextsCount());
sl@0: #endif
sl@0: 	
sl@0: 	TUint64 contextId;
sl@0: 	TMMRCServerState serverState;
sl@0: 	TInt err = KErrNone;
sl@0: 	iMMRCServerInfo->ServerState(serverState, contextId);
sl@0: 	switch(serverState)
sl@0: 		{
sl@0: 		case EMMRCServerStateWaitPreemptionResponse: // here we process the response
sl@0: 			{
sl@0: 			switch(aResult)
sl@0: 				{
sl@0: 				case EMMRCAdaptationToServerResourceComplete:
sl@0: 					{
sl@0: 					//we remove the request in process from the queue
sl@0: 					CMMRCServerSession* serverSession = iMMRCServerInfo->PopAndRemoveFirstAllocatedResourceContext();
sl@0: 					if(serverSession)
sl@0: 						{
sl@0: 						TRAP(err, iMMRCServerInfo->PushPausedContextL(*serverSession));
sl@0: 						DP1(DLERR,"EPushPauseContextLeft %d", err);
sl@0: 						__ASSERT_DEBUG(err == KErrNone, Panic(EPushPauseContextLeft));
sl@0: 						}
sl@0: 					//Do not wait for a client acknowledgment
sl@0: 					iMMRCServerInfo->SwitchServerState(EMMRCServerStateIdle, 0);
sl@0: 					}
sl@0: 				break;
sl@0: 				case EMMRCAdaptationToServerResourceTimeout:
sl@0: 				default:
sl@0: 					{
sl@0: 					//jjpy TODO: What if the preemption request failed?!
sl@0: 					// That will be specified/implemented during the integration with the resource manager
sl@0: 					//we remove the request in process from the queue
sl@0: 					iMMRCServerInfo->PopAndRemoveFirstAllocatedResourceContext();
sl@0: 					}
sl@0: 				} // end switch(aResult)
sl@0: 			} //end case EMMRCServerStateWaitPreemptionResponse
sl@0: 		break;
sl@0: 		case EMMRCServerStateWaitResourceResponseFromAdaptation: // here we process the response
sl@0: 			{
sl@0: 			switch(aResult)
sl@0: 				{
sl@0: 				case EMMRCAdaptationToServerResourceComplete:
sl@0: 					{
sl@0: 					CMMRCServerSession* serverSessionAllocatedResource = iMMRCServerInfo->PopFirstAllocatedResourceContext();
sl@0: 					if( serverSessionAllocatedResource ) //If some previously some context has allocated a resource
sl@0: 						{
sl@0: 					 	//check if same context, if not it might be an error
sl@0: 					 	TAudioContextId contextId = aServerSession.ContextId( );
sl@0: 					 	TAudioContextId contextIdAllocatedResource = serverSessionAllocatedResource->ContextId( );
sl@0: 					#ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 							RDebug::Print(_L("contextId          = %d"),  contextId.Id());
sl@0: 							RDebug::Print(_L("contextIdAllocatedResource = %d"),  contextIdAllocatedResource.Id());
sl@0: 					#endif
sl@0: 						MLogicalChain* logicalChainNew = aServerSession.LogicalChainRequested();
sl@0: 						MLogicalChain* logicalChainOld = aServerSession.LogicalChainLastCommited();
sl@0: 						TAudioState audioStateNew = logicalChainNew->StreamState ( );
sl@0: 					 	if(contextId != contextIdAllocatedResource)
sl@0: 					 		{
sl@0: 					 		//it is ok if the rule said process always
sl@0: 							MLogicalChain* logicalChainUsingResource = serverSessionAllocatedResource->LogicalChainLastCommited();
sl@0: 							TAudioState audioStateAllocatedResource = logicalChainUsingResource->StreamState();
sl@0: 							TAudioState audioStateNew = logicalChainNew->StreamState ( );
sl@0: 							TMMRCRule rule = DecisionRule(audioStateAllocatedResource, audioStateNew);
sl@0: 					 		if( rule != EAlwaysProcess )
sl@0: 					 			{
sl@0: 					 			//not possible in theory... this is an error
sl@0: 							#ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 									RDebug::Print(_L("!!!!CMMRCServerController::AdaptationRequestAcknowledgment - contextId allocating a resource and new request different. Should be the same!"),  iMMRCServerInfo->AllocatedResourceContextsCount());
sl@0: 							#endif				 		
sl@0: 					 			}
sl@0: 					 		}
sl@0: 					 	else //same context here, so check if the resource has been deallocated
sl@0: 					 		{
sl@0: 						 	// in case of stop etc. remove from in process request
sl@0: 						 	//now check the reason
sl@0: 							TAudioState audioStateOld = EUninitialized;
sl@0: 							if(logicalChainOld)
sl@0: 								{
sl@0: 								audioStateOld = logicalChainOld->StreamState();
sl@0: 								}
sl@0: 							TReason reason = ActionReason(audioStateOld, audioStateNew);
sl@0: 								
sl@0: 							if (reason == ELoad)
sl@0: 								{
sl@0: 								iARNNotificationObject->Cancel();
sl@0: 								iMMRCServerInfo->PopAndRemovePausedContext(contextId);
sl@0: 								}
sl@0: 							else if (reason == EUnload)
sl@0: 								{
sl@0: 								iARNNotificationObject->Initialize();
sl@0: 								iMMRCServerInfo->PopAndRemoveFirstAllocatedResourceContextByContextId(contextId);			
sl@0: 								}
sl@0: 					 		}
sl@0: 					 	}
sl@0: 					else //no in process request locking a resource
sl@0: 						{
sl@0: 						MLogicalChain* logicalChainNew = aServerSession.LogicalChainRequested();
sl@0: 						MLogicalChain* logicalChainOld = aServerSession.LogicalChainLastCommited();
sl@0: 						TAudioState audioStateNew = logicalChainNew->StreamState ( );
sl@0: 						TAudioState audioStateOld = EUninitialized;
sl@0: 						if(logicalChainOld)
sl@0: 							{
sl@0: 							audioStateOld = logicalChainOld->StreamState();
sl@0: 							}
sl@0: 						TReason reason = ActionReason(audioStateOld, audioStateNew);
sl@0: 						if( reason == ELoad ||
sl@0: 			 					reason == EPrimeReason ||
sl@0: 			 					reason == EActivate )
sl@0: 			 					{
sl@0: 			 					TRAP(err, iMMRCServerInfo->PushAllocatedResourceContextL( aServerSession ));
sl@0: 			 					DP1(DLERR,"EPushAllocatedResourceContextFailed %d", err);
sl@0: 								__ASSERT_DEBUG(err == KErrNone, Panic(EPushAllocatedResourceContextFailed));
sl@0: 			 					}					
sl@0: 						}
sl@0: 					iMMRCServerInfo->SwitchServerState(EMMRCServerStateIdle, 0);
sl@0: 					}
sl@0: 				break;
sl@0: 	 			case EMMRCAdaptationToServerResourceTimeout:
sl@0: 	 			default:
sl@0: 	 				{
sl@0: 					//Just switch the state
sl@0: 					iMMRCServerInfo->SwitchServerState(EMMRCServerStateIdle, 0);
sl@0: 					}
sl@0: 	 			break;
sl@0: 	 			} //end switch switch(aResult)
sl@0: 	 		} // end case EMMRCServerStateWaitResourceResponseFromAdaptation
sl@0: 	 	break;
sl@0: 		case EMMRCServerStateIdle: //not possible....
sl@0: 	 	default:
sl@0:  	 	break;
sl@0: 	 	}
sl@0:  	
sl@0: 	TRAP(err, ProcessNextRequestL());
sl@0: 	DP1(DLERR,"EProcessNextRequestLeft %d", err);
sl@0: 	__ASSERT_DEBUG(err == KErrNone, Panic(EProcessNextRequestLeft));
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /*
sl@0:  * 
sl@0:  */
sl@0: void CMMRCServerController::NotifyPausedClientsResourceUnallocated()
sl@0: 	{
sl@0:  	DP_CONTEXT(----> CMMRCServerController::NotifyClientsResourceUnallocated *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	CMMRCServerSession* serverSession  = iMMRCServerInfo->PopAndRemoveFirstPausedContext( );
sl@0: 	while( serverSession )
sl@0: 		{
sl@0: 		serverSession->NotifyClientResourceUnallocated();
sl@0: 		serverSession  = iMMRCServerInfo->PopAndRemoveFirstPausedContext( );
sl@0: 		}
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /*
sl@0:  * 
sl@0:  */
sl@0: void CMMRCServerController::CloseSessionByContextId(TInt32 aContextId)
sl@0: 	{
sl@0:  	DP_CONTEXT(----> CMMRCServerController::CloseSessionByContextId *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	while( iMMRCServerInfo->PopAndRemoveFirstAllocatedResourceContextByContextId( aContextId ) ){}
sl@0: 	while( iMMRCServerInfo->PopAndRemoveFirstRequestByContextId( aContextId ) ){}
sl@0: 	while( iMMRCServerInfo->PopAndRemovePausedContext( aContextId ) ){}
sl@0: 	while( iMMRCServerInfo->PopAndRemoveFirstAPRContextByContextId( aContextId ) ){}
sl@0: 	TUint64 contextId;
sl@0: 	TMMRCServerState serverState;
sl@0: 	iMMRCServerInfo->ServerState(serverState, contextId);
sl@0: 	if( contextId == aContextId)
sl@0: 		{
sl@0: 		iMMRCServerInfo->SwitchServerState(EMMRCServerStateIdle, 0);
sl@0: 		}
sl@0: #ifdef SYMBIAN_MULTIMEDIA_ENABLE_LOGGING	
sl@0: 	RDebug::Print(_L("size of message queue    = %d"),  iMMRCServerInfo->RequestsCount());
sl@0: 	RDebug::Print(_L("size of inprocess queue = %d"),  iMMRCServerInfo->AllocatedResourceContextsCount());
sl@0: 	RDebug::Print(_L("size of paused queue = %d"),  iMMRCServerInfo->AllocatedPausedContextsCount());
sl@0: 	RDebug::Print(_L("size of APR queue  = %d"),  iMMRCServerInfo->AllocatedAPRContextsCount());
sl@0: #endif
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /*
sl@0:  *
sl@0:  */
sl@0: void CMMRCServerController::ServerState(TMMRCServerState& aServerState, TUint64& aContextId) const
sl@0: 	{
sl@0: 	iMMRCServerInfo->ServerState(aServerState, aContextId);
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: 
sl@0: */
sl@0: TInt CMMRCServerController::EnqueueRequestForAPRL(CMMRCServerSession& aServerSession)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::EnqueueRequestForAPRL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	//add the request to the queue
sl@0: 	TInt err = KErrNone;
sl@0: 	//if already there, should return KErrAlreadyExists
sl@0: 
sl@0: 	if (iMMRCServerInfo->IsOnAPRList(aServerSession.ContextId()))
sl@0: 		{
sl@0: 		err = KErrAlreadyExists;
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		iMMRCServerInfo->PushAPRContextL(aServerSession);
sl@0: 		}	
sl@0: 	DP0_RET(err, "err=%d");
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: 
sl@0: */
sl@0: TInt CMMRCServerController::RemoveRequestForAPR(CMMRCServerSession& aServerSession)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::RemoveRequestForAPR *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TInt err = KErrNone;
sl@0: 	TInt32 iContextId = aServerSession.ContextId();
sl@0: 	TBool iIsOnAPRList = iMMRCServerInfo->IsOnAPRList(iContextId);
sl@0: 	if(iIsOnAPRList)
sl@0: 		{
sl@0: 
sl@0: 		// Its possible that the remove request has occured whilst clients are being notified that the resource is available
sl@0: 		// Check if a notification sequence is currently under way
sl@0: 		if ( iARNNotificationObject->IsActive() )
sl@0: 			{
sl@0: 			
sl@0: 			// Iterate through each paused client 
sl@0: 			for ( TInt index = 0 ; index < iMMRCServerInfo->AllocatedPausedContextsCount() ; index++ )
sl@0: 				{
sl@0: 				
sl@0: 				// Find the client that has requested removal in the list
sl@0: 				TAudioContextId id = iMMRCServerInfo->PausedContextByIndex(index)->ContextId();
sl@0: 				if ( aServerSession.ContextId() == id )
sl@0: 					{
sl@0: 					// Object has already received a notification
sl@0: 					if ( index < iARNNotificationObject->iIndex )
sl@0: 						{
sl@0: 						// decrement the notification objects list index to account for the item that will be removed from the queue
sl@0: 						--iARNNotificationObject->iIndex;
sl@0: 						}
sl@0: 						
sl@0: 					// no action needs to be taken if 
sl@0: 					// index >= iMMRCServerInfo.iIndex
sl@0: 					
sl@0: 					break;
sl@0: 					}
sl@0: 				}
sl@0: 			
sl@0: 			}
sl@0: 
sl@0: 		iMMRCServerInfo->PopAndRemoveFirstAPRContextByContextId(iContextId);
sl@0: 		iMMRCServerInfo->PopAndRemovePausedContext(iContextId); //removing this session from the list of paused too.
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		err = KErrCancel;
sl@0: 		}
sl@0: 	
sl@0: 	DP0_RET(err, "err=%d");
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: 
sl@0: */
sl@0: TInt CMMRCServerController::WillResumePlay()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCServerController::WillResumePlay *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TInt err = KErrNone;
sl@0: 	iARNNotificationObject->Cancel();
sl@0: 	
sl@0: 	
sl@0: 	DP0_RET(err, "err=%d");
sl@0: 	}
sl@0: 
sl@0: 
sl@0: //From CActive
sl@0: /**
sl@0:  * Constructor.
sl@0:  */
sl@0: CARNNotificationObject::CARNNotificationObject(const TInt aPriority)
sl@0: :CActive(aPriority)
sl@0: 	{
sl@0: 	TRACE_CREATE();
sl@0: 	DP_CONTEXT(----> CARNNotificationObject::CARNNotificationObject *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: /**
sl@0:  * Destructor.
sl@0:  */
sl@0: CARNNotificationObject::~CARNNotificationObject()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CARNNotificationObject::~CARNNotificationObject *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	Cancel();
sl@0: 	iTimer.Close();
sl@0: 	delete iMMRCServerInfo;
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: /**
sl@0:  	CARNNotificationObject::ConstructL
sl@0:  	Symbian 2nd phase constructor can leave.
sl@0:  */
sl@0: void CARNNotificationObject::ConstructL(CMMRCServerInfo& aMMRCServerInfo)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CARNNotificationObject::ConstructL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	iMMRCServerInfo = &aMMRCServerInfo; 
sl@0: 	CActiveScheduler::Add(this);
sl@0: 	User::LeaveIfError(iTimer.CreateLocal());
sl@0: 	
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: // ---------------------------------------------------------------------------
sl@0: // CARNNotificationObject::NewL
sl@0: // ---------------------------------------------------------------------------
sl@0: CARNNotificationObject* CARNNotificationObject::NewL(const TInt aPriority, CMMRCServerInfo& aMMRCServerInfo)
sl@0: 	{
sl@0: 	DP_STATIC_CONTEXT(----> CARNNotificationObject::NewL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	CARNNotificationObject* self = new(ELeave)CARNNotificationObject(aPriority);
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL(aMMRCServerInfo);
sl@0: 	CleanupStack::Pop(self);
sl@0: 	
sl@0: 	DP0_RET(self, "0x%x");
sl@0: 	} 
sl@0: 
sl@0: // ---------------------------------------------------------------------------
sl@0: // CARNNotificationObject::RunL
sl@0: // ---------------------------------------------------------------------------
sl@0: void CARNNotificationObject::RunL()
sl@0: 	{
sl@0: 	DP_CONTEXT(CARNNotificationObject::RunL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	#if defined(_DEBUG) && defined(__WINS__) 
sl@0: 	const TTimeIntervalMicroSeconds32 KTimer = 1.8*1000000; // 1.8 seconds
sl@0: 	#else
sl@0: 	const TTimeIntervalMicroSeconds32 KTimer = 800000; // 0.8 seconds
sl@0: 	#endif
sl@0: 	
sl@0: 	TInt numPausedContext = iMMRCServerInfo->AllocatedPausedContextsCount();
sl@0: 
sl@0: 	// The list may have been modified whilst the AO was asleep, need to check that:
sl@0: 	// 1) iIndex is still in range
sl@0: 	// 2) the object at that location should still receive a notification
sl@0: 	
sl@0: 	if ( (iIndex > -1) && (iIndex < numPausedContext) )
sl@0: 		{
sl@0: 		CMMRCServerSession* mmrcSession = iMMRCServerInfo->PausedContextByIndex(iIndex);
sl@0: 		
sl@0: 		TAudioContextId id = mmrcSession->ContextId( );
sl@0: 		TBool isOnAPRList = iMMRCServerInfo->IsOnAPRList(id);
sl@0: 		if(isOnAPRList)
sl@0: 			{
sl@0: 			mmrcSession->NotifyClientResourceUnallocated();
sl@0: 			}
sl@0: 
sl@0: 		
sl@0: 		for(TInt aux = iIndex + 1; aux < numPausedContext ; aux++)
sl@0: 			{
sl@0: 			mmrcSession = iMMRCServerInfo->PausedContextByIndex(aux);
sl@0: 			id = mmrcSession->ContextId( );
sl@0: 			isOnAPRList = iMMRCServerInfo->IsOnAPRList(id);
sl@0: 			if(isOnAPRList)
sl@0: 				{
sl@0: 				iIndex = aux;		
sl@0: 				After(KTimer);
sl@0: 				break;
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 		
sl@0: 	else
sl@0: 		{
sl@0: 		iIndex = 0;
sl@0: 		}
sl@0: 		
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: // ---------------------------------------------------------------------------
sl@0: // CARNNotificationObject::After
sl@0: // ---------------------------------------------------------------------------
sl@0: void CARNNotificationObject::After(TTimeIntervalMicroSeconds32 aInterval)
sl@0: 	{
sl@0: 	DP_CONTEXT(CARNNotificationObject::After *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	Cancel();
sl@0: 	iTimer.After(iStatus,aInterval);
sl@0: 	SetActive();
sl@0: 
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: // ---------------------------------------------------------------------------
sl@0: // CARNNotificationObject::Initialize
sl@0: // ---------------------------------------------------------------------------
sl@0: void CARNNotificationObject::Initialize()
sl@0: 	{
sl@0: 	DP_CONTEXT(CARNNotificationObject::Initialize *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	#if defined(_DEBUG) && defined(__WINS__)
sl@0: 	const TTimeIntervalMicroSeconds32 KTimer = 1.8*1000000; // 1.8 seconds
sl@0: 	#else
sl@0: 	const TTimeIntervalMicroSeconds32 KTimer = 800000; // 0.8 seconds
sl@0: 	#endif
sl@0: 
sl@0: 	TInt numPausedContext = iMMRCServerInfo->AllocatedPausedContextsCount();
sl@0: 	iIndex = 0;
sl@0: 	CMMRCServerSession* mmrcSession = NULL;
sl@0: 	
sl@0: 	if(numPausedContext) // don't bother if zero.
sl@0: 		{
sl@0: 		for(TInt i(0); i<numPausedContext ; ++i)
sl@0: 			{
sl@0: 			mmrcSession = iMMRCServerInfo->PausedContextByIndex(i);
sl@0: 			TAudioContextId id = mmrcSession->ContextId( );
sl@0: 			TBool isOnAPRList = iMMRCServerInfo->IsOnAPRList(id);
sl@0: 			if(isOnAPRList)
sl@0: 				{
sl@0: 				iIndex = i;
sl@0: 				After(KTimer);
sl@0: 				break;
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: // ---------------------------------------------------------------------------
sl@0: // CMMRCServer::DoCancel
sl@0: // ---------------------------------------------------------------------------
sl@0: void CARNNotificationObject::DoCancel()
sl@0: 	{
sl@0: 	DP_CONTEXT(CARNNotificationObject::DoCancel *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	iTimer.Cancel();
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMRCServerController::Panic(TMMRCServerControllerPanicCodes aCode)
sl@0: 	{
sl@0: 	User::Panic(KMMRCServerControllerPanicCategory, aCode);
sl@0: 	}	
sl@0: //EOF