/*

* 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

 *

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

#include <e32std.h>

#include <e32base.h>

#include <f32file.h>

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

 *

 * Local Includes

 *

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

#include "dataconsumer_memory.h"

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

 *

 * Definitions

 *

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

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

 *

 * CDataConsumerMemory - Construction

 *

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

CDataConsumerMemory *CDataConsumerMemory::NewL()

	{

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

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CDataConsumerMemory::CDataConsumerMemory() : CBase(),

	iDataBuffer( NULL )

	{

	;

	}

void CDataConsumerMemory::ConstructL( void ) 

	{

	iLock.CreateLocal( EOwnerProcess );

	}

CDataConsumerMemory::~CDataConsumerMemory( )

	{

	iLock.Wait( );

		{

		delete iDataBuffer;

		iDataBuffer = NULL;

		iLock.Close( );

		}

	}

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

 *

 * CDataConsumerMemory - Public interface

 *

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

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

 *

 * Delete

 *

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

void CDataConsumerMemory::Delete( void ) 

	{

	delete this;

	}

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

 *

 * GetTotalSize

 *

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

TInt CDataConsumerMemory::GetTotalSize( TInt &aTotalSize )

	{

	TInt	err = KErrNone;

	TInt	size = 0;

	iLock.Wait( );

		{

		size = iDataBuffer->Length( );

		aTotalSize = size;

		iLock.Signal( );

		}

	return ( err );

	}

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

 *

 * AddData

 *

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

TInt CDataConsumerMemory::AddData( const TDesC8 &aSource )

	{

	TInt	err = KErrNone;

	iLock.Wait( );

		{

		TInt currentLength = 0;

		if(iDataBuffer)

			{

			currentLength = iDataBuffer->Length( );

			}

		HBufC8 *currentDataBuffer = iDataBuffer;

		TInt srcLength = aSource.Length( );

		TInt length = currentLength + srcLength;

		iDataBuffer = HBufC8::New( length );

		if(iDataBuffer)

			{

				TPtr8	destPtr( iDataBuffer->Des( ) );

				if(currentDataBuffer)

					{

					destPtr.Copy( currentDataBuffer->Ptr( ),

										currentLength );

					delete currentDataBuffer;

					currentDataBuffer = NULL;

					}

				destPtr.Append( aSource.Ptr( ), srcLength );

			}

		else

			{

			err = KErrNoMemory;

			}

		iLock.Signal( );

		}

#ifdef _DEBUG

	{

	TInt totalSize = 0;

	GetTotalSize( totalSize );

	}

#endif

	return ( err );

	}

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

 *

 * GetData

 *

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

TInt CDataConsumerMemory::GetData( HBufC8 &aDestination )

	{

	TInt	err = KErrNone;

	iLock.Wait( );

		{

		TInt currentLength = 0;

		if(iDataBuffer)

			{

			currentLength = iDataBuffer->Length( );

			TPtr8 destPtr( aDestination.Des( ) );

			destPtr.Copy( iDataBuffer->Ptr( ), currentLength );

			}

		iLock.Signal( );

		}

	return ( err );

	}

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

 *

 * SaveData

 *

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

TInt CDataConsumerMemory::SaveData( const TDesC &filePath )

	{

	TInt	err = KErrNone;

	RFs		FsSession;

	err = FsSession.Connect( );

	if( err == KErrNone )

		{

		iLock.Wait( );

			{

			RFile	file;

			TInt	shareMode = EFileWrite | EFileStream | EFileShareExclusive;

			err = file.Open( FsSession, filePath, shareMode );

			if( err == KErrNotFound )

    			{

    			err = file.Create( FsSession, filePath, shareMode );

    			}

			if( err == KErrNone )

				{

				if( NULL != iDataBuffer )

					{

					err = file.Write( iDataBuffer->Des( ) );

					}

				file.Flush( );

				file.Close( );

				}

			iLock.Signal( );

			}

		FsSession.Close( );

		}

	return ( err );

	}

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

 *

 * operator const TDesC8&

 *

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

CDataConsumerMemory::operator const TDesC8&( void ) const

	{

	return ( *iDataBuffer );

	}