blob: 7c21d84d1dce80629c4dbc9d4a12bc6096fa85e6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
#!/usr/bin/env python2
#
# present statistics from dabmux Stats Server
# to munin
import sys
import json
import socket
import os
SOCK_RECV_SIZE = 10240
config_top = """
"""
config_template = """
multigraph buffers_{ident}
graph_title Contribution {ident} buffer
graph_order high low
graph_args --base 1000
graph_vlabel max/min buffer size bytes during last ${{graph_period}}
graph_category dabmux
graph_info This graph shows the high and low buffer sizes for the {ident} ZMQ input
high.info Max buffer size
high.label Max Buffer Bytes
high.min 0
high.warning 1:
low.info Min buffer size
low.label Min Buffer Bytes
low.min 0
low.warning 1:
multigraph over_underruns_{ident}
graph_title Contribution {ident} over/underruns
graph_order underruns overruns
graph_args --base 1000
graph_vlabel number of underruns/overruns during last ${{graph_period}}
graph_category dabmux
graph_info This graph shows the number of under/overruns for the {ident} ZMQ input
underruns.info Number of underruns
underruns.label Number of underruns
underruns.min 0
underruns.warning 0:0
underruns.type COUNTER
overruns.info Number of overruns
overruns.label Number of overruns
overruns.min 0
overruns.warning 0:0
overruns.type COUNTER
multigraph audio_levels_{ident}
graph_title Contribution {ident} audio level (peak)
graph_order left right
graph_args --base 1000
graph_vlabel peak audio level during last ${{graph_period}}
graph_category encoders
graph_info This graph shows the audio level of both channels of the {ident} ZMQ input
left.info Left channel audio level
left.label Left channel audio level
left.min -90
left.max 0
left.warning -40:0
left.critical -80:0
right.info Right channel audio level
right.label Right channel audio level
right.min -90
right.max 0
right.warning -40:0
right.critical -80:0
"""
if not os.environ.get("MUNIN_CAP_MULTIGRAPH"):
print("This needs munin version 1.4 at least")
sys.exit(1)
def connect():
"""Create a connection to the dabmux stats server
returns: the socket"""
sock = socket.socket()
sock.connect(("localhost", 12720))
version = json.loads(sock.recv(SOCK_RECV_SIZE))
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\n")
values = json.loads(sock.recv(SOCK_RECV_SIZE))['values']
munin_values = ""
for ident in values:
v = values[ident]['inputstat']
munin_values += "multigraph buffers_{ident}\n".format(ident=ident)
munin_values += "high.value {}\n".format(v['max_fill'])
munin_values += "low.value {}\n".format(v['min_fill'])
munin_values += "multigraph over_underruns_{ident}\n".format(ident=ident)
munin_values += "underruns.value {}\n".format(v['num_underruns'])
munin_values += "overruns.value {}\n".format(v['num_overruns'])
munin_values += "multigraph audio_levels_{ident}\n".format(ident=ident)
munin_values += "left.value {}\n".format(v['peak_left'])
munin_values += "right.value {}\n".format(v['peak_right'])
print(munin_values)
elif len(sys.argv) == 2 and sys.argv[1] == "config":
sock = connect()
sock.send("config\n")
config = json.loads(sock.recv(SOCK_RECV_SIZE))
munin_config = config_top
for conf in config['config']:
munin_config += config_template.format(ident=conf)
print(munin_config)
|
