trackrdrd: add global worker restart count to monitoring stats

trackrdrd/src/monitor.c

@@ -63,6 +63,7 @@ log_output(void)
         "sent=%u "
         "reconnects=%u "
         "failed=%u "
+        "restarts=%u "
         "occ_hi=%u "
         "occ_hi_this=%u ",
         dtbl.len,
@@ -77,6 +78,7 @@ log_output(void)
         dtbl.r_stats.sent,
         dtbl.r_stats.reconnects,
         dtbl.r_stats.failed,
+        dtbl.r_stats.restarts,
         dtbl.r_stats.occ_hi,
         dtbl.r_stats.occ_hi_this
             );
@@ -192,6 +194,10 @@ MON_StatsUpdate(stats_update_t update)
         dtbl.w_stats.nodata++;
         dtbl.r_stats.done--;
         break;
+
+    case STATS_RESTART:
+        dtbl.r_stats.restarts++;
+        break;
         
     default:
         /* Unreachable */

trackrdrd/src/trackrdrd.h

@@ -144,7 +144,8 @@ struct data_reader_stats_s {
     unsigned       	open;	
     unsigned		sent;		/* Sent successfully to MQ */
     unsigned		failed;		/* MQ send fails */
-    unsigned		reconnects;
+    unsigned		reconnects;	/* Reconnects to MQ */
+    unsigned		restarts;	/* Worker thread restarts */
     unsigned		occ_hi;		/* Occupancy high water mark */ 
     unsigned		occ_hi_this;	/* Occupancy high water mark
                                            this reporting interval*/
@@ -346,6 +347,8 @@ typedef enum {
     STATS_OCCUPANCY,
     /* ReqEnd seen, no data in the record */
     STATS_NODATA,
+    /* Worker thread restarted */
+    STATS_RESTART,
 } stats_update_t;
 
 void *MON_StatusThread(void *arg);

trackrdrd/src/worker.c

@@ -359,6 +359,7 @@ WRK_Restart(void)
             wrk->deqs = wrk->waits = wrk->sends = wrk->fails = wrk->reconnects
                 = 0;
             wrk->restarts++;
+            MON_StatsUpdate(STATS_RESTART);
             wrk->state = WRK_NOTSTARTED;
             if (pthread_create(&thread_data[i].worker, NULL, wrk_main, wrk)
                 != 0) {