From f89e82bdc87f7f2a5d27883d1b01f0e071a42454 Mon Sep 17 00:00:00 2001 From: garnier-quentin Date: Tue, 30 Jun 2015 15:05:57 +0200 Subject: [PATCH] + Enhance jmx threads mode --- apps/java/weblogic/jmx/plugin.pm | 2 +- apps/tomcat/jmx/plugin.pm | 2 +- centreon/common/jvm/mode/threadcount.pm | 120 ------------- centreon/common/jvm/mode/threads.pm | 224 ++++++++++++++++++++++++ 4 files changed, 226 insertions(+), 122 deletions(-) delete mode 100644 centreon/common/jvm/mode/threadcount.pm create mode 100644 centreon/common/jvm/mode/threads.pm diff --git a/apps/java/weblogic/jmx/plugin.pm b/apps/java/weblogic/jmx/plugin.pm index f88740891..deef66517 100644 --- a/apps/java/weblogic/jmx/plugin.pm +++ b/apps/java/weblogic/jmx/plugin.pm @@ -50,7 +50,7 @@ sub new { 'class-count' => 'centreon::common::jvm::mode::classcount', 'memory' => 'centreon::common::jvm::mode::memory', 'memory-detailed' => 'centreon::common::jvm::mode::memorydetailed', - 'thread-count' => 'centreon::common::jvm::mode::threadcount', + 'threads' => 'ccentreon::common::jvm::mode::threads', 'work-manager' => 'apps::java::weblogic::jmx::mode::workmanager', ); diff --git a/apps/tomcat/jmx/plugin.pm b/apps/tomcat/jmx/plugin.pm index 0de2638cd..00cf17c74 100644 --- a/apps/tomcat/jmx/plugin.pm +++ b/apps/tomcat/jmx/plugin.pm @@ -51,9 +51,9 @@ sub new { 'memory' => 'centreon::common::jvm::mode::memory', 'fd-usage' => 'centreon::common::jvm::mode::fdusage', 'load-average' => 'centreon::common::jvm::mode::loadaverage', - 'thread-count' => 'centreon::common::jvm::mode::threadcount', 'cpu-load' => 'centreon::common::jvm::mode::cpuload', 'class-count' => 'centreon::common::jvm::mode::classcount', + 'threads' => 'centreon::common::jvm::mode::threads', ); $self->{custom_modes}{jolokia} = 'centreon::common::protocols::jmx::custom::jolokia'; diff --git a/centreon/common/jvm/mode/threadcount.pm b/centreon/common/jvm/mode/threadcount.pm deleted file mode 100644 index 830cebd04..000000000 --- a/centreon/common/jvm/mode/threadcount.pm +++ /dev/null @@ -1,120 +0,0 @@ -################################################################################ -# Copyright 2005-2013 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 -# Simon Bomm -#################################################################################### - -package centreon::common::jvm::mode::threadcount; - -use base qw(centreon::plugins::mode); - -use strict; -use warnings; - -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 => - { - "warning:s" => { name => 'warning' }, - "critical:s" => { name => 'critical' }, - }); - return $self; -} - -sub check_options { - my ($self, %options) = @_; - $self->SUPER::init(%options); - - if (($self->{perfdata}->threshold_validate(label => 'warning', value => $self->{option_results}->{warning})) == 0) { - $self->{output}->add_option_msg(short_msg => "Wrong warning threshold '" . $self->{option_results}->{warning} . "'."); - $self->{output}->option_exit(); - } - if (($self->{perfdata}->threshold_validate(label => 'critical', value => $self->{option_results}->{critical})) == 0) { - $self->{output}->add_option_msg(short_msg => "Wrong critical threshold '" . $self->{option_results}->{critical} . "'."); - $self->{output}->option_exit(); - } -} - -sub run { - my ($self, %options) = @_; - # $options{snmp} = snmp object - $self->{connector} = $options{custom}; - - $self->{request} = [ - { mbean => "java.lang:type=Threading", attributes => [ { name => 'ThreadCount' } ] }, - ]; - - my $result = $self->{connector}->get_attributes(request => $self->{request}, nothing_quit => 1); - - my $exit = $self->{perfdata}->threshold_check(value => $result->{"java.lang:type=Threading"}->{ThreadCount}, - threshold => [ { label => 'critical', exit_litteral => 'critical' }, { label => 'warning', exit_litteral => 'warning' } ]); - - $self->{output}->perfdata_add(label => 'ThreadCount', - value => $result->{"java.lang:type=Threading"}->{ThreadCount}, - warning => $self->{perfdata}->get_perfdata_for_output(label => 'warning'), - critical => $self->{perfdata}->get_perfdata_for_output(label => 'critical'), - min => 0); - - $self->{output}->output_add(severity => $exit, - short_msg => sprintf("Thread Count : %s", $result->{"java.lang:type=Threading"}->{ThreadCount})); - $self->{output}->display(); - $self->{output}->exit(); -} - -1; - -__END__ - -=head1 MODE - -Check Java Heap and NonHeap Memory usage (Mbean java.lang:type=Memory). - -Example: -perl centreon_plugins.pl --plugin=apps::weblogic::jmx::plugin --custommode=jolokia --url=http://10.30.2.22:8080/jolokia-war --mode=thread-count --warning 10 --critical 15 - -=over 8 - -=item B<--warning> - -Threshold warning - -=item B<--critical> - -Threshold critical - -=back - -=cut diff --git a/centreon/common/jvm/mode/threads.pm b/centreon/common/jvm/mode/threads.pm new file mode 100644 index 000000000..ce4e78754 --- /dev/null +++ b/centreon/common/jvm/mode/threads.pm @@ -0,0 +1,224 @@ +################################################################################ +# 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 centreon::common::jvm::mode::threads; + +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 $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_started' => { set => { key_values => [ { name => 'started', diff => 1 } ], + output_template => 'Started : %s', + perfdatas => [ + { label => 'started', value => 'started_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 => + { + }); + $self->{statefile_value} = centreon::plugins::statefile->new(%options); + + 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( + statefile => $self->{statefile_value}, + 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}); + } + } + + $self->{statefile_value}->check_options(%options); + $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(); + + $self->{new_datas} = {}; + $self->{statefile_value}->read(statefile => "jvm_standard_" . $self->{mode} . '_' . md5_hex($self->{connector}->{url})); + $self->{new_datas}->{last_timestamp} = time(); + + 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}, + new_datas => $self->{new_datas}); + + if ($value_check != 0) { + $long_msg .= $long_msg_append . $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->{statefile_value}->write(data => $self->{new_datas}); + $self->{output}->display(); + $self->{output}->exit(); +} + +sub manage_selection { + my ($self, %options) = @_; + + my $mbean = 'java.lang:type=Threading'; + $self->{request} = [ + { mbean => $mbean, attributes => [ { name => 'TotalStartedThreadCount ' }, { name => 'ThreadCount' }, { name => 'DaemonThreadCount ' } ] }, + ]; + my $result = $self->{connector}->get_attributes(request => $self->{request}, nothing_quit => 1); + + $self->{global} = {}; + $self->{global}->{started} = $result->{$mbean}->{TotalStartedThreadCount} if (defined($result->{$mbean}->{TotalStartedThreadCount})); + $self->{global}->{active} = $result->{$mbean}->{ThreadCount} if (defined($result->{$mbean}->{ThreadCount})); + $self->{global}->{daemon} = $result->{$mbean}->{DaemonThreadCount} if (defined($result->{$mbean}->{DaemonThreadCount})); +} + +1; + +__END__ + +=head1 MODE + +Check threads. + +=over 8 + +=item B<--warning-*> + +Threshold warning. +Can be: 'active', 'started', 'daemon'. + +=item B<--critical-*> + +Threshold critical. +Can be: 'active', 'started', 'daemon'. + +=back + +=cut \ No newline at end of file