--- a/persistentstorage/sqlite3api/TEST/t_sqliteapi.c Thu Aug 19 11:36:21 2010 +0300
+++ b/persistentstorage/sqlite3api/TEST/t_sqliteapi.c Tue Aug 31 16:57:14 2010 +0300
@@ -942,6 +942,8 @@
}
}
+ srand((unsigned)&ThreadFunc);
+
PrintS("Thread \"%s\" - begin\r\n", (char*)pname);
err = sqlite3_open(TheTestDbName, &db);
TEST2(err, SQLITE_OK);
@@ -949,6 +951,10 @@
while(records < KRecordsCount)
{
+ if((records % 10) == 0)
+ {
+ PrintSI("Thread \"%s\", %d records.\r\n", (char*)pname, records);
+ }
err = sqlite3_exec(db, "BEGIN", 0, 0, &errmsg);
if(err == SQLITE_OK)
{
@@ -966,7 +972,7 @@
if(err == SQLITE_OK)
{
TheInsertRecCnt[threadIdx] += KCommitRecordsCount;
- records += 2;
+ records += KCommitRecordsCount;
}
else if(err == SQLITE_BUSY)
{
@@ -974,11 +980,15 @@
(void)sqlite3_exec(db, "ROLLBACK", 0, 0, 0);
if(errmsg)
{
- PrintSI("Err msg: %s. Err: %d.\r\n", errmsg, err);
+ char fmt[100];
+ strcpy(fmt, "Thread \"");
+ strcat(fmt, (char*)pname);
+ strcat(fmt, "\". Err msg: %s. Err: %d.\r\n");
+ PrintSI(fmt, errmsg, err);
sqlite3_free(errmsg);
errmsg = 0;
}
- usleep(100);
+ usleep((rand() % 3000) + 500);
}
}
@@ -1347,6 +1357,7 @@
UNUSED_ARG(argc);
UNUSED_ARG(argv);
+ TestOpen("t_sqliteapi test");
TestTitle();
TestHeapMark();