/*

* Copyright (c) 2005-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: 

*

*/

 /*************************************************************************

 *

 * System Includes

 *

 *************************************************************************/

/*************************************************************************

 *

 * Local Includes

 *

 *************************************************************************/

#include "datasupplier_memory.h"

/*************************************************************************

 *

 * Definitions

 *

 *************************************************************************/

/*************************************************************************

 *

 * CDataSupplierMemory - Construction

 *

 *************************************************************************/

CDataSupplierMemory *CDataSupplierMemory::NewL()

	{

	CDataSupplierMemory *self = new (ELeave) CDataSupplierMemory();

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CDataSupplierMemory::CDataSupplierMemory() : CBase(),

	iDataBuffer( NULL ), iCurrentLocation( 0 )

	{

	;

	}

void CDataSupplierMemory::ConstructL( void ) 

	{

	iLock.CreateLocal( EOwnerProcess );

	}

CDataSupplierMemory::~CDataSupplierMemory( )

	{

	iLock.Wait( );

		{

		delete iDataBuffer;

		iDataBuffer = NULL;

		iCurrentLocation = 0;

		iLock.Close( );

		}

	}

/*************************************************************************

 *

 * CDataSupplierMemory - Public interface

 *

 *************************************************************************/

/*************************************************************************

 *

 * Delete

 *

 *************************************************************************/

void CDataSupplierMemory::Delete( void ) 

	{

	delete this;

	}

/*************************************************************************

 *

 * GetTotalSize

 *

 *************************************************************************/

TInt CDataSupplierMemory::GetTotalSize( TInt &aTotalSize )

	{

	TInt	err = KErrNone;

	TInt	size = 0;

	iLock.Wait( );

		{

		size = iDataBuffer->Length( );

		aTotalSize = size;

		iLock.Signal( );

		}

	return ( err );

	}

/*************************************************************************

 *

 * GetRemainingSize

 *

 *************************************************************************/

TInt CDataSupplierMemory::GetRemainingSize( TInt &aRemainingSize )

	{

	TInt	err = KErrNone;

	TInt	remaining = 0;

	iLock.Wait( );

		{

		TInt	totalSize =	0;

		err = GetTotalSize( totalSize );

		if( err == KErrNone )

			{

			remaining = totalSize - iCurrentLocation;

			aRemainingSize = remaining;

			}

		iLock.Signal( );

		}

	return ( err );

	}

/*************************************************************************

 *

 * SetData

 *

 *************************************************************************/

TInt CDataSupplierMemory::SetData( const TDesC8 &aSource )

	{

	TInt	err = KErrNone;

	iLock.Wait( );

		{

		delete iDataBuffer;

		iDataBuffer = NULL;

		TInt length = aSource.Length( );

		iDataBuffer = HBufC8::New( length );

		if(iDataBuffer)

			{

			*iDataBuffer = aSource;

			}

		else

			{

			err = KErrNoMemory;

			}

		iCurrentLocation = 0;

		iLock.Signal( );

		}

#ifdef _DEBUG

	{

	TInt totalSize = 0;

	GetTotalSize( totalSize );

	TInt remainingSize = 0;

	GetRemainingSize( remainingSize );

	}

#endif

	return ( err );

	}

/*************************************************************************

 *

 * GetData

 *

 *************************************************************************/

TInt CDataSupplierMemory::GetData( HBufC8 &aDestination, 

				TInt aLengthToCopy, TInt &aActuallyCopied )

	{

	TInt	err = KErrNone;

	iLock.Wait( );

		{

		TInt remainingSize = 0;

		err = GetRemainingSize( remainingSize );

		if( err == KErrNone )

			{

			TInt toCopy = Min( aLengthToCopy, remainingSize );

			TPtr8 destPtr( aDestination.Des( ) );

			destPtr.Copy( iDataBuffer->Ptr( ) + iCurrentLocation,

							toCopy );

			if( err == KErrNone )

				{

				iCurrentLocation += toCopy;

				aActuallyCopied = toCopy;

				}

			}

		iLock.Signal( );

		}

	return ( err );

	}