1
package probes::basefork;
7
probes::basefork - Yet Another Base Class for implementing SmokePing Probes
11
Like probes::basevars, but supports the probe-specific property `forks'
12
to determine how many processes should be run concurrently.
19
# run this many concurrent processes
23
# we don't want any concurrent processes at all for some reason.
28
Not all pinger programs support testing multiple hosts in a single go like
29
fping(1). If the measurement takes long enough, there may be not enough time
30
perform all the tests in the time available. For example, if the test takes
31
30 seconds, measuring ten hosts already fills up the SmokePing default
34
Thus, it may be necessary to do some of the tests concurrently. This module
35
defines the B<ping> method that forks the requested number of concurrent
36
processes and calls the B<pingone> method that derived classes must provide.
38
The B<pingone> method is called with one argument: a hash containing
39
the target that is to be measured. The contents of the hash are
40
described in I<probes::basevars>(3pm).
42
The number of concurrent processes is determined by the probe-specific
43
variable `forks' and is 5 by default. If there are more
44
targets than this value, another round of forks is done after the first
45
processes are finished. This continues until all the targets have been
50
Niko Tyni E<lt>ntyni@iki.fiE<gt>
54
Doesn't signal failures in child processes, partly because SmokePing
55
hasn't any logging features after daemonization.
59
probes::basevars(3pm), probes::EchoPing(3pm)
64
use base qw(probes::basevars);
70
croak "ping_one: this must be overridden by the subclass";
75
my $forks = $self->{properties}{forks};
76
$forks = $DEFAULTFORKS unless defined $forks;
77
$forks = $DEFAULTFORKS if $forks !~ /^\d+$/ or $forks < 1;
79
my @targets = @{$self->targets};
83
my $s = IO::Select->new();
90
$pid = open($handle, "-|");
93
unless (defined $pid) {
94
carp("cannot fork: $!");
96
if $sleep_count++ > 6;
102
$targetlookup{$handle} = $t;
104
my @times = $self->pingone($t);
105
print join(" ", @times), "\n";
109
my $step = $self->{cfg}{Database}{step};
110
my $starttime = time();
111
while ($s->handles and time() - $starttime < $step) {
112
if( $s->can('has_exception') ) {
113
$s->remove($s->has_exception(0)); # should we carp?
114
} elsif( $s->can('has_error') ) {
115
$s->remove($s->has_error(0));
117
croak 'IO::Select neither knows has_exception() nor has_error()';
119
for my $ready ($s->can_read($step / 2)) {
121
my $response = <$ready>;
125
my @times = split(/ /, $response);
126
my $target = $targetlookup{$ready};
127
my $tree = $target->{tree};
128
$self->{rtts}{$tree} = \@times;
135
return "Probe that can fork and doesn't override the ProbeDesc method";
added
removed
lib/probes/basefork.pm
