/*

* Copyright (c) 2010 Ixonos Plc.

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the "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:

* Ixonos Plc

*

* Description:  

* Base class for data processor objects.

*

*/

//  EXTERNAL RESOURCES  

//  Include Files  

#include "dataprocessor.h"

//  MEMBER FUNCTIONS

//=============================================================================

/*

-----------------------------------------------------------------------------

    CDataProcessor

    CDataProcessor()

    Standard C++ constructor

-----------------------------------------------------------------------------

*/

CDataProcessor::CDataProcessor(TInt aPriority)

    : CActive(aPriority)

{

}

/*

-----------------------------------------------------------------------------

    CDataProcessor

    ~CDataProcessor()

    Standard C++ destructor

-----------------------------------------------------------------------------

*/

CDataProcessor::~CDataProcessor()

{

    Cancel();

}

/*

-----------------------------------------------------------------------------

    CDataProcessor

    ConstructL()

    Standard Symbian OS second-phase constructor

-----------------------------------------------------------------------------

*/

void CDataProcessor::ConstructL()

{

    // Add to active scheduler and activate

    CActiveScheduler::Add(this);

    SetActive();

    iStatus = KRequestPending;

}

/*

-----------------------------------------------------------------------------

    CDataProcessor

    InputDataAvailable()

    Called by CActiveQueue when input data is available, simply signals the

    object

-----------------------------------------------------------------------------

*/

void CDataProcessor::InputDataAvailable(TAny* /*aUserPointer*/)

{

    if ( iStatus == KRequestPending )

    {

        TRequestStatus *status = &iStatus;

        User::RequestComplete(status, KErrNone);

    }

}

/*

-----------------------------------------------------------------------------

    CDataProcessor

    OutputSpaceAvailable()

    Called by CActiveQueue when output space is available, simply signals the

    object

-----------------------------------------------------------------------------

*/

void CDataProcessor::OutputSpaceAvailable(TAny* /*aUserPointer*/)

{

    if ( iStatus == KRequestPending )

    {

        TRequestStatus *status = &iStatus;

        User::RequestComplete(status, KErrNone);

    }

}

/*

-----------------------------------------------------------------------------

    CDataProcessor

    StreamEndReached()

    Called by CActiveQeueue after all data has been read from a queue where

    stream end has been signaled. Does nothing in this base class.

-----------------------------------------------------------------------------

*/

void CDataProcessor::StreamEndReached(TAny* /*aUserPointer*/)

{

}

/*

-----------------------------------------------------------------------------

    CDataProcessor

    DoCancel()

    Cancels the internal request.

-----------------------------------------------------------------------------

*/

void CDataProcessor::DoCancel()

{

    if ( iStatus == KRequestPending )

    {

        TRequestStatus *status = &iStatus;

        User::RequestComplete(status, KErrCancel);

    }

}

// End of File