1 /*

     2 * Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).

     3 * All rights reserved.

     4 * This component and the accompanying materials are made available

     5 * under the terms of "Eclipse Public License v1.0"

     6 * which accompanies this distribution, and is available

     7 * at the URL "http://www.eclipse.org/legal/epl-v10.html".

     8 *

     9 * Initial Contributors:

    10 * Nokia Corporation - initial contribution.

    11 *

    12 * Contributors:

    13 *

    14 * Description:

    15 *

    16 */

    17 

    18 

    19 /**

    20 @file

    21 @internalComponent

    22 */

    23 

    24 #ifndef BUFFERCOPIER_H_

    25 #define BUFFERCOPIER_H_

    26 

    27 #include <e32base.h>

    28 #include <e32msgqueue.h>

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

    30 

    31 class MBufferCopierIf

    32 	{

    33 public:

    34 	/** Called when the buffer copier has transferred the data from an input buffer to an output buffer. */

    35 	virtual void MbcBufferCopied(OMX_BUFFERHEADERTYPE* aInBuffer, OMX_BUFFERHEADERTYPE* aOutBuffer) = 0;

    36 	/** Called when a buffer is flushed from the buffer copier. */

    37 	virtual void MbcBufferFlushed(OMX_BUFFERHEADERTYPE* aBuffer, OMX_DIRTYPE aDirection) = 0;

    38 	};

    39 

    40 class CBufferCopier : public CActive

    41 	{

    42 public:

    43 	static CBufferCopier* NewL(MBufferCopierIf& aCallback, TInt aMaxBuffers);

    44 	~CBufferCopier();

    45 	

    46 	void DeliverBuffer(OMX_BUFFERHEADERTYPE* aBuffer, OMX_DIRTYPE aDirection);

    47 	TBool RemoveBuffer(OMX_BUFFERHEADERTYPE* aBuffer, OMX_DIRTYPE aDirection);

    48 	void FlushBuffers(OMX_DIRTYPE aDirection);

    49 	

    50 protected:

    51 	void RunL();

    52 	void DoCancel();

    53 	

    54 private:

    55 	CBufferCopier(MBufferCopierIf& aCallback);

    56 	void ConstructL(TInt aMaxBuffers);

    57 	

    58 	void CopyBuffer(OMX_BUFFERHEADERTYPE* aInBuffer, OMX_BUFFERHEADERTYPE* aOutBuffer);

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

    60 

    61 	MBufferCopierIf& iCallback;

    62 	RMsgQueue<OMX_BUFFERHEADERTYPE*> iInQueue;

    63 	RMsgQueue<OMX_BUFFERHEADERTYPE*> iOutQueue;

    64 	RMsgQueue<OMX_BUFFERHEADERTYPE*> iRemoveQueue;

    65 	OMX_BUFFERHEADERTYPE* iInBuffer;

    66 	};

    67 

    68 #endif /*BUFFERCOPIER_H_*/