// Copyright (c) 2006-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:

//

/**

 @file 

 @publishedAll

 @released

*/

#include <cntfldst.h>

#include "RandomBlobStep.h"

#include "PerformanceFunctionalityDefs.h"

const TInt KKByte = 1024;

_LIT(KRun1,"BlobTests");

_LIT(KRun2,"MaxBlob");

_LIT(KTest1, "Blobs tests");

_LIT(KTest2, "Max Blob size test");

#define KNumberOfContacts 10

CRandomBlobStep::CRandomBlobStep() : CPerformanceFunctionalityBase( KNumberOfContacts )

	{

	SetTestStepName(KRandomBlobStep);

	TTime time;

	time.UniversalTime();

	iSeed = time.Int64();

	}

TVerdict CRandomBlobStep::doTestStepL()

	{

	__UHEAP_MARK;

	InitializeL();

	_LIT(KDoStepPrint,"CRandomBlobStep::doTestStepL()");

	INFO_PRINTF1(KDoStepPrint);  //Block start 

	const TDesC &run = ConfigSection();

	if( run == KRun1 )

		{

		INFO_PRINTF1(KTest1);

		BlobTestL();

		}

	else if( run == KRun2 )

		{

		INFO_PRINTF1(KTest2);

		MaxBlobTestL();

		}

	else

		{

		MissingTestPanic();

		}

	Cleanup();

	__UHEAP_MARKEND;

	return TestStepResult();

	}

/**

creates a blob with the specified size and fills it with random values

*/

HBufC8 *CRandomBlobStep::RandomBlobLC(const TInt aSize)

	{

	HBufC8 *buf = HBufC8::NewLC( aSize );

	TPtr8 tptr8 = buf->Des();

	for( TInt i = 0; i < aSize; ++i)

		{

		tptr8.Append( TChar( static_cast<TUint>( Math::Rand(iSeed) % 256 ) ) );

		}

	return buf;

	}

/**

sets the value of all blobs in a contact (aCid) with aBuf

*/

void CRandomBlobStep::SetAllBlobsL(const TContactItemId aCid, const HBufC8 &aBuf)

	{

	OpenL( aCid );

	TInt length = iFields->Count();

	for( TInt i = 0; i < length; ++i )

		{

		if( (*iFields)[i].StorageType() == KStorageTypeStore )

			{

			(*iFields)[i].StoreStorage()->SetThingL(aBuf);

			}

		}

	CommitL( EFalse );

	}

/**

checks that all blobs in aCid match aBuf

*/

TBool CRandomBlobStep::CheckAllBlobsL(const TContactItemId aCid, const HBufC8 &aBuf)

	{

	TBool SingleTestResult 	= EFalse;

	TBool OverallTestResult = EFalse;

	ReadL( aCid );

	TInt length = iFields->Count();

	for( TInt i = 0; i < length; ++i )

		{

		if( (*iFields)[i].StorageType() == KStorageTypeStore )

			{

			TDesC8 *thething = (*iFields)[i].StoreStorage()->Thing();

			TESTPRINTI( SingleTestResult = ( thething != NULL ), i );

			OverallTestResult = SingleTestResult;

			TESTPRINTI( SingleTestResult = ( (*iFields)[i].StoreStorage()->Thing()->Compare(aBuf) == 0 ), i );

			OverallTestResult = OverallTestResult && SingleTestResult;

			}

		}

	CloseL( EFalse );

	return OverallTestResult;

	}

void CRandomBlobStep::BlobTestL()

	{

	TAutoClose< RPointerArray< HBufC8 > > blobs;

	//test for 0 bytes, empty descriptor fails

	blobs.iObj.AppendL( RandomBlobLC( 1 ) );//1 byte

	blobs.iObj.AppendL( RandomBlobLC( KKByte ) );//1 kbyte

	blobs.iObj.AppendL( RandomBlobLC( 10 * KKByte ) ); //10 kbytes

	blobs.iObj.AppendL( RandomBlobLC( 50 * KKByte ) ); //50 kbytes

	blobs.iObj.AppendL( RandomBlobLC( 100 * KKByte ) ); //100 kbytes

	TContactItemId cid = 0;

	TInt length = blobs.iObj.Count();

	TInt i = 0;

	iIterate->Reset();

	for(; i < length; ++i )

		{

		cid = iIterate->NextL();

		SetAllBlobsL( cid, *(blobs.iObj[i]) );

		}

	iIterate->Reset();

	for( i = 0; i < length; ++i )

		{

		cid = iIterate->NextL();

		TESTPRINTI( CheckAllBlobsL( cid, *(blobs.iObj[i]) ), i);

		}

	for( i = length - 1; i >= 0; --i )

		{

		CleanupStack::PopAndDestroy( blobs.iObj[i] );

		}

	}

//increments the size of blobs created by 1 kb until a failiure occurs

void CRandomBlobStep::MaxBlobTestL()

	{

	TBool SetSuccess = EFalse;

	HBufC8 *theblob = NULL;

	TContactItemId cid = iIterate->NextL();

	TInt i = 0;

	TInt err = KErrNone;

	for( i = 1; (i < KKByte); ++i )

		{

		theblob = RandomBlobLC( i * KKByte );

		TRAP( err, SetAllBlobsL( cid, *theblob ) );

		if( (KErrNone != err) &&  (KErrNoMemory != err) )

			{

			User::Leave( err );

			}

		else if( KErrNoMemory == err )

			{

			SetSuccess = EFalse;

			}

		else

			{

			TESTPRINTI( SetSuccess = CheckAllBlobsL( cid, *theblob ), i );

			}

		CleanupStack::PopAndDestroy( theblob );

		theblob = NULL;

		if( !SetSuccess )

			{

			break;

			}

		}

	_LIT(KMaxSizePrint,"Max size is %d KiloBytes");

	INFO_PRINTF2(KMaxSizePrint, SetSuccess ? i : --i);

	}