Add parameter checking to dtmbench

knizhnik · knizhnik · commit 3c5b2fb0e37e · 2015-11-11T12:31:12.000+03:00
diff --git a/contrib/pg_dtm/tests/dtmbench.cpp b/contrib/pg_dtm/tests/dtmbench.cpp
@@ -253,6 +253,10 @@ int main (int argc, char* argv[])
                "\t-i\tinitialize datanase\n");
         return 1;
     }
+    if (cfg.connections.size() < 2) { 
+        printf("At least two connections has to be specified\n");
+        return 1;
+    }
     if (initialize) { 
         initializeDatabase();
     }
@@ -287,6 +291,10 @@ int main (int argc, char* argv[])
     }
  
     time_t elapsed = getCurrentTime() - start;
-    printf("TPS(updates)=%f, TPS(selects)=%f, aborts=%ld\n", (double)(nWrites*USEC)/elapsed, (double)(nReads*USEC)/elapsed, nAborts);
+    if (elapsed == 0) { 
+        printf("Test is completed too fast\n");
+    } else { 
+        printf("TPS(updates)=%f, TPS(selects)=%f, aborts=%ld\n", (double)(nWrites*USEC)/elapsed, (double)(nReads*USEC)/elapsed, nAborts);
+    }
     return 0;
 }

Original file line number	Diff line number	Diff line change
`@@ -253,6 +253,10 @@ int main (int argc, char* argv[])`
`253`	`253`	`"\t-i\tinitialize datanase\n");`
`254`	`254`	`return 1;`
`255`	`255`	`}`
	`256`	`+ if (cfg.connections.size() < 2) {`
	`257`	`+ printf("At least two connections has to be specified\n");`
	`258`	`+ return 1;`
	`259`	`+ }`
`256`	`260`	`if (initialize) {`
`257`	`261`	`initializeDatabase();`
`258`	`262`	`}`
`@@ -287,6 +291,10 @@ int main (int argc, char* argv[])`
`287`	`291`	`}`
`288`	`292`
`289`	`293`	`time_t elapsed = getCurrentTime() - start;`
`290`		`- printf("TPS(updates)=%f, TPS(selects)=%f, aborts=%ld\n", (double)(nWritesUSEC)/elapsed, (double)(nReadsUSEC)/elapsed, nAborts);`
	`294`	`+ if (elapsed == 0) {`
	`295`	`+ printf("Test is completed too fast\n");`
	`296`	`+ } else {`
	`297`	`+ printf("TPS(updates)=%f, TPS(selects)=%f, aborts=%ld\n", (double)(nWritesUSEC)/elapsed, (double)(nReadsUSEC)/elapsed, nAborts);`
	`298`	`+ }`
`291`	`299`	`return 0;`
`292`	`300`	`}`