/*

* Copyright (c) 2005 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:  Implementation of Stream Source Reader active object.

*

*/

// INCLUDE FILES

#ifdef _DEBUG

#include 	<e32svr.h>

#endif

#include "ReadRequest.h"

#include <mmfdatasource.h>

#include <mmfdatasink.h>

// ============================ MEMBER FUNCTIONS ===============================

// -----------------------------------------------------------------------------

// CReadRequest::CReadRequest

// C++ default constructor can NOT contain any code, that

// might leave.

// -----------------------------------------------------------------------------

//

CReadRequest::CReadRequest(

	CS60StreamingSource& aCallback,

	CMMFBuffer* aBuffer,

	MDataSink* aConsumer )

    :   CActive(CActive::EPriorityStandard),

    	iCallback(aCallback),

    	iBuffer(aBuffer),

    	iConsumer(aConsumer)

    {

    }

// -----------------------------------------------------------------------------

// CReadRequest::ConstructL

// Symbian 2nd phase constructor can leave.

// -----------------------------------------------------------------------------

//

void CReadRequest::ConstructL()

    {

    CActiveScheduler::Add(this);

	}

// -----------------------------------------------------------------------------

// CReadRequest::NewL

// Two-phased constructor.

// -----------------------------------------------------------------------------

//

CReadRequest* CReadRequest::NewL(

	CS60StreamingSource& aCallback,

	CMMFBuffer* aBuffer,

	MDataSink* aConsumer )

    {

    CReadRequest* self = new(ELeave) CReadRequest(aCallback, aBuffer, aConsumer);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

// -----------------------------------------------------------------------------

// CReadRequest::~CReadRequest

// Destructor

// -----------------------------------------------------------------------------

//

CReadRequest::~CReadRequest()

    {

    // We should not have to cancel the outstanding request because the message

    // handler will complete our request with KErrCancel in its destructor.

    Cancel();

    }

// -----------------------------------------------------------------------------

// CReadRequest::HandleRequest

// -----------------------------------------------------------------------------

//

void CReadRequest::HandleRequest()

    {

	if (!IsActive())

		{

		TRequestStatus* s = &iStatus;

		SetActive();

		User::RequestComplete(s, KErrNone);

		}

    }

// -----------------------------------------------------------------------------

// CReadRequest::RunL

// Invoke by the active scheduler when a request completes -- the buffer has been

// processed.

// -----------------------------------------------------------------------------

//

void CReadRequest::RunL()

    {

#ifdef _DEBUG

    RDebug::Print(_L("CReadRequest::RunL()\n"));

#endif

	iCallback.HandleFillBuffer(iBuffer, iConsumer);

    }

// -----------------------------------------------------------------------------

// CReadRequest::DoCancel

// Cancels the current and any on going requests/tasks.

// -----------------------------------------------------------------------------

//

void CReadRequest::DoCancel()

    {

#ifdef _DEBUG

    RDebug::Print(_L("CReadRequest::DoCancel()\n"));

#endif

    }

// End of file