/*

* Copyright (c) 2008 - 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 C3GPDEMUXER_H

#define C3GPDEMUXER_H

#include <f32file.h>

#include <e32msgqueue.h>

#include <c3gplibrary.h>

#include "comxil3gpdemuxer.h"

#include "tvideoformat.h"

#include "taudioformat.h"

class MOmxILCallbackNotificationIf;

NONSHARABLE_CLASS(C3GPDemuxer) : public CActive

								,public M3GPParseCallback

	{

public:	

	static C3GPDemuxer* NewL(MOmxILCallbackNotificationIf& aCallbacks);

	~C3GPDemuxer();

	OMX_ERRORTYPE AcquireResources(const TDesC& aFilename);

	void ReleaseResources();

	void Start();

	OMX_ERRORTYPE Stop();

	void Pause();

	TBool Invalid() const;

	void ProcessThisBufferL(OMX_BUFFERHEADERTYPE* aBufferHeader, TUint32 aPortIndex);

	void FlushBuffers(TUint32 aPortIndex);

	TBool RemoveBuffer(OMX_BUFFERHEADERTYPE* aBufferHeader, OMX_DIRTYPE aDirection);

	TBool GetVideoFormat(TSize& aFrameSize, TVideoFormat& aFormat) const;

	TBool GetAudioFormat(TAudioFormat& aFormat) const;

	OMX_ERRORTYPE GetVideoTimestamp(OMX_TICKS& aOmxTicks);

	OMX_ERRORTYPE Seek(const OMX_TICKS& aOmxTicks, OMX_TIME_SEEKMODETYPE aSeekModeType);

	OMX_ERRORTYPE DetectStreams();

	OMX_ERRORTYPE GetMetadataL(OMX_CONFIG_METADATAITEMTYPE* aMetadata);

protected:

	void RunL();

	void DoCancel();

private:

	typedef RPointerArray<OMX_BUFFERHEADERTYPE> RQueuedBuffers;

	class CPort : public CBase

		{

	public:

		static CPort* NewL(TInt aBufferCount);

		~CPort();

	private:	

		CPort();	

		void ConstructL(TInt aBufferCount);

	public:

		// Queue of buffers waiting to be processed. Buffers are not owned.

		RQueuedBuffers iBuffers;

		TBool iEOS;

		};

	class TBufferMessage

		{

	public:

		OMX_BUFFERHEADERTYPE* iBufferHeader;

		TUint32 iPortIndex;

		};

	enum TState

		{

		EStateWaitingToStart,

		EStateWaitingForBuffer,

		EStateFillingBuffer,

		EStateWaitingToSubmit

		};

private:

	C3GPDemuxer(MOmxILCallbackNotificationIf& aCallbacks);

	void ConstructL();

	void DoFlushBuffers(TUint32 aPortIndex);

	TBool ProcessBuffers();

	void DoProcessBuffer();

	void ProcessTimeBuffer();

	void FillAudioBuffer();

	void FillVideoBuffer();

	void FileReadComplete(TInt aNextFrameError, TUint32 aTimeStamp, TBool& aFirstFrame, TBool aKeyFrame);

	void SubmitBuffer();

	void CreateBufferQueueL();

	void DeleteBufferQueue();

	void HandleIfError(TInt aError);

	OMX_ERRORTYPE SymbianOSErrorToOmx(TInt aError) const;

	void ReceiveQueuedBuffers();

	void StartWaitingForBuffer();

	void CompleteSelf();

	TInt NextPort();

	TUint32 Pack32(const TUint8* aPtr);

	TInt SetPosition(TUint aTimePosition, TBool aKeyFrame);

	//M3GPParseCallback functions

	void AudioFramesAvailable(TInt aError, TUint aReturnedFrames, TUint aTimeStampInMs, TUint aTimeStampInTimescale);

	void VideoFrameAvailable(TInt aError, TBool aKeyFrame, TUint aTimeStampInMs, TUint aTimeStampInTimescale);

private:

	MOmxILCallbackNotificationIf& iCallbacks;

	TUint32 iCurrentPort;

	OMX_BUFFERHEADERTYPE* iCurrentBuffer;  // Not owned

	CPort* iPort[COmxIL3GPDemuxer::EPortIndexMax];

	C3GPParse* i3GPParser;

	TBool iVideoPropertiesRead;

	T3GPVideoType iVideoType;

	TVideoFormat iOmxVideoFormat;

	TUint32 iVideoWidth;

	TUint32 iVideoHeight;

	TBool iAudioPropertiesRead;

	T3GPAudioType iAudioType;

	TAudioFormat iOmxAudioFormat;

	TBool iInvalid;

	TBool iPaused;

	TState iState;

	TBool iVideoHeadersSent;

	TBool iAudioHeadersSent;

	TBool iFirstVideoFrame;

	TBool iFirstAudioFrame;

	RMsgQueue<TBufferMessage> iBufferQueue;

	TBool iBufferQueueCreated;

	TBool iWaitingOnBufferQueue;

	TPtr8 iAsyncBuf;

	TBool iParserOpened;

	TUint iStartTimePosition;

	TBool iStartKeyFrame;

	TUint iSeekPosition; // The requested seek time in ms.

	};

#endif //C3GPDEMUXER_H