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

#include <e32base.h>

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

class MASBreakCallback
	{
public:
	virtual void AllComponentsEOS() = 0;
	virtual void AllComponentsTransitioned(OMX_STATETYPE aNewState,
			                               OMX_STATETYPE aOldState) = 0;
	virtual void EventReceived(OMX_COMPONENTTYPE* aComponent, OMX_EVENTTYPE aEvent, TUint32 aData1, TUint32 aData2, TAny* aEventData) = 0;
	virtual void ComponentTransitioned(OMX_STATETYPE aNewState,
				                   OMX_STATETYPE aOldState) = 0;
	virtual void BufferDone(OMX_COMPONENTTYPE* aComp, OMX_BUFFERHEADERTYPE* aBufHdr, TBool aSource) = 0;
	};

class RASBreakEventHandler
	{
public:
	RASBreakEventHandler(MASBreakCallback& aHandler);
	TInt Create();
	void Close();
	
	void InstallIntoL(OMX_COMPONENTTYPE* aComponent, const TDesC& aName);
	void AddComponentL(OMX_COMPONENTTYPE* aComponent, const TDesC& aName);
	
	void AwaitTransition(OMX_STATETYPE aNewState, OMX_STATETYPE aOldState);
	void AwaitEOS();
	void AwaitEOS(OMX_COMPONENTTYPE* aComponent);
	void AwaitSingleTransition(OMX_COMPONENTTYPE* aComponent, OMX_STATETYPE aNewState, OMX_STATETYPE aOldState);
	
	OMX_CALLBACKTYPE& CallbackStruct();
	
	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);

private:	
	void StateSet(OMX_COMPONENTTYPE* aComponent, OMX_STATETYPE aState);
	void EndOfStream(OMX_COMPONENTTYPE* aComponent);
	OMX_ERRORTYPE DoBufferDone(OMX_COMPONENTTYPE* aComponent,
	                           OMX_BUFFERHEADERTYPE* aBufHdr,
	                           TBool aSource);
	OMX_ERRORTYPE DoEventHandler(OMX_COMPONENTTYPE* aComponent,
	                          OMX_EVENTTYPE aEvent,
	                          OMX_U32 aData1,
	                          OMX_U32 aData2,
	                          OMX_PTR aEventData);
	const TDesC* ComponentName(OMX_COMPONENTTYPE* aComponent);
	
	OMX_CALLBACKTYPE iOmxCallbackType;

	OMX_STATETYPE iNewState;
	OMX_STATETYPE iOldState;
	
	enum TMode { EIdle, EAwaitingTransition, EAwaitingEOS, EAwaitingSingleTransition };
	MASBreakCallback& iHandler;
	
	class TComponentInfo
		{
	public:
		static TBool CompareHandle(OMX_COMPONENTTYPE* const * a1, const TComponentInfo& a2)
			{
			return (*a1) == a2.iHandle;
			}
		
		OMX_COMPONENTTYPE* iHandle;
		TBool iComplete;
		HBufC* iName;
		};
		
	RArray<TComponentInfo> iComponents;
	TInt iCounter;
	TMode iMode;
	RMutex iMutex;
	
	OMX_COMPONENTTYPE* iEOSComponent;	// from which component we expect EOS. all components if NULL
	};
	
#endif /*ASBREAKEVENTHANDLER_H_*/