--- a/persistentstorage/sqlite3api/TEST/t_sqliteapi.c Wed Sep 01 12:39:58 2010 +0100
+++ b/persistentstorage/sqlite3api/TEST/t_sqliteapi.c Wed Sep 15 00:35:00 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);
}
}