// Copyright (c) 2005-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:
//

#include "SoundDeviceBody.h"
#include "MmfDevSoundCallbackHandler.h"
#include "MmfAudioClientServer.h"

CMsgQueueHandler* CMsgQueueHandler::NewL(RMMFDevSoundProxy* aDevSoundProxy,
										 MDevSoundObserver& aDevSoundObserver,
										 RMsgQueue<TMMFDevSoundQueueItem>* aMsgQueue,
										 MMMFDevSoundCustomInterfaceObserver& aDevSoundIntfcObserver)
	{
	CMsgQueueHandler* self = new(ELeave) CMsgQueueHandler(aDevSoundProxy, aDevSoundObserver, aMsgQueue, aDevSoundIntfcObserver);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();
	return self;
	}

void CMsgQueueHandler::SetObserver(MDevSoundObserver& aDevSoundObserver)
	{
	iDevSoundObserver = &aDevSoundObserver;
	}

CMsgQueueHandler::CMsgQueueHandler(RMMFDevSoundProxy* aDevSoundProxy,
								   MDevSoundObserver& aDevSoundObserver,
								   RMsgQueue<TMMFDevSoundQueueItem>* aMsgQueue,
								   MMMFDevSoundCustomInterfaceObserver& aDevSoundIntfcObserver) :
								   CActive(EPriorityStandard), iDevSoundProxy(aDevSoundProxy),
								   iDevSoundObserver(&aDevSoundObserver), iMsgQueue(aMsgQueue), iDevSoundIntfcObserver(aDevSoundIntfcObserver)
	{
	CActiveScheduler::Add(this);
	}

void CMsgQueueHandler::ConstructL()
	{
	}

CMsgQueueHandler::~CMsgQueueHandler()
	{
	delete iBuffer;
	Cancel();
	iMsgQueue->Close();
	}

void CMsgQueueHandler::ReceiveEvents()
	{
	iMsgQueue->NotifyDataAvailable(iStatus);
	SetActive();
	}

void CMsgQueueHandler::RunL()
	{
	TInt queueErr = iMsgQueue->Receive(iCurrentItem);	
	TInt err = KErrNone;

	if (!queueErr || queueErr == KErrUnderflow)
		{
		// Signal that we're ready to process the next message
		iMsgQueue->NotifyDataAvailable(iStatus);
		SetActive();							
		}

	if (!queueErr)
		{	
		iCurrentRequest = iCurrentItem.iRequest;
		switch (iCurrentRequest)
			{
			case EMMFDevSoundProxyICEvent:
				DoInitComplete();
				break;
			case EMMFDevSoundProxyBTBFEvent:
				{
				TRAP(err, DoBTBFCompleteL());
				if (err)
					{
					iDevSoundObserver->PlayError(err);
					}
				}
				break;
			case EMMFDevSoundProxyBTBEEvent:
				{
				TRAP(err, DoBTBECompleteL());
				if (err)
					{
					iDevSoundObserver->RecordError(err);
					}
				}
				break;					
			case EMMFDevSoundProxyPEEvent:
				DoPlayErrorComplete();
				break;
			case EMMFDevSoundProxyREEvent:
				DoRecordErrorComplete();
				break;
			case EMMFDevSoundProxyTFEvent:
				DoToneFinishedComplete();
				break;
			case EMMFDevSoundProxySETCEvent:
				DoSendEventToClientComplete();
				break;
			case EMMFDevSoundCustomCommandCloseMuxDemuxPair:
				{
				TMMFEvent pckgevent = iCurrentItem.iEventPckg();
				TInt handle = pckgevent.iEventType.iUid;
				iDevSoundIntfcObserver.CloseCustomInterface(handle);
				}
				break;
			default:
				break;
			}
		
		}
	}

TInt CMsgQueueHandler::RunError(TInt aError)
	{
	TMMFEvent event;
	event.iErrorCode = aError;
	iDevSoundObserver->SendEventToClient(event);
	return KErrNone;
	}
	
void CMsgQueueHandler::DoCancel()
	{
	iMsgQueue->CancelDataAvailable();
	}

void CMsgQueueHandler::DoInitComplete()
	{
	iDevSoundObserver->InitializeComplete(iCurrentItem.iErrorCode);
	}

void CMsgQueueHandler::DoPlayErrorComplete()
	{
	iDevSoundObserver->PlayError(iCurrentItem.iErrorCode);
	}

void CMsgQueueHandler::DoBTBFCompleteL()
	{
	// Wanted to push both the message request and the message's data
	// through the queue in one go but the data is too large so try
	// issuing a new request for the data before doing all this...
	User::LeaveIfError(iDevSoundProxy->BufferToBeFilledData(iSetPckg));
	
	TMMFDevSoundProxyHwBuf set;
	set.iBufferType = iSetPckg().iBufferType;
	set.iRequestSize = iSetPckg().iRequestSize;
	set.iBufferSize = iSetPckg().iBufferSize;
	set.iLastBuffer = iSetPckg().iLastBuffer;

	CMMFDataBuffer* buffer = CMMFDescriptorBuffer::NewL(set.iBufferSize);
	CleanupStack::PushL(buffer);
	buffer->SetRequestSizeL(set.iRequestSize);
	CleanupStack::Pop(buffer);
	buffer->SetLastBuffer(set.iLastBuffer);
	iDevSoundProxy->SetBuffer(buffer);//DevSoundProxy takes the ownership of "buffer"

	iDevSoundObserver->BufferToBeFilled(buffer);
	}

void CMsgQueueHandler::DoBTBECompleteL()
	{
	User::LeaveIfError(iDevSoundProxy->BufferToBeEmptiedData(iSetPckg));
	
	TMMFDevSoundProxyHwBuf aSet;
	aSet.iBufferType = iSetPckg().iBufferType;
	aSet.iRequestSize = iSetPckg().iRequestSize;
	aSet.iBufferSize = iSetPckg().iBufferSize;
	aSet.iLastBuffer = iSetPckg().iLastBuffer;

	if(iBuffer)
		{
		delete iBuffer;
		iBuffer = NULL;
		}
	iBuffer = CMMFDescriptorBuffer::NewL(aSet.iBufferSize);
	iBuffer->SetRequestSizeL(aSet.iRequestSize);
	iBuffer->SetLastBuffer(aSet.iLastBuffer);
	
	User::LeaveIfError(iDevSoundProxy->GetRecordedBufferL(*iBuffer));  

	iDevSoundObserver->BufferToBeEmptied(iBuffer);
	}

void CMsgQueueHandler::DoRecordErrorComplete()
	{
	iDevSoundObserver->RecordError(iCurrentItem.iErrorCode);
	}
	
void CMsgQueueHandler::DoToneFinishedComplete()
	{
	iDevSoundObserver->ToneFinished(iCurrentItem.iErrorCode);
	}
	
void CMsgQueueHandler::DoSendEventToClientComplete()
	{
	iDevSoundObserver->SendEventToClient(iCurrentItem.iEventPckg());	
	}