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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
|
package probes::RemoteFPing;
=head1 NAME
probes::RemoteFPing - Remote FPing Probe for SmokePing
=head1 SYNOPSIS
*** Probes ***
+ RemoteFPing
binary = /usr/bin/ssh
packetsize = 1024
rhost = HostA.foobar.com
ruser = foo
rbinary = /usr/local/sbin/fping
*** Targets ***
+ Targetname
Probe = RemoteFPing
Menu = menuname
Title = Remote Fping from HostA to HostB
Host = HostB.barfoo.com
=head1 DESCRIPTION
Integrates the remote execution of FPing via ssh/rsh into smokeping.
The variable B<binary> must point to your copy of the ssh/rsh program.
=head1 OPTIONS
The B<binary> and B<rhost> are mandatory. The B<binary> option
specifies the path of the remote shell program (usually ssh,
rsh or remsh). Any other script or binary that can be called as
binary [ -l ruser ] rhost rbinary
may be used.
The (optional) B<packetsize> option lets you configure the packetsize
for the pings sent.
The B<rhost> option specifies the remote device from where fping will
be launched.
The (optional) B<ruser> option allows you to specify the remote user,
if different from the one running the smokeping daemon.
The (optional) B<rbinary> option allows you to specify the location of
the remote fping binary. If not specified the probe will assume that
fping is in the remote host's path.
=head1 NOTES
It is important to make sure that you can access the remote machine
without a password prompt, otherwise this probe will not work properly.
To test just try something like this:
$ ssh foo@HostA.foobar.com fping HostB.barfoo.com
The next thing you see must be fping's output.
The B<rhost>, B<ruser> and B<rbinary> variables used to be configured in
the PROBE_CONF section of the first target or its parents They were moved
to the Probes section, because the variables aren't really target-specific
(all the targets are measured with the same parameters). The PROBE_CONF
sections aren't recognized anymore.
=head1 AUTHOR
Luis F Balbinot <hades@inf.ufrgs.br>
based on probes::FPing by
Tobias Oetiker <tobi@oetiker.ch>
=cut
use strict;
use base qw(probes::base);
use IPC::Open3;
use Symbol;
use Carp;
sub new($$$) {
my $proto = shift;
my $class = ref($proto) || $proto;
my $self = $class->SUPER::new(@_);
# no need for this if we run as a cgi
unless ( $ENV{SERVER_SOFTWARE} ) {
croak "ERROR: RemoteFPing packetsize must be between 12 and 64000"
if $self->{properties}{packetsize} and
( $self->{properties}{packetsize} < 12 or $self->{properties}{packetsize} > 64000 );
croak "ERROR: RemoteFPing 'binary' not defined in RemoteFPing probe definition"
unless defined $self->{properties}{binary};
croak "ERROR: RemoteFPing 'binary' does not point to an executable"
unless -f $self->{properties}{binary} and -x $self->{properties}{binary};
croak "ERROR: RemoteFPing 'rhost' not defined in RemoteFPing probe definition. This might be because the configuration syntax has changed. See the RemoteFPing manual for details."
unless defined $self->{properties}{rhost};
$self->{pingfactor} = 1000; # Gives us a good-guess default
print "### assuming you are using a remote fping copy reporting in milliseconds\n";
};
return $self;
}
sub ProbeDesc($) {
my $self = shift;
my $bytes = $self->{properties}{packetsize} || 56;
return "Remote ICMP Echo Pings ($bytes Bytes)";
}
sub ping ($) {
my $self = shift;
# do NOT call superclass ... the ping method MUST be overwriten
my %upd;
my $inh = gensym;
my $outh = gensym;
my $errh = gensym;
# pinging nothing is pointless
return unless @{$self->addresses};
my @bytes = ();
push @bytes, "-b$self->{properties}{packetsize}" if $self->{properties}{packetsize};
my @rargs;
for my $what (qw(ruser rhost rbinary)) {
my $prefix = ($what eq 'ruser' ? "-l" : "");
if (defined $self->{properties}{$what}) {
push @rargs, $prefix . $self->{properties}{$what};
}
}
my $query = "$self->{properties}{binary} @rargs @bytes -C " . $self->pings . " -q -B1 -i10 -r1 @{$self->addresses}";
$self->do_debug("query=$query\n");
my $pid = open3($inh,$outh,$errh,$query );
my @times =() ;
$self->{rtts}={};
while (<$errh>) {
chomp;
next unless /^\S+\s+:\s+[\d\.]/; #filter out error messages from fping
$self->do_debug("array element=$_ \n");
@times = split /\s+/;
my $ip = shift @times;
next unless ':' eq shift @times; #drop the colon
@times = map {sprintf "%.10e", $_ / $self->{pingfactor}} sort {$a <=> $b} grep {$_ ne "-"} @times;
map { $self->{rtts}{$_} = [@times] } @{$self->{addrlookup}{$ip}} ;
}
waitpid $pid,0;
close $inh;
close $outh;
close $errh;
return @times;
}
1;
|
