Changeset 3322

Timestamp:

01/19/10 22:00:10 (2 years ago)

Author:

steve.schnepp

Message:

Initial add of update_rate. Still quite rough (uses tie() and files in /tmp)

Files:

• people/snide/pre_1.5/master/lib/Munin/Master/UpdateWorker.pm (modified) (2 diffs)

people/snide/pre_1.5/master/lib/Munin/Master/UpdateWorker.pm

@@ -81 +81 @@
-                    WARN "[WARNING] Service $plugin on $nodedesignation ".
-                        "returned no config";
+                    next;
+                }
+
+                # Check if this plugin has to be updated
+                my $update_rate_in_seconds = get_global_service_value(\%service_config, $plugin, "update_rate", 0); # default is 0 sec : always update when asked
+                DEBUG "[DEBUG] update_rate $update_rate_in_seconds for $plugin on $nodedesignation";
+                if ($update_rate_in_seconds 
+                        && is_fresh_enough($nodedesignation, $plugin, $update_rate_in_seconds)) {
+                    # It's fresh enough, skip this $service
+                    DEBUG "[DEBUG] $plugin is fresh enough, not updating it";
-                    next;
-                }
@@ -148 +158 @@
-        service_configs => \%all_service_configs,
-    }
+}
+
+sub get_global_service_value {
+        my ($service_config, $service, $conf_field_name, $default) = @_;
+        foreach my $array (@{$service_config->{global}{$service}}) {
+                my ($field_name, $field_value) = @$array;
+                if ($field_name eq $conf_field_name) {
+                        return $field_value;
+                }
+        }
+
+        return $default;
+}
+
+sub is_fresh_enough {
+        my ($nodedesignation, $service, $update_rate_in_seconds) = @_;
+
+        my $key = "$nodedesignation/$service";
+        DEBUG "is_fresh_enough asked for $key with a rate of $update_rate_in_seconds";
+
+        my %last_updated;
+        # XXX - ugly hack. Should be refactored to use a a common state provider
+
+        use Fcntl;   # For O_RDWR, O_CREAT, etc.
+        use NDBM_File;
+        tie(%last_updated, 'NDBM_File', '/tmp/munin_plugins_last_updated', O_RDWR|O_CREAT, 0666) or ERROR "$!";
+        DEBUG "last_updated{$key}: " . $last_updated{$key};
+        my @last = split(/ /, $last_updated{$key});
+   
+        use Time::HiRes qw(gettimeofday tv_interval);   
+        my $now = [ gettimeofday ];
+
+        my $age = tv_interval(\@last, $now);    
+        DEBUG "last: " . Dumper(\@last) . ", now: " . Dumper($now) . ", age: $age";
+        my $is_fresh_enough = ($age < $update_rate_in_seconds);
+        DEBUG "is_fresh_enough  $is_fresh_enough";
+
+        if (! $is_fresh_enough) {
+                DEBUG "new value: " . join(" ", @$now);
+                $last_updated{$key} = join(" ", @$now);
+        }
+
+        untie(%last_updated);
+
+        return $is_fresh_enough;
-}
-