os/mm/devsound/devsoundrefplugin/src/platsec/SoundDevice/MmfDevSoundCallbackHandler.cpp
1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/mm/devsound/devsoundrefplugin/src/platsec/SoundDevice/MmfDevSoundCallbackHandler.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,211 @@
1.4 +// Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +//
1.18 +
1.19 +#include "SoundDeviceBody.h"
1.20 +#include "MmfDevSoundCallbackHandler.h"
1.21 +#include "MmfAudioClientServer.h"
1.22 +
1.23 +CMsgQueueHandler* CMsgQueueHandler::NewL(RMMFDevSoundProxy* aDevSoundProxy,
1.24 + MDevSoundObserver& aDevSoundObserver,
1.25 + RMsgQueue<TMMFDevSoundQueueItem>* aMsgQueue,
1.26 + MMMFDevSoundCustomInterfaceObserver& aDevSoundIntfcObserver)
1.27 + {
1.28 + CMsgQueueHandler* self = new(ELeave) CMsgQueueHandler(aDevSoundProxy, aDevSoundObserver, aMsgQueue, aDevSoundIntfcObserver);
1.29 + CleanupStack::PushL(self);
1.30 + self->ConstructL();
1.31 + CleanupStack::Pop();
1.32 + return self;
1.33 + }
1.34 +
1.35 +void CMsgQueueHandler::SetObserver(MDevSoundObserver& aDevSoundObserver)
1.36 + {
1.37 + iDevSoundObserver = &aDevSoundObserver;
1.38 + }
1.39 +
1.40 +CMsgQueueHandler::CMsgQueueHandler(RMMFDevSoundProxy* aDevSoundProxy,
1.41 + MDevSoundObserver& aDevSoundObserver,
1.42 + RMsgQueue<TMMFDevSoundQueueItem>* aMsgQueue,
1.43 + MMMFDevSoundCustomInterfaceObserver& aDevSoundIntfcObserver) :
1.44 + CActive(EPriorityStandard), iDevSoundProxy(aDevSoundProxy),
1.45 + iDevSoundObserver(&aDevSoundObserver), iMsgQueue(aMsgQueue), iDevSoundIntfcObserver(aDevSoundIntfcObserver)
1.46 + {
1.47 + CActiveScheduler::Add(this);
1.48 + }
1.49 +
1.50 +void CMsgQueueHandler::ConstructL()
1.51 + {
1.52 + }
1.53 +
1.54 +CMsgQueueHandler::~CMsgQueueHandler()
1.55 + {
1.56 + delete iBuffer;
1.57 + Cancel();
1.58 + iMsgQueue->Close();
1.59 + }
1.60 +
1.61 +void CMsgQueueHandler::ReceiveEvents()
1.62 + {
1.63 + iMsgQueue->NotifyDataAvailable(iStatus);
1.64 + SetActive();
1.65 + }
1.66 +
1.67 +void CMsgQueueHandler::RunL()
1.68 + {
1.69 + TInt queueErr = iMsgQueue->Receive(iCurrentItem);
1.70 + TInt err = KErrNone;
1.71 +
1.72 + if (!queueErr || queueErr == KErrUnderflow)
1.73 + {
1.74 + // Signal that we're ready to process the next message
1.75 + iMsgQueue->NotifyDataAvailable(iStatus);
1.76 + SetActive();
1.77 + }
1.78 +
1.79 + if (!queueErr)
1.80 + {
1.81 + iCurrentRequest = iCurrentItem.iRequest;
1.82 + switch (iCurrentRequest)
1.83 + {
1.84 + case EMMFDevSoundProxyICEvent:
1.85 + DoInitComplete();
1.86 + break;
1.87 + case EMMFDevSoundProxyBTBFEvent:
1.88 + {
1.89 + TRAP(err, DoBTBFCompleteL());
1.90 + if (err)
1.91 + {
1.92 + iDevSoundObserver->PlayError(err);
1.93 + }
1.94 + }
1.95 + break;
1.96 + case EMMFDevSoundProxyBTBEEvent:
1.97 + {
1.98 + TRAP(err, DoBTBECompleteL());
1.99 + if (err)
1.100 + {
1.101 + iDevSoundObserver->RecordError(err);
1.102 + }
1.103 + }
1.104 + break;
1.105 + case EMMFDevSoundProxyPEEvent:
1.106 + DoPlayErrorComplete();
1.107 + break;
1.108 + case EMMFDevSoundProxyREEvent:
1.109 + DoRecordErrorComplete();
1.110 + break;
1.111 + case EMMFDevSoundProxyTFEvent:
1.112 + DoToneFinishedComplete();
1.113 + break;
1.114 + case EMMFDevSoundProxySETCEvent:
1.115 + DoSendEventToClientComplete();
1.116 + break;
1.117 + case EMMFDevSoundCustomCommandCloseMuxDemuxPair:
1.118 + {
1.119 + TMMFEvent pckgevent = iCurrentItem.iEventPckg();
1.120 + TInt handle = pckgevent.iEventType.iUid;
1.121 + iDevSoundIntfcObserver.CloseCustomInterface(handle);
1.122 + }
1.123 + break;
1.124 + default:
1.125 + break;
1.126 + }
1.127 +
1.128 + }
1.129 + }
1.130 +
1.131 +TInt CMsgQueueHandler::RunError(TInt aError)
1.132 + {
1.133 + TMMFEvent event;
1.134 + event.iErrorCode = aError;
1.135 + iDevSoundObserver->SendEventToClient(event);
1.136 + return KErrNone;
1.137 + }
1.138 +
1.139 +void CMsgQueueHandler::DoCancel()
1.140 + {
1.141 + iMsgQueue->CancelDataAvailable();
1.142 + }
1.143 +
1.144 +void CMsgQueueHandler::DoInitComplete()
1.145 + {
1.146 + iDevSoundObserver->InitializeComplete(iCurrentItem.iErrorCode);
1.147 + }
1.148 +
1.149 +void CMsgQueueHandler::DoPlayErrorComplete()
1.150 + {
1.151 + iDevSoundObserver->PlayError(iCurrentItem.iErrorCode);
1.152 + }
1.153 +
1.154 +void CMsgQueueHandler::DoBTBFCompleteL()
1.155 + {
1.156 + // Wanted to push both the message request and the message's data
1.157 + // through the queue in one go but the data is too large so try
1.158 + // issuing a new request for the data before doing all this...
1.159 + User::LeaveIfError(iDevSoundProxy->BufferToBeFilledData(iSetPckg));
1.160 +
1.161 + TMMFDevSoundProxyHwBuf set;
1.162 + set.iBufferType = iSetPckg().iBufferType;
1.163 + set.iRequestSize = iSetPckg().iRequestSize;
1.164 + set.iBufferSize = iSetPckg().iBufferSize;
1.165 + set.iLastBuffer = iSetPckg().iLastBuffer;
1.166 +
1.167 + CMMFDataBuffer* buffer = CMMFDescriptorBuffer::NewL(set.iBufferSize);
1.168 + CleanupStack::PushL(buffer);
1.169 + buffer->SetRequestSizeL(set.iRequestSize);
1.170 + CleanupStack::Pop(buffer);
1.171 + buffer->SetLastBuffer(set.iLastBuffer);
1.172 + iDevSoundProxy->SetBuffer(buffer);//DevSoundProxy takes the ownership of "buffer"
1.173 +
1.174 + iDevSoundObserver->BufferToBeFilled(buffer);
1.175 + }
1.176 +
1.177 +void CMsgQueueHandler::DoBTBECompleteL()
1.178 + {
1.179 + User::LeaveIfError(iDevSoundProxy->BufferToBeEmptiedData(iSetPckg));
1.180 +
1.181 + TMMFDevSoundProxyHwBuf aSet;
1.182 + aSet.iBufferType = iSetPckg().iBufferType;
1.183 + aSet.iRequestSize = iSetPckg().iRequestSize;
1.184 + aSet.iBufferSize = iSetPckg().iBufferSize;
1.185 + aSet.iLastBuffer = iSetPckg().iLastBuffer;
1.186 +
1.187 + if(iBuffer)
1.188 + {
1.189 + delete iBuffer;
1.190 + iBuffer = NULL;
1.191 + }
1.192 + iBuffer = CMMFDescriptorBuffer::NewL(aSet.iBufferSize);
1.193 + iBuffer->SetRequestSizeL(aSet.iRequestSize);
1.194 + iBuffer->SetLastBuffer(aSet.iLastBuffer);
1.195 +
1.196 + User::LeaveIfError(iDevSoundProxy->GetRecordedBufferL(*iBuffer));
1.197 +
1.198 + iDevSoundObserver->BufferToBeEmptied(iBuffer);
1.199 + }
1.200 +
1.201 +void CMsgQueueHandler::DoRecordErrorComplete()
1.202 + {
1.203 + iDevSoundObserver->RecordError(iCurrentItem.iErrorCode);
1.204 + }
1.205 +
1.206 +void CMsgQueueHandler::DoToneFinishedComplete()
1.207 + {
1.208 + iDevSoundObserver->ToneFinished(iCurrentItem.iErrorCode);
1.209 + }
1.210 +
1.211 +void CMsgQueueHandler::DoSendEventToClientComplete()
1.212 + {
1.213 + iDevSoundObserver->SendEventToClient(iCurrentItem.iEventPckg());
1.214 + }