]>
git.ipfire.org Git - 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
):
38 "DEF:latency=%(file)s:latency:AVERAGE",
39 "DEF:latency_loss=%(file)s:latency_loss:AVERAGE",
40 "DEF:latency_stddev=%(file)s:latency_stddev:AVERAGE",
42 # Compute loss in percentage.
43 "CDEF:latency_ploss=latency_loss,100,*",
45 # Compute standard deviation.
46 "CDEF:stddev1=latency,latency_stddev,+",
47 "CDEF:stddev2=latency,latency_stddev,-",
49 "CDEF:l005=latency_ploss,0,5,LIMIT,UN,UNKN,INF,IF",
50 "CDEF:l010=latency_ploss,5,10,LIMIT,UN,UNKN,INF,IF",
51 "CDEF:l025=latency_ploss,10,25,LIMIT,UN,UNKN,INF,IF",
52 "CDEF:l050=latency_ploss,25,50,LIMIT,UN,UNKN,INF,IF",
53 "CDEF:l100=latency_ploss,50,100,LIMIT,UN,UNKN,INF,IF",
55 "AREA:l005#ffffff:%s" % _("0-5%%"),
56 "AREA:l010#000000:%s" % _("5-10%%"),
57 "AREA:l025#ff0000:%s" % _("10-25%%"),
58 "AREA:l050#00ff00:%s" % _("25-50%%"),
59 "AREA:l100#0000ff:%s" % _("50-100%%") + "\\n",
61 "LINE1:stddev1#00660088",
62 "LINE1:stddev2#00660088",
64 "LINE3:latency#ff0000:%s" % _("Latency"),
65 "VDEF:latencymin=latency,MINIMUM",
66 "VDEF:latencymax=latency,MAXIMUM",
67 "VDEF:latencyavg=latency,AVERAGE",
68 "GPRINT:latencymax:%12s\:" % _("Maximum") + " %6.2lf",
69 "GPRINT:latencymin:%12s\:" % _("Minimum") + " %6.2lf",
70 "GPRINT:latencyavg:%12s\:" % _("Average") + " %6.2lf\\n",
72 "LINE1:latencyavg#000000:%s" % _("Average latency"),
76 def rrd_graph_args(self
):
78 "--title", _("Latency to %(host)s"),
79 "--vertical-label", _("Milliseconds"),
81 "--lower-limit", "0", "--rigid",
85 class DataSourceLatency(base
.DataSource
):
87 description
= "Latency (ICMP ping) Data Source"
89 templates
= [GraphTemplateLatency
,]
92 "DS:latency:GAUGE:0:U",
93 "DS:latency_loss:GAUGE:0:100",
94 "DS:latency_stddev:GAUGE:0:U",
99 return "-".join((self
.name
, self
.host
))
102 def autocreate(cls
, collecty
, **kwargs
):
104 for host
in PING_HOSTS
:
105 ds
= cls(collecty
, host
=host
, **kwargs
)
110 def init(self
, **kwargs
):
111 self
.host
= kwargs
.get("host")
116 return self
.interval
- 10
119 # Send up to five ICMP echo requests.
121 ping
= collecty
.ping
.Ping(destination
=self
.host
, timeout
=20000)
122 ping
.run(count
=5, deadline
=self
.deadline
)
124 except collecty
.ping
.PingError
, e
:
125 self
.log
.warning(_("Could not run latency check for %(host)s: %(msg)s") \
126 % { "host" : self
.host
, "msg" : e
.msg
})
130 "%.10f" % ping
.avg_time
,
132 "%.10f" % ping
.stddev
,