diff -r 7d4490026038 -r 44f437012c90 persistentstorage/sql/TEST/t_sqlmulti.cpp --- a/persistentstorage/sql/TEST/t_sqlmulti.cpp Mon Sep 27 11:59:56 2010 +0100 +++ b/persistentstorage/sql/TEST/t_sqlmulti.cpp Tue Oct 19 16:26:13 2010 +0100 @@ -43,11 +43,11 @@ { RThread th; TName name = th.Name(); - RDebug::Print(_L("*** Thread %S, Line %d\r\n"), &name, aLine); + RDebug::Print(_L("*** Thread %S, Line %d. Expression evaluated to false\r\n"), &name, aLine); } else { - RDebug::Print(_L("*** Line %d\r\n"), aLine); + TheTest.Printf(_L("*** Line %d. Expression evaluated to false\r\n"), aLine); } TheTest(EFalse, aLine); } @@ -65,7 +65,7 @@ } else { - RDebug::Print(_L("*** Line %d, Expected error: %d, got: %d\r\n"), aLine, aExpected, aValue); + TheTest.Printf(_L("*** Line %d, Expected error: %d, got: %d\r\n"), aLine, aExpected, aValue); } TheTest(EFalse, aLine); } @@ -111,7 +111,7 @@ TEST2(err, KErrNone); //Create test database - RDebug::Print(_L("###Create test database\r\n")); + TheTest.Printf(_L("###Create test database\r\n")); _LIT8(KCreateSql, "CREATE TABLE A(Id INTEGER PRIMARY KEY AUTOINCREMENT, Data INTEGER)"); err = db1.Exec(KCreateSql); TEST(err >= 0); @@ -122,7 +122,7 @@ TEST2(err, KErrNone); //Insert some records using both connections - RDebug::Print(_L("###Insert some records\r\n")); + TheTest.Printf(_L("###Insert some records\r\n")); const TInt KRecNum = 100; _LIT8(KInsertSql, "INSERT INTO A(Data) VALUES("); for(TInt i=0;i= 0); @@ -283,7 +283,7 @@ TInt low = 1; TInt high = KRange; - RDebug::Print(_L("+++:MainThread: Test: thread count %d, records %d, trans type %d, isolation level: %S\r\n"), + TheTest.Printf(_L("+++:MainThread: Test: thread count %d, records %d, trans type %d, isolation level: %S\r\n"), KThreadCnt, KRange, transType, &KIsolationLevelName[isolLevel]); RThread thread[KThreadCnt]; @@ -320,7 +320,7 @@ } //Check that all records which are esupposed to be in the database, are there. - RDebug::Print(_L("+++:MainThread: Check that all records have been written\r\n")); + TheTest.Printf(_L("+++:MainThread: Check that all records have been written\r\n")); _LIT8(KSelectSql1, "SELECT COUNT(*) FROM A;"); RSqlStatement stmt; err = stmt.Prepare(db, KSelectSql1); @@ -332,7 +332,7 @@ stmt.Close(); //Check that all records have expected column values. - RDebug::Print(_L("+++:MainThread: Check that all records have expected column values\r\n")); + TheTest.Printf(_L("+++:MainThread: Check that all records have expected column values\r\n")); _LIT8(KSelectSql2, "SELECT * FROM A;"); err = stmt.Prepare(db, KSelectSql2); TEST2(err, KErrNone); @@ -346,7 +346,7 @@ stmt.Close(); //Prepare for the next test run - delete all records. - RDebug::Print(_L("+++:MainThread: Delete all records\r\n")); + TheTest.Printf(_L("+++:MainThread: Delete all records\r\n")); _LIT8(KDeleteSql, "DELETE FROM A"); err = db.Exec(KDeleteSql); TEST(err >= 0); @@ -354,7 +354,7 @@ }//end of "for(TInt transType=0;transType= 0); - RDebug::Print(_L("+++:MainThread: Insert one record in the table\r\n")); + TheTest.Printf(_L("+++:MainThread: Insert one record in the table\r\n")); _LIT8(KInsertSql, "INSERT INTO A(Id) VALUES("); TBuf8<64> sql(KInsertSql); sql.AppendNum((TInt64)KInitialValue); @@ -456,7 +456,7 @@ err = db.Exec(sql); TEST2(err, 1); - RDebug::Print(_L("+++:MainThread: Create the \"update\" thread\r\n")); + TheTest.Printf(_L("+++:MainThread: Create the \"update\" thread\r\n")); _LIT(KThreadName, "UpdTh"); RThread thread; TEST2(thread.Create(KThreadName, &UpdateThreadFunc, 0x2000, 0x1000, 0x10000, NULL, EOwnerThread), KErrNone); @@ -465,10 +465,10 @@ TEST2(status.Int(), KRequestPending); thread.Resume(); - RDebug::Print(_L("+++:MainThread: Wait for record update completion...\r\n")); + TheTest.Printf(_L("+++:MainThread: Wait for record update completion...\r\n")); MainThreadCrS.Wait(); - RDebug::Print(_L("+++:MainThread: Read the record and check the data...\r\n")); + TheTest.Printf(_L("+++:MainThread: Read the record and check the data...\r\n")); _LIT8(KSelectSql, "SELECT * FROM A"); RSqlStatement stmt; err = stmt.Prepare(db, KSelectSql); @@ -479,13 +479,13 @@ TEST(val == KUpdatedValue); stmt.Close(); - RDebug::Print(_L("+++:MainThread: Notify the update thread that it can rollback\r\n")); + TheTest.Printf(_L("+++:MainThread: Notify the update thread that it can rollback\r\n")); UpdateThreadCrS.Signal(); - RDebug::Print(_L("+++:MainThread: Wait for rollback completion...\r\n")); + TheTest.Printf(_L("+++:MainThread: Wait for rollback completion...\r\n")); MainThreadCrS.Wait(); - RDebug::Print(_L("+++:MainThread: Read the record and check the data...\r\n")); + TheTest.Printf(_L("+++:MainThread: Read the record and check the data...\r\n")); err = stmt.Prepare(db, KSelectSql); TEST2(err, KErrNone); err = stmt.Next(); @@ -498,10 +498,10 @@ thread.Close(); db.Close(); - RDebug::Print(_L("+++:MainThread: Delete the test database\r\n")); + TheTest.Printf(_L("+++:MainThread: Delete the test database\r\n")); (void)RSqlDatabase::Delete(KTestDbName1); - RDebug::Print(_L("+++:MainThread: Close critical sections\r\n")); + TheTest.Printf(_L("+++:MainThread: Close critical sections\r\n")); MainThreadCrS.Close(); UpdateThreadCrS.Close(); }