--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/omxilcomp/omxilgeneric/filesource/inc/omxilfilesourceprocessingfunction.h Thu Sep 02 20:13:57 2010 +0300
@@ -0,0 +1,200 @@
+// 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
+ * @internalTechnology
+ */
+
+#ifndef OMXILFILESOURCEPROCESSINGFUNCTION_H
+#define OMXILFILESOURCEPROCESSINGFUNCTION_H
+
+#include <openmax/il/common/omxilprocessingfunction.h>
+#include <e32base.h>
+#include <e32msgqueue.h>
+#include <f32file.h>
+#include <openmax/il/khronos/v1_x/OMX_Component.h>
+
+class COmxILFileSourceProcessingFunction : public COmxILProcessingFunction
+ {
+public:
+ static COmxILFileSourceProcessingFunction* NewL(MOmxILCallbackNotificationIf& aCallbacks);
+ ~COmxILFileSourceProcessingFunction();
+
+ 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);
+
+ MOmxILCallbackNotificationIf& GetCallbacks();
+
+ /** can return NULL if parameter has not been set. */
+ const HBufC* FileName() const;
+ const HBufC8* Uri() const;
+
+private:
+ COmxILFileSourceProcessingFunction(MOmxILCallbackNotificationIf& aCallbacks);
+ void ConstructL();
+
+ void InitFileAndUriL();
+ OMX_ERRORTYPE SetFileName(const OMX_PARAM_CONTENTURITYPE* aContentUriType);
+
+private:
+ RPointerArray<OMX_BUFFERHEADERTYPE> iBuffersToFill;
+ OMX_STATETYPE iState;
+ HBufC8* ipUri;
+ HBufC* ipFileName;
+
+private:
+ class CPFHelper;
+ class CBufferArrivalHandler;
+
+ class CFileSourceAccess : public CActive
+ {
+ friend class CPFHelper;
+ public:
+ static CFileSourceAccess* NewL(COmxILFileSourceProcessingFunction& aParent);
+ ~CFileSourceAccess();
+
+ // from CActive
+ void RunL();
+ void DoCancel();
+
+ TInt Execute();
+ void Pause();
+ void Stop();
+ void Idle();
+
+ void CancelDataTransfer();
+
+ TInt ProcessNextBuffer();
+
+ private:
+ CFileSourceAccess(COmxILFileSourceProcessingFunction& aParent);
+ void ConstructL();
+
+ private:
+ COmxILFileSourceProcessingFunction& iParent;
+ OMX_BUFFERHEADERTYPE* iCurrentBuffer;
+
+ RFs iFs;
+ RFile iFileHandle;
+ TInt iBufferOffset;
+ TPtr8 iReadBuffer;
+ TBool iEOSFlag; // Notifies that end of file has been reached.
+ TInt iEOSBufferNotificationCount; // counts the number of responses to buffer notification when URI is unspecified
+
+ } *ipFileSourceAccess;
+
+ class CPFHelper : public CActive
+ {
+ public:
+ static CPFHelper* NewL(COmxILFileSourceProcessingFunction& aParent, CFileSourceAccess& aFileSourceAccess, CBufferArrivalHandler& aBufferArrivalHandler);
+ ~CPFHelper();
+
+ static OMX_ERRORTYPE ConvertSymbianErrorType(TInt aError);
+
+ // from CActive
+ void RunL();
+ void DoCancel();
+
+ TInt ExecuteAsync();
+ TInt StopAsync();
+ TInt PauseAsync();
+ void StopSync();
+ TInt IdleAsync();
+ TInt FlushIndication();
+ OMX_BOOL RemoveBufferIndication(OMX_BUFFERHEADERTYPE* apBufferHeader);
+
+ enum TMessageType
+ {
+ EExecuteCommand,
+ EStopCommand,
+ EPauseCommand,
+ ECancelCommand,
+ EIdleCommand,
+ EFlushCommand,
+ ERemoveBufferCommand
+ };
+
+ class TProcMessage
+ {
+ public:
+ TMessageType iType;
+ TAny* iPtr;
+ };
+
+ class TBufferRemovalArgs
+ {
+ public:
+ OMX_BUFFERHEADERTYPE* ipHeader; // Input parameter. Not owned
+ OMX_BOOL* iHdrRemoved; // Return parameter. Not owned
+ };
+
+ RMsgQueue<TProcMessage> iMsgQueue;
+
+ private:
+ CPFHelper(COmxILFileSourceProcessingFunction& aParent, CFileSourceAccess& aFileSourceAccess,CBufferArrivalHandler& aBufferArrivalHandler);
+ void ConstructL();
+
+ TInt ProcessQueue();
+ void PerformFlush();
+ OMX_BOOL PerformBufferRemoval(OMX_BUFFERHEADERTYPE* apBufferHeader);
+
+ private:
+ COmxILFileSourceProcessingFunction& iParent;
+ CFileSourceAccess& iFileSourceAccess;
+ CBufferArrivalHandler& iBufferArrivalHandler;
+ RThread iRunLContext;
+ RSemaphore iWaitSemaphore;
+ } *ipPFHelper;
+
+ class CBufferArrivalHandler : public CActive
+ {
+ public:
+ static CBufferArrivalHandler* NewL(COmxILFileSourceProcessingFunction& aParent, CFileSourceAccess& aFileSourceAccess);
+ ~CBufferArrivalHandler();
+
+ TInt BufferIndication(OMX_BUFFERHEADERTYPE* apBufferHeader);
+ void FlushIndication();
+ OMX_BOOL RemoveBufferIndication(OMX_BUFFERHEADERTYPE* apBufferHeader);
+
+ // CActive
+ void RunL();
+ void DoCancel();
+
+ private:
+ CBufferArrivalHandler(COmxILFileSourceProcessingFunction& aParent, CFileSourceAccess& aFileSourceAccess);
+ void ConstructL();
+
+ private:
+ class TBufferIndicationMessage
+ {
+ public:
+ OMX_BUFFERHEADERTYPE* iBufferHdr; // Not owned
+ };
+
+ RMsgQueue<TBufferIndicationMessage> iMsgQueue;
+ COmxILFileSourceProcessingFunction& iParent;
+ CFileSourceAccess& iFileSourceAccess;
+ } *ipBufferArrivalHandler;
+ };
+
+#endif // OMXILFILESOURCEPROCESSINGFUNCTION_H
+