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

 //

 #include <e32test.h>

 #include <e32uid.h>

 #include <f32file.h>

 #include <e32math.h>

 #include <sqlite3.h>

 #include "t_sqlitewsd.h"

 void DoInserts(TInt aProcId, TInt aRecId1, TInt aRecId2)

 	{

 	TEST(TheDb != 0);

 	TTime now;

 	now.UniversalTime();

 	TInt64 seed = now.Int64();

 	const TInt KMaxFailingAllocationNo = 20;

 	TInt lockcnt = 0;

 	for(TInt recno=0;recno<KTestRecordCnt;)

 		{

 		//Insert record 1 under OOM simulation

 		TInt failingAllocationNo = Math::Rand(seed) % (KMaxFailingAllocationNo + 1);

 		__UHEAP_SETFAIL(RHeap::EDeterministic, failingAllocationNo );

 		TBuf8<100> sql;

 		sql.Format(_L8("INSERT INTO A VALUES(%d)"), aRecId1);

 		TInt err = sqlite3_exec(TheDb, (const char*)sql.PtrZ(), 0, 0, 0);

 		__UHEAP_SETFAIL(RHeap::ENone, 0);	

 		TEST(err == SQLITE_NOMEM || err == SQLITE_BUSY || err == SQLITE_OK);

 		if(err == SQLITE_BUSY)

 			{

 			++lockcnt;

 			User::After(1);

 			continue;	

 			}

 		else if(err == SQLITE_OK)

 			{

 			++recno;

 			if((recno % 100) == 0)

 				{

 				RDebug::Print(_L("Process %d: %d records inserted.\r\n"), aProcId, recno);	

 				}

 			continue;	

 			}

 		//Insert record 2

 		sql.Format(_L8("INSERT INTO A VALUES(%d)"), aRecId2);

 		err = sqlite3_exec(TheDb, (const char*)sql.PtrZ(), 0, 0, 0);

 		TEST(err == SQLITE_BUSY || err == SQLITE_OK);

 		if(err == SQLITE_BUSY)

 			{

 			++lockcnt;

 			User::After(1);

 			continue;	

 			}

 		//SQLITE_OK case

 		++recno;

 		if((recno % 100) == 0)

 			{

 			RDebug::Print(_L("Process %d: %d records inserted.\r\n"), aProcId, recno);	

 			}

 		}

 	RDebug::Print(_L("Process %d inserted %d records. %d locks occured.\r\n"), aProcId, KTestRecordCnt, lockcnt);

 	}