diff -r ae942d28ec0e -r 2455ef1f5bbc javauis/mmapi_akn/audiostreaming/src.emc/cmmastreamrequest.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/javauis/mmapi_akn/audiostreaming/src.emc/cmmastreamrequest.cpp Wed Sep 01 12:33:18 2010 +0100 @@ -0,0 +1,106 @@ +/* +* Copyright (c) 2002 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: Request used to write or read data +* +*/ + + +// INCLUDE FILES +#include +#include "cmmastreamrequest.h" +#include "mmmastreamrequestlistener.h" + +CMMAStreamRequest* CMMAStreamRequest::NewLC(MMMAStreamRequestListener* aListener) +{ + DEBUG("MMA::CMMAStreamRequest::NewLC +"); + CMMAStreamRequest* self = new(ELeave)CMMAStreamRequest(aListener); + CleanupStack::PushL(self); + self->ConstructL(); + DEBUG("MMA::CMMAStreamRequest::NewLC -"); + return self; +} + +CMMAStreamRequest::~CMMAStreamRequest() +{ + DEBUG("MMA::CMMAStreamRequest::~CMMAStreamRequest +"); + delete iData; + DEBUG("MMA::CMMAStreamRequest::~CMMAStreamRequest -"); +} + +TPtr8& CMMAStreamRequest::DataPtr() +{ + return iDataPtr; +} + +void CMMAStreamRequest::CompleteRead(TInt aError) +{ + DEBUG("MMA::CMMAStreamRequest::CompleteRead +"); + if (aError < KErrNone) + { + iListener->HandleError(this, aError); + } + else // OK + { + iListener->ReadComplete(this); + } + DEBUG("MMA::CMMAStreamRequest::CompleteRead -"); +} + +void CMMAStreamRequest::SetActive(TBool aActive) +{ + iActive = aActive; +} + +TBool CMMAStreamRequest::IsActive() +{ + return iActive; +} + +TPckgBuf< TInt >& CMMAStreamRequest::RequestBuffer() +{ + return iRequestBuffer; +} + +void CMMAStreamRequest::WriteRequestComplete(TInt Err) +{ + DEBUG("MMA::CMMAStreamRequest::WriteRequestComplete +"); + if (Err == KErrNone) + { + // data is processed, set ready for reuse + iDataPtr.SetLength(0); + iListener->WriteComplete(this); + } + else // error + { + iListener->HandleError(this, Err); + } + DEBUG("MMA::CMMAStreamRequest::WriteRequestComplete -"); +} + +CMMAStreamRequest::CMMAStreamRequest(MMMAStreamRequestListener* aListener): + iListener(aListener), + iDataPtr(NULL, 0),iActive(EFalse) +{ + //Do Nothing +} + +void CMMAStreamRequest::ConstructL() +{ + DEBUG("MMA::CMMAStreamRequest::ConstructL +"); + iData = HBufC8::NewL(KMMAStreamRequestBufferSize); + iDataPtr.Set(iData->Des()); + DEBUG("MMA::CMMAStreamRequest::ConstructL -"); +} + +// END OF FILE