diff -r 000000000000 -r 5d29cba61097 omxilvideocomps/omxil3gpdemuxer/src/comxil3gpdemuxerrequesthelper.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/omxilvideocomps/omxil3gpdemuxer/src/comxil3gpdemuxerrequesthelper.cpp	Fri Oct 08 22:09:17 2010 +0100
@@ -0,0 +1,233 @@
+/*
+* Copyright (c) 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
+*/
+
+#include "log.h"
+#include "comxil3gpdemuxerrequesthelper.h"
+#include "comxil3gpdemuxerprocessingfunction.h"
+#include "comxil3gpdemuxer.h"
+
+COmxIL3GPDemuxerRequestHelper* COmxIL3GPDemuxerRequestHelper::NewL(COmxILProcessingFunction* aProcessingFunction)
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::NewL"));
+
+    COmxIL3GPDemuxerRequestHelper* self = new (ELeave) COmxIL3GPDemuxerRequestHelper(aProcessingFunction);
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop(self);
+    return self;
+    }
+
+COmxIL3GPDemuxerRequestHelper::COmxIL3GPDemuxerRequestHelper(COmxILProcessingFunction* aProcessingFunction):
+    CActive(EPriorityStandard),
+    iProcessingFunction(aProcessingFunction),
+    iFunctionCode(EC3GPDemuxerFunctionCodeNone)
+    {
+    CActiveScheduler::Add(this);
+    }
+
+void COmxIL3GPDemuxerRequestHelper::ConstructL()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::ConstructL"));
+
+    RThread me;
+    iConstructionThreadId = me.Id();
+    
+    iStatus = KRequestPending;
+    SetActive();
+    }
+
+COmxIL3GPDemuxerRequestHelper::~COmxIL3GPDemuxerRequestHelper()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::~COmxIL3GPDemuxerRequestHelper"));
+    
+    Cancel(); // safe as takes place in core thread which has Active Scheduler running. 
+    }
+
+void COmxIL3GPDemuxerRequestHelper::RunL()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::RunL"));
+
+    __ASSERT_DEBUG(iStatus == KErrNone, User::Panic(_L("Demuxer COmxIL3GPDemuxerRequestHelper::RunL"), KErrUnknown));
+
+    iStatus = KRequestPending;
+    SetActive();
+    
+    // list of requests that need to be synchronised with AS
+    switch(iFunctionCode)
+        {
+        case EC3GPDemuxerFunctionCodeStateTransitionIndication:
+            DoStateTransitionIndication();
+            break;
+            
+        case EC3GPDemuxerFunctionCodeBufferFlushingIndication:
+            DoBufferFlushingIndication();
+            break;
+                    
+        case EC3GPDemuxerFunctionCodeBufferRemovalIndication:
+            DoBufferRemovalIndication();
+            break;
+                    
+        default:
+            // should never reach here
+            User::Panic(_L("COmxIL3GPDemuxerRequestHelper"), KErrArgument);
+        }
+  
+     TRequestStatus *status = iCallingStatus;
+     RThread callingThread;
+     callingThread.Open(iCallingThreadId);
+     callingThread.RequestComplete(status, KErrNone);
+     callingThread.Close();
+    }
+
+void COmxIL3GPDemuxerRequestHelper::DoCancel()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::DoCancel"));
+    
+    TRequestStatus* status = &iStatus;
+    User::RequestComplete(status, KErrCancel);
+    }
+
+OMX_ERRORTYPE COmxIL3GPDemuxerRequestHelper::StateTransitionIndication(TStateIndex aNewState)
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::StateTransitionIndication"));
+
+    iNewState = aNewState;
+    
+    RThread me;
+    if(me.Id() != iConstructionThreadId)
+        {
+        // in different thread to that which 'this' was constructed
+        iFunctionCode = EC3GPDemuxerFunctionCodeStateTransitionIndication;
+        DoRequest();
+        }
+    else
+        {
+        // in same thread to that which 'this' was constructed therefore
+        // active scheduler must exist and following call is safe
+        DoStateTransitionIndication();
+        }
+    
+    return iOMXError;
+    }
+
+OMX_ERRORTYPE COmxIL3GPDemuxerRequestHelper::BufferFlushingIndication(TUint32 aPortIndex, OMX_DIRTYPE aDirection)
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::BufferFlushingIndication"));
+    
+    iPortIndex = aPortIndex;
+    iDirection = aDirection;
+    
+    RThread me;
+    if(me.Id() != iConstructionThreadId)
+        {
+        // in different thread to that which 'this' was constructed
+        iFunctionCode = EC3GPDemuxerFunctionCodeBufferFlushingIndication;
+        DoRequest();
+        }
+    else
+        {
+        // in same thread to that which 'this' was constructed therefore
+        // active scheduler must exist and following call is safe
+        DoBufferFlushingIndication();
+        }
+    
+    return iOMXError;
+    }
+
+OMX_BOOL COmxIL3GPDemuxerRequestHelper::BufferRemovalIndication(OMX_BUFFERHEADERTYPE* apBufferHeader, OMX_DIRTYPE aDirection)
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::BufferRemovalIndication"));
+    
+    ipBufferHeader = apBufferHeader;
+    iDirection = aDirection;
+    
+    RThread me;
+    if(me.Id() != iConstructionThreadId)
+        {
+        // in different thread to that which 'this' was constructed
+        iFunctionCode = EC3GPDemuxerFunctionCodeBufferRemovalIndication;
+        DoRequest();
+        }
+    else
+        {
+        // in same thread to that which 'this' was constructed therefore
+        // active scheduler must exist and following call is safe
+        DoBufferRemovalIndication();
+        }
+    
+    return iOMXBool;
+    }
+
+void COmxIL3GPDemuxerRequestHelper::DoRequest()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::DoRequest"));
+    
+    RThread me;
+    iCallingThreadId = me.Id();
+    TRequestStatus requestStatus = KRequestPending;
+    iCallingStatus = &requestStatus;
+    
+    // send request to active scheduler thread
+    RThread schedulerThread;
+    schedulerThread.Open(iConstructionThreadId);
+    
+    TRequestStatus* schedulerRequest = &iStatus;
+    schedulerThread.RequestComplete(schedulerRequest, KErrNone);
+    schedulerThread.Close();
+    
+    // block until request completes
+    User::WaitForRequest(requestStatus);
+    
+    iFunctionCode = EC3GPDemuxerFunctionCodeNone;
+    }
+
+void COmxIL3GPDemuxerRequestHelper::DoStateTransitionIndication()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::DoStateTransitionIndication"));
+
+    COmxIL3GPDemuxerProcessingFunction* processingFunction = 
+             dynamic_cast<COmxIL3GPDemuxerProcessingFunction*>(iProcessingFunction);
+    
+    iOMXError = processingFunction->DoStateTransitionIndication(iNewState);
+    }
+
+void COmxIL3GPDemuxerRequestHelper::DoBufferFlushingIndication()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::DoBufferFlushingIndication"));
+    
+    COmxIL3GPDemuxerProcessingFunction* processingFunction = 
+             dynamic_cast<COmxIL3GPDemuxerProcessingFunction*>(iProcessingFunction);
+    
+    iOMXError = processingFunction->DoBufferFlushingIndication(iPortIndex, iDirection);
+    }
+
+void COmxIL3GPDemuxerRequestHelper::DoBufferRemovalIndication()
+    {
+    DEBUG_PRINTF(_L8("COmxIL3GPDemuxerRequestHelper::DoBufferRemovalIndication"));
+    
+    COmxIL3GPDemuxerProcessingFunction* processingFunction = 
+             dynamic_cast<COmxIL3GPDemuxerProcessingFunction*>(iProcessingFunction);
+    
+    iOMXBool = processingFunction->DoBufferRemovalIndication(ipBufferHeader, iDirection);
+    }
+