summaryrefslogtreecommitdiffstats
path: root/doc/show_dabmux_stats.py
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2018-02-01 04:03:10 +0100
committerMatthias P. Braendli <matthias.braendli@mpb.li>2018-02-01 04:03:10 +0100
commitd1b74c21d8c6f816179cd700dd5859f51bf01d88 (patch)
treee432447ad3aae628f246520c25d1a061cdfedee3 /doc/show_dabmux_stats.py
parent61a6b19c48da87d6e64ee3cc5d207c95d7ab7e4a (diff)
downloaddabmux-d1b74c21d8c6f816179cd700dd5859f51bf01d88.tar.gz
dabmux-d1b74c21d8c6f816179cd700dd5859f51bf01d88.tar.bz2
dabmux-d1b74c21d8c6f816179cd700dd5859f51bf01d88.zip
Add show_dabmux_stats script to doc
Diffstat (limited to 'doc/show_dabmux_stats.py')
-rwxr-xr-xdoc/show_dabmux_stats.py83
1 files changed, 83 insertions, 0 deletions
diff --git a/doc/show_dabmux_stats.py b/doc/show_dabmux_stats.py
new file mode 100755
index 0000000..f781839
--- /dev/null
+++ b/doc/show_dabmux_stats.py
@@ -0,0 +1,83 @@
+#!/usr/bin/env python2
+#
+# present statistics from dabmux Stats Server
+# to standard output.
+#
+# If you are looking for munin integration, use
+# ODR-DabMux/doc/stats_dabmux_multi.py
+
+import sys
+import json
+import zmq
+import os
+
+ctx = zmq.Context()
+
+def connect():
+ """Create a connection to the dabmux stats server
+
+ returns: the socket"""
+
+ sock = zmq.Socket(ctx, zmq.REQ)
+ sock.connect("tcp://localhost:12720")
+
+ sock.send("info")
+ version = json.loads(sock.recv())
+
+ if not version['service'].startswith("ODR-DabMux"):
+ sys.stderr.write("Wrong version\n")
+ sys.exit(1)
+
+ return sock
+
+if len(sys.argv) == 1:
+ sock = connect()
+ sock.send("values")
+
+ poller = zmq.Poller()
+ poller.register(sock, zmq.POLLIN)
+
+ socks = dict(poller.poll(1000))
+ if socks:
+ if socks.get(sock) == zmq.POLLIN:
+
+ data = sock.recv()
+ values = json.loads(data)['values']
+
+ tmpl = "{ident:20}{maxfill:>8}{minfill:>8}{under:>8}{over:>8}{peakleft:>8}{peakright:>8}{state:>16}"
+ print(tmpl.format(
+ ident="id",
+ maxfill="max",
+ minfill="min",
+ under="under",
+ over="over",
+ peakleft="peak L",
+ peakright="peak R",
+ state="state"))
+
+ for ident in values:
+ v = values[ident]['inputstat']
+
+ if 'state' not in v:
+ v['state'] = None
+
+ print(tmpl.format(
+ ident=ident,
+ maxfill=v['max_fill'],
+ minfill=v['min_fill'],
+ under=v['num_underruns'],
+ over=v['num_overruns'],
+ peakleft=v['peak_left'],
+ peakright=v['peak_right'],
+ state=v['state']))
+
+
+elif len(sys.argv) == 2 and sys.argv[1] == "config":
+ sock = connect()
+
+ sock.send("config")
+
+ config = json.loads(sock.recv())
+
+ print(config['config'])
+