From 80e3688f4a061a43a6be3a0b1d3b9a94bf4dcfd3 Mon Sep 17 00:00:00 2001 From: garnier-quentin Date: Tue, 30 Jun 2015 14:50:54 +0200 Subject: [PATCH] + Enhance weblogic jmx mode --- apps/java/peoplesoft/jmx/mode/threads.pm | 223 ------------------ apps/java/peoplesoft/jmx/plugin.pm | 1 - .../jmx/mode/{health.pm => workmanager.pm} | 102 ++++++-- apps/java/weblogic/jmx/plugin.pm | 2 +- 4 files changed, 85 insertions(+), 243 deletions(-) delete mode 100644 apps/java/peoplesoft/jmx/mode/threads.pm rename apps/java/weblogic/jmx/mode/{health.pm => workmanager.pm} (67%) diff --git a/apps/java/peoplesoft/jmx/mode/threads.pm b/apps/java/peoplesoft/jmx/mode/threads.pm deleted file mode 100644 index 4556a819a..000000000 --- a/apps/java/peoplesoft/jmx/mode/threads.pm +++ /dev/null @@ -1,223 +0,0 @@ -################################################################################ -# Copyright 2005-2014 MERETHIS -# Centreon is developped by : Julien Mathis and Romain Le Merlus under -# GPL Licence 2.0. -# -# 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. -# -# 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, see . -# -# Linking this program statically or dynamically with other modules is making a -# combined work based on this program. Thus, the terms and conditions of the GNU -# General Public License cover the whole combination. -# -# As a special exception, the copyright holders of this program give MERETHIS -# permission to link this program with independent modules to produce an executable, -# regardless of the license terms of these independent modules, and to copy and -# distribute the resulting executable under terms of MERETHIS choice, provided that -# MERETHIS also meet, for each linked independent module, the terms and conditions -# of the license of that module. An independent module is a module which is not -# derived from this program. If you modify this program, you may extend this -# exception to your version of the program, but you are not obliged to do so. If you -# do not wish to do so, delete this exception statement from your version. -# -# For more information : contact@centreon.com -# Authors : Quentin Garnier -# -#################################################################################### - -package apps::java::peoplesoft::jmx::mode::threads; - -use base qw(centreon::plugins::mode); - -use strict; -use warnings; -use centreon::plugins::values; - -my $instance_mode; - -my $maps_counters = { - threads => { - '000_active' => { set => { key_values => [ { name => 'active' } ], - output_template => 'Active : %s', - perfdatas => [ - { label => 'active', value => 'active_absolute', template => '%s', min => 0 }, - ], - } - }, - '001_idle' => { set => { key_values => [ { name => 'idle' } ], - output_template => 'Idle : %s', - perfdatas => [ - { label => 'idle', value => 'idle_absolute', template => '%s', min => 0 }, - ], - } - }, - '002_total' => { set => { key_values => [ { name => 'total' } ], - output_template => 'Total : %s', - perfdatas => [ - { label => 'total', value => 'total_absolute', template => '%s', min => 0 }, - ], - } - }, - '003_daemon' => { set => { key_values => [ { name => 'daemon' } ], - output_template => 'Daemon : %s', - perfdatas => [ - { label => 'daemon', value => 'daemon_absolute', template => '%s', min => 0 }, - ], - } - }, - }, -}; - -sub new { - my ($class, %options) = @_; - my $self = $class->SUPER::new(package => __PACKAGE__, %options); - bless $self, $class; - - $self->{version} = '1.0'; - $options{options}->add_options(arguments => - { - }); - - foreach my $key (('threads')) { - foreach (keys %{$maps_counters->{$key}}) { - my ($id, $name) = split /_/; - if (!defined($maps_counters->{$key}->{$_}->{threshold}) || $maps_counters->{$key}->{$_}->{threshold} != 0) { - $options{options}->add_options(arguments => { - 'warning-' . $name . ':s' => { name => 'warning-' . $name }, - 'critical-' . $name . ':s' => { name => 'critical-' . $name }, - }); - } - $maps_counters->{$key}->{$_}->{obj} = centreon::plugins::values->new(output => $self->{output}, perfdata => $self->{perfdata}, - label => $name); - $maps_counters->{$key}->{$_}->{obj}->set(%{$maps_counters->{$key}->{$_}->{set}}); - } - } - - return $self; -} - -sub check_options { - my ($self, %options) = @_; - $self->SUPER::init(%options); - - foreach my $key (('threads')) { - foreach (keys %{$maps_counters->{$key}}) { - $maps_counters->{$key}->{$_}->{obj}->init(option_results => $self->{option_results}); - } - } - - $instance_mode = $self; - - $self->{overload_th} = {}; - foreach my $val (@{$self->{option_results}->{threshold_overload}}) { - if ($val !~ /^(.*?),(.*?),(.*)$/) { - $self->{output}->add_option_msg(short_msg => "Wrong threshold-overload option '" . $val . "'."); - $self->{output}->option_exit(); - } - my ($section, $status, $filter) = ($1, $2, $3); - if ($self->{output}->is_litteral_status(status => $status) == 0) { - $self->{output}->add_option_msg(short_msg => "Wrong threshold-overload status '" . $val . "'."); - $self->{output}->option_exit(); - } - $self->{overload_th}->{$section} = [] if (!defined($self->{overload_th}->{$section})); - push @{$self->{overload_th}->{$section}}, {filter => $filter, status => $status}; - } -} - -sub run { - my ($self, %options) = @_; - $self->{connector} = $options{custom}; - - $self->manage_selection(); - - my ($short_msg, $short_msg_append, $long_msg, $long_msg_append) = ('', '', '', ''); - my @exits; - foreach (sort keys %{$maps_counters->{threads}}) { - my $obj = $maps_counters->{threads}->{$_}->{obj}; - $obj->set(instance => 'global'); - - my ($value_check) = $obj->execute(values => $self->{global); - - if ($value_check != 0) { - $long_msg .= $long_msg_append . $maps_counters->{$_}->{obj}->output_error(); - $long_msg_append = ', '; - next; - } - my $exit2 = $obj->threshold_check(); - push @exits, $exit2; - - my $output = $obj->output(); - $long_msg .= $long_msg_append . $output; - $long_msg_append = ', '; - - if (!$self->{output}->is_status(litteral => 1, value => $exit2, compare => 'ok')) { - $short_msg .= $short_msg_append . $output; - $short_msg_append = ', '; - } - - $obj->perfdata(); - } - - my $exit = $self->{output}->get_most_critical(status => [ @exits ]); - if (!$self->{output}->is_status(litteral => 1, value => $exit, compare => 'ok')) { - $self->{output}->output_add(severity => $exit, - short_msg => "Threads $short_msg" - ); - } else { - $self->{output}->output_add(short_msg => "Threads $long_msg"); - } - - $self->{output}->display(); - $self->{output}->exit(); -} - -sub manage_selection { - my ($self, %options) = @_; - - my $mbean_queuer = 'com.bea:Name=weblogic.socket.Muxer,ServerRuntime=PIA,Type=ExecuteQueueRuntime'; - my $mbean_queue = 'com.bea:Name=weblogic.socket.Muxer,ServerRuntime=PIA,Type=ExecuteQueue'; - $self->{request} = [ - { mbean => $mbean_queuer, attributes => [ { name => 'ExecuteThreadCurrentIdleCount' }, { name => 'ThreadCount' } ] }, - { mbean => $mbean_queue, attributes => [ { name => 'ExecuteThreadTotalCount' } ] }, - { mbean => 'java.lang:type=Threading', attributes => [ { name => 'DaemonThreadCount' } ] }, - ]; - my $result = $self->{connector}->get_attributes(request => $self->{request}, nothing_quit => 1); - - $self->{global} = {}; - $self->{global}->{idle} = $result->{$mbean_queuer}->{ExecuteThreadCurrentIdleCount} if (defined($result->{$mbean_queuer}->{ExecuteThreadCurrentIdleCount})); - $self->{global}->{active} = $result->{$mbean_queuer}->{ThreadCount} if (defined($result->{$mbean_queuer}->{ThreadCount})); - $self->{global}->{total} = $result->{$mbean_queue}->{ExecuteThreadTotalCount} if (defined($result->{$mbean_queue}->{ExecuteThreadTotalCount})); - $self->{global}->{daemon} = $result->{'java.lang:type=Threading'}->{DaemonThreadCount} if (defined($result->{'java.lang:type=Threading'}->{DaemonThreadCount})); -} - -1; - -__END__ - -=head1 MODE - -Check threads. - -=over 8 - -=item B<--warning-*> - -Threshold warning. -Can be: 'active', 'total', 'idle', 'daemon'. - -=item B<--critical-*> - -Threshold critical. -Can be: 'active', 'total', 'idle', 'daemon'. - -=back - -=cut diff --git a/apps/java/peoplesoft/jmx/plugin.pm b/apps/java/peoplesoft/jmx/plugin.pm index 2bd95781b..7888c2ff4 100644 --- a/apps/java/peoplesoft/jmx/plugin.pm +++ b/apps/java/peoplesoft/jmx/plugin.pm @@ -49,7 +49,6 @@ sub new { %{$self->{modes}} = ( 'queue-length' => 'apps::java::peoplesoft::jmx::mode::queuelength', 'sessions' => 'apps::java::peoplesoft::jmx::mode::sessions', - 'threads' => 'apps::java::peoplesoft::jmx::mode::threads', ); $self->{custom_modes}{jolokia} = 'centreon::common::protocols::jmx::custom::jolokia'; diff --git a/apps/java/weblogic/jmx/mode/health.pm b/apps/java/weblogic/jmx/mode/workmanager.pm similarity index 67% rename from apps/java/weblogic/jmx/mode/health.pm rename to apps/java/weblogic/jmx/mode/workmanager.pm index 873272c17..9fc561ecb 100644 --- a/apps/java/weblogic/jmx/mode/health.pm +++ b/apps/java/weblogic/jmx/mode/workmanager.pm @@ -33,13 +33,15 @@ # #################################################################################### -package apps::java::weblogic::jmx::mode::health; +package apps::java::weblogic::jmx::mode::workmanager; use base qw(centreon::plugins::mode); use strict; use warnings; use centreon::plugins::values; +use centreon::plugins::statefile; +use Digest::MD5 qw(md5_hex); my $thresholds = { health => [ @@ -64,10 +66,37 @@ my $maps_counters = { closure_custom_threshold_check => \&custom_threshold_output, } }, - }, + + '001_request-completed' => { set => { + key_values => [ { name => 'completed', diff => 1 }, { name => 'runtime' } ], + output_template => 'Requests completed : %s', + perfdatas => [ + { label => 'request_completed', value => 'completed_absolute', template => '%s', + min => 0, label_extra_instance => 1, instance_use => 'runtime_absolute' }, + ], + } + }, + '002_request-pending' => { set => { + key_values => [ { name => 'pending' }, { name => 'runtime' } ], + output_template => 'Requests pending : %s', + perfdatas => [ + { label => 'request_pending', value => 'pending_absolute', template => '%s', + min => 0, label_extra_instance => 1, instance_use => 'runtime_absolute' }, + ], + } + }, + '003_thread-stuck' => { set => { + key_values => [ { name => 'stuck' }, { name => 'runtime' } ], + output_template => 'Threads stuck : %s', + perfdatas => [ + { label => 'thread_stuck', value => 'stuck_absolute', template => '%s', + min => 0, label_extra_instance => 1, instance_use => 'runtime_absolute' }, + ], + } + }, + }, }; - sub custom_threshold_output { my ($self, %options) = @_; @@ -89,10 +118,12 @@ sub new { $self->{version} = '1.0'; $options{options}->add_options(arguments => { - "filter-name:s" => { name => 'filter_name' }, - "filter-runtime:s" => { name => 'filter_runtime' }, + "filter-application:s" => { name => 'filter_application' }, + "filter-name:s" => { name => 'filter_name' }, + "filter-runtime:s" => { name => 'filter_runtime' }, "threshold-overload:s@" => { name => 'threshold_overload' }, }); + $self->{statefile_value} = centreon::plugins::statefile->new(%options); foreach my $key (('runtime')) { foreach (keys %{$maps_counters->{$key}}) { @@ -103,7 +134,9 @@ sub new { 'critical-' . $name . ':s' => { name => 'critical-' . $name }, }); } - $maps_counters->{$key}->{$_}->{obj} = centreon::plugins::values->new(output => $self->{output}, perfdata => $self->{perfdata}, + $maps_counters->{$key}->{$_}->{obj} = centreon::plugins::values->new( + statefile => $self->{statefile_value}, + output => $self->{output}, perfdata => $self->{perfdata}, label => $name); $maps_counters->{$key}->{$_}->{obj}->set(%{$maps_counters->{$key}->{$_}->{set}}); } @@ -122,6 +155,7 @@ sub check_options { } } + $self->{statefile_value}->check_options(%options); $instance_mode = $self; $self->{overload_th} = {}; @@ -153,9 +187,17 @@ sub run { if ($multiple == 1) { $self->{output}->output_add(severity => 'OK', - short_msg => 'All ServerRuntimes are ok'); + short_msg => 'All WorkerManagers are ok'); } + my $matching = ''; + foreach (('filter_application', 'filter_name', 'filter_runtime')) { + $matching .= defined($self->{option_results}->{$_}) ? $self->{option_results}->{$_} : 'all'; + } + $self->{new_datas} = {}; + $self->{statefile_value}->read(statefile => "weblogic_" . $self->{mode} . '_' . md5_hex($self->{connector}->{url}) . '_' . md5_hex($matching)); + $self->{new_datas}->{last_timestamp} = time(); + foreach my $id (sort keys %{$self->{runtime}}) { my ($short_msg, $short_msg_append, $long_msg, $long_msg_append) = ('', '', '', ''); my @exits = (); @@ -163,7 +205,8 @@ sub run { my $obj = $maps_counters->{runtime}->{$_}->{obj}; $obj->set(instance => $id); - my ($value_check) = $obj->execute(values => $self->{runtime}->{$id}); + my ($value_check) = $obj->execute(values => $self->{runtime}->{$id}, + new_datas => $self->{new_datas}); if ($value_check != 0) { $long_msg .= $long_msg_append . $obj->output_error(); @@ -182,22 +225,23 @@ sub run { $short_msg_append = ', '; } - $maps_counters->{runtime}->{$_}->{obj}->perfdata(extra_instance => $multiple); + $obj->perfdata(extra_instance => $multiple); } - $self->{output}->output_add(long_msg => "ServerRuntime '$self->{runtime}->{$id}->{name}/$self->{runtime}->{$id}->{runtime}' $long_msg"); + $self->{output}->output_add(long_msg => "WorkerManager '$id' $long_msg"); my $exit = $self->{output}->get_most_critical(status => [ @exits ]); if (!$self->{output}->is_status(litteral => 1, value => $exit, compare => 'ok')) { $self->{output}->output_add(severity => $exit, - short_msg => "ServerRuntime '$self->{runtime}->{$id}->{name}/$self->{runtime}->{$id}->{runtime}' $short_msg" + short_msg => "WorkerManager '$id' $short_msg" ); } if ($multiple == 0) { - $self->{output}->output_add(short_msg => "ServerRuntime '$self->{runtime}->{$id}->{name}/$self->{runtime}->{$id}->{runtime}' $long_msg"); + $self->{output}->output_add(short_msg => "WorkerManager '$id' $long_msg"); } } + $self->{statefile_value}->write(data => $self->{new_datas}); $self->{output}->display(); $self->{output}->exit(); } @@ -232,21 +276,28 @@ my %map_state = ( 4 => 'HEALTH_OVERLOADED', 5 => 'LOW_MEMORY_REASON', ); + sub manage_selection { my ($self, %options) = @_; $self->{request} = [ - { mbean => 'com.bea:ApplicationRuntime=bea_wls_deployment_internal,Name=*,ServerRuntime=*,Type=WorkManagerRuntime', attributes => [ { name => 'HealthState' } ] } + { mbean => 'com.bea:ApplicationRuntime=*,Name=*,ServerRuntime=*,Type=WorkManagerRuntime', + attributes => [ { name => 'HealthState' }, { name => 'StuckThreadCount' }, { name => 'CompletedRequests' }, { name => 'PendingRequests' } ] } ]; my $result = $self->{connector}->get_attributes(request => $self->{request}, nothing_quit => 1); $self->{runtime} = {}; foreach my $mbean (keys %{$result}) { - next if ($mbean !~ /Name=(.*?),ServerRuntime=(.*?),/); - my ($name, $runtime) = ($1, $2); + next if ($mbean !~ /ApplicationRuntime=(.*?),Name=(.*?),ServerRuntime=(.*?),/); + my ($app, $name, $runtime) = ($1, $2, $3); my $health_state = defined($map_state{$result->{$mbean}->{HealthState}->{state}}) ? $map_state{$result->{$mbean}->{HealthState}->{state}} : 'unknown'; + if (defined($self->{option_results}->{filter_application}) && $self->{option_results}->{filter_application} ne '' && + $app !~ /$self->{option_results}->{filter_application}/) { + $self->{output}->output_add(long_msg => "Skipping '" . $app . "': no matching filter application."); + next; + } if (defined($self->{option_results}->{filter_name}) && $self->{option_results}->{filter_name} ne '' && $name !~ /$self->{option_results}->{filter_name}/) { $self->{output}->output_add(long_msg => "Skipping '" . $name . "': no matching filter name."); @@ -258,7 +309,8 @@ sub manage_selection { next; } - $self->{runtime}->{$name . $runtime} = { name => $name, runtime => $runtime, health_state => $health_state }; + $self->{runtime}->{$app . '/' . $name . '/' . $runtime} = { health_state => $health_state, runtime => $app . '/' . $name . '/' . $runtime, + completed => $result->{$mbean}->{CompletedRequests}, pending => $result->{$mbean}->{PendingRequests}, stuck => $result->{$mbean}->{StuckThreadCount} }; } if (scalar(keys %{$self->{runtime}}) <= 0) { @@ -273,17 +325,31 @@ __END__ =head1 MODE -Check WebLogic Runtimes Health State. +Check WebLogic WorkManagers. =over 8 +=item B<--warning-*> + +Threshold warning. +Can be: 'thread-stuck', 'request-completed', 'request-pending'. + +=item B<--critical-*> + +Threshold critical. +Can be: 'thread-stuck', 'request-completed', 'request-pending'. + +=item B<--filter-application> + +Filter by application runtime. + =item B<--filter-name> Filter by name (regexp can be used). =item B<--filter-runtime> -Filter by runtime. +Filter by server runtime. =item B<--threshold-overload> diff --git a/apps/java/weblogic/jmx/plugin.pm b/apps/java/weblogic/jmx/plugin.pm index 501f2cb29..f88740891 100644 --- a/apps/java/weblogic/jmx/plugin.pm +++ b/apps/java/weblogic/jmx/plugin.pm @@ -48,10 +48,10 @@ sub new { $self->{version} = '0.1'; %{$self->{modes}} = ( 'class-count' => 'centreon::common::jvm::mode::classcount', - 'health' => 'apps::java::weblogic::jmx::mode::health', 'memory' => 'centreon::common::jvm::mode::memory', 'memory-detailed' => 'centreon::common::jvm::mode::memorydetailed', 'thread-count' => 'centreon::common::jvm::mode::threadcount', + 'work-manager' => 'apps::java::weblogic::jmx::mode::workmanager', ); $self->{custom_modes}{jolokia} = 'centreon::common::protocols::jmx::custom::jolokia';