2
0
mirror of https://github.com/munin-monitoring/contrib.git synced 2018-11-08 00:59:34 +01:00
contrib-munin/plugins/munin/munin_stats_plugins
2012-02-13 18:24:46 +01:00

175 lines
3.9 KiB
Perl
Executable File

#!/usr/bin/env perl
use 5.010;
use strict;
use warnings;
use autodie;
use Munin::Plugin;
use File::Temp qw(tempdir tempfile);
use Time::HiRes qw(gettimeofday tv_interval);
use File::Spec::Functions qw(catfile);
use File::Basename qw(basename);
=head1 NAME
munin_stats_plugins - Report the time it takes to run all munin plugins
=head1 SYNOPSIS
In F</etc/munin/plugin-conf.d/munin-node>, because we invoke plugins
with munin-run, some of which may need root privileges:
[munin_stats_plugins]
user root
Put this in cron somewhere:
# Refresh the statistics
MUNIN_STATS_PLUGINS_RELOAD=1 munin-run munin_stats_plugins
E.g.:
40 4 * * * root MUNIN_STATS_PLUGINS_RELOAD=1 munin-run munin_stats_plugins
Then run it:
# Get the statistics
munin-run munin_stats_plugins
=head1 DESCRIPTION
Runs all the munin plugins in F</etc/munin/plugins> and reports the
time it takes to run each one with C<system> and L<Time::HiRes>. Since
running all the plugins again on each munin-update run would lead to
epic recursive failure, you have to reload the statistics database
yourself by reloading it in cron somewhere.
=head1 AUTHOR
E<AElig>var ArnfjE<ouml>rE<eth> Bjarmason <avar@cpan.org>
=head1 LICENSE
This program is in the public domain.
=head1 MAGIC MARKERS
#%# family=manual
=cut
my $statedir = $ENV{MUNIN_PLUGSTATE};
my $statefile = $0; $statefile =~ s[^.*/][];
my $cache = catfile($statedir, $statefile . '-cache');
my $cache_tmp = "$cache.tmp";
my @plugins = parse_plugin_time($cache);
# We should reload our data
if (not $ARGV[0] and $ENV{MUNIN_STATS_PLUGINS_RELOAD}) {
$ARGV[0] = 'reload';
}
given ($ARGV[0]) {
when ("reload") {
# Plugin names
my @plugs = plugin_names();
# Run all the plugins
my $time = plugin_times(@plugs);
write_plugin_times($cache_tmp, $cache, $time);
}
when ("config") {
print <<END;
graph_title Munin plugin processing time
graph_scale yes
graph_vlabel seconds
graph_category munin
graph_info Shows the processing time of munin plugins in seconds
END
for my $plugin (@plugins) {
my ($time, $name) = @$plugin;
my $fieldname = clean_fieldname($name);
print <<END;
$fieldname.label $name
$fieldname.info The processing time of $name
$fieldname.draw AREASTACK
END
}
}
default {
for my $plugin (@plugins) {
my ($time, $name) = @$plugin;
my $fieldname = clean_fieldname($name);
print <<END;
$fieldname.value $time
END
}
}
}
sub slurp {
do {
local (@ARGV, $/) = shift;
scalar <>;
};
}
sub parse_plugin_time
{
my ($file) = @_;
my $cont = slurp($file);
my @plugins;
while ($cont =~ /^ (?<time>[\d.]+) \s+ (?<plugin>.*) $/mgx) {
push @plugins => [ $+{time} => $+{plugin} ];
}
# Sort by size
@plugins = sort { $b->[0] <=> $a->[0] } @plugins;
@plugins;
}
sub plugin_names {
map { basename $_ } grep { -x } glob "/etc/munin/plugins/*";
}
sub plugin_times {
my (@p) = @_;
my %time;
my $dir = tempdir("munin-stats-plugins-XXXX", CLEANUP => 1, TMPDIR => 1);
for my $plugin (@p) {
my ($fh, $file) = tempfile(DIR => $dir);
my $t0 = [gettimeofday];
if (system qq[MUNIN_STATS_PLUGINS_RELOAD=0 munin-run "$plugin" >"$file" 2>&1]) {
my $cont = slurp($file);
die "munin-run: Failed to run plugin $plugin: $?, output: $cont";
}
my $t1 = [gettimeofday];
my $elapsed = tv_interval($t0, $t1);
$time{$plugin} = sprintf "%0.2f", $elapsed;
}
return \%time;
}
sub write_plugin_times {
my ($tmp, $real, $time) = @_;
# Write out the runtimes to a tempfile
open my $fh, ">", $cache_tmp;
while (my ($p, $t) = each %$time) {
say $fh "$t $p";
}
close $fh;
# Rename the temp to the real thing. If we wrote it to begin
# with we might have a race condition.
rename $cache_tmp, $cache;
}