aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2018-02-01 04:00:33 +0100
committerMatthias P. Braendli <matthias.braendli@mpb.li>2018-02-01 04:00:33 +0100
commitad52cf5274b3ef186fc043eeedddebb336215fa2 (patch)
tree430e34ba46dc8a34c89b6e0f17a4fcb47791237d
parent80ee87ac3e2b0d51a5d0da38e0bfbfa708261a19 (diff)
downloadmmbtools-aux-ad52cf5274b3ef186fc043eeedddebb336215fa2.tar.gz
mmbtools-aux-ad52cf5274b3ef186fc043eeedddebb336215fa2.tar.bz2
mmbtools-aux-ad52cf5274b3ef186fc043eeedddebb336215fa2.zip
Move show_dabmux_stats to dabmux repository
-rwxr-xr-xshow_dabmux_stats.py83
1 files changed, 0 insertions, 83 deletions
diff --git a/show_dabmux_stats.py b/show_dabmux_stats.py
deleted file mode 100755
index f781839..0000000
--- a/show_dabmux_stats.py
+++ /dev/null
@@ -1,83 +0,0 @@
-#!/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'])
-