qos server demos: fix reporting over client reboots.

Author: peterhinch

iot/qos/check_mid.py

@@ -12,18 +12,24 @@
 # message is missing after n have been received, it is assumed lost.
 
 class CheckMid:
-    def __init__(self, buff=5):
+    def __init__(self, buff=10):
         self._buff = buff
         self._mids = set()
         self.miss = 0  # Count missing message ID's
         self.dupe = 0  # Duplicates
         self.oord = 0  # Received out of order
-        self.bcnt = 0  # Reboot count
+        self.bcnt = 0  # Client reboot count. Running totals over reboots:
+        self.tot_miss = 0  # Missing
+        self.tot_dupe = 0  # Dupes
+        self.tot_oord = 0  # Out of order
 
     def __call__(self, mid):
         mids = self._mids
         if mid <= 1 and len(mids) > 1:  # Target has rebooted
             self._mids.clear()
+            self.tot_miss += self.miss
+            self.tot_dupe += self.dupe
+            self.tot_oord += self.oord
             self.miss = 0
             self.dupe = 0
             self.oord = 0

iot/qos/s_qos_cp.py

@@ -52,8 +52,9 @@ async def start(self):
             outages = self.conn.nconns - 1
             ut = (time.time() - st) / 3600  # Uptime in hrs
             print('Uptime {:6.2f}hr outages {}'.format(ut, outages))
-            print('Dupes ignored {} local {} remote. '.format(cm.dupe, data[3]), end='')
-            print('Missed msg {} local {} remote.'.format(cm.miss, data[4]))
+            print('Dupes ignored {} local {} remote. '.format(cm.tot_dupe, data[3]), end='')
+            print('Missed msg {} local {} remote.'.format(cm.tot_miss, data[4]), end='')
+            print('Client reboots', cm.bcnt)
 
     async def reader(self):
         print('Started reader')

iot/qos/s_qos_fast.py

@@ -54,12 +54,12 @@ async def start(self):
             outages = self.conn.nconns - 1
             ut = (time.time() - st) / 3600  # Uptime in hrs
             print('Uptime {:6.2f}hr outages {}'.format(ut, outages))
-            print('Dupes ignored {} local {} remote. '.format(cm.dupe, data[3]), end='')
-            print('Missed msg {} local {} remote.'.format(cm.miss, data[4]))
+            print('Dupes ignored {} local {} remote. '.format(cm.tot_dupe, data[3]), end='')
+            print('Missed msg {} local {} remote.'.format(cm.tot_miss, data[4]), end='')
+            print('Client reboots', cm.bcnt)
 
     async def reader(self):
         print('Started reader')
-        cm = CheckMid()  # Check message ID's for dupes, missing etc.
         while True:
             line = await self.conn.readline()  # Pause in event of outage
             data = json.loads(line)