/*

* 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 C3GPMUXER_H

#define C3GPMUXER_H

#include <e32base.h>

#include <e32std.h>

#include <f32file.h>

#include <e32msgqueue.h>

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

#include <c3gplibrary.h>

#include "comxil3gpmuxer.h"

#include "endwaitao.h"

class MOmxILCallbackNotificationIf;

NONSHARABLE_CLASS(C3GPMuxer) : public CActive

	{

	friend class C3GPMuxerWriterThreadObserver;

public:	

	static C3GPMuxer* NewL(MOmxILCallbackNotificationIf& aCallbacks);

	~C3GPMuxer();

	void ProcessThisBufferL(OMX_BUFFERHEADERTYPE* aBufferHeader, TUint32 aPortIndex);

	void FlushBuffers(TUint32 aPortIndex);

	TBool RemoveBuffer(OMX_BUFFERHEADERTYPE* aBufferHeader);

	void SetFilename(const HBufC* aFilename);

	void SetAudioVideoProperties(OMX_U32& aFrameWidth, OMX_U32& aFrameHeight, 

									OMX_U32& aFramerate, OMX_U32& aBitRate, OMX_U32& aAudioFramerate);

	void StartL(TBool aAudioPortEnabled, TBool aVideoPortEnabled);

	void Pause();

	TBool IsMuxerInvalid() const;

	void HandleError(TInt aError);

	OMX_ERRORTYPE SymbianErrorToOmx(TInt aError);

protected:

	void RunL();	

	void RunAudioVideoL();

	void RunAudioL();

	void RunVideoL();

	void DoCancel();

private:

	C3GPMuxer(MOmxILCallbackNotificationIf& aCallbacks);

	void ConstructL();

	void OpenComposerL();

	void WriteVideoBufferL();

	void WriteAudioBuffer();

	void DoFlushBuffers(TUint32 aPortIndex);

	void ReturnBuffer(OMX_BUFFERHEADERTYPE* aBuffer, TUint32 aPortIndex);

	static TInt ThreadEntryPoint(TAny* aPtr);

	void RunThreadL();

	TBool RemoveFromQueue(RMsgQueue<OMX_BUFFERHEADERTYPE*>& aQueue, OMX_BUFFERHEADERTYPE* aBufferHeader);

	void CalculateVideoTimeScale(OMX_U32& aFramerate);

	TInt CalculateNextFrameDuration();

	TInt CalculateNextFrameDurationPartial(TBool aFrameWritten);

private:

	MOmxILCallbackNotificationIf& iCallbacks;

	C3GPCompose* iComposer;

	const HBufC* iFilename;  // Not owned by this class

	TSize iVideoSize;

	TInt iVideoTimeScale;

	TInt iDefaultVideoFrameDuration;

	TUint iBitRate;

	TBool iAudioPortEnabled;

	TBool iVideoPortEnabled;

	RMsgQueue<OMX_BUFFERHEADERTYPE*> iAudioQueue;

	RMsgQueue<OMX_BUFFERHEADERTYPE*> iVideoQueue;

	OMX_BUFFERHEADERTYPE* iAudioBuffer;	 

	OMX_BUFFERHEADERTYPE* iCurrentVideoBuffer;	 

	TBool iComposerOpened;

	TUint iAudioFrameDuration;

	RThread iThread;

	RMutex iQueMutex;	

	TBool iThreadRunning;

	CEndWaitAO* iEndWaitAO;

	RMsgQueue<OMX_BUFFERHEADERTYPE*> iRemoveQueue;

	TBool iPaused;

	TBool iMuxerInvalid;

	RBuf8 iPartialFrame;

	OMX_BUFFERHEADERTYPE* iNextVideoBuffer;	 

	TInt64 iVideoDuration;

	TUint iRemoveQueueLength;

	TBool iRemoveQueueNeedsReallocation;

	TBool iRequestOutstanding;

	};

#endif //C3GPMUXER_H