tyler.durden/centreon-plugins
1
0
Fork 0
mirror of https://github.com/centreon/centreon-plugins.git synced 2025-07-27 07:34:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix #5497

Browse Source 
git-svn-id: http://svn.merethis.net/centreon-esxd/trunk@86 a5eaa968-4c79-4d68-970d-af6011b5b055
This commit is contained in:
Quentin Garnier 2013-10-07 18:07:33 +00:00
parent 0a3e6f1876
commit bf74e6a0f0
4 changed files with 109 additions and 58 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
connectors/vmware/centreon_esx_client.pl
View File

@ -35,6 +35,7 @@ my %OPTION = (
consolidation => undef, consolidation => undef,
check_disk_limit => undef, check_disk_limit => undef,
details_value => undef,
# For Autodisco # For Autodisco
xml => undef, xml => undef,
@ -73,11 +74,13 @@ GetOptions(
"check-consolidation" => \$OPTION{consolidation}, "check-consolidation" => \$OPTION{consolidation},
"check-disk" => \$OPTION{check_disk_limit}, "check-disk" => \$OPTION{check_disk_limit},
"w|warning:f" => \$OPTION{warning}, "w|warning:s" => \$OPTION{warning},
"c|critical:f" => \$OPTION{critical}, "c|critical:s" => \$OPTION{critical},
"warning2:f" => \$OPTION{warning2}, "warning2:s" => \$OPTION{warning2},
"critical2:f" => \$OPTION{critical2}, "critical2:s" => \$OPTION{critical2},
"details-value:s" => \$OPTION{details_value},
"xml" => \$OPTION{xml}, "xml" => \$OPTION{xml},
"show-attributes" => \$OPTION{show_attributes}, "show-attributes" => \$OPTION{show_attributes},
@ -131,6 +134,7 @@ sub print_usage () {
print " -c (--critical) Critical Threshold (default none)\n"; print " -c (--critical) Critical Threshold (default none)\n";
print " --filter Use regexp for --datastore option (can check multiples datastores at once)\n"; print " --filter Use regexp for --datastore option (can check multiples datastores at once)\n";
print " --skip-errors Status OK if a datastore is not accessible (when you checks multiples)\n"; print " --skip-errors Status OK if a datastore is not accessible (when you checks multiples)\n";
print " --details-value Only display VMs with iops higher than the following value (permits to see VMs with high values) (default 50)\n";
print "\n"; print "\n";
print "'datastore-io':\n"; print "'datastore-io':\n";
print " --datastore Datastore name to check (required)\n"; print " --datastore Datastore name to check (required)\n";
@ -373,6 +377,9 @@ sub datastoreiops_check_arg {
if (!defined($OPTION{critical})) { if (!defined($OPTION{critical})) {
$OPTION{critical} = ''; $OPTION{critical} = '';
} }
if (!defined($OPTION{details_value})) {
$OPTION{details_value} = 50;
}
$OPTION{filter} = (defined($OPTION{filter}) ? 1 : 0); $OPTION{filter} = (defined($OPTION{filter}) ? 1 : 0);
$OPTION{skip_errors} = (defined($OPTION{skip_errors}) ? 1 : 0); $OPTION{skip_errors} = (defined($OPTION{skip_errors}) ? 1 : 0);
return 0; return 0;
@ -380,7 +387,7 @@ sub datastoreiops_check_arg {
sub datastoreiops_get_str { sub datastoreiops_get_str {
return join($separatorin, return join($separatorin,
('datastore-iops', $OPTION{vsphere}, $OPTION{datastore}, $OPTION{filter}, $OPTION{warning}, $OPTION{critical}, $OPTION{skip_errors})); ('datastore-iops', $OPTION{vsphere}, $OPTION{datastore}, $OPTION{filter}, $OPTION{warning}, $OPTION{critical}, $OPTION{details_value}, $OPTION{skip_errors}));
} }
sub datastoreio_check_arg { sub datastoreio_check_arg {
@ -475,7 +482,7 @@ sub datastoreshost_check_arg {
sub datastoreshost_get_str { sub datastoreshost_get_str {
return join($separatorin, return join($separatorin,
('datastoreshost', $OPTION{vsphere}, $OPTION{'esx-host'}, $OPTION{warning}, $OPTION{critical} , $OPTION{datastore}, $OPTION{filter})); ('datastoreshost', $OPTION{vsphere}, $OPTION{'esx-host'}, $OPTION{filter}, $OPTION{warning}, $OPTION{critical} , $OPTION{datastore}));
} }
sub memhost_check_arg { sub memhost_check_arg {

126
connectors/vmware/lib/cmddatastoreiops.pm
View File

@ -23,12 +23,16 @@ sub getCommandName {
sub checkArgs { sub checkArgs {
my $self = shift; my $self = shift;
my ($ds, $warn, $crit) = @_; my ($ds, $filter, $warn, $crit, $details_value) = @_;
if (!defined($ds) || $ds eq "") { if (!defined($ds) || $ds eq "") {
$self->{logger}->writeLogError("ARGS error: need datastore name"); $self->{logger}->writeLogError("ARGS error: need datastore name");
return 1; return 1;
} }
if (defined($details_value) && $details_value ne "" && $details_value !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
$self->{logger}->writeLogError("ARGS error: details-value must be a positive number");
return 1;
}
if (defined($warn) && $warn ne "" && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) { if (defined($warn) && $warn ne "" && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
$self->{logger}->writeLogError("ARGS error: warn threshold must be a positive number"); $self->{logger}->writeLogError("ARGS error: warn threshold must be a positive number");
return 1; return 1;
@ -50,14 +54,26 @@ sub initArgs {
$self->{filter} = (defined($_[1]) && $_[1] == 1) ? 1 : 0; $self->{filter} = (defined($_[1]) && $_[1] == 1) ? 1 : 0;
$self->{warn} = (defined($_[2]) ? $_[2] : ''); $self->{warn} = (defined($_[2]) ? $_[2] : '');
$self->{crit} = (defined($_[3]) ? $_[3] : ''); $self->{crit} = (defined($_[3]) ? $_[3] : '');
$self->{skip_errors} = (defined($_[4]) && $_[4] == 1) ? 1 : 0; $self->{details_value} = (defined($_[4]) ? $_[4] : 50);
$self->{skip_errors} = (defined($_[5]) && $_[5] == 1) ? 1 : 0;
} }
sub run { sub run {
my $self = shift; my $self = shift;
my $status = 0; # OK
my $output = '';
my $output_append = '';
my $output_warning = '';
my $output_warning_append = '';
my $output_critical = '';
my $output_critical_append = '';
my $output_unknown = '';
my $output_unknown_append = '';
my $perfdata = '';
if (!($self->{obj_esxd}->{perfcounter_speriod} > 0)) { if (!($self->{obj_esxd}->{perfcounter_speriod} > 0)) {
my $status = centreon::esxd::common::errors_mask(0, 'UNKNOWN'); $status = centreon::esxd::common::errors_mask(0, 'UNKNOWN');
$self->{obj_esxd}->print_response(centreon::esxd::common::get_status($status) . "|Can't retrieve perf counters.\n"); $self->{obj_esxd}->print_response(centreon::esxd::common::get_status($status) . "|Can't retrieve perf counters.\n");
return ; return ;
} }
@ -79,6 +95,15 @@ sub run {
my %disk_name = (); my %disk_name = ();
my %datastore_lun = (); my %datastore_lun = ();
foreach (@$result) { foreach (@$result) {
if (!centreon::esxd::common::is_accessible($_->{'summary.accessible'})) {
if ($self->{skip_errors} == 0 || $self->{filter} == 0) {
$status = centreon::esxd::common::errors_mask($status, 'UNKNOWN');
centreon::esxd::common::output_add(\$output_unknown, \$output_unknown_append, ", ",
"'" . $_->{'summary.name'} . "' not accessible. Can be disconnected");
}
next;
}
if ($_->info->isa('VmfsDatastoreInfo')) { if ($_->info->isa('VmfsDatastoreInfo')) {
#$uuid_list{$_->volume->uuid} = $_->volume->name; #$uuid_list{$_->volume->uuid} = $_->volume->name;
# Not need. We are on Datastore level (not LUN level) # Not need. We are on Datastore level (not LUN level)
@ -93,8 +118,6 @@ sub run {
# Zero disk Info # Zero disk Info
#} #}
} }
use Data::Dumper;
my @vm_array = (); my @vm_array = ();
my %added_vm = (); my %added_vm = ();
@ -108,77 +131,83 @@ sub run {
} }
} }
@properties = ('name', 'runtime.connectionState'); @properties = ('name', 'runtime.connectionState', 'runtime.powerState');
my $result2 = centreon::esxd::common::get_views($self->{obj_esxd}, \@vm_array, \@properties); my $result2 = centreon::esxd::common::get_views($self->{obj_esxd}, \@vm_array, \@properties);
if (!defined($result2)) { if (!defined($result2)) {
return ; return ;
} }
# Remove disconnected or not running vm
my %ref_ids_vm = (); my %ref_ids_vm = ();
foreach (@$result2) { for(my $i = $#{$result2}; $i >= 0; --$i) {
$ref_ids_vm{$_->{mo_ref}->{value}} = $_->{name}; if (!centreon::esxd::common::is_connected(${$result2}[$i]->{'runtime.connectionState'}->val) ||
!centreon::esxd::common::is_running(${$result2}[$i]->{'runtime.powerState'}->val)) {
splice @$result2, $i, 1;
next;
}
$ref_ids_vm{${$result2}[$i]->{mo_ref}->{value}} = ${$result2}[$i]->{name};
} }
print STDERR Data::Dumper::Dumper(%ref_ids_vm);
# Vsphere >= 4.1 # Vsphere >= 4.1
my $values = centreon::esxd::common::generic_performance_values_historic($self->{obj_esxd}, my $values = centreon::esxd::common::generic_performance_values_historic($self->{obj_esxd},
$result2, $result2,
[{'label' => 'disk.numberRead.summation', 'instances' => ['*']}, [{'label' => 'disk.numberRead.summation', 'instances' => ['*']},
{'label' => 'disk.numberWrite.summation', 'instances' => ['*']}], {'label' => 'disk.numberWrite.summation', 'instances' => ['*']}],
$self->{obj_esxd}->{perfcounter_speriod}, 1, 1); $self->{obj_esxd}->{perfcounter_speriod}, 1, 1);
print STDERR Data::Dumper::Dumper($values);
return ;
return if (centreon::esxd::common::performance_errors($self->{obj_esxd}, $values) == 1); return if (centreon::esxd::common::performance_errors($self->{obj_esxd}, $values) == 1);
foreach (keys %$values) { foreach (keys %$values) {
my ($id, $disk_name) = split(/:/); my ($vm_id, $id, $disk_name) = split(/:/);
$datastore_lun{$disk_name{$disk_name}}{$self->{obj_esxd}->{perfcounter_cache_reverse}->{$id}} += $values->{$_}[0]; my $tmp_value = centreon::esxd::common::simplify_number(centreon::esxd::common::convert_number($values->{$_}[0] / $self->{obj_esxd}->{perfcounter_speriod}));
$datastore_lun{$disk_name{$disk_name}}{$self->{obj_esxd}->{perfcounter_cache_reverse}->{$id}} += $tmp_value;
if (!defined($datastore_lun{$disk_name{$disk_name}}{$vm_id . '_' . $self->{obj_esxd}->{perfcounter_cache_reverse}->{$id}})) {
$datastore_lun{$disk_name{$disk_name}}{$vm_id . '_' . $self->{obj_esxd}->{perfcounter_cache_reverse}->{$id}} = $tmp_value;
} else {
$datastore_lun{$disk_name{$disk_name}}{$vm_id . '_' . $self->{obj_esxd}->{perfcounter_cache_reverse}->{$id}} += $tmp_value;
}
} }
my $status = 0; # OK
my $output = '';
my $output_append = '';
my $output_warning = '';
my $output_warning_append = '';
my $output_critical = '';
my $output_critical_append = '';
my $perfdata = '';
foreach (keys %datastore_lun) { foreach (keys %datastore_lun) {
my $read_counter = centreon::esxd::common::simplify_number(centreon::esxd::common::convert_number($datastore_lun{$_}{'disk.numberRead.summation'} / $self->{obj_esxd}->{perfcounter_speriod})); my $total_read_counter = $datastore_lun{$_}{'disk.numberRead.summation'};
my $write_counter = centreon::esxd::common::simplify_number(centreon::esxd::common::convert_number($datastore_lun{$_}{'disk.numberWrite.summation'} / $self->{obj_esxd}->{perfcounter_speriod})); my $total_write_counter = $datastore_lun{$_}{'disk.numberWrite.summation'};
if (defined($self->{crit}) && $self->{crit} ne "" && ($read_counter >= $self->{crit})) { if (defined($self->{crit}) && $self->{crit} ne "" && ($total_read_counter >= $self->{crit})) {
centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ", centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ",
"read on '" . $_ . "' is $read_counter ms"); "'$total_read_counter' read iops on '" . $_ . "'" . $self->vm_iops_details('disk.numberRead.summation', $datastore_lun{$_}, \%ref_ids_vm));
$status = centreon::esxd::common::errors_mask($status, 'CRITICAL'); $status = centreon::esxd::common::errors_mask($status, 'CRITICAL');
} elsif (defined($self->{warn}) && $self->{warn} ne "" && ($read_counter >= $self->{warn})) { } elsif (defined($self->{warn}) && $self->{warn} ne "" && ($total_read_counter >= $self->{warn})) {
centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ", centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ",
"read on '" . $_ . "' is $read_counter ms"); "'$total_read_counter' read on '" . $_ . "'" . $self->vm_iops_details('disk.numberRead.summation', $datastore_lun{$_}, \%ref_ids_vm));
$status = centreon::esxd::common::errors_mask($status, 'WARNING'); $status = centreon::esxd::common::errors_mask($status, 'WARNING');
} }
if (defined($self->{crit}) && $self->{crit} ne "" && ($write_counter >= $self->{crit})) { if (defined($self->{crit}) && $self->{crit} ne "" && ($total_write_counter >= $self->{crit})) {
centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ", centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ",
"write on '" . $_ . "' is $write_counter ms"); "'$total_write_counter' write iops on '" . $_ . "'" . $self->vm_iops_details('disk.numberWrite.summation', $datastore_lun{$_}, \%ref_ids_vm));
$status = centreon::esxd::common::errors_mask($status, 'CRITICAL'); $status = centreon::esxd::common::errors_mask($status, 'CRITICAL');
} elsif (defined($self->{warn}) && $self->{warn} ne "" && ($write_counter >= $self->{warn})) { } elsif (defined($self->{warn}) && $self->{warn} ne "" && ($total_write_counter >= $self->{warn})) {
centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ", centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ",
"write on '" . $_ . "' is $write_counter ms"); "'$total_write_counter' write iops on '" . $_ . "'" . $self->vm_iops_details('disk.numberWrite.summation', $datastore_lun{$_}, \%ref_ids_vm));
$status = centreon::esxd::common::errors_mask($status, 'WARNING'); $status = centreon::esxd::common::errors_mask($status, 'WARNING');
} }
$perfdata .= " 'riops_" . $_ . "'=" . $read_counter . "iops 'wiops_" . $_ . "'=" . $write_counter . 'iops'; if ($self->{filter} == 1) {
$perfdata .= " 'riops_" . $_ . "'=" . $total_read_counter . "iops;$self->{warn};$self->{crit};0; 'wiops_" . $_ . "'=" . $total_write_counter . "iops;$self->{warn};$self->{crit};0;";
} else {
$perfdata .= " 'riops=" . $total_read_counter . "iops;$self->{warn};$self->{crit};0; wiops=" . $total_write_counter . "iops;$self->{warn};$self->{crit};0;";
}
} }
if ($output_unknown ne "") {
$output .= $output_append . "UNKNOWN - $output_unknown";
$output_append = ". ";
}
if ($output_critical ne "") { if ($output_critical ne "") {
$output .= $output_append . "CRITICAL - Datastore IOPS counter: $output_critical"; $output .= $output_append . "CRITICAL - $output_critical";
$output_append = ". "; $output_append = ". ";
} }
if ($output_warning ne "") { if ($output_warning ne "") {
$output .= $output_append . "WARNING - Datastore IOPS counter: $output_warning"; $output .= $output_append . "WARNING - $output_warning";
} }
if ($status == 0) { if ($status == 0) {
$output = "All Datastore IOPS counters are ok"; $output = "All Datastore IOPS counters are ok";
@ -186,4 +215,19 @@ sub run {
$self->{obj_esxd}->print_response(centreon::esxd::common::get_status($status) . "|$output|$perfdata\n"); $self->{obj_esxd}->print_response(centreon::esxd::common::get_status($status) . "|$output|$perfdata\n");
} }
sub vm_iops_details {
my ($self, $label, $ds_details, $ref_ids_vm) = @_;
my $details = '';
foreach my $value (keys %$ds_details) {
# Dont need to display vm with iops < 1
if ($value =~ /^vm.*?$label$/ && $ds_details->{$value} >= $self->{details_value}) {
my ($vm_ids) = split(/_/, $value);
$details .= " ['" . $ref_ids_vm->{$vm_ids} . "' " . $ds_details->{$value} . ']';
}
}
return $details;
}
1; 1;

10
connectors/vmware/lib/cmddatastoreshost.pm
View File

@ -24,7 +24,7 @@ sub getCommandName {
sub checkArgs { sub checkArgs {
my $self = shift; my $self = shift;
my ($lhost, $warn, $crit) = @_; my ($lhost, $filter, $warn, $crit) = @_;
if (!defined($lhost) || $lhost eq "") { if (!defined($lhost) || $lhost eq "") {
$self->{logger}->writeLogError("ARGS error: need host name"); $self->{logger}->writeLogError("ARGS error: need host name");
@ -48,10 +48,10 @@ sub checkArgs {
sub initArgs { sub initArgs {
my $self = shift; my $self = shift;
$self->{lhost} = $_[0]; $self->{lhost} = $_[0];
$self->{warn} = (defined($_[1]) ? $_[1] : ''); $self->{filter} = (defined($_[1]) && $_[1] == 1) ? 1 : 0;
$self->{crit} = (defined($_[2]) ? $_[2] : ''); $self->{warn} = (defined($_[2]) ? $_[2] : '');
$self->{ds} = (defined($_[3]) ? $_[3] : ''); $self->{crit} = (defined($_[3]) ? $_[3] : '');
$self->{filter} = (defined($_[4]) && $_[4] == 1) ? 1 : 0; $self->{ds} = (defined($_[4]) ? $_[4] : '');
} }
sub run { sub run {

12
connectors/vmware/lib/cmddatastoresvm.pm
View File

@ -129,20 +129,20 @@ sub run {
if (defined($self->{crit}) && $self->{crit} ne "" && ($read_counter >= $self->{crit})) { if (defined($self->{crit}) && $self->{crit} ne "" && ($read_counter >= $self->{crit})) {
centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ", centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ",
"read on '" . $_ . "' is $read_counter ms"); "read iops on '" . $_ . "' is $read_counter");
$status = centreon::esxd::common::errors_mask($status, 'CRITICAL'); $status = centreon::esxd::common::errors_mask($status, 'CRITICAL');
} elsif (defined($self->{warn}) && $self->{warn} ne "" && ($read_counter >= $self->{warn})) { } elsif (defined($self->{warn}) && $self->{warn} ne "" && ($read_counter >= $self->{warn})) {
centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ", centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ",
"read on '" . $_ . "' is $read_counter ms"); "read iops on '" . $_ . "' is $read_counter");
$status = centreon::esxd::common::errors_mask($status, 'WARNING'); $status = centreon::esxd::common::errors_mask($status, 'WARNING');
} }
if (defined($self->{crit}) && $self->{crit} ne "" && ($write_counter >= $self->{crit})) { if (defined($self->{crit}) && $self->{crit} ne "" && ($write_counter >= $self->{crit})) {
centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ", centreon::esxd::common::output_add(\$output_critical, \$output_critical_append, ", ",
"write on '" . $_ . "' is $write_counter ms"); "write iops on '" . $_ . "' is $write_counter");
$status = centreon::esxd::common::errors_mask($status, 'CRITICAL'); $status = centreon::esxd::common::errors_mask($status, 'CRITICAL');
} elsif (defined($self->{warn}) && $self->{warn} ne "" && ($write_counter >= $self->{warn})) { } elsif (defined($self->{warn}) && $self->{warn} ne "" && ($write_counter >= $self->{warn})) {
centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ", centreon::esxd::common::output_add(\$output_warning, \$output_warning_append, ", ",
"write on '" . $_ . "' is $write_counter ms"); "write iops '" . $_ . "' is $write_counter");
$status = centreon::esxd::common::errors_mask($status, 'WARNING'); $status = centreon::esxd::common::errors_mask($status, 'WARNING');
} }
@ -150,11 +150,11 @@ sub run {
} }
if ($output_critical ne "") { if ($output_critical ne "") {
$output .= $output_append . "CRITICAL - Datastore IOPS counter: $output_critical"; $output .= $output_append . "CRITICAL - $output_critical";
$output_append = ". "; $output_append = ". ";
} }
if ($output_warning ne "") { if ($output_warning ne "") {
$output .= $output_append . "WARNING - Datastore IOPS counter: $output_warning"; $output .= $output_append . "WARNING - $output_warning";
} }
if ($status == 0) { if ($status == 0) {
$output = "All Datastore IOPS counters are ok"; $output = "All Datastore IOPS counters are ok";