diff -r 000000000000 -r 08ec8eefde2f persistentstorage/sqlite3api/TEST/t_sqlitewsd.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/persistentstorage/sqlite3api/TEST/t_sqlitewsd.cpp	Fri Jan 22 11:06:30 2010 +0200
@@ -0,0 +1,219 @@
+// Copyright (c) 2007-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"
+
+#include <spawn.h>
+#include <sys/wait.h>
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+static RTest	TheTest(_L("t_sqlitewsd test"));
+static RFs		TheFs;
+
+static pid_t	TheKSqliteWsdProc2Pid = 0;
+const char* 	KSqliteWsdProc2Name = "z:\\sys\\bin\\t_sqlitewsd2.exe";
+
+const char* KTestDir = "c:\\test\\";
+const char* KTestDb  = "c:\\test\\t_sqlitewsd.db";
+
+sqlite3* TheDb = 0;
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+static void DestroyTestEnv()
+	{
+	if(TheDb)
+		{
+		(void)sqlite3_close(TheDb);
+		TheDb = 0;
+		}
+	if(TheFs.Handle() != KNullHandle)
+		{
+		TFileName fname;
+		fname.Copy(TPtrC8((const TUint8*)KTestDb));
+		(void)TheFs.Delete(fname);
+		}
+	TheFs.Close();
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+//Test macros and functions
+void Check(TInt aValue, TInt aLine)
+	{
+	if(!aValue)
+		{
+		DestroyTestEnv();
+		TheTest(EFalse, aLine);
+		}
+	}
+	
+void Check(TInt aValue, TInt aExpected, TInt aLine)
+	{
+	if(aValue != aExpected)
+		{
+		RDebug::Print(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
+		const char* errMsg = sqlite3_errmsg(TheDb);
+		if(errMsg)
+			{
+			TBuf<200> msgBuf;
+			msgBuf.Copy(TPtrC8((const TUint8*)errMsg));
+			RDebug::Print(_L("*** SQLITE error msg: \"%S\".\r\n"), &msgBuf);
+			}
+		DestroyTestEnv();
+		TheTest(EFalse, aLine);
+		}
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+static void CreateTestEnv()
+    {
+	TInt err = TheFs.Connect();
+	TEST2(err, KErrNone);
+
+    TFileName testDir;
+    testDir.Copy(TPtrC8((const TUint8*)KTestDir));
+	err = TheFs.MkDir(testDir);
+	TEST(err == KErrNone || err == KErrAlreadyExists);
+
+	TFileName fname;
+	fname.Copy(TPtrC8((const TUint8*)KTestDb));
+	(void)TheFs.Delete(fname);
+
+	err = sqlite3_open(KTestDb, &TheDb);
+	TEST2(err, SQLITE_OK);
+	TEST(TheDb != 0);
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+static void CreateDb()
+	{
+	TEST(TheDb != 0);
+	TInt err = sqlite3_exec(TheDb, "CREATE TABLE A(F1 INTEGER)", 0, 0, 0);
+	TEST2(err, SQLITE_OK);
+	}
+
+static void RunSqliteWsd2()
+	{
+	TInt err = posix_spawn(&TheKSqliteWsdProc2Pid, KSqliteWsdProc2Name, 0, 0, 0, 0);
+	TEST2(err, 0);
+	}
+	
+static void DestroySqliteWsd2()
+	{
+	(void)waitpid(TheKSqliteWsdProc2Pid, 0, 0);
+	}
+
+void DoVerify()
+	{
+	sqlite3_stmt* stmt = 0;
+  	const char* tail = 0;
+	TInt err = sqlite3_prepare(TheDb, "SELECT * FROM A", -1, &stmt, &tail);
+	TEST2(err, SQLITE_OK);
+	TEST(!tail || tail[0] == 0);
+	TInt proc1Id1recCnt = 0;
+	TInt proc1Id2recCnt = 0;
+	TInt proc2Id1recCnt = 0;
+	TInt proc2Id2recCnt = 0;
+	while((err = sqlite3_step(stmt)) == SQLITE_ROW)
+		{
+		TInt val = sqlite3_column_int(stmt, 0);
+		switch(val)
+			{
+			case KWsdProc1RecId1: 
+				++proc1Id1recCnt;
+				break;
+			case KWsdProc1RecId2: 
+				++proc1Id2recCnt;
+				break;
+			case KWsdProc2RecId1: 
+				++proc2Id1recCnt;
+				break;
+			case KWsdProc2RecId2: 
+				++proc2Id2recCnt;
+				break;
+			default:
+				TEST(0);
+				break;
+			}
+		}
+	sqlite3_finalize(stmt);
+	TEST2(err, SQLITE_DONE);
+	TEST2((proc1Id1recCnt + proc1Id2recCnt), KTestRecordCnt);
+	TEST2((proc2Id1recCnt + proc2Id2recCnt), KTestRecordCnt);
+	}
+
+/**
+@SYMTestCaseID			SYSLIB-SQLITE3-UT-4026
+@SYMTestCaseDesc		SQLITE OS porting layer - WSD test.
+						The test verifies that the WSD object allocation and access	inside the OS porting layer 
+						works properly on both the emulator and the hardware.
+						The test runs two separate processes. Each process establishes a connection to the same
+						database and inserts 500 records simultaneously.
+						During the inserts, the SQLITE OS porting layer will use a mutex to synchronise the database
+						operations between the two processes. If the WSD implementation does not work properly,
+						then the mutex object won't be allocated per process and the same mutex instance will be used by
+						both processes on the emulator. This will lead to panics/asserts inside the OS porting layer.
+						The number of the inserted record and record ids is verified at the end of the test.
+@SYMTestPriority		High
+@SYMTestActions			SQLITE OS porting layer - WSD test.
+@SYMTestExpectedResults Test must not fail
+@SYMREQ					REQ8782
+*/
+static void DoWsdTests()
+	{
+	TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-SQLITE3-UT-4026 Create the test database "));
+	CreateDb();
+	TheTest.Next(_L("Run the second process: t_sqlitewsd2"));
+	RunSqliteWsd2();
+	TheTest.Next(_L("Insert the records"));
+	DoInserts(KWsdProc1Id, KWsdProc1RecId1, KWsdProc1RecId2);
+	DestroySqliteWsd2();
+	TheTest.Next(_L("Verify the inserted records"));
+	DoVerify();
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+TInt E32Main()
+	{
+	TheTest.Title();
+	
+	CTrapCleanup* tc = CTrapCleanup::New();
+	
+	__UHEAP_MARK;
+	
+	CreateTestEnv();
+	DoWsdTests();
+	DestroyTestEnv();
+	
+	__UHEAP_MARKEND;
+	
+	TheTest.End();
+	TheTest.Close();
+	
+	delete tc;
+	
+	User::Heap().Check();
+	return KErrNone;
+	}