diff --git a/lib/wowza.pm b/lib/wowza.pm index 29082dd..11fb840 100644 --- a/lib/wowza.pm +++ b/lib/wowza.pm @@ -37,9 +37,15 @@ sub wowza_init { my $info; my @ds; + my @rra; my @tmp; my $n; + my @average; + my @min; + my @max; + my @last; + if(-e $rrd) { $info = RRDs::info($rrd); for my $key (keys %$info) { @@ -48,15 +54,30 @@ sub wowza_init { push(@ds, substr($key, 3, index($key, ']') - 3)); } } + if(index($key, 'rra[') == 0) { + if(index($key, '.rows') != -1) { + push(@rra, substr($key, 4, index($key, ']') - 4)); + } + } } 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."); + logger("$myself: Detected size mismatch between 'list' (" . scalar(my @il = split(',', $wowza->{list})) . ") and $rrd (" . scalar(@ds) / 130 . "). Resizing it accordingly. All historical data will be lost. Backup file created."); + rename($rrd, "$rrd.bak"); + } + if(scalar(@rra) != 12 + (4 * $config->{max_historic_years})) { + logger("$myself: Detected size mismatch between 'max_historic_years' (" . $config->{max_historic_years} . ") and $rrd (" . ((scalar(@rra) -12) / 4) . "). Resizing it accordingly. All historical data will be lost. Backup file created."); rename($rrd, "$rrd.bak"); } } if(!(-e $rrd)) { logger("Creating '$rrd' file."); + for($n = 1; $n <= $config->{max_historic_years}; $n++) { + push(@average, "RRA:AVERAGE:0.5:1440:" . (365 * $n)); + push(@min, "RRA:MIN:0.5:1440:" . (365 * $n)); + push(@max, "RRA:MAX:0.5:1440:" . (365 * $n)); + push(@last, "RRA:LAST:0.5:1440:" . (365 * $n)); + } 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"); @@ -196,19 +217,19 @@ sub wowza_init { "RRA:AVERAGE:0.5:1:1440", "RRA:AVERAGE:0.5:30:336", "RRA:AVERAGE:0.5:60:744", - "RRA:AVERAGE:0.5:1440:365", + @average, "RRA:MIN:0.5:1:1440", "RRA:MIN:0.5:30:336", "RRA:MIN:0.5:60:744", - "RRA:MIN:0.5:1440:365", + @min, "RRA:MAX:0.5:1:1440", "RRA:MAX:0.5:30:336", "RRA:MAX:0.5:60:744", - "RRA:MAX:0.5:1440:365", + @max, "RRA:LAST:0.5:1:1440", "RRA:LAST:0.5:30:336", "RRA:LAST:0.5:60:744", - "RRA:LAST:0.5:1440:365", + @last, ); }; my $err = RRDs::error;