/*

* 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 the audio buffer write request active object.

*

*/

// INCLUDE FILES

#ifdef _DEBUG

#include 	<e32svr.h>

#endif

#include "S60StreamingSourceCustomCommands.h"

#include "WriteRequest.h"

#include "S60SourceEventDispatcher.h"

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

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

// CWriteRequest::CWriteRequest

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

// might leave.

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

//

CWriteRequest::CWriteRequest(

	TMMFMessageDestinationPckg aMessageHandler,

	RMMFController& aController,

	CS60SourceEventDispatcher& aCallback )

    :   CActive(CActive::EPriorityStandard),

    	iController(aController),

    	iMessageHandler(aMessageHandler),

    	iCallback(aCallback),

    	iClientBuffer(NULL),

    	iProcessed(EFalse),

    	iFree(ETrue)

    {

    }

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

// CWriteRequest::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CWriteRequest::ConstructL()

    {

    CActiveScheduler::Add(this);

	}

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

// CWriteRequest::NewL

// Two-phased constructor.

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

//

CWriteRequest* CWriteRequest::NewL(

	TMMFMessageDestinationPckg aMessageHandler,

	RMMFController& aController,

	CS60SourceEventDispatcher& aCallback )

    {

    CWriteRequest* self = new(ELeave) CWriteRequest(aMessageHandler, aController, aCallback);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

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

// CWriteRequest::~CWriteRequest

// Destructor

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

//

CWriteRequest::~CWriteRequest()

    {

#ifdef _DEBUG

    RDebug::Print(_L("CWriteRequest::~CWriteRequest()\n"));

#endif

    Cancel();

    }

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

// CWriteRequest::WriteAudioData

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

//

void CWriteRequest::WriteAudioData(CClientAudioBuffer& aBuffer)

    {

	if( !IsActive() )

		{

		if( aBuffer.IsLastBuffer() )

			iLastBufferPckg() = 1;

		else

			iLastBufferPckg() = 0;

		iClientBuffer = &aBuffer;

    	iController.CustomCommandAsync(iMessageHandler, (TInt)EProcessBuffer, iClientBuffer->GetBufferPtr(), iLastBufferPckg, iStatus);

    	iProcessed = EFalse;

    	iFree = EFalse;

    	SetActive();

		}

    }

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

// CWriteRequest::IsFree

// Destructor

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

//

TBool CWriteRequest::IsFree()

    {

 	return iFree;

    }

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

// CWriteRequest::RunL

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

// processed.

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

//

void CWriteRequest::RunL()

    {

#ifdef _DEBUG

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

#endif

	if( iStatus == KErrNone )

		{

		iCallback.BufferProcessed(*iClientBuffer, KErrNone);

		iClientBuffer = NULL;

		iFree = ETrue;

		}

	if( iStatus == KErrCancel )

		{

		iCallback.BufferProcessed(*iClientBuffer, KErrCancel);

		iClientBuffer = NULL;

		iFree = ETrue;

		}

    }

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

// CWriteRequest::DoCancel

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

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

//

void CWriteRequest::DoCancel()

    {

#ifdef _DEBUG

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

#endif

	TRequestStatus* s = &iStatus;

	User::RequestComplete(s, KErrCancel);

    }

// End of file