/*

* 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);

    }