File: ntpq

package info (click to toggle)
hobbit-plugins 20190129
  • links: PTS, VCS
  • area: main
  • in suites: buster
  • size: 588 kB
  • sloc: perl: 3,273; sh: 84; makefile: 22
file content (118 lines) | stat: -rwxr-xr-x 4,411 bytes parent folder | download | duplicates (2)
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
#!/usr/bin/perl

# A Hobbit client-side module to check the local ntpd daemon
# synchronization status.  Not to be confused with the built-in "ntp"
# test, which checks the ntpd server remotely.

# Copyright (C) 2008 Peter Eisentraut <petere@debian.org>
#
# Permission is hereby granted, free of charge, to any person
# obtaining a copy of this software and associated documentation
# files (the "Software"), to deal in the Software without
# restriction, including without limitation the rights to use,
# copy, modify, merge, publish, distribute, sublicense, and/or sell
# copies of the Software, and to permit persons to whom the
# Software is furnished to do so, subject to the following
# conditions:
#
# The above copyright notice and this permission notice shall be
# included in all copies or substantial portions of the Software.
#
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
# EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
# OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
# NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
# HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
# FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
# OTHER DEALINGS IN THE SOFTWARE.

use warnings;
use strict;
use Hobbit;
use YAML::Tiny;

if (! -x '/usr/bin/ntpq' and system('ntpq -? >/dev/null 2>&1') != 0) {
	exit 0;
}

my $testname = 'ntpq';
my $bb = new Hobbit("$testname");
my $trends = Hobbit::trends;
my $syspeer_stats = {};
my $plugins_config = '/etc/xymon/plugins.yaml';
my $ntpd_pid_file = '/var/run/ntpd.pid';
my $offset_warning = 100;
my $offset_critical = 2000;

if (-e $plugins_config) {
    my $config_yaml = YAML::Tiny->read($plugins_config);
    my $config = $config_yaml->[0]{"$testname"};

    $ntpd_pid_file = $config->{'ntpd_pid_file'} if ( defined($config->{'ntpd_pid_file'}) );
    $offset_warning = $config->{'offset_warning'} if ( defined($config->{'offset_warning'}) );
    $offset_critical = $config->{'offset_critical'} if ( defined($config->{'offset_critical'}) );
}

$bb->print("NTP peers:\n\n");

my $found_syspeer = 0;
my $recently_started = 0;
my $initializing = 0;

if (-f $ntpd_pid_file) {
    $recently_started = (time - (stat($ntpd_pid_file))[9]) < 300;
} else {
    $bb->color_line('yellow', "ntpd pid file $ntpd_pid_file not found. Is ntpd running?\n\n");
}

my @output = `ntpq -np 2>&1` or die;
foreach my $line (@output) {
	if ($line =~ /^  / or $line =~ /^==/) {
		$bb->print('   ' . $line);
	} elsif ($line =~ /^\*\S+\s+\S+\s+\d+ \w\s+[\dm-]+\s+[\d-]+\s+[\d-]+\s+([\d\.-]+)\s+([\d\.-]+)\s+([\d\.-]+)/) {
		($syspeer_stats->{'delay'}, $syspeer_stats->{'offset'}, $syspeer_stats->{'jitter'}) = ($1, $2, $3);
		$bb->color_line('green', $line);
		$found_syspeer = 1;
	} elsif ($line =~ /^( |x|\.|\-|\+|\#|o)/) {
		$bb->color_line('clear', $line);
		$initializing = 1 if $line =~ /\.INIT\.|\.STEP\./;
	} else {
		$bb->color_line('yellow', $line);
	}
}

if ($found_syspeer) {

    $bb->print( "\n" );
    $bb->print( "SyspeerDelay: $syspeer_stats->{'delay'}\n" );
    $bb->print( "SyspeerOffset: $syspeer_stats->{'offset'}\n" );
    $bb->print( "SyspeerJitter: $syspeer_stats->{'jitter'}\n\n" );
    $bb->print( "SyspeerOffset thresholds:\n" );
    $bb->print( "Warning: ${offset_warning}ms\n" );
    $bb->print( "Critical: ${offset_critical}ms\n" );

    if (abs($syspeer_stats->{'offset'}) > $offset_critical) {
        $bb->color_line('red', "SyspeerOffset > ${offset_critical}ms\n" );
    } elsif (abs($syspeer_stats->{'offset'}) > $offset_warning) {
        $bb->color_line('yellow', "SyspeerOffset > ${offset_warning}ms\n" );
    }

    $trends->print ("[${testname},SyspeerDelay.rrd]\n");
    $trends->print ("DS:lambda:GAUGE:600:U:U $syspeer_stats->{'delay'}\n");
    $trends->print ("[${testname},SyspeerOffset.rrd]\n");
    $trends->print ("DS:lambda:GAUGE:600:U:U $syspeer_stats->{'offset'}\n");
    $trends->print ("[${testname},SyspeerJitter.rrd]\n");
    $trends->print ("DS:lambda:GAUGE:600:U:U $syspeer_stats->{'jitter'}\n");

} else {
	$bb->print("\n");
	if ($recently_started and $initializing) {
		$bb->color_line('yellow', "No system peer entry (\"*\") found; ntpd was recently started and is initializing.\n");
	} else {
		$bb->color_line('red', "No system peer entry (\"*\") found\n");
	}
}

$trends->send;
$bb->send;