Changeset 1255

Timestamp:

11/18/06 02:10:32 (5 years ago)

Author:

janl

Message:

Think Munin.pm is free of server only functions now. Keeping the config handling ones as nodes will probably have to be more configured soon.

Files:

• people/janl/src/libperl/Munin.pm (modified) (15 diffs)
• people/janl/src/libperl/Munin/Server.pm (modified) (10 diffs)

people/janl/src/libperl/Munin.pm

@@ -1 +1 @@
-package Munin;
-
-#
-# Copyright (C) 2003-2006 Jimmy Olsen, Audun Ytterdal, Nicolai Langfeldt
@@ -46 +45 @@
-my $configfile = '@@CONFDIR@@/munin.conf';
-@legalfetch  = qw(.value);
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
-
-# Fields to copy when "aliasing" a field
@@ -61 +59 @@
-my $PREFIX = '@@PREFIX@@';
-$ENV{'MUNIN_PREFIX'} = $PREFIX;
-
+           
-print "CONFDIR: $CONFDIR!\n";
-$ENV{'MUNIN_CONFDIR'} = $CONFDIR;
@@ -70 +68 @@
-my $DOCDIR = '@@DOCDIR@@';
-$ENV{'MUNIN_DOCDIR'} = $DOCDIR;
-
+          
-$ENV{'MUNIN_LIBDIR'} = $LIBDIR;
-my $HTMLDIR = '@@HTMLDIR@@';
@@ -78 +76 @@
-my $DBDIR = '@@DBDIR@@';
-$ENV{'MUNIN_DBDIR'} = $DBDIR;
-
- 
+    
+
-my $MANDIR = '@@MANDIR@@';
-$ENV{'MUNIN_MANDIR'} = $MANDIR;
@@ -85 +83 @@
-$ENV{'MUNIN_LOGDIR'} = $LOGDIR;
-my $STATEDIR = '@@STATEDIR@@';           # This is for .pid files
-     # This is for .pid files
+
-my $USER = '@@USER@@';                   # User munin runs as (mostly)
-              # User munin runs as (mostly)
+
-my $GROUP = '@@GROUP@@';                 # Group ditto
-            # Group ditto
+
-my $PLUGINUSER = '@@PLUGINUSER@@';       # Default user for plugin running
-  # Default user for plugin running
+
-$ENV{'MUNIN_VERSION'}    = $VERSION;
-my $PERL = '@@PERL@@';
@@ -111 +109 @@
-
-sub munin_createlock {
-
-    # Create lock file, fail and die if not possible.
+    
-    my ($lockname) = @_;
-    if ( sysopen( LOCK, $lockname, O_WRONLY | O_CREAT | O_EXCL ) ) {
@@ -125 +123 @@
-
-sub munin_removelock {
-
-    # Remove lock or die trying.
+    
-    my ($lockname) = @_;
-    unlink $lockname
@@ -133 +131 @@
-
-sub munin_runlock {
-
-    # Simple get lock: Get lock or die trying
+    
-    my ($lockname) = @_;
-    unless ( &munin_getlock($lockname) ) {
@@ -143 +141 @@
-}
-
+
-sub munin_getlock {
-
-    # Complicated get lock: Try getting it, if it's taken see if the
-    # invoking process is still alive.
-    my ($lockname) = @_;
-    if ( -f $lockname ) {
-
-        # Is the lockpid alive?
-        # To check this is inteligent and so on.  It also makes for a
@@ -172 +169 @@
-} ## end sub munin_getlock
-
-sub munin_delete {
-    # Delete a domain, and corresponding set of nodes from config tree
-    my ( $config, $data ) = @_;
-    for my $domain ( keys %{ $data->{domain} } ) {
-        if ( !$config->{domain}->{$domain} ) {
-            ::logger("Removing domain: $domain");
-            delete( $data->{domain}->{$domain} );
-            next;
-        }
-        for my $node ( keys %{ $data->{domain}->{$domain}->{node} } ) {
-            unless ( $config->{domain}->{$domain}->{node}->{$node} ) {
-                ::logger("Removing node from $domain: $node");
-                delete( $data->{domain}->{$domain}->{node}->{$node} );
-            }
-        }
-    }
-    return ($data);
-}
-
-sub munin_overwrite {
@@ -224 +203 @@
-} ## end sub munin_get_picture_filename
-
-sub munin_get_filename {
-    my ( $config, $domain, $node, $service, $field ) = @_;
-    return (
-        $config->{'dbdir'} . "/$domain/$node-$service-$field-"
-          . lc substr(
-            (
-                $config->{domain}->{$domain}->{node}->{$node}->{client}
-                  ->{$service}->{ $field . ".type" } || "GAUGE"
-            ),
-            0, 1
-          )
-          . ".rrd"
-    );
-}
-
-sub munin_get_bool {
+    # Like munin_get but interpret the value as a boolean value.
-    my $conf    = shift;
-    my $field   = shift;
@@ -274 +240 @@
-} ## end sub munin_get_bool
-
+
-sub munin_get_bool_val {
+    # Interpret some string as a boolean value.
-    my $field   = shift;
-    my $default = shift;
@@ -306 +274 @@
-} ## end sub munin_get_bool_val
-
+
-sub munin_get {
-
-    # Fetch value from configuration tree.  Start at deepest level and
-    # "recurse" upwards.  This allows defaulting at shalow levels and
-    # specific overrides at deeper levels.
+    
-    my $conf    = shift;
-    my $field   = shift;
@@ -318 +287 @@
-    my $service = shift;
-    my $plot    = shift;
+    
-    if ( defined $field ) {
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-        return $conf->{domain}->{$domain}->{node}->{$node}->{$field}
-
-defined $domain
-and defined $node
-and defined $conf->{domain}->{$domain}->{node}->{$node}->{$field} );
+defined $domain and
+  defined $node and
+  defined($conf->{domain}->{$domain}->{node}->{$node}->{$field}) );
+  
-        return $conf->{domain}->{$domain}->{$field}
-
-defined $domain
-and defined $conf->{domain}->{$domain}->{$field} );
+defined $domain and
+  defined $conf->{domain}->{$domain}->{$field} );
+  
-        return $conf->{$field}
-          if ( defined $conf->{$field} );
+          
-        return $default;
-
+
+
+
-        return $conf->{domain}->{$domain}->{node}->{$node}->{client}->{$service}
-
-defined $domain
-and defined $node
-and defined $service
-and defined $conf->{domain}->{$domain}->{node}->{$node}->{client}
-->{$service} );
+defined $domain and
+  defined $node and
+  defined $service and
+  defined($conf->{domain}->{$domain}->{node}->{$node}->{client}->
+        {$service}) );
+        
-        return $conf->{domain}->{$domain}->{node}->{$node}
-
-defined $domain
-and defined $node
-and defined $conf->{domain}->{$domain}->{node}->{$node} );
+defined $domain and
+  defined $node and
+  defined $conf->{domain}->{$domain}->{node}->{$node} );
+  
-        return $conf->{domain}->{$domain}
-
-defined $domain
-
-
-  if ( defined $conf );
+defined $domain and
+  defined $conf->{domain}->{$domain} );
+
+ if ( defined $conf );
+
-        return $default;
-    } ## end else [ if ( defined $field )
-} ## end sub munin_get
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
-1;
-

people/janl/src/libperl/Munin/Server.pm

@@ -12 +12 @@
-
-@EXPORT = qw(
-
-             $configfile @legal %legal_expanded @copy_fields
-             munin_readconfig munin_parse_config munin_trend
-             munin_fetch munin_nscasend
-
-            );
-
@@ -34 +32 @@
-            category_order version tls_certificate tls_private_key
-            tls_pem tls_verify_certificate tls_verify_depth
-
+
+
-
-push(@legal,@Munin::legalfetch,@Munin::legalconfig);
@@ -128 +127 @@
-}
-
+
-sub munin_get_var_path
-{
@@ -165 +165 @@
-    return undef;
-}
+
-
-sub munin_set_var_path {
@@ -218 +219 @@
-    return $hash;
-}
+
-
-sub munin_writeconfig_loop {
@@ -264 +266 @@
-        die "Fatal error: Could not open \"$datafilename\" for writing: $!"
-          unless open ($fh, ">$datafilename");
-        }
-    }
-
@@ -292 +293 @@
-}
-
+
-sub munin_fetch {
-    # Fetch data from a rrd file.
@@ -297 +299 @@
-    my ($start,$step,$names,$data) = RRDs::fetch $file,$type || "AVERAGE";
-    if (!defined $data) {
-
+
+
-        return undef;
-    }
@@ -322 +325 @@
-
-
-
-sub munin_nscasend {
-    my ($name,$service,$label,$level,$comment) = @_;
-
-
-
+
+
+
+
-    }
-    if ($label) {
-
+::
-        print ("$name;$service: $label;$level;$comment\n") if $::DEBUG;
-    } else {
-
+::
-        print ("$name;$service;$level;$comment\n") if $::DEBUG;
-    }
@@ -347 +351 @@
-
-
+sub munin_delete {
+    # Delete a domain, and corresponding set of nodes from config tree
+    my ( $config, $data ) = @_;
+    for my $domain ( keys %{ $data->{domain} } ) {
+        if ( !$config->{domain}->{$domain} ) {
+            ::logger("Removing domain: $domain");
+            delete( $data->{domain}->{$domain} );
+            next;
+        }
+        for my $node ( keys %{ $data->{domain}->{$domain}->{node} } ) {
+            unless ( $config->{domain}->{$domain}->{node}->{$node} ) {
+                ::logger("Removing node from $domain: $node");
+                delete( $data->{domain}->{$domain}->{node}->{$node} );
+            }
+        }
+    }
+    return ($data);
+}
+
+
+sub munin_get_filename {
+    my ( $config, $domain, $node, $service, $field ) = @_;
+    return (
+        $config->{'dbdir'} . "/$domain/$node-$service-$field-"
+          . lc substr(
+                      ($config->{domain}->{$domain}->{node}->{$node}->{client}->
+                       {$service}->{ $field . ".type" } || "GAUGE"),
+            0, 1 ) . ".rrd" );
+}
+
+sub munin_node_status {
+    # Return node status.  Does this propagate plugin status to nodes to
+    # higher levels?
+    # FIXME: Complete documentation if munin_node_status
+    my ( $config, $limits, $domain, $node, $check_draw ) = @_;
+    my $state = "ok";
+    return undef unless defined $config->{domain}->{$domain}->{node}->{$node};
+    my $snode = $config->{domain}->{$domain}->{node}->{$node};
+    foreach my $service ( keys %{$snode} ) {
+        my $fres =
+          &munin_service_status(
+            $config, $limits, $domain, $node, $service,
+            $check_draw );
+        if ( defined $fres ) {
+            if ( $fres eq "critical" ) {
+                $state = $fres;
+                last;
+            } elsif ( $fres eq "warning" ) {
+                $state = $fres;
+            }
+        }
+    }
+    return $state;
+} ## end sub munin_node_status
+
+
+sub munin_category_status {
+    # Get status of graph category.  Is there any kind of status propagation
+    # here?
+    # FIXME: Complete documentation of munin_category_status
+    my ( $config, $limits, $domain, $node, $category, $check_draw ) = @_;
+    my $state = "ok";
+    return undef unless defined $config->{domain}->{$domain}->{node}->{$node};
+    my $snode = $config->{domain}->{$domain}->{node}->{$node};
+    foreach my $service ( keys %{ $snode->{client} } ) {
+        next
+          if (
+            ( not defined $snode->{client}->{$service}->{graph_category} )
+            and $category ne 'other' );
+        next
+          if (
+            ( defined $snode->{client}->{$service}->{graph_category} )
+            and ( $snode->{client}->{$service}->{graph_category} ne $category )
+          );
+        my $fres =
+          &munin_service_status(
+            $config, $limits, $domain, $node, $service,
+            $check_draw );
+        if ( defined $fres ) {
+            if ( $fres eq "critical" ) {
+                $state = $fres;
+                last;
+            } elsif ( $fres eq "warning" ) {
+                $state = $fres;
+            }
+        }
+    } ## end foreach my $service ( keys ...
+    return $state;
+} ## end sub munin_category_status
+
+
+sub munin_service_status {
+    # Return status of service.
+    my ( $config, $limits, $domain, $node, $service, $check_draw ) = @_;
+    my $state = "ok";
+    return undef
+      unless defined $config->{domain}->{$domain}->{node}->{$node}->
+        {client}->{$service};
+    foreach my $key (
+        keys
+        %{$config->{domain}->{$domain}->{node}->{$node}->{client}->{$service}} )
+    {
+        next unless $key =~ /^([^\.]+)\.label$/;
+        my $field = $1;
+        my $fres  =
+          &munin_field_status(
+            $config, $limits, $domain, $node, $service,
+            $field, $check_draw );
+        if ( defined $fres ) {
+            if ( $fres eq "critical" ) {
+                $state = $fres;
+                last;
+            } elsif ( $fres eq "warning" ) {
+                $state = $fres;
+            }
+        }
+    } ## end foreach my $key ( keys %{ $config...
+    return $state;
+} ## end sub munin_service_status
+
+
+sub munin_field_status {
+    # Something to do with warning and critical levels.
+    # Appears to not set warning/critical state if "nagios" is turned
+    # off.  Isn't that a bit odd?
+    my ( $config, $limits, $domain, $node, $service, $field, $check_draw ) = @_;
+    my $state = undef;
+
+    # Return undef if nagios is turned off, or the field doesn't have any limits
+    unless ((defined($config->{domain}->{$domain}->{node}->{$node}->{client}->
+                     {$service}->{"$field.warning"})) or
+            (defined($config->{domain}->{$domain}->{node}->{$node}->{client}->
+                    {$service}->{"$field.critical"}))) {
+        return undef;
+    }
+    
+    if (defined($limits->{domain}->{$domain}->{node}->{$node}->{client}->
+                {$service}->{"$field.critical"}) and
+        (!defined $check_draw or
+         !$check_draw or
+         &munin_draw_field($config->{domain}->{$domain}->{node}->{$node},
+                           $service, $field)
+        )
+       ) {
+        return "critical";
+    } elsif (defined($limits->{domain}->{$domain}->{node}->{$node}->{client}->
+             {$service}->{"$field.warning"}) and
+             (!defined $check_draw or
+              !$check_draw or
+              &munin_draw_field($config->{domain}->{$domain}->{node}->{$node},
+                                $service, $field)
+             )
+            ) {
+        return "warning";
+    } else {
+        return "ok";
+    }
+} ## end sub munin_field_status
+
+
+sub munin_graph_column_headers {
+    my ( $config, $domain, $node, $serv ) = @_;
+    my $ret    = 0;
+    my @fields = ();
+    foreach my $field (
+        keys
+        %{ $config->{domain}->{$domain}->{node}->{$node}->{client}->{$serv} } )
+    {
+        if ($field =~ /^([^\.]+)\.negative$/ and
+            munin_draw_field($config->{domain}->{$domain}->{node}->{$node},
+                             $serv, $1)) {
+            return 1;
+        } elsif ($field =~ /^([^\.]+)\.label$/ and
+                 munin_draw_field($config->{domain}->{$domain}->{node}->{$node},
+                                  $serv, $1)) {
+            push @fields, $1;
+        }
+    }
+        
+    return 1
+      if (
+        munin_get_max_label_length(
+            $config->{'domain'}->{$domain}->{'node'}->{$node},
+            $config, $domain, $node, $serv, \@fields
+        ) > 20
+      );
+    return $ret;
+} ## end sub munin_graph_column_headers
+
+
+sub munin_get_max_label_length {
+    my $node    = shift;
+    my $config  = shift;
+    my $domain  = shift;
+    my $host    = shift;
+    my $service = shift;
+    my $order   = shift;
+    my $result  = 0;
+    for my $field (@$order) {
+        my $path = undef;
+        ( my $f = $field ) =~ s/=.+//;
+        next
+          if (
+            exists $node->{client}->{$service}->{ $f . ".process" }
+            and $node->{client}->{$service}->{ $f . ".process" } ne "yes" );
+        next if ( exists $node->{client}->{$service}->{ $f . ".skipdraw" } );
+        next
+          unless (
+            !exists $node->{client}->{$service}->{ $f . ".graph" }
+            or $node->{client}->{$service}->{ $f . ".graph" } eq "yes" );
+        if ($result <
+            length( $node->{client}->{$service}->{ $f . ".label" } || $f ) )
+        {
+            $result =
+              length( $node->{client}->{$service}->{ $f . ".label" } || $f );
+        }
+        if (exists $node->{client}->{$service}->{graph_total}
+            and length $node->{client}->{$service}->{graph_total} > $result )
+        {
+            $result = length $node->{client}->{$service}->{graph_total};
+        }
+    } ## end for my $field (@$order)
+    return $result;
+} ## end sub munin_get_max_label_length
+
+
+sub munin_get_field_order {
+    my $node    = shift;
+    my $config  = shift;
+    my $domain  = shift;
+    my $host    = shift;
+    my $service = shift;
+    my $result  = [];
+    if ( $node->{client}->{$service}->{graph_sources} ) {
+        foreach
+          my $gs ( split /\s+/, $node->{client}->{$service}->{'graph_sources'} )
+        {
+            push( @$result, "-" . $gs );
+        }
+    }
+    if ( $node->{client}->{$service}->{graph_order} ) {
+        push(
+            @$result,
+            split /\s+/, $node->{client}->{$service}->{'graph_order'} );
+    }
+    for my $key ( keys %{ $node->{client}->{$service} } ) {
+        my ( $client, $type ) = "";
+        ( $client, $type ) = split /\./, $key;
+        if ( defined $type and $type eq "label" ) {
+            push @$result, $client if !grep /^\Q$client\E(?:=|$)/, @$result;
+        }
+    }
+    return $result;
+} ## end sub munin_get_field_order
+
+
+sub munin_get_rrd_filename {
+    my $node    = shift;
+    my $config  = shift;
+    my $domain  = shift;
+    my $name    = shift;
+    my $service = shift;
+    my $field   = shift;
+    my $path    = shift;
+    my $result  = "unknown";
+    if ( $node->{client}->{$service}->{ $field . ".filename" } ) {
+        $result = $node->{client}->{$service}->{ $field . ".filename" };
+    } elsif ($path) {
+        if ( !defined( $node->{client}->{$service}->{ $field . ".label" } ) ) {
+            print "DEBUG: Setting label: $field\n" if $::DEBUG;
+            $node->{client}->{$service}->{ $field . ".label" } = $field;
+        }
+        if ( $path =~ /^\s*([^:;]+)[:;]([^:]+):([^:\.]+)[:\.]([^:\.]+)\s*$/ ) {
+            $result = munin_get_filename( $config, $1, $2, $3, $4 );
+            print "\nDEBUG1: Expanding $path...\n" if $::DEBUG;
+            if ( !defined $node->{client}->{$service}->{ $field . "label" } ) {
+                for my $f (@copy_fields) {
+                    if (not exists $node->{client}->{$service}->{"$field.$f"}
+                        and exists $config->{'domain'}->{$1}->{'node'}->{$2}
+                        ->{'client'}->{$3}->{"$4.$f"} )
+                    {
+                        $node->{client}->{$service}->{"$field.$f"} =
+                          $config->{'domain'}->{$1}->{'node'}->{$2}->{'client'}
+                          ->{$3}->{"$4.$f"};
+                    }
+                }
+            }
+        } elsif ( $path =~ /^\s*([^:]+):([^:\.]+)[:\.]([^:\.]+)\s*$/ ) {
+            print "\nDEBUG2: Expanding $path...\n" if $::DEBUG;
+            $result = munin_get_filename( $config, $domain, $1, $2, $3 );
+            for my $f (@copy_fields) {
+                if (not exists $node->{client}->{$service}->{"$field.$f"}
+                    and exists $config->{'domain'}->{$domain}->{'node'}->{$1}
+                    ->{'client'}->{$2}->{"$3.$f"} )
+                {
+                    print "DEBUG: Copying $f...\n" if $::DEBUG;
+                    $node->{client}->{$service}->{"$field.$f"} =
+                      $config->{'domain'}->{$domain}->{'node'}->{$1}->{'client'}
+                      ->{$2}->{"$3.$f"};
+                }
+            }
+        } elsif ( $path =~ /^\s*([^:\.]+)[:\.]([^:\.]+)\s*$/ ) {
+            print "\nDEBUG3: Expanding $path...\n" if $::DEBUG;
+            $result = munin_get_filename( $config, $domain, $name, $1, $2 );
+            for my $f (@copy_fields) {
+                if (not exists $node->{client}->{$service}->{"$field.$f"}
+                    and exists $node->{client}->{$1}->{"$2.$f"} )
+                {
+                    $node->{client}->{$service}->{"$field.$f"} =
+                      $node->{client}->{$1}->{"$2.$f"};
+                }
+            }
+        } elsif ( $path =~ /^\s*([^:\.]+)\s*$/ ) {
+            print "\nDEBUG4: Expanding $path...\n" if $::DEBUG;
+            $result =
+              munin_get_filename( $config, $domain, $name, $service, $1 );
+            for my $f (@copy_fields) {
+                if (not exists $node->{client}->{$service}->{"$field.$f"}
+                    and exists $node->{client}->{$service}->{"$1.$f"} )
+                {
+                    $node->{client}->{$service}->{"$field.$f"} =
+                      $node->{client}->{$service}->{"$1.$f"};
+                }
+            }
+        }
+    } else {
+        print "\nDEBUG5: Doing path...\n" if $::DEBUG;
+        $result =
+          munin_get_filename( $config, $domain, $name, $service, $field );
+    }
+    return $result;
+} ## end sub munin_get_rrd_filename
+
-1;