// 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:
//

#ifndef OMXPCMCODEC_H
#define OMXPCMCODEC_H

#include <e32msgqueue.h>
#include <mdaaudiooutputstream.h>
#include <openmax/il/khronos/v1_x/OMX_Audio.h>
#include "OmxImpl.h"

#include <mmfcodec/mmfaudiou8tos16pcmcodec.h>
#include <mmfcodec/mmfaudiopcm8topcm16codec.h>
#include <mmfcodec/mmfaudiopcms16topcms8codec.h>
#include <mmfcodec/mmfaudios16tou8pcmcodec.h>

class COmxPCMCodec;


class CCodecProcessor : public CBase
		{

	enum TCodecMessageType
		{
		EStopProcessing,
		EPauseProcessing,
		EInputBuffer,
		EOutputBuffer,
		EExit				
		};

	class TCodecMessage 
		{
	public:
		TCodecMessageType iType;
		OMX_BUFFERHEADERTYPE* iBuffer;
		};
	
	public:		
		static CCodecProcessor* NewL(COmxPCMCodec& aParent);		

		void RunThreadL();
		void Stop();
		void Exit();
	    
        OMX_ERRORTYPE EmptyThisBuffer(
            OMX_BUFFERHEADERTYPE* pBuffer);
	    OMX_ERRORTYPE FillThisBuffer(
            OMX_BUFFERHEADERTYPE* pBuffer);
            
		void SetInputDataType(OMX_NUMERICALDATATYPE aType);
		void SetInputBitsPerSample(TInt aBitsPerSample);
		void SetOutputDataType(OMX_NUMERICALDATATYPE aType);
		void SetOutputBitsPerSample(TInt aBitsPerSample);

		virtual ~CCodecProcessor();		
	    
	private:
		void ConstructL();
		CCodecProcessor(COmxPCMCodec& aParent);

		void ProcessAvailableBuffers();
		void ChooseCodec();
	
	private:
		COmxPCMCodec* iParent;
		RPointerArray<OMX_BUFFERHEADERTYPE> iBuffersToEmpty;
		RPointerArray<OMX_BUFFERHEADERTYPE> iBuffersToFill;	
		
		TRequestStatus iQueueStatus;
		RMsgQueue<TCodecMessage> iMessageQueue;
		
		OMX_BUFFERHEADERTYPE* iInputBuffer;
		OMX_BUFFERHEADERTYPE* iOutputBuffer;
		
		TMMFAudioCodecBase* iCodec;

		// codec configuration settings
		TInt iInputBitsPerSample; 
		TInt iOutputBitsPerSample; 
		OMX_NUMERICALDATATYPE iInputDataType;
		OMX_NUMERICALDATATYPE iOutputDataType;
		
		TInt iInputBufferPos;
		
		TMMFAudioCodecBase* iCurrentCodec;
			
		TMMFAudioU8ToS16PcmCodec iAudioU8ToS16PcmCodec;
		TMMFAudioPcm8ToPcm16Codec iAudioS8ToS16PcmCodec;
		
		TMMFAudioPcmS16ToPcmS8Codec iAudioS16ToS8PcmCodec;
		TMMFAudioS16ToU8PcmCodec iAudioS16ToU8PcmCodec;

		TBool iStarted;
		TReal iOutputSamplesPerInputSample;
		};



class COmxPCMCodec : public COmxComponentImpl
	{
public:
	friend class CCodecProcessor;
	friend class CCodecCallbacks;

	static TInt CreateComponent(OMX_HANDLETYPE hComponent);
	~COmxPCMCodec();
	
	OMX_ERRORTYPE GetComponentVersion(
			OMX_STRING pComponentName,
			OMX_VERSIONTYPE* pComponentVersion,
			OMX_VERSIONTYPE* pSpecVersion,
			OMX_UUIDTYPE* pComponentUUID);
    OMX_ERRORTYPE SendCommand(
			OMX_COMMANDTYPE Cmd,
			TUint32 nParam1,
			TAny* pCmdData);
    OMX_ERRORTYPE GetParameter(
			OMX_INDEXTYPE nParamIndex,  
			TAny* ComponentParameterStructure);
    OMX_ERRORTYPE SetParameter(
			OMX_INDEXTYPE nIndex,
			TAny* ComponentParameterStructure);
    OMX_ERRORTYPE GetConfig(
			OMX_INDEXTYPE nIndex, 
			TAny* value);
    OMX_ERRORTYPE SetConfig(
			OMX_INDEXTYPE nIndex, 
			TAny* value);
    OMX_ERRORTYPE GetExtensionIndex(
			OMX_STRING ParameterName,
			OMX_INDEXTYPE* pIndexType);
    OMX_ERRORTYPE GetState(
			OMX_STATETYPE* pState);
    OMX_ERRORTYPE ComponentTunnelRequest(
			OMX_HANDLETYPE hInput,
			TUint32 nInputPort,
			OMX_HANDLETYPE hOutput,
			TUint32 nOutputPort,
			OMX_TUNNELSETUPTYPE* pTunnelSetup);
    virtual OMX_ERRORTYPE UseBuffer(
			OMX_BUFFERHEADERTYPE** pBufferHdr,
			TUint32 nPortIndex,
			TAny* pAppPrivate,
			TUint32 nSizeBytes,
			TUint8* pBuffer);
    virtual OMX_ERRORTYPE AllocateBuffer(
           OMX_BUFFERHEADERTYPE** pBuffer,
           TUint32 nPortIndex,
           TAny* pAppData,
           TUint32 nSizeBytes);
    OMX_ERRORTYPE FreeBuffer(
    		  TUint32 nPortIndex,	
              OMX_BUFFERHEADERTYPE* pBuffer);
    OMX_ERRORTYPE EmptyThisBuffer(
              OMX_BUFFERHEADERTYPE* pBuffer);
    OMX_ERRORTYPE FillThisBuffer(
              OMX_BUFFERHEADERTYPE* pBuffer);
    OMX_ERRORTYPE SetCallbacks(
              OMX_CALLBACKTYPE* pCallbacks, 
              TAny* pAppData);
              
	TInt StartExecution();
            
	void EventHandlerCallback(
        			 OMX_EVENTTYPE eEvent, 
        			 TUint32 nData1,
        			 TUint32 nData2,
        			 OMX_STRING cExtraInfo);
	void FillBufferDoneCallback(OMX_BUFFERHEADERTYPE* pBuffer);
	void EmptyBufferDoneCallback(OMX_BUFFERHEADERTYPE* pBuffer);
            

private:
	COmxPCMCodec(OMX_HANDLETYPE hComponent);
	void ConstructL();

private:
	OMX_CALLBACKTYPE* iCallback;
	TAny* iAppData;
	OMX_STATETYPE iState;
	
	TRequestStatus iThreadDeath;
	CCodecProcessor* iCodecProcessor;
	TBool iCreatedThread;
	RThread iProcessingThread;
	};
	
#endif // OMXPCMCODEC_H