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


/**
@file
@internalComponent
*/
#ifndef COMXILTESTMD5SINKPROCESSINGFUNCTION_H
#define COMXILTESTMD5SINKPROCESSINGFUNCTION_H

#include <e32base.h>
#include <e32msgqueue.h>
#include <f32file.h>
#include <openmax/il/khronos/v1_x/OMX_Index.h>
#include <openmax/il/khronos/v1_x/OMX_Component.h>
#include <openmax/il/common/omxilprocessingfunction.h>

class COmxILTestMD5SinkConfigManager;
class CMD5Active;
class CFlushActive;

class COmxILTestMD5SinkProcessingFunction : public COmxILProcessingFunction
	{
public:
	static COmxILTestMD5SinkProcessingFunction* NewL(MOmxILCallbackNotificationIf&);
	~COmxILTestMD5SinkProcessingFunction();

	void SetConfigManager(COmxILTestMD5SinkConfigManager* aConfigManager);
	
	OMX_ERRORTYPE StateTransitionIndication(TStateIndex aNewState);
	OMX_ERRORTYPE BufferFlushingIndication(TUint32 aPortIndex, OMX_DIRTYPE aDirection);
	OMX_ERRORTYPE ParamIndication(OMX_INDEXTYPE aParamIndex, const TAny* apComponentParameterStructure);
	OMX_ERRORTYPE ConfigIndication(OMX_INDEXTYPE aConfigIndex, const TAny* apComponentConfigStructure);
	OMX_ERRORTYPE BufferIndication(OMX_BUFFERHEADERTYPE* apBufferHeader, OMX_DIRTYPE aDirection);
	OMX_BOOL BufferRemovalIndication(OMX_BUFFERHEADERTYPE* apBufferHeader, OMX_DIRTYPE aDirection);

private:
	COmxILTestMD5SinkProcessingFunction(MOmxILCallbackNotificationIf&);
	void ConstructL(MOmxILCallbackNotificationIf&);
			
private:
	CMD5Active* iMD5Active;
	CFlushActive* iFlushHandler;
	};

class CMD5;

class CMD5Active : public CActive
	{
public:
	static CMD5Active* NewL(MOmxILCallbackNotificationIf& aCallback);
	~CMD5Active();
	
	OMX_ERRORTYPE DeliverBuffer(OMX_BUFFERHEADERTYPE*);
	OMX_BOOL RemoveBuffer(OMX_BUFFERHEADERTYPE*);
	
	void FlushHeaders();
	void SetConfigManager(COmxILTestMD5SinkConfigManager* aConfigManager);
		
protected:
	void RunL();
	void DoCancel();
	
private:
	CMD5Active(MOmxILCallbackNotificationIf& aCallback);
	void ConstructL();
	
	TBool RemoveFromQueueL(RMsgQueue<OMX_BUFFERHEADERTYPE*>& aQueue, OMX_BUFFERHEADERTYPE* aBufferHeader);

	COmxILTestMD5SinkConfigManager* iConfigManager;
	RMsgQueue<OMX_BUFFERHEADERTYPE*> iBuffers;
	MOmxILCallbackNotificationIf& iCallback;
	CMD5* iMD5;
	};

/*
 * Dependant on whether the client has an Active Scheduler or not the active objects may be running in a 
 * different thread context to that of the caller, in which case for flush to work it needs to run in this
 * context to ensure we don't complete while CMD5Active::RunL() is executing concurrently which would 
 * fail the conformance suite and the spec. because we complete the flush call yet still own a buffer.
 */
class CFlushActive : public CActive
    {
public:
    static CFlushActive* NewL(CMD5Active& aBufferHandler);
    ~CFlushActive();
    
    void Flush();
    
protected:
    CFlushActive(CMD5Active& aBufferHandler);
    void ConstructL();
    
    void RunL();
    void DoCancel();
    
private:
    CMD5Active& iBufferHandler;
    RSemaphore iWaitSemaphore;
    RThread iRunLContext;
    };

#endif //COMXILTESTMD5SINKPROCESSINGFUNCTION_H