/*
* Copyright (c) 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 BASEPROFILEHANDLER_H_
#define BASEPROFILEHANDLER_H_

#include <e32base.h>

#include <openmax/il/khronos/v1_x/OMX_Core.h>
#include <openmax/il/khronos/v1_x/OMX_Component.h>

#include "asbreakeventhandler.h"
#include "omxscripttest.h"


NONSHARABLE_CLASS(CBaseProfileHandler) : public CBase
    {
public:
    CBaseProfileHandler(ROmxScriptTest& aTestOwner, RASBreakEventHandler& aParentEventHandler);
    ~CBaseProfileHandler();
    
    OMX_COMPONENTTYPE* LoadComponentL(const TDesC8& aTestSpecificName, const TDesC8& aOmxName);
    
    void AddPortSupportL(TInt aPortIndex);
    void SetBufferSupplier(TInt aPortIndex, TBool aComponentBufferSupplier);
    void SetAutoMode(TInt aPortIndex, TBool aAutoMode);
    void SetupBuffersL(TInt aPortIndex, TInt aNumberBuffers);
	void FreeAllocatedBuffersL();
    void FillThisBuffer(TInt aPortIndex, TInt aBufferIndexInPort);
    void EmptyThisBuffer(TInt aPortIndex, TInt aBufferIndexInPort);
    void WaitForBufferCompletion(TInt aPortIndex, TInt aBufferIndexInPort);
    
    //OpenMAX IL callbacks
    static OMX_ERRORTYPE EventHandler(OMX_HANDLETYPE hComponent, OMX_PTR pAppData, OMX_EVENTTYPE eEvent, OMX_U32 nData1, OMX_U32 nData2, OMX_PTR pEventData);
    static OMX_ERRORTYPE FillBufferDone(OMX_IN OMX_HANDLETYPE hComponent, OMX_IN OMX_PTR pAppData, OMX_IN OMX_BUFFERHEADERTYPE* pBuffer);
    static OMX_ERRORTYPE EmptyBufferDone(OMX_IN OMX_HANDLETYPE hComponent, OMX_IN OMX_PTR pAppData, OMX_IN OMX_BUFFERHEADERTYPE* pBuffer);
    
    void HandleEventReceived(OMX_EVENTTYPE aeEvent, OMX_U32 anData1, OMX_U32 anData2, OMX_PTR apEventData);
    void HandleFillBufferDone(OMX_IN OMX_BUFFERHEADERTYPE* aFilledBuffer);
    void HandleEmptyBufferDone(OMX_IN OMX_BUFFERHEADERTYPE* aEmptiedBuffer);
    
protected:
    
    NONSHARABLE_CLASS(CBufferHeaderInfo) : public CBase
        {
    public:
        CBufferHeaderInfo(CBaseProfileHandler& aParent);
        ~CBufferHeaderInfo();
        
    public:
        OMX_BUFFERHEADERTYPE* iBufferHeader;    
        TBool iBufferAvailable;     //EFalse if buffer currently with IL Component
        TInt iPortIndex;    //Port the buffer is assigned to
        CBaseProfileHandler& iParent;
        };
    
    struct TPortInfo
        {
        TInt iPortIndex;
        TBool iWeAreBufferSupplier;
        TBool iAutoMode;
        };
    
    virtual void DoEventReceived(OMX_EVENTTYPE aeEvent, OMX_U32 anData1, OMX_U32 anData2, OMX_PTR apEventData);
    virtual void DoFillBufferDone(OMX_IN OMX_BUFFERHEADERTYPE* aFilledBuffer);
    virtual void DoEmptyBufferDone(OMX_IN OMX_BUFFERHEADERTYPE* aEmptiedBuffer); 

    static TBool PortIndexMatchComparison(const TInt* aPortIndex, const TPortInfo& aPortInfo);
    static TBool BufferHeaderMatchComparison(const OMX_BUFFERHEADERTYPE* aBufferHeader, const CBufferHeaderInfo& aBufferHeaderInfo);

    //aBufferIndexInPort starts at 0 for the first buffer
    TInt LocateBufferForPort(TInt aPortIndex, TInt aBufferIndexInPort);
    
protected:
    OMX_CALLBACKTYPE iOmxCallbacks;
    OMX_COMPONENTTYPE* iOmxComponent;   //Not owned    

    RPointerArray<CBufferHeaderInfo> iBufferHeaders;

    RArray<TPortInfo> iPortsUsingBaseProfile;
     
    HBufC* iXmlName;
    
    ROmxScriptTest& iErrorCallbacks;
    RASBreakEventHandler& iEventHandlerCallbacks;
 
    OMX_BUFFERHEADERTYPE* iWaitingOnBuffer; //Not owned, only ever one wait request pending at any one time so this suffices
    
    RMutex iMutex;  //Used to ensure serialised execution of buffer completions and calls to wait on buffer completions
    };

#endif /* BASEPROFILEHANDLER_H_ */