--- /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;
+ }