]>
git.ipfire.org Git - oddments/collecty.git/blob - src/collecty/plugins/latency.py
2 ###############################################################################
4 # collecty - A system statistics collection daemon for IPFire #
5 # Copyright (C) 2012 IPFire development team #
7 # This program is free software: you can redistribute it and/or modify #
8 # it under the terms of the GNU General Public License as published by #
9 # the Free Software Foundation, either version 3 of the License, or #
10 # (at your option) any later version. #
12 # This program is distributed in the hope that it will be useful, #
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of #
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the #
15 # GNU General Public License for more details. #
17 # You should have received a copy of the GNU General Public License #
18 # along with this program. If not, see <http://www.gnu.org/licenses/>. #
20 ###############################################################################
32 class GraphTemplateLatency(base
.GraphTemplate
):
40 "DEF:latency=%(file)s:latency:AVERAGE",
41 "DEF:latency_loss=%(file)s:latency_loss:AVERAGE",
42 "DEF:latency_stddev=%(file)s:latency_stddev:AVERAGE",
44 # Compute loss in percentage.
45 "CDEF:latency_ploss=latency_loss,100,*",
47 # Compute standard deviation.
48 "CDEF:stddev1=latency,latency_stddev,+",
49 "CDEF:stddev2=latency,latency_stddev,-",
51 "CDEF:l005=latency_ploss,0,5,LIMIT,UN,UNKN,INF,IF",
52 "CDEF:l010=latency_ploss,5,10,LIMIT,UN,UNKN,INF,IF",
53 "CDEF:l025=latency_ploss,10,25,LIMIT,UN,UNKN,INF,IF",
54 "CDEF:l050=latency_ploss,25,50,LIMIT,UN,UNKN,INF,IF",
55 "CDEF:l100=latency_ploss,50,100,LIMIT,UN,UNKN,INF,IF",
57 "AREA:l005#ffffff:%s" % _("0-5%%"),
58 "AREA:l010#000000:%s" % _("5-10%%"),
59 "AREA:l025#ff0000:%s" % _("10-25%%"),
60 "AREA:l050#00ff00:%s" % _("25-50%%"),
61 "AREA:l100#0000ff:%s" % _("50-100%%") + "\\n",
63 "LINE1:stddev1#00660088",
64 "LINE1:stddev2#00660088",
66 "LINE3:latency#ff0000:%s" % _("Latency"),
67 "VDEF:latencymin=latency,MINIMUM",
68 "VDEF:latencymax=latency,MAXIMUM",
69 "VDEF:latencyavg=latency,AVERAGE",
70 "GPRINT:latencymax:%12s\:" % _("Maximum") + " %6.2lf",
71 "GPRINT:latencymin:%12s\:" % _("Minimum") + " %6.2lf",
72 "GPRINT:latencyavg:%12s\:" % _("Average") + " %6.2lf\\n",
74 "LINE1:latencyavg#000000:%s" % _("Average latency"),
78 def graph_title(self
):
79 return _("Latency to %(host)s")
82 def graph_vertical_label(self
):
83 return _("Milliseconds")
86 class LatencyObject(base
.Object
):
88 "DS:latency:GAUGE:0:U",
89 "DS:latency_loss:GAUGE:0:100",
90 "DS:latency_stddev:GAUGE:0:U",
94 return "<%s %s>" % (self
.__class
__.__name
__, self
.hostname
)
96 def init(self
, hostname
, deadline
=None):
97 self
.hostname
= hostname
98 self
.deadline
= deadline
105 # Send up to five ICMP echo requests.
107 ping
= collecty
.ping
.Ping(destination
=self
.hostname
, timeout
=20000)
108 ping
.run(count
=5, deadline
=self
.deadline
)
110 except collecty
.ping
.PingError
as e
:
111 self
.log
.warning(_("Could not run latency check for %(host)s: %(msg)s") \
112 % { "host" : self
.hostname
, "msg" : e
.msg
})
116 "%.10f" % ping
.avg_time
,
118 "%.10f" % ping
.stddev
,
122 class LatencyPlugin(base
.Plugin
):
124 description
= "Latency (ICMP ping) Plugin"
126 templates
= [GraphTemplateLatency
]
132 deadline
= self
.interval
/ len(PING_HOSTS
)
134 for hostname
in PING_HOSTS
:
135 yield LatencyObject(self
, hostname
, deadline
=deadline
)