diff --git a/lib/wowza.pm b/lib/wowza.pm new file mode 100644 index 0000000..fce67ec --- /dev/null +++ b/lib/wowza.pm @@ -0,0 +1,882 @@ +# +# Monitorix - A lightweight system monitoring tool. +# +# Copyright (C) 2005-2013 by Jordi Sanfeliu +# +# This program is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation; either version 2 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along +# with this program; if not, write to the Free Software Foundation, Inc., +# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. +# + +package wowza; + +#use strict; +use warnings; +use Monitorix; +use RRDs; +use LWP::UserAgent; +use XML::Simple; +use Exporter 'import'; +our @EXPORT = qw(wowza_init wowza_update wowza_cgi); + +sub wowza_init { + my $myself = (caller(0))[3]; + my ($package, $config, $debug) = @_; + my $rrd = $config->{base_lib} . $package . ".rrd"; + my $wowza = $config->{wowza}; + + my $info; + my @ds; + my @tmp; + my $n; + + if(-e $rrd) { + $info = RRDs::info($rrd); + for my $key (keys %$info) { + if(index($key, 'ds[') == 0) { + if(index($key, '.type') != -1) { + push(@ds, substr($key, 3, index($key, ']') - 3)); + } + } + } + if(scalar(@ds) / 130 != scalar(my @il = split(',', $wowza->{list}))) { + logger("Detected size mismatch between 'list' (" . scalar(my @il = split(',', $wowza->{list})) . ") and $rrd (" . scalar(@ds) / 130 . "). Resizing it accordingly. All historic data will be lost. Backup file created."); + rename($rrd, "$rrd.bak"); + } + } + + if(!(-e $rrd)) { + logger("Creating '$rrd' file."); + for($n = 0; $n < scalar(my @il = split(',', $wowza->{list})); $n++) { + push(@tmp, "DS:wms" . $n . "_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_val03:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a0_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a1_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a2_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a3_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a4_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a5_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a6_val02:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_timerun:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_connt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_conncur:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_conntacc:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_conntrej:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_minbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_moutbrt:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_sesrtsp:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_sessmoo:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_sescupe:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_sesflas:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_sessanj:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_sestot:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_val01:GAUGE:120:0:U"); + push(@tmp, "DS:wms" . $n . "_a7_val02:GAUGE:120:0:U"); + } + eval { + RRDs::create($rrd, + "--step=60", + @tmp, + "RRA:AVERAGE:0.5:1:1440", + "RRA:AVERAGE:0.5:30:336", + "RRA:AVERAGE:0.5:60:744", + "RRA:AVERAGE:0.5:1440:365", + "RRA:MIN:0.5:1:1440", + "RRA:MIN:0.5:30:336", + "RRA:MIN:0.5:60:744", + "RRA:MIN:0.5:1440:365", + "RRA:MAX:0.5:1:1440", + "RRA:MAX:0.5:30:336", + "RRA:MAX:0.5:60:744", + "RRA:MAX:0.5:1440:365", + "RRA:LAST:0.5:1:1440", + "RRA:LAST:0.5:30:336", + "RRA:LAST:0.5:60:744", + "RRA:LAST:0.5:1440:365", + ); + }; + my $err = RRDs::error; + if($@ || $err) { + logger("$@") unless !$@; + if($err) { + logger("ERROR: while creating $rrd: $err"); + if($err eq "RRDs::error") { + logger("... is the RRDtool Perl package installed?"); + } + } + return; + } + } + + push(@{$config->{func_update}}, $package); + logger("$myself: Ok") if $debug; +} + +sub wowza_update { + my $myself = (caller(0))[3]; + my ($package, $config, $debug) = @_; + my $rrd = $config->{base_lib} . $package . ".rrd"; + my $wowza = $config->{wowza}; + + my @ls; + my @br; + + my $n; + my $rrdata = "N"; + + my $e = 0; + foreach(my @wl = split(',', $wowza->{list})) { + my $wls = trim($wl[$e]); + my $ua = LWP::UserAgent->new(timeout => 30); + my $response = $ua->request(HTTP::Request->new('GET', $wls)); + my $data = XMLin($response->content); + + if(!$response->is_success) { + logger("$myself: ERROR: Unable to connect to '$wls'."); + } + + # main (VHost) stats + $rrdata .= ":" . $data->{VHost}->{TimeRunning}; + $rrdata .= ":" . $data->{VHost}->{ConnectionsTotal}; + $rrdata .= ":" . $data->{VHost}->{ConnectionsCurrent}; + $rrdata .= ":" . $data->{VHost}->{ConnectionsTotalAccepted}; + $rrdata .= ":" . $data->{VHost}->{ConnectionsTotalRejected}; + $rrdata .= ":" . $data->{VHost}->{MessagesInBytesRate}; + $rrdata .= ":" . $data->{VHost}->{MessagesOutBytesRate}; + $rrdata .= ":" . "0:0:0"; + + # application stats + # + # '$app' may be a HASH or an ARRAY depending if it has only one + # duplicate or if it has more than one, respectively. We need + # to convert it to an array in all cases. + my $app = $data->{VHost}->{Application}; + my @array; + if(ref($app) eq "HASH") { + $array[0] = $app; + } else { + @array = @$app; + } + + my $e2 = 0; + foreach my $an (split(',', $wowza->{desc}->{$wls})) { + foreach my $entry (@array) { + if($entry->{Name} eq trim($an)) { + $rrdata .= ":" . $entry->{TimeRunning}; + $rrdata .= ":" . $entry->{ConnectionsTotal}; + $rrdata .= ":" . $entry->{ConnectionsCurrent}; + $rrdata .= ":" . $entry->{ConnectionsTotalAccepted}; + $rrdata .= ":" . $entry->{ConnectionsTotalRejected}; + $rrdata .= ":" . $entry->{MessagesInBytesRate}; + $rrdata .= ":" . $entry->{MessagesOutBytesRate}; + my $instance = $entry->{ApplicationInstance}->{Stream}; + $rrdata .= ":" . $instance->{SessionsRTSP}; + $rrdata .= ":" . $instance->{SessionsSmooth}; + $rrdata .= ":" . $instance->{SessionsCupertino}; + $rrdata .= ":" . $instance->{SessionsFlash}; + $rrdata .= ":" . $instance->{SessionsSanJose}; + $rrdata .= ":" . $instance->{SessionsTotal}; + $rrdata .= ":" . "0:0"; + $e2++; + last; + } + } + } + while($e2 < 8) { + $rrdata .= ":0:0:0:0:0:0:0:0:0:0:0:0:0:0:0"; + $e2++; + } + + $e++; + } + + RRDs::update($rrd, $rrdata); + logger("$myself: $rrdata") if $debug; + my $err = RRDs::error; + logger("ERROR: while updating $rrd: $err") if $err; +} + +sub wowza_cgi { + my ($package, $config, $cgi) = @_; + + my $wowza = $config->{wowza}; + my @rigid = split(',', $wowza->{rigid}); + my @limit = split(',', $wowza->{limit}); + my $tf = $cgi->{tf}; + my $colors = $cgi->{colors}; + my $graph = $cgi->{graph}; + my $silent = $cgi->{silent}; + + my $u = ""; + my $width; + my $height; + my @riglim; + my @PNG; + my @PNGz; + my @tmp; + my @tmpz; + my @CDEF; + my $e; + my $e2; + my $n; + my $n2; + my $str; + my $stack; + my $err; + my @AC = ( + "#FFA500", + "#44EEEE", + "#44EE44", + "#4444EE", + "#448844", + "#EE4444", + "#EE44EE", + "#EEEE44", + "#444444", + ); + my @LC = ( + "#FFA500", + "#00EEEE", + "#00EE00", + "#0000EE", + "#448844", + "#EE0000", + "#EE00EE", + "#EEEE00", + "#444444", + ); + + my $rrd = $config->{base_lib} . $package . ".rrd"; + my $title = $config->{graph_title}->{$package}; + my $PNG_DIR = $config->{base_dir} . "/" . $config->{imgs_dir}; + + $title = !$silent ? $title : ""; + + + # text mode + # + if(lc($config->{iface_mode}) eq "text") { + if($title) { + main::graph_header($title, 2); + print(" \n"); + print(" \n"); + } + my (undef, undef, undef, $data) = RRDs::fetch("$rrd", + "--start=-$tf->{nwhen}$tf->{twhen}", + "AVERAGE", + "-r $tf->{res}"); + $err = RRDs::error; + print("ERROR: while fetching $rrd: $err\n") if $err; + my $line1; + my $line2; + my $line3; + my $line4; + print("
\n");
+		print("    ");
+		for($n = 0; $n < scalar(my @il = split(',', $icecast->{list})); $n++) {
+			my $l = trim($il[$n]);
+			$line1 = "  ";
+			$line2 .= "  ";
+			$line3 .= "  ";
+			$line4 .= "--";
+			foreach my $i (split(',', $icecast->{desc}->{$l})) {
+				$line1 .= "           ";
+				$line2 .= sprintf(" %10s", trim($i));
+				$line3 .= "  List BitR";
+				$line4 .= "-----------";
+			}
+			if($line1) {
+				my $i = length($line1);
+				printf(sprintf("%${i}s", sprintf("Icecast Server %2d", $n)));
+			}
+		}
+		print("\n");
+		print("    $line2");
+		print("\n");
+		print("Time$line3\n");
+		print("----$line4 \n");
+		my $line;
+		my @row;
+		my $time;
+		my $n2;
+		my $n3;
+		my $from;
+		my $to;
+		for($n = 0, $time = $tf->{tb}; $n < ($tf->{tb} * $tf->{ts}); $n++) {
+			$line = @$data[$n];
+			$time = $time - (1 / $tf->{ts});
+			printf(" %2d$tf->{tc}", $time);
+			for($n2 = 0; $n2 < scalar(my @il = split(',', $icecast->{list})); $n2++) {
+				my $ls = trim($il[$n2]);
+				print("  ");
+				$n3 = 0;
+				foreach my $i (split(',', $icecast->{desc}->{$ls})) {
+					$from = $n2 * 36 + ($n3++ * 4);
+					$to = $from + 4;
+					my ($l, $b, undef, undef) = @$line[$from..$to];
+					@row = ($l, $b);
+					printf("  %4d %4d", @row);
+				}
+			}
+			print("\n");
+		}
+		print("    
\n"); + if($title) { + print(" \n"); + print(" \n"); + main::graph_footer(); + } + print("
\n"); + return; + } + + + # graph mode + # + if($silent eq "yes" || $silent eq "imagetag") { + $colors->{fg_color} = "#000000"; # visible color for text mode + $u = "_"; + } + if($silent eq "imagetagbig") { + $colors->{fg_color} = "#000000"; # visible color for text mode + $u = ""; + } + + for($n = 0; $n < scalar(my @wl = split(',', $wowza->{list})); $n++) { + for($n2 = 1; $n2 <= 5; $n2++) { + $str = $u . $package . $n . $n2 . "." . $tf->{when} . ".png"; + push(@PNG, $str); + unlink("$PNG_DIR" . $str); + if(lc($config->{enable_zoom}) eq "y") { + $str = $u . $package . $n . $n2 . "z." . $tf->{when} . ".png"; + push(@PNGz, $str); + unlink("$PNG_DIR" . $str); + } + } + } + + $e = 0; + foreach my $url (my @wl = split(',', $wowza->{list})) { + $url = trim($url); + if($e) { + print("
\n"); + } + if($title) { + main::graph_header($title, 2); + } + undef(@riglim); + if(trim($rigid[0]) eq 1) { + push(@riglim, "--upper-limit=" . trim($limit[0])); + } else { + if(trim($rigid[0]) eq 2) { + push(@riglim, "--upper-limit=" . trim($limit[0])); + push(@riglim, "--rigid"); + } + } + undef(@tmp); + undef(@tmpz); + $n = 0; + foreach my $w (split(',', $wowza->{desc}->{$url})) { + $w = trim($w); + $str = sprintf("%-15s", substr($w, 0, 15)); + $stack = ""; + if(lc($wowza->{graph_mode}) eq "s") { + $stack = ":STACK"; + } + push(@tmp, "AREA:wms" . $e . "_a$n" . $AC[$n] . ":$str" . $stack); + push(@tmpz, "AREA:wms" . $e . "_a$n" . $AC[$n] . ":$w" . $stack); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":LAST: Cur\\:%4.0lf"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":AVERAGE: Avg\\:%4.0lf"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":MIN: Min\\:%4.0lf"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":MAX: Max\\:%4.0lf\\n"); + $n++; + } + if(lc($wowza->{graph_mode}) ne "s") { + foreach my $w (split(',', $wowza->{desc}->{$url})) { + push(@tmp, "LINE1:wms" . $e . "_a$n" . $LC[$n]); + push(@tmpz, "LINE2:wms" . $e . "_a$n" . $LC[$n]); + } + } + + if($title) { + print(" \n"); + print(" \n"); + } + ($width, $height) = split('x', $config->{graph_size}->{main}); + RRDs::graph("$PNG_DIR" . "$PNG[$e * 5]", + "--title=$config->{graphs}->{_wowza1} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=Connections", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0=$rrd:wms" . $e . "_a0_conncur:AVERAGE", + "DEF:wms" . $e . "_a1=$rrd:wms" . $e . "_a1_conncur:AVERAGE", + "DEF:wms" . $e . "_a2=$rrd:wms" . $e . "_a2_conncur:AVERAGE", + "DEF:wms" . $e . "_a3=$rrd:wms" . $e . "_a3_conncur:AVERAGE", + "DEF:wms" . $e . "_a4=$rrd:wms" . $e . "_a4_conncur:AVERAGE", + "DEF:wms" . $e . "_a5=$rrd:wms" . $e . "_a5_conncur:AVERAGE", + "DEF:wms" . $e . "_a6=$rrd:wms" . $e . "_a6_conncur:AVERAGE", + "DEF:wms" . $e . "_a7=$rrd:wms" . $e . "_a7_conncur:AVERAGE", + @tmp); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . "$PNG[$e * 5]: $err\n") if $err; + if(lc($config->{enable_zoom}) eq "y") { + ($width, $height) = split('x', $config->{graph_size}->{zoom}); + RRDs::graph("$PNG_DIR" . "$PNGz[$e * 5]", + "--title=$config->{graphs}->{_wowza1} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=Connections", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0=$rrd:wms" . $e . "_a0_conncur:AVERAGE", + "DEF:wms" . $e . "_a1=$rrd:wms" . $e . "_a1_conncur:AVERAGE", + "DEF:wms" . $e . "_a2=$rrd:wms" . $e . "_a2_conncur:AVERAGE", + "DEF:wms" . $e . "_a3=$rrd:wms" . $e . "_a3_conncur:AVERAGE", + "DEF:wms" . $e . "_a4=$rrd:wms" . $e . "_a4_conncur:AVERAGE", + "DEF:wms" . $e . "_a5=$rrd:wms" . $e . "_a5_conncur:AVERAGE", + "DEF:wms" . $e . "_a6=$rrd:wms" . $e . "_a6_conncur:AVERAGE", + "DEF:wms" . $e . "_a7=$rrd:wms" . $e . "_a7_conncur:AVERAGE", + @tmpz); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . "$PNGz[$e * 5]: $err\n") if $err; + } + $e2 = $e + 1; + if($title || ($silent =~ /imagetag/ && $graph =~ /wowza$e2/)) { + if(lc($config->{enable_zoom}) eq "y") { + if(lc($config->{disable_javascript_void}) eq "y") { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5] . "\">\n"); + } + else { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5] . "','','width=" . ($width + 115) . ",height=" . ($height + 100) . ",scrollbars=0,resizable=0'))\">\n"); + } + } else { + print(" \n"); + } + } + + undef(@riglim); + if(trim($rigid[1]) eq 1) { + push(@riglim, "--upper-limit=" . trim($limit[1])); + } else { + if(trim($rigid[1]) eq 2) { + push(@riglim, "--upper-limit=" . trim($limit[1])); + push(@riglim, "--rigid"); + } + } + undef(@tmp); + undef(@tmpz); + $n = 0; + foreach my $w (split(',', $wowza->{desc}->{$url})) { + $w = trim($w); + $str = sprintf("%-15s", $w); + push(@tmp, "LINE2:wms" . $e . "_a$n" . $LC[$n] . ":$str"); + push(@tmpz, "LINE2:wms" . $e . "_a$n" . $LC[$n] . ":$w"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":LAST: Cur\\:%3.0lf"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":AVERAGE: Avg\\:%3.0lf"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":MIN: Min\\:%3.0lf"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":MAX: Max\\:%3.0lf\\n"); + push(@CDEF, "CDEF:wms" . $e . "_a$n=wms" . $e . "_a$n" . "i,wms" . $e . "_a$n" . "o,+"); + $n++; + } + ($width, $height) = split('x', $config->{graph_size}->{main}); + RRDs::graph("$PNG_DIR" . $PNG[$e * 5 + 1], + "--title=$config->{graphs}->{_wowza2} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=bytes/s", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0i=$rrd:wms" . $e . "_a0_minbrt:AVERAGE", + "DEF:wms" . $e . "_a0o=$rrd:wms" . $e . "_a0_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a1i=$rrd:wms" . $e . "_a1_minbrt:AVERAGE", + "DEF:wms" . $e . "_a1o=$rrd:wms" . $e . "_a1_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a2i=$rrd:wms" . $e . "_a2_minbrt:AVERAGE", + "DEF:wms" . $e . "_a2o=$rrd:wms" . $e . "_a2_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a3i=$rrd:wms" . $e . "_a3_minbrt:AVERAGE", + "DEF:wms" . $e . "_a3o=$rrd:wms" . $e . "_a3_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a4i=$rrd:wms" . $e . "_a4_minbrt:AVERAGE", + "DEF:wms" . $e . "_a4o=$rrd:wms" . $e . "_a4_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a5i=$rrd:wms" . $e . "_a5_minbrt:AVERAGE", + "DEF:wms" . $e . "_a5o=$rrd:wms" . $e . "_a5_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a6i=$rrd:wms" . $e . "_a6_minbrt:AVERAGE", + "DEF:wms" . $e . "_a6o=$rrd:wms" . $e . "_a6_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a7i=$rrd:wms" . $e . "_a7_minbrt:AVERAGE", + "DEF:wms" . $e . "_a7o=$rrd:wms" . $e . "_a7_moutbrt:AVERAGE", + @CDEF, + @tmp); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . $PNG[$e * 5 + 1] . ": $err\n") if $err; + if(lc($config->{enable_zoom}) eq "y") { + ($width, $height) = split('x', $config->{graph_size}->{zoom}); + RRDs::graph("$PNG_DIR" . $PNGz[$e * 5 + 1], + "--title=$config->{graphs}->{_wowza2} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=bytes/s", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0i=$rrd:wms" . $e . "_a0_minbrt:AVERAGE", + "DEF:wms" . $e . "_a0o=$rrd:wms" . $e . "_a0_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a1i=$rrd:wms" . $e . "_a1_minbrt:AVERAGE", + "DEF:wms" . $e . "_a1o=$rrd:wms" . $e . "_a1_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a2i=$rrd:wms" . $e . "_a2_minbrt:AVERAGE", + "DEF:wms" . $e . "_a2o=$rrd:wms" . $e . "_a2_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a3i=$rrd:wms" . $e . "_a3_minbrt:AVERAGE", + "DEF:wms" . $e . "_a3o=$rrd:wms" . $e . "_a3_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a4i=$rrd:wms" . $e . "_a4_minbrt:AVERAGE", + "DEF:wms" . $e . "_a4o=$rrd:wms" . $e . "_a4_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a5i=$rrd:wms" . $e . "_a5_minbrt:AVERAGE", + "DEF:wms" . $e . "_a5o=$rrd:wms" . $e . "_a5_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a6i=$rrd:wms" . $e . "_a6_minbrt:AVERAGE", + "DEF:wms" . $e . "_a6o=$rrd:wms" . $e . "_a6_moutbrt:AVERAGE", + "DEF:wms" . $e . "_a7i=$rrd:wms" . $e . "_a7_minbrt:AVERAGE", + "DEF:wms" . $e . "_a7o=$rrd:wms" . $e . "_a7_moutbrt:AVERAGE", + @CDEF, + @tmpz); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . $PNGz[$e * 5 + 1] . ": $err\n") if $err; + } + $e2 = $e + 2; + if($title || ($silent =~ /imagetag/ && $graph =~ /wowza$e2/)) { + if(lc($config->{enable_zoom}) eq "y") { + if(lc($config->{disable_javascript_void}) eq "y") { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5 + 1] . "\">\n"); + } + else { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5 + 1] . "','','width=" . ($width + 115) . ",height=" . ($height + 100) . ",scrollbars=0,resizable=0'))\">\n"); + } + } else { + print(" \n"); + } + } + + if($title) { + print(" \n"); + print(" \n"); + } + + undef(@riglim); + if(trim($rigid[2]) eq 1) { + push(@riglim, "--upper-limit=" . trim($limit[2])); + } else { + if(trim($rigid[2]) eq 2) { + push(@riglim, "--upper-limit=" . trim($limit[2])); + push(@riglim, "--rigid"); + } + } + undef(@tmp); + undef(@tmpz); + $n = 0; + foreach my $w (split(',', $wowza->{desc}->{$url})) { + $w = trim($w); + $str = sprintf("%-13s", substr($w, 0, 13)); + push(@tmp, "LINE2:wms" . $e . "_a$n" . $LC[$n] . ":$str\\g"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":LAST:\\:%3.0lf "); + push(@tmpz, "LINE2:wms" . $e . "_a$n" . $LC[$n] . ":$w"); + $n++; + push(@tmp, "COMMENT: \\n") if !($n + 1) % 2; + } + ($width, $height) = split('x', $config->{graph_size}->{small}); + RRDs::graph("$PNG_DIR" . $PNG[$e * 5 + 2], + "--title=$config->{graphs}->{_wowza3} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=connections/s", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0=$rrd:wms" . $e . "_a0_conntacc:AVERAGE", + "DEF:wms" . $e . "_a1=$rrd:wms" . $e . "_a1_conntacc:AVERAGE", + "DEF:wms" . $e . "_a2=$rrd:wms" . $e . "_a2_conntacc:AVERAGE", + "DEF:wms" . $e . "_a3=$rrd:wms" . $e . "_a3_conntacc:AVERAGE", + "DEF:wms" . $e . "_a4=$rrd:wms" . $e . "_a4_conntacc:AVERAGE", + "DEF:wms" . $e . "_a5=$rrd:wms" . $e . "_a5_conntacc:AVERAGE", + "DEF:wms" . $e . "_a6=$rrd:wms" . $e . "_a6_conntacc:AVERAGE", + "DEF:wms" . $e . "_a7=$rrd:wms" . $e . "_a7_conntacc:AVERAGE", + @tmp); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . $PNG[$e * 5 + 2] . ": $err\n") if $err; + if(lc($config->{enable_zoom}) eq "y") { + ($width, $height) = split('x', $config->{graph_size}->{zoom}); + RRDs::graph("$PNG_DIR" . $PNGz[$e * 5 + 2], + "--title=$config->{graphs}->{_wowza3} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=connections/s", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0=$rrd:wms" . $e . "_a0_conntacc:AVERAGE", + "DEF:wms" . $e . "_a1=$rrd:wms" . $e . "_a1_conntacc:AVERAGE", + "DEF:wms" . $e . "_a2=$rrd:wms" . $e . "_a2_conntacc:AVERAGE", + "DEF:wms" . $e . "_a3=$rrd:wms" . $e . "_a3_conntacc:AVERAGE", + "DEF:wms" . $e . "_a4=$rrd:wms" . $e . "_a4_conntacc:AVERAGE", + "DEF:wms" . $e . "_a5=$rrd:wms" . $e . "_a5_conntacc:AVERAGE", + "DEF:wms" . $e . "_a6=$rrd:wms" . $e . "_a6_conntacc:AVERAGE", + "DEF:wms" . $e . "_a7=$rrd:wms" . $e . "_a7_conntacc:AVERAGE", + @tmpz); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . $PNGz[$e * 5 + 2] . ": $err\n") if $err; + } + $e2 = $e + 3; + if($title || ($silent =~ /imagetag/ && $graph =~ /wowza$e3/)) { + if(lc($config->{enable_zoom}) eq "y") { + if(lc($config->{disable_javascript_void}) eq "y") { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5 + 2] . "\">\n"); + } + else { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5 + 2] . "','','width=" . ($width + 115) . ",height=" . ($height + 100) . ",scrollbars=0,resizable=0'))\">\n"); + } + } else { + print(" \n"); + } + } + + undef(@riglim); + if(trim($rigid[3]) eq 1) { + push(@riglim, "--upper-limit=" . trim($limit[3])); + } else { + if(trim($rigid[3]) eq 2) { + push(@riglim, "--upper-limit=" . trim($limit[3])); + push(@riglim, "--rigid"); + } + } + undef(@tmp); + undef(@tmpz); + $n = 0; + foreach my $w (split(',', $wowza->{desc}->{$url})) { + $w = trim($w); + $str = sprintf("%-13s", substr($w, 0, 13)); + push(@tmp, "LINE2:wms" . $e . "_a$n" . $LC[$n] . ":$str\\g"); + push(@tmp, "GPRINT:wms" . $e . "_a$n" . ":LAST:\\:%3.0lf "); + push(@tmpz, "LINE2:wms" . $e . "_a$n" . $LC[$n] . ":$w"); + $n++; + push(@tmp, "COMMENT: \\n") if !($n + 1) % 2; + } + ($width, $height) = split('x', $config->{graph_size}->{small}); + RRDs::graph("$PNG_DIR" . $PNG[$e * 5 + 3], + "--title=$config->{graphs}->{_wowza4} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=connections/s", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0=$rrd:wms" . $e . "_a0_conntrej:AVERAGE", + "DEF:wms" . $e . "_a1=$rrd:wms" . $e . "_a1_conntrej:AVERAGE", + "DEF:wms" . $e . "_a2=$rrd:wms" . $e . "_a2_conntrej:AVERAGE", + "DEF:wms" . $e . "_a3=$rrd:wms" . $e . "_a3_conntrej:AVERAGE", + "DEF:wms" . $e . "_a4=$rrd:wms" . $e . "_a4_conntrej:AVERAGE", + "DEF:wms" . $e . "_a5=$rrd:wms" . $e . "_a5_conntrej:AVERAGE", + "DEF:wms" . $e . "_a6=$rrd:wms" . $e . "_a6_conntrej:AVERAGE", + "DEF:wms" . $e . "_a7=$rrd:wms" . $e . "_a7_conntrej:AVERAGE", + @tmp); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . $PNG[$e * 5 + 3] . ": $err\n") if $err; + if(lc($config->{enable_zoom}) eq "y") { + ($width, $height) = split('x', $config->{graph_size}->{zoom}); + RRDs::graph("$PNG_DIR" . $PNGz[$e * 5 + 3], + "--title=$config->{graphs}->{_wowza4} ($tf->{nwhen}$tf->{twhen})", + "--start=-$tf->{nwhen}$tf->{twhen}", + "--imgformat=PNG", + "--vertical-label=connections/s", + "--width=$width", + "--height=$height", + @riglim, + "--lower-limit=0", + @{$cgi->{version12}}, + @{$colors->{graph_colors}}, + "DEF:wms" . $e . "_a0=$rrd:wms" . $e . "_a0_conntrej:AVERAGE", + "DEF:wms" . $e . "_a1=$rrd:wms" . $e . "_a1_conntrej:AVERAGE", + "DEF:wms" . $e . "_a2=$rrd:wms" . $e . "_a2_conntrej:AVERAGE", + "DEF:wms" . $e . "_a3=$rrd:wms" . $e . "_a3_conntrej:AVERAGE", + "DEF:wms" . $e . "_a4=$rrd:wms" . $e . "_a4_conntrej:AVERAGE", + "DEF:wms" . $e . "_a5=$rrd:wms" . $e . "_a5_conntrej:AVERAGE", + "DEF:wms" . $e . "_a6=$rrd:wms" . $e . "_a6_conntrej:AVERAGE", + "DEF:wms" . $e . "_a7=$rrd:wms" . $e . "_a7_conntrej:AVERAGE", + @tmpz); + $err = RRDs::error; + print("ERROR: while graphing $PNG_DIR" . $PNGz[$e * 5 + 3] . ": $err\n") if $err; + } + $e2 = $e + 4; + if($title || ($silent =~ /imagetag/ && $graph =~ /wowza$e3/)) { + if(lc($config->{enable_zoom}) eq "y") { + if(lc($config->{disable_javascript_void}) eq "y") { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5 + 3] . "\">\n"); + } + else { + print(" {url} . "/" . $config->{imgs_dir} . $PNGz[$e * 5 + 3] . "','','width=" . ($width + 115) . ",height=" . ($height + 100) . ",scrollbars=0,resizable=0'))\">\n"); + } + } else { + print(" \n"); + } + } + + + + + + if($title) { + print(" \n"); + print(" \n"); + + print(" \n"); + print " \n"; + print " \n"; + print " \n"; + print "   $url\n"; + print " \n"; + print " \n"; + print(" \n"); + main::graph_footer(); + } + $e++; + } + print("
\n"); + return; +} + +1; diff --git a/monitorix.conf b/monitorix.conf index ac86194..cade2ee 100644 --- a/monitorix.conf +++ b/monitorix.conf @@ -84,6 +84,7 @@ secure_log_date_format = %b %e fail2ban = n icecast = n raspberrypi = n + wowza = n int = y @@ -435,6 +436,19 @@ secure_log_date_format = %b %e +# WOWZA graph +# ----------------------------------------------------------------------------- + + list = http://localhost:8086/connectioncounts + + http://localhost:8086/connectioncounts = channel1, channel2 + + graph_mode = r + rigid = 0, 0, 0, 0, 0 + limit = 100, 100, 100, 100, 100 + + + # INT graph # ----------------------------------------------------------------------------- @@ -531,7 +545,7 @@ logo_bottom = logo_bot.png remote = 300x100 -graph_name = system, kern, proc, hptemp, lmsens, nvidia, disk, fs, net, serv, mail, port, user, ftp, apache, nginx, lighttpd, mysql, squid, nfss, nfsc, bind, ntp, fail2ban, icecast, raspberrypi, int +graph_name = system, kern, proc, hptemp, lmsens, nvidia, disk, fs, net, serv, mail, port, user, ftp, apache, nginx, lighttpd, mysql, squid, nfss, nfsc, bind, ntp, fail2ban, icecast, raspberrypi, wowza, int system = System load average and usage @@ -560,6 +574,7 @@ graph_name = system, kern, proc, hptemp, lmsens, nvidia, disk, fs, net, serv, ma fail2ban = Fail2ban statistics icecast = Icecast Streaming Media Server raspberrypi = Raspberry Pi sensor statistics + wowza = Wowza Media Server int = Devices interrupt activity @@ -661,6 +676,11 @@ graph_name = system, kern, proc, hptemp, lmsens, nvidia, disk, fs, net, serv, ma _raspberrypi1 = Clock frequency _raspberrypi2 = Temperatures _raspberrypi3 = Voltages + _wowza1 = Current connections + _wowza2 = Messages bytes rate + _wowza3 = Connections accepted + _wowza4 = Connections rejected + _wowza5 = Stream _int1 = Interrupt activity _int2 = Core activity _int3 = Interrupt activity