Add EDI/TCP number of active connections statistics

1 files changed, 22 insertions, 0 deletions

diff --git a/doc/show_dabmux_stats.py b/doc/show_dabmux_stats.py
index 7ea60f7..3b6d869 100755
--- a/doc/show_dabmux_stats.py
+++ b/doc/show_dabmux_stats.py
@@ -46,6 +46,7 @@ if len(sys.argv) == 1:
             data = sock.recv().decode("utf-8")
             values = json.loads(data)['values']
 
+            print("## INPUT STATS")
             tmpl = "{ident:20}{maxfill:>8}{minfill:>8}{under:>8}{over:>8}{audioleft:>8}{audioright:>8}{peakleft:>8}{peakright:>8}{state:>16}{version:>48}{uptime:>8}{offset:>8}"
             print(tmpl.format(
                 ident="id",
@@ -89,6 +90,27 @@ if len(sys.argv) == 1:
                     uptime=v['uptime'],
                     offset=v['last_tist_offset']))
 
+    sock.send(b"output_values")
+
+    poller = zmq.Poller()
+    poller.register(sock, zmq.POLLIN)
+
+    socks = dict(poller.poll(1000))
+    if socks:
+        if socks.get(sock) == zmq.POLLIN:
+            print()
+            print("## OUTPUT STATS")
+            data = sock.recv().decode("utf-8")
+            values = json.loads(data)['output_values']
+            for identifier in values:
+                if identifier.startswith("edi_tcp_"):
+                    listen_port = identifier.rsplit("_", 1)[-1]
+                    num_connections = values[identifier]["num_connections"]
+                    print(f"EDI TCP on port {listen_port}: {num_connections} connections")
+                else:
+                    print(f"Unknown output type: {identifier}")
+
+
 
 elif len(sys.argv) == 2 and sys.argv[1] == "config":
     sock = connect()