Fix bugs in dtmbench

knizhnik · knizhnik · commit ed4f3e360000 · 2015-11-08T11:55:25.000+03:00
diff --git a/tests/dtmbench.cpp b/tests/dtmbench.cpp
@@ -196,7 +196,7 @@ void initializeDatabase()
         exec(txn, "create extension pg_dtm");
         exec(txn, "drop table if exists t");
         exec(txn, "create table t(u int primary key, v int)");
-        exec(txn, "insert into t (select generate_series(0,%d), %d)", cfg.nAccounts, 0);
+        exec(txn, "insert into t (select generate_series(0,%d), %d)", cfg.nAccounts-1, 0);
         txn.commit();
     }        
 }
@@ -264,7 +264,7 @@ int main (int argc, char* argv[])
 
     for (int i = 0; i < cfg.nReaders; i++) { 
         readers[i].wait();
-        nReads += writers[i].proceeded;
+        nReads += readers[i].proceeded;
     }
  
     time_t elapsed = getCurrentTime() - start;

Original file line number	Diff line number	Diff line change
`@@ -196,7 +196,7 @@ void initializeDatabase()`
`196`	`196`	`exec(txn, "create extension pg_dtm");`
`197`	`197`	`exec(txn, "drop table if exists t");`
`198`	`198`	`exec(txn, "create table t(u int primary key, v int)");`
`199`		`- exec(txn, "insert into t (select generate_series(0,%d), %d)", cfg.nAccounts, 0);`
	`199`	`+ exec(txn, "insert into t (select generate_series(0,%d), %d)", cfg.nAccounts-1, 0);`
`200`	`200`	`txn.commit();`
`201`	`201`	`}`
`202`	`202`	`}`
`@@ -264,7 +264,7 @@ int main (int argc, char* argv[])`
`264`	`264`
`265`	`265`	`for (int i = 0; i < cfg.nReaders; i++) {`
`266`	`266`	`readers[i].wait();`
`267`		`- nReads += writers[i].proceeded;`
	`267`	`+ nReads += readers[i].proceeded;`
`268`	`268`	`}`
`269`	`269`
`270`	`270`	`time_t elapsed = getCurrentTime() - start;`