Newer
Older
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
#!/usr/bin/perl
#
# process sip log files from sipp-responder and sipp-test and report to Xymon
# the task.log file gives meta-info
use XML::Simple;
use Data::Dumper;
use Socket;
use IO::Select;
require "newgetopt.pl";
@opts=( 'f', 'die=s', 'timeout=s', 'bb=s', 'remote', 'debug', 'dump', 'v', 'h', 'help' );
my $usage="Usage $0 [-debug] [-die mins] [-remote] [-f]
-bb <hostname> - XYMON/BB host to receive reports
-remote - this is remote sipp (not used)
-f - wait for results like tail -f
-die <minutes> - end after <minutes>
";
my $rc=&NGetOpt(@opts);
die $usage if not $rc or $opt_h or $opt_help;
my $bb_host = $opt_bb || `hostname -f`;
$mos_limit=[0,3.2,3.9]; # mos values
$bb_color=["red", "yellow", "green"];
$call_limit=[0,70,90]; # call succes in percent
# check results from sipp-initated calls with tcpdumps in sipp-test
$tmp="/tmp/qstream-sipp-$$.xml";
my $endooflife=0;
if ($opt_die){
$endoflife=time+$opt_die*60;
}
my $timeout= $opt_timeout || 1; # wait n seconds for file too be updated
foreach $tasklog(@ARGV){
open TASKLOG, "<$tasklog" || die "Could not open $tasklog : $!";
while( 1 ){ # read task.log
# while(eof(TASKLOG)){ # wait for next line to file
# exit(1) if $opt_die && (time > $endoflife);
# last if !$opt_f;
# sleep $timeout;
# next; # wait for more data
# }
exit(1) if $opt_die && (time > $endoflife);
if (! ($line=<TASKLOG>)){ # could not read the line
exit(1) if $opt_die && (time > $endoflife);
last if !$opt_f;
sleep $timeout;
next;
}
next if $line !~ /[\d-]+ [\d:]+ \d+ \d+/; # invalid line/empty ..Format : date time port port
my ($date, $time, $pid, $sip_port, $rtp_port, $id, $function, $machine, $rtt)=split(/\s+/, $line);
# sleep 300; # minutes to be sure that the forked processes are dead
# active=1 test $active -gt 0
until (system("ps -p $pid > /dev/null")){ # wait until process finished
sleep $timeout;
}
$src=$id; $src=~ s/.*@//;
$machine=$src if !$machine ne '';
$machine=~s/:\d+$//;
if ($machine=~ /^\d+\.\d+/){ # lookup hostname
my $iaddr=inet_aton($machine);
$machine= gethostbyaddr($iaddr, AF_INET);
}
$machine=~s/\./,/g;
my $mossum=0, $n=0;
my @f=`ls rtp_*${pid}_*.pcap* 2>/dev/null`;
my $qstream_rep='';
if($#f >=0){ # yess some files
chomp(@f);
my $rtp_files= join(' ', @f);
$cmd="/usr/bin/qstream -v -rtp -rtt '$rtt' -id $src -xml $tmp $rtp_files";
my $T=`date +%T`; chomp($T);
$qstream_rep=sprintf "%s $pid $port $mport $service@$server $function $machine ping",$T;
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
open QSTREAM, "$cmd|";
while(<QSTREAM>){ $qstream_rep.=$_}
close QSTREAM;
# system($cmd); # || die "command failed : $cmd : $!";
$xml = XMLin($tmp) || die "Could not analyze XML $tmp : $!";
print Dumper($xml) if $opt_dump;
my @flow=();
if (ref($xml->{flow}) eq "ARRAY"){
@flow= @{$xml->{flow}};
} else { # just one
@flow=($xml->{flow});
}
$min_mos=10;
foreach $flow (@flow){
my $mos= $flow->{network_stats}->{MOS};
$mossum += $mos;
$n++;
$min_mos=$mos if ($mos < $min_mos) ;
}
}
if ($n >0){
my $mean_mos=$mossum/$n;
&bb_report("M-$function", $machine, &bb_color($mos_limit,$bb_color,$min_mos),
sprintf "$date $time - %.1f \n%s\n",$min_mos,$qstream_rep);
} else {
&bb_report("M-$function", $machine, &bb_color($mos_limit,$bb_color,0), "No RTP files");
}
my $log='';
# checking call success
if ($opt_remote){
if ($n > 0){
$status=100;
$message="Call received successfully";
} else {
$status=0;
$message="No calls received\n";
}
&bb_report("C-$function", $machine, &bb_color($call_limit,$bb_color,$status), $message);
} else {
open (CSV, "/usr/bin/sipp-print -f 'OutgoingCall(C)|SuccessfulCall(C)|FailedCall(C)|Retransmissions(C)|ResponseTime1(C)|ResponseTime1StDev(C)|CallLength(C)|CallLengthStDev(C)' *${pid}_.csv|");
while(<CSV>){
$log.=$_;
if (/^\s+\d+\s+\d+\s+/){
my ($callsout, $success, $failed, $rest)=split;
if ($success>0){
$calls=$success+$failed;
$status=100*$success/$calls; # success rate in %
$message=sprintf "$date $time - %d percent success (%d/%d)\n%s",$status,$success,$calls,$log;
} else {
$status=0;
$message="No successfull calls :\n $log";
}
&bb_report("C-$function", $machine, &bb_color($call_limit,$bb_color,$status), $message);
}
}
close CSV;
}
}
close TASKLOG;
}
# /usr/bin/sipp-print -id $src -q -f 'OutgoingCall(C)|SuccessfulCall(C)|FailedCall(C)|Retransmissions(C)|ResponseTime1(C)|ResponseTime1StDev(C)|CallLength(C)|CallLengthStDev(C)' *${pid}_.csv
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
unlink ($tmp);
exit(0);
sub bb_color {
my ($limit, $color, $value)=@_;
for ($i=$#$limit;$i>=$[;$i--){
if ( $value >= @$limit[$i]){
return @$color[$i];
}
}
}
sub bb_report {
my ($bbtest, $machine, $color, $msg)=@_;
# my $cmd="/usr/lib/hobbit/client/bin/bb $bb_host 'status $machine.$bbtest $color $msg\n'>>$ENV{HOME}/cmd.log 2>&1";
my $cmd="/usr/lib/hobbit/client/bin/bb $bb_host 'status $machine.$bbtest $color $msg\n'";
# system($cmd)|| warn "Command failed : $cmd : $!";
my @cmd=("/usr/lib/hobbit/client/bin/bb", "$bb_host", "status $machine.$bbtest $color $msg\n");
system(@cmd); # || warn "Command failed : $cmd : $!";
print $cmd, "\n" if $opt_v;
}