Fix result graphs in case of DB stall

Emit an all-zero result set into the result.csv file once
per reportIntervalSecs. This ensures that the result data
aggregated for use in the report graphs isn't screwed up
when the DB system completely freezes for extended periods
of time.

Author: wieck

src/main/java/com/github/pgsqlio/benchmarksql/jtpcc/jTPCC.java

@@ -476,6 +476,7 @@ else if (iDBType.equals("babelfish"))
       this.scheduler.at(now + reportIntervalSecs * 1000, jTPCCScheduler.SCHED_REPORT,
           new jTPCCTData());
     }
+    this.scheduler.at(now + resultIntervalSecs * 1000, jTPCCScheduler.SCHED_DUMMY_RESULT, new jTPCCTData());
 
     try {
       scheduler_thread.join();

src/main/java/com/github/pgsqlio/benchmarksql/jtpcc/jTPCCResult.java

@@ -94,28 +94,31 @@ public void collect(jTPCCTData tdata) {
 
     long now = System.currentTimeMillis();
     if (now >= resultNextDue) {
-      long second = (resultNextDue - resultStartMS) / 1000;
-
-      for (int tt = 0; tt <= jTPCCTData.TT_DELIVERY_BG; tt++) {
-        jTPCC.csv_result_write(
-            jTPCCTData.trans_type_names[tt] + "," + second + "," + resCounter[tt].numTrans + ","
-                + resCounter[tt].sumLatencyMS + "," + resCounter[tt].minLatencyMS + ","
-                + resCounter[tt].maxLatencyMS + "," + resCounter[tt].sumDelayMS + ","
-                + resCounter[tt].minDelayMS + "," + resCounter[tt].maxDelayMS + "\n");
-
-        resCounter[tt].numTrans = 0;
-        resCounter[tt].sumLatencyMS = 0;
-        resCounter[tt].minLatencyMS = 0;
-        resCounter[tt].maxLatencyMS = 0;
-        resCounter[tt].sumDelayMS = 0;
-        resCounter[tt].minDelayMS = 0;
-        resCounter[tt].maxDelayMS = 0;
-      }
-
+      this.emit(now);
+    }
+  }
 
-      while (resultNextDue <= now)
-        resultNextDue += (jTPCC.resultIntervalSecs * 1000);
+  public void emit(long now) {
+    long second = (resultNextDue - resultStartMS) / 1000;
+
+    for (int tt = 0; tt <= jTPCCTData.TT_DELIVERY_BG; tt++) {
+      jTPCC.csv_result_write(
+          jTPCCTData.trans_type_names[tt] + "," + second + "," + resCounter[tt].numTrans + ","
+              + resCounter[tt].sumLatencyMS + "," + resCounter[tt].minLatencyMS + ","
+              + resCounter[tt].maxLatencyMS + "," + resCounter[tt].sumDelayMS + ","
+              + resCounter[tt].minDelayMS + "," + resCounter[tt].maxDelayMS + "\n");
+
+      resCounter[tt].numTrans = 0;
+      resCounter[tt].sumLatencyMS = 0;
+      resCounter[tt].minLatencyMS = 0;
+      resCounter[tt].maxLatencyMS = 0;
+      resCounter[tt].sumDelayMS = 0;
+      resCounter[tt].minDelayMS = 0;
+      resCounter[tt].maxDelayMS = 0;
     }
+
+    while (resultNextDue <= now)
+      resultNextDue += (jTPCC.resultIntervalSecs * 1000);
   }
 
   public void aggregate(jTPCCResult into) {

src/main/java/com/github/pgsqlio/benchmarksql/jtpcc/jTPCCScheduler.java

@@ -12,7 +12,8 @@ public class jTPCCScheduler implements Runnable {
   private static Logger log = LogManager.getLogger(jTPCCScheduler.class);
   public final static int SCHED_TERM_LAUNCH = 0, SCHED_SUT_LAUNCH = 1, SCHED_BEGIN = 2,
       SCHED_TERMINAL_DATA = 3, SCHED_DELIVERY_DATA = 4, SCHED_END = 5, SCHED_DONE = 6,
-      SCHED_TERM_LAUNCH_DONE = 7, SCHED_SUT_LAUNCH_DONE = 8, SCHED_REPORT = 9;
+      SCHED_TERM_LAUNCH_DONE = 7, SCHED_SUT_LAUNCH_DONE = 8, SCHED_REPORT = 9,
+      SCHED_DUMMY_RESULT = 10;
 
 
   private jTPCC gdata;
@@ -24,6 +25,7 @@ public class jTPCCScheduler implements Runnable {
   private int avl_max_nodes = 0;
   private int avl_max_height = 0;
   private Random random;
+  private jTPCCResult dummy_result;
 
   private long current_trans_count = 0;
   private long current_neword_count = 0;
@@ -34,6 +36,7 @@ public jTPCCScheduler(jTPCC gdata) {
     this.duration_ms = (gdata.rampupMins + gdata.runMins) * 60000;
     this.random = new Random(System.currentTimeMillis());
     this.avl_lock = new Object();
+    this.dummy_result = new jTPCCResult();
   }
 
   public void run() {
@@ -152,6 +155,11 @@ public void run() {
           this.at(tdata.trans_due + jTPCC.reportIntervalSecs * 1000, SCHED_REPORT, tdata);
           break;
 
+        case SCHED_DUMMY_RESULT:
+          dummy_result.emit(tdata.trans_due);
+          this.at(tdata.trans_due + jTPCC.resultIntervalSecs * 1000, SCHED_DUMMY_RESULT, tdata);
+          break;
+
         default:
           log.error("Scheduler, unknown scheduler code {}", tdata.sched_code);
           break;