tyler.durden
/
centreon-plugins
mirror of https://github.com/centreon/centreon-plugins.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Evolution #3994 

Splitter les commandes dans des sous fichiers


git-svn-id: http://svn.merethis.net/centreon-esxd/trunk@15 a5eaa968-4c79-4d68-970d-af6011b5b055
This commit is contained in:
Quentin Garnier 2012-09-20 14:34:18 +00:00
parent bf38da172a
commit 9d0199eac5
17 changed files with 1128 additions and 1152 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1168
connectors/vmware/centreon_esxd
View File

File diff suppressed because it is too large Load Diff

2
connectors/vmware/centreon_esxd-conf.pm
View File

@ -1,3 +1,5 @@
our $libpath = '/usr/share/centreon/lib/centreon-esxd';
our $port = 5700;
our $service_url = "https://XXXX.XXXX.XXX/sdk";
our $username = "xxxxx";

76
connectors/vmware/lib/command-cpuhost.pm Normal file
View File

@ -0,0 +1,76 @@
sub cpuhost_check_args {
my ($host, $warn, $crit) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
if (defined($warn) && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be a positive number\n");
return 1;
}
if (defined($crit) && $crit !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: crit threshold must be a positive number\n");
return 1;
}
if (defined($warn) && defined($crit) && $warn > $crit) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be lower than crit threshold\n");
return 1;
}
return 0;
}
sub cpuhost_compute_args {
my $lhost = $_[0];
my $warn = (defined($_[1]) ? $_[1] : 80);
my $crit = (defined($_[2]) ? $_[2] : 90);
return ($lhost, $warn, $crit);
}
sub cpuhost_do {
my ($lhost, $warn, $crit) = @_;
if (!($perfcounter_speriod > 0)) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print_response($ERRORS{$MYERRORS{$status}} . "|Can't retrieve perf counters.\n");
return ;
}
my %filters = ('name' => $lhost);
my @properties = ('hardware.cpuInfo.numCpuThreads');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my @instances = ('*');
my $values = generic_performance_values_historic($$result[0],
[{'label' => 'cpu.usage.average', 'instances' => \@instances}],
$perfcounter_speriod);
my $status = 0; # OK
my $output = '';
my $total_cpu_average = simplify_number(convert_number($values->{$perfcounter_cache{'cpu.usage.average'}->{'key'} . ":"}[0] * 0.01));
if ($total_cpu_average >= $warn) {
$status |= $MYERRORS_MASK{'WARNING'};
}
if ($total_cpu_average >= $crit) {
$status |= $MYERRORS_MASK{'CRITICAL'};
}
$output = "Total Average CPU usage '$total_cpu_average%' on last " . ($perfcounter_speriod / 60) . "min | cpu_total=$total_cpu_average%;$warn;$crit;0;100";
foreach my $id (sort { my ($cida, $cia) = split /:/, $a;
my ($cidb, $cib) = split /:/, $b;
$cia = -1 if (!defined($cia) || $cia eq "");
$cib = -1 if (!defined($cib) || $cib eq "");
$cia <=> $cib} keys %$values) {
my ($counter_id, $instance) = split /:/, $id;
if ($instance ne "") {
$output .= " cpu$instance=" . simplify_number(convert_number($values->{$id}[0]) * 0.01) . "%;;0;100";
}
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

68
connectors/vmware/lib/command-datastoreio.pm Normal file
View File

@ -0,0 +1,68 @@
sub datastoreio_check_args {
my ($ds, $warn, $crit) = @_;
if (!defined($ds) || $ds eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need datastore name\n");
return 1;
}
if (defined($warn) && $warn ne "" && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be a positive number\n");
return 1;
}
if (defined($crit) && $crit ne "" && $crit !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: crit threshold must be a positive number\n");
return 1;
}
if (defined($warn) && defined($crit) && $warn ne "" && $crit ne "" && $warn > $crit) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be lower than crit threshold\n");
return 1;
}
return 0;
}
sub datastoreio_compute_args {
my $ds = $_[0];
my $warn = (defined($_[1]) ? $_[1] : '');
my $crit = (defined($_[2]) ? $_[2] : '');
return ($ds, $warn, $crit);
}
sub datastoreio_do {
my ($ds, $warn, $crit) = @_;
if (!($perfcounter_speriod > 0)) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print_response($ERRORS{$MYERRORS{$status}} . "|Can't retrieve perf counters.\n");
return ;
}
my %filters = ('summary.name' => $ds);
my @properties = ('summary.name');
my $result = get_entities_host('Datastore', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $values = generic_performance_values_historic($$result[0],
[{'label' => 'datastore.read.average', 'instances' => ['']},
{'label' => 'datastore.write.average', 'instances' => ['']}],
$perfcounter_speriod);
my $read_counter = simplify_number(convert_number($values->{$perfcounter_cache{'datastore.read.average'}->{'key'} . ":"}[0]));
my $write_counter = simplify_number(convert_number($values->{$perfcounter_cache{'datastore.write.average'}->{'key'} . ":"}[0]));
my $status = 0; # OK
my $output = '';
if ((defined($warn) && $warn ne "") && ($read_counter >= $warn || $write_counter >= $warn)) {
$status |= $MYERRORS_MASK{'WARNING'};
}
if ((defined($crit) && $crit ne "") && ($read_counter >= $crit || $write_counter >= $crit)) {
$status |= $MYERRORS_MASK{'CRITICAL'};
}
$output = "Rate of reading data : " . simplify_number($read_counter / 1024 * 8) . " Mb/s, Rate of writing data : " . simplify_number($write_counter / 1024 * 8) . " Mb/s";
$output .= "|read_rate=" . ($read_counter * 1024 * 8) . "b/s write_rate=" . (($write_counter * 1024 * 8)) . "b/s";
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

114
connectors/vmware/lib/command-datastoreshost.pm Normal file
View File

@ -0,0 +1,114 @@
sub datastoreshost_check_args {
my ($lhost, $warn, $crit) = @_;
if (!defined($lhost) || $lhost eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need host name\n");
return 1;
}
if (defined($warn) && $warn ne "" && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be a positive number\n");
return 1;
}
if (defined($crit) && $crit ne "" && $crit !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: crit threshold must be a positive number\n");
return 1;
}
if (defined($warn) && defined($crit) && $warn ne "" && $crit ne "" && $warn > $crit) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be lower than crit threshold\n");
return 1;
}
return 0;
}
sub datastoreshost_compute_args {
my $lhost = $_[0];
my $warn = (defined($_[1]) ? $_[1] : '');
my $crit = (defined($_[2]) ? $_[2] : '');
return ($lhost, $warn, $crit);
}
sub datastoreshost_do {
my ($lhost, $warn, $crit) = @_;
if (!($perfcounter_speriod > 0)) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print_response($ERRORS{$MYERRORS{$status}} . "|Can't retrieve perf counters.\n");
return ;
}
my %filters = ('name' => $lhost);
my @properties = ('config.fileSystemVolume.mountInfo');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my %uuid_list = ();
my %disk_name = ();
foreach (@{$$result[0]->{'config.fileSystemVolume.mountInfo'}}) {
if ($_->volume->isa('HostVmfsVolume')) {
$uuid_list{$_->volume->uuid} = $_->volume->name;
# Not need. We are on Datastore level (not LUN level)
#foreach my $extent (@{$_->volume->extent}) {
# $disk_name{$extent->diskName} = $_->volume->name;
#}
}
if ($_->volume->isa('HostNasVolume')) {
$uuid_list{basename($_->mountInfo->path)} = $_->volume->name;
}
}
# Vsphere >= 4.1
my $values = generic_performance_values_historic($$result[0],
[{'label' => 'datastore.totalReadLatency.average', 'instances' => ['*']},
{'label' => 'datastore.totalWriteLatency.average', 'instances' => ['*']}],
$perfcounter_speriod);
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 %uuid_list) {
if (defined($values->{$perfcounter_cache{'datastore.totalReadLatency.average'}->{'key'} . ":" . $_}) and
defined($values->{$perfcounter_cache{'datastore.totalWriteLatency.average'}->{'key'} . ":" . $_})) {
my $read_counter = simplify_number(convert_number($values->{$perfcounter_cache{'datastore.totalReadLatency.average'}->{'key'} . ":" . $_}[0]));
my $write_counter = simplify_number(convert_number($values->{$perfcounter_cache{'datastore.totalWriteLatency.average'}->{'key'} . ":" . $_}[0]));
if (defined($crit) && $crit ne "" && ($read_counter >= $crit)) {
output_add(\$output_critical, \$output_critical_append, ", ",
"read on '" . $uuid_list{$_} . "' is $read_counter ms");
$status |= $MYERRORS_MASK{'WARNING'};
} elsif (defined($warn) && $warn ne "" && ($read_counter >= $warn)) {
output_add(\$output_warning, \$output_warning_append, ", ",
"read on '" . $uuid_list{$_} . "' is $read_counter ms");
$status |= $MYERRORS_MASK{'WARNING'};
}
if (defined($crit) && $crit ne "" && ($write_counter >= $crit)) {
output_add(\$output_critical, \$output_critical_append, ", ",
"write on '" . $uuid_list{$_} . "' is $write_counter ms");
$status |= $MYERRORS_MASK{'WARNING'};
} elsif (defined($warn) && $warn ne "" && ($write_counter >= $warn)) {
output_add(\$output_warning, \$output_warning_append, ", ",
"write on '" . $uuid_list{$_} . "' is $write_counter ms");
$status |= $MYERRORS_MASK{'WARNING'};
}
$perfdata .= " 'trl_" . $uuid_list{$_} . "'=" . $read_counter . "ms 'twl_" . $uuid_list{$_} . "'=" . $write_counter . 'ms';
}
}
if ($output_critical ne "") {
$output .= $output_append . "CRITICAL - Latency counter: $output_critical";
$output_append = ". ";
}
if ($output_warning ne "") {
$output .= $output_append . "WARNING - Latency counter: $output_warning";
}
if ($status == 0) {
$output = "All Datastore latency counters are ok";
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output|$perfdata\n");
}
1;

64
connectors/vmware/lib/command-datastoreusage.pm Normal file
View File

@ -0,0 +1,64 @@
sub datastoreusage_check_args {
my ($ds, $warn, $crit) = @_;
if (!defined($ds) || $ds eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need datastore name\n");
return 1;
}
if (defined($warn) && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be a positive number\n");
return 1;
}
if (defined($crit) && $crit !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: crit threshold must be a positive number\n");
return 1;
}
if (defined($warn) && defined($crit) && $warn > $crit) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be lower than crit threshold\n");
return 1;
}
return 0;
}
sub datastoreusage_compute_args {
my $ds = $_[0];
my $warn = (defined($_[1]) ? $_[1] : 80);
my $crit = (defined($_[2]) ? $_[2] : 90);
return ($ds, $warn, $crit);
}
sub datastoreusage_do {
my ($ds, $warn, $crit) = @_;
my %filters = ('summary.name' => $ds);
my @properties = ('summary');
my $result = get_entities_host('Datastore', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output = "";
if ($$result[0]->summary->accessible == 1) {
my $dsName = $$result[0]->summary->name;
my $capacity = $$result[0]->summary->capacity;
my $free = $$result[0]->summary->freeSpace;
my $pct = ($capacity - $free) / $capacity * 100;
my $usedD = ($capacity - $free) / 1024 / 1024 / 1024;
my $sizeD = $capacity / 1024 / 1024 / 1024;
$output = "Datastore $dsName - used ".sprintf("%.2f", $usedD)." Go / ".sprintf("%.2f", $sizeD)." Go (".sprintf("%.2f", $pct)." %) |used=".($capacity - $free)."o;;;0;".$capacity." size=".$capacity."o\n";
if ($pct >= $warn) {
$status |= $MYERRORS_MASK{'WARNING'};
}
if ($pct > $crit) {
$status |= $MYERRORS_MASK{'CRITICAL'};
}
} else {
$output = "Datastore '$ds' summary not accessible.";
$status |= $MYERRORS_MASK{'UNKNOWN'};
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

53
connectors/vmware/lib/command-getmap.pm Normal file
View File

@ -0,0 +1,53 @@
sub getmap_check_args {
return 0;
}
sub getmap_compute_args {
my $lhost = $_[0];
return ($lhost);
}
sub getmap_do {
my ($lhost) = @_;
my %filters = ();
if (defined($lhost) and $lhost ne "") {
%filters = ('name' => $lhost);
}
my @properties = ('name', 'vm');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output = '';
my $output_append = "";
foreach my $entity_view (@$result) {
$output .= $output_append . "ESX Host '" . $entity_view->name . "': ";
my @vm_array = ();
if (defined $entity_view->vm) {
@vm_array = (@vm_array, @{$entity_view->vm});
}
@properties = ('name', 'summary.runtime.powerState');
my $result2 = get_views(\@vm_array, \@properties);
if (!defined($result)) {
return ;
}
my $output_append2 = '';
foreach my $vm (@$result2) {
if ($vm->{'summary.runtime.powerState'}->val eq "poweredOn") {
$output .= $output_append2 . "[" . $vm->name . "]";
$output_append2 = ', ';
}
}
$output_append = ". ";
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

97
connectors/vmware/lib/command-healthhost.pm Normal file
View File

@ -0,0 +1,97 @@
sub healthhost_check_args {
my ($host) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
return 0;
}
sub healthhost_compute_args {
my $lhost = $_[0];
return ($lhost);
}
sub healthhost_do {
my ($lhost) = @_;
my %filters = ('name' => $lhost);
my @properties = ('runtime.healthSystemRuntime.hardwareStatusInfo.cpuStatusInfo', 'runtime.healthSystemRuntime.systemHealthInfo.numericSensorInfo');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output_critical = '';
my $output_critical_append = '';
my $output_warning = '';
my $output_warning_append = '';
my $output = '';
my $output_append = '';
my $OKCount = 0;
my $CAlertCount = 0;
my $WAlertCount = 0;
foreach my $entity_view (@$result) {
my $cpuStatusInfo = $entity_view->{'runtime.healthSystemRuntime.hardwareStatusInfo.cpuStatusInfo'};
my $numericSensorInfo = $entity_view->{'runtime.healthSystemRuntime.systemHealthInfo.numericSensorInfo'};
if (!defined($cpuStatusInfo)) {
$status |= $MYERRORS_MASK{'CRITICAL'};
output_add(\$output_critical, \$output_critical_append, ", ",
"API error - unable to get cpuStatusInfo");
}
if (!defined($numericSensorInfo)) {
$status |= $MYERRORS_MASK{'CRITICAL'};
output_add(\$output_critical, \$output_critical_append, ", ",
"API error - unable to get numericSensorInfo");
}
# CPU
foreach (@$cpuStatusInfo) {
if ($_->status->key =~ /^red$/i) {
output_add(\$output_critical, \$output_critical_append, ", ",
$_->name . ": " . $_->status->summary);
$status |= $MYERRORS_MASK{'CRITICAL'};
$CAlertCount++;
} elsif ($_->status->key =~ /^yellow$/i) {
output_add(\$output_warning, \$output_warning_append, ", ",
$_->name . ": " . $_->status->summary);
$status |= $MYERRORS_MASK{'WARNING'};
$WAlertCount++;
} else {
$OKCount++;
}
}
# Sensor
foreach (@$numericSensorInfo) {
if ($_->healthState->key =~ /^red$/i) {
output_add(\$output_critical, \$output_critical_append, ", ",
$_->sensorType . " sensor " . $_->name . ": ".$_->healthState->summary);
$status |= $MYERRORS_MASK{'CRITICAL'};
$CAlertCount++;
} elsif ($_->healthState->key =~ /^yellow$/i) {
output_add(\$output_warning, \$output_warning_append, ", ",
$_->sensorType . " sensor " . $_->name . ": ".$_->healthState->summary);
$status |= $MYERRORS_MASK{'WARNING'};
$WAlertCount++;
} else {
$OKCount++;
}
}
}
if ($output_critical ne "") {
$output .= $output_append . "CRITICAL - $CAlertCount health issue(s) found: $output_critical";
$output_append = ". ";
}
if ($output_warning ne "") {
$output .= $output_append . "WARNING - $WAlertCount health issue(s) found: $output_warning";
}
if ($status == 0) {
$output = "All $OKCount health checks are green";
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

45
connectors/vmware/lib/command-listdatastore.pm Normal file
View File

@ -0,0 +1,45 @@
sub listdatastore_check_args {
return 0;
}
sub listdatastore_compute_args {
return undef;
}
sub listdatastore_do {
my ($ds, $warn, $crit) = @_;
my %filters = ();
my @properties = ('datastore');
my $result = get_entities_host('Datacenter', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my @ds_array = ();
foreach my $entity_view (@$result) {
if (defined $entity_view->datastore) {
@ds_array = (@ds_array, @{$entity_view->datastore});
}
}
@properties = ('summary');
$result = get_views(\@ds_array, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output = 'Datastore List: ';
my $output_append = "";
foreach my $datastore (@$result) {
if ($datastore->summary->accessible) {
$output .= $output_append . "'" . $datastore->summary->name . "'";
$output_append = ', ';
}
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

30
connectors/vmware/lib/command-listhost.pm Normal file
View File

@ -0,0 +1,30 @@
sub listhost_check_args {
return 0;
}
sub listhost_compute_args {
return undef;
}
sub listhost_do {
my %filters = ();
my @properties = ('name');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output = 'Host List: ';
my $output_append = "";
foreach my $entity_view (@$result) {
$output .= $output_append . $entity_view->{name};
$output_append = ', ';
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

43
connectors/vmware/lib/command-listnichost.pm Normal file
View File

@ -0,0 +1,43 @@
sub listnichost_check_args {
my ($host) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
return 0;
}
sub listnichost_compute_args {
my $lhost = $_[0];
return ($lhost);
}
sub listnichost_do {
my ($lhost) = @_;
my %filters = ('name' => $lhost);
my @properties = ('config.network.pnic');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output_up = 'Nic Up List: ';
my $output_down = 'Nic Down List: ';
my $output_up_append = "";
my $output_down_append = "";
foreach (@{$$result[0]->{'config.network.pnic'}}) {
if (defined($_->linkSpeed)) {
$output_up .= $output_up_append . "'" . $_->device . "'";
$output_up_append = ', ';
} else {
$output_down .= $output_down_append . "'" . $_->device . "'";
$output_down_append = ', ';
}
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output_up. $output_down.\n");
}
1;

39
connectors/vmware/lib/command-maintenancehost.pm Normal file
View File

@ -0,0 +1,39 @@
sub maintenancehost_check_args {
my ($host) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
return 0;
}
sub maintenancehost_compute_args {
my $lhost = $_[0];
return ($lhost);
}
sub maintenancehost_do {
my ($lhost) = @_;
my %filters = ('name' => $lhost);
my @properties = ('runtime.inMaintenanceMode');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output = '';
foreach my $entity_view (@$result) {
if ($entity_view->{'runtime.inMaintenanceMode'} ne "false") {
$status |= $MYERRORS_MASK{'CRITICAL'};
$output = "Server $lhost is on maintenance mode.";
} else {
$output = "Server $lhost is not on maintenance mode.";
}
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

70
connectors/vmware/lib/command-memhost.pm Normal file
View File

@ -0,0 +1,70 @@
sub memhost_check_args {
my ($host, $warn, $crit) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
if (defined($warn) && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be a positive number\n");
return 1;
}
if (defined($crit) && $crit !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: crit threshold must be a positive number\n");
return 1;
}
if (defined($warn) && defined($crit) && $warn > $crit) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be lower than crit threshold\n");
return 1;
}
return 0;
}
sub memhost_compute_args {
my $lhost = $_[0];
my $warn = (defined($_[1]) ? $_[1] : 80);
my $crit = (defined($_[2]) ? $_[2] : 90);
return ($lhost, $warn, $crit);
}
sub memhost_do {
my ($lhost, $warn, $crit) = @_;
if (!($perfcounter_speriod > 0)) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print_response($ERRORS{$MYERRORS{$status}} . "|Can't retrieve perf counters.\n");
return ;
}
my %filters = ('name' => $lhost);
my @properties = ('summary.hardware.memorySize');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $memory_size = $$result[0]->{'summary.hardware.memorySize'};
my $values = generic_performance_values_historic($$result[0],
[{'label' => 'mem.consumed.average', 'instances' => ['']},
{'label' => 'mem.overhead.average', 'instances' => ['']}],
$perfcounter_speriod);
my $mem_used = simplify_number(convert_number($values->{$perfcounter_cache{'mem.consumed.average'}->{'key'} . ":"}[0]));
my $mem_overhead = simplify_number(convert_number($values->{$perfcounter_cache{'mem.overhead.average'}->{'key'} . ":"}[0]));
my $status = 0; # OK
my $output = '';
if ($mem_used * 100 / ($memory_size / 1024) >= $warn) {
$status |= $MYERRORS_MASK{'WARNING'};
}
if ($mem_used * 100 / ($memory_size / 1024) >= $crit) {
$status |= $MYERRORS_MASK{'CRITICAL'};
}
$output = "Memory used : " . simplify_number($mem_used / 1024 / 1024) . " Go - size : " . simplify_number($memory_size / 1024 / 1024 / 1024) . " Go - percent : " . simplify_number($mem_used * 100 / ($memory_size / 1024)) . " %";
$output .= "|used=" . ($mem_used * 1024) . "o;" . simplify_number($memory_size * $warn / 100, 0) . ";" . simplify_number($memory_size * $crit / 100, 0) . ";0;" . ($memory_size) . " size=" . $memory_size . "o" . " overhead=" . ($mem_overhead * 1024) . "o";
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

86
connectors/vmware/lib/command-nethost.pm Normal file
View File

@ -0,0 +1,86 @@
sub nethost_check_args {
my ($host, $pnic, $warn, $crit) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
if (!defined($pnic) || $pnic eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need physical nic name\n");
return 1;
}
if (defined($warn) && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be a positive number\n");
return 1;
}
if (defined($crit) && $crit !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: crit threshold must be a positive number\n");
return 1;
}
if (defined($warn) && defined($crit) && $warn > $crit) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be lower than crit threshold\n");
return 1;
}
return 0;
}
sub nethost_compute_args {
my $lhost = $_[0];
my $pnic = $_[1];
my $warn = (defined($_[2]) ? $_[2] : 80);
my $crit = (defined($_[3]) ? $_[3] : 90);
return ($lhost, $pnic, $warn, $crit);
}
sub nethost_do {
my ($lhost, $pnic, $warn, $crit) = @_;
if (!($perfcounter_speriod > 0)) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print_response($ERRORS{$MYERRORS{$status}} . "|Can't retrieve perf counters.\n");
return ;
}
my %filters = ('name' => $lhost);
my @properties = ('config.network.pnic');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my %pnic_def = ();
foreach (@{$$result[0]->{'config.network.pnic'}}) {
if (defined($_->linkSpeed)) {
$pnic_def{$_->device} = $_->linkSpeed->speedMb;
}
}
if (!defined($pnic_def{$pnic})) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print $ERRORS{$MYERRORS{$status}} . "|Link '$pnic' not exist or down.\n";
return ;
}
my $values = generic_performance_values_historic($$result[0],
[{'label' => 'net.received.average', 'instances' => [$pnic]},
{'label' => 'net.transmitted.average', 'instances' => [$pnic]}],
$perfcounter_speriod);
my $traffic_in = simplify_number(convert_number($values->{$perfcounter_cache{'net.received.average'}->{'key'} . ":" . $pnic}[0]));
my $traffic_out = simplify_number(convert_number($values->{$perfcounter_cache{'net.transmitted.average'}->{'key'} . ":" . $pnic}[0]));
my $status = 0; # OK
my $output = '';
if (($traffic_in / 1024 * 8 * 100 / $pnic_def{$pnic}) >= $warn || ($traffic_out / 1024 * 8 * 100 / $pnic_def{$pnic}) >= $warn) {
$status |= $MYERRORS_MASK{'WARNING'};
}
if (($traffic_in / 1024 * 8 * 100 / $pnic_def{$pnic}) >= $crit || ($traffic_out / 1024 * 8 * 100 / $pnic_def{$pnic}) >= $crit) {
$status |= $MYERRORS_MASK{'CRITICAL'};
}
$output = "Traffic In : " . simplify_number($traffic_in / 1024 * 8) . " Mb/s (" . simplify_number($traffic_in / 1024 * 8 * 100 / $pnic_def{$pnic}) . " %), Out : " . simplify_number($traffic_out / 1024 * 8) . " Mb/s (" . simplify_number($traffic_out / 1024 * 8 * 100 / $pnic_def{$pnic}) . " %)";
$output .= "|traffic_in=" . ($traffic_in * 1024 * 8) . "b/s traffic_out=" . (($traffic_out * 1024 * 8)) . "b/s";
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

57
connectors/vmware/lib/command-statushost.pm Normal file
View File

@ -0,0 +1,57 @@
sub statushost_check_args {
my ($host) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
return 0;
}
sub statushost_compute_args {
my $lhost = $_[0];
return ($lhost);
}
sub statushost_do {
my ($lhost) = @_;
my %filters = ('name' => $lhost);
my @properties = ('summary.overallStatus');
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $status = 0; # OK
my $output = '';
my %overallStatus = (
'gray' => 'status is unknown',
'green' => 'is OK',
'red' => 'has a problem',
'yellow' => 'might have a problem',
);
my %overallStatusReturn = (
'gray' => 'UNKNOWN',
'green' => 'OK',
'red' => 'CRITICAL',
'yellow' => 'WARNING'
);
foreach my $entity_view (@$result) {
my $status = $entity_view->{'summary.overallStatus'}->val;
if (defined($status) && $overallStatus{$status}) {
$output = "The Server '$lhost' " . $overallStatus{$status};
if ($MYERRORS_MASK{$overallStatusReturn{$status}} != 0) {
$status |= $MYERRORS_MASK{$overallStatusReturn{$status}};
}
} else {
$output = "Can't interpret data...";
$status |= $MYERRORS_MASK{'UNKNOWN'};
}
}
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

68
connectors/vmware/lib/command-swaphost.pm Normal file
View File

@ -0,0 +1,68 @@
sub swaphost_check_args {
my ($host, $warn, $crit) = @_;
if (!defined($host) || $host eq "") {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: need hostname\n");
return 1;
}
if (defined($warn) && $warn !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be a positive number\n");
return 1;
}
if (defined($crit) && $crit !~ /^-?(?:\d+\.?|\.\d)\d*\z/) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: crit threshold must be a positive number\n");
return 1;
}
if (defined($warn) && defined($crit) && $warn > $crit) {
writeLogFile(LOG_ESXD_ERROR, "ARGS error: warn threshold must be lower than crit threshold\n");
return 1;
}
return 0;
}
sub swaphost_compute_args {
my $lhost = $_[0];
my $warn = (defined($_[1]) ? $_[1] : 0.8);
my $crit = (defined($_[2]) ? $_[2] : 1);
return ($lhost, $warn, $crit);
}
sub swaphost_do {
my ($lhost, $warn, $crit) = @_;
if (!($perfcounter_speriod > 0)) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print_response($ERRORS{$MYERRORS{$status}} . "|Can't retrieve perf counters.\n");
return ;
}
my %filters = ('name' => $lhost);
#my @properties = ('summary');
my @properties = ();
my $result = get_entities_host('HostSystem', \%filters, \@properties);
if (!defined($result)) {
return ;
}
my $values = generic_performance_values_historic($$result[0],
[{'label' => 'mem.swapinRate.average', 'instances' => ['']},
{'label' => 'mem.swapoutRate.average', 'instances' => ['']}],
$perfcounter_speriod);
my $swap_in = simplify_number(convert_number($values->{$perfcounter_cache{'mem.swapinRate.average'}->{'key'} . ":"}[0]));
my $swap_out = simplify_number(convert_number($values->{$perfcounter_cache{'mem.swapoutRate.average'}->{'key'} . ":"}[0]));
my $status = 0; # OK
my $output = '';
if (($swap_in / 1024) >= $warn || ($swap_out / 1024) >= $warn) {
$status |= $MYERRORS_MASK{'WARNING'};
}
if (($swap_in / 1024) >= $crit || ($swap_out / 1024) >= $crit) {
$status |= $MYERRORS_MASK{'CRITICAL'};
}
$output = "Swap In : " . simplify_number($swap_in / 1024 * 8) . " Mb/s , Swap Out : " . simplify_number($swap_out / 1024 * 8) . " Mb/s ";
$output .= "|swap_in=" . ($swap_in * 1024 * 8) . "b/s swap_out=" . (($swap_out * 1024 * 8)) . "b/s";
print_response($ERRORS{$MYERRORS{$status}} . "|$output\n");
}
1;

200
connectors/vmware/lib/esxd-common.pm Normal file
View File

@ -0,0 +1,200 @@
sub writeLogFile($$) {
if (($log_crit & $_[0]) == 0) {
return ;
}
if ($log_mode == 0) {
print $_[1];
} elsif ($log_mode == 1) {
my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time());
open (LOG, ">> ".$LOG) || print "can't write $LOG: $!";
printf LOG "%04d-%02d-%02d %02d:%02d:%02d - %s", $year+1900, $mon+1, $mday, $hour, $min, $sec, $_[1];
close LOG;
} elsif ($log_mode == 2) {
syslog LOG_ERR, $_[1] if ($_[0] == LOG_ESXD_ERROR);
syslog LOG_INFO, $_[1] if ($_[0] == LOG_ESXD_INFO);
}
}
sub connect_vsphere {
writeLogFile(LOG_ESXD_INFO, "Vsphere connection in progress\n");
eval {
$SIG{ALRM} = sub { die('TIMEOUT'); };
alarm($TIMEOUT_VSPHERE);
$session1 = Vim->new(service_url => $service_url);
$session1->login(
user_name => $username,
password => $password);
alarm(0);
};
if($@) {
writeLogFile(LOG_ESXD_ERROR, "No response from VirtualCentre server\n") if($@ =~ /TIMEOUT/);
writeLogFile(LOG_ESXD_ERROR, "You need to upgrade HTTP::Message!\n") if($@ =~ /HTTP::Message/);
writeLogFile(LOG_ESXD_ERROR, "Login to VirtualCentre server failed: $@");
return 1;
}
# eval {
# $session_id = Vim::get_session_id();
# };
# if($@) {
# writeLogFile("Can't get session_id: $@\n");
# return 1;
# }
return 0;
}
sub print_response {
print "$global_id|" . $_[0];
}
sub output_add($$$$) {
my ($output_str, $output_append, $delim, $str) = (shift, shift, shift, shift);
$$output_str .= $$output_append . $str;
$$output_append = $delim;
}
sub simplify_number{
my ($number, $cnt) = @_;
$cnt = 2 if (!defined($cnt));
return sprintf("%.${cnt}f", "$number");
}
sub convert_number {
my ($number) = shift(@_);
$number =~ s/\,/\./;
return $number;
}
sub get_views {
my $results;
eval {
$results = $session1->get_views(mo_ref_array => $_[0], properties => $_[1]);
};
if ($@) {
writeLogFile(LOG_ESXD_ERROR, "$@");
my $lerror = $@;
$lerror =~ s/\n/ /g;
print_response("-1|Error: " . $lerror . "\n");
return undef;
}
return $results;
}
sub get_perf_metric_ids {
my $perf_names = $_[0];
my @filtered_list;
foreach (@$perf_names) {
if (defined($perfcounter_cache{$_->{'label'}})) {
foreach my $instance (@{$_->{'instances'}}) {
my $metric = PerfMetricId->new(counterId => $perfcounter_cache{$_->{'label'}}{'key'},
instance => $instance);
push @filtered_list, $metric;
}
} else {
writeLogFile(LOG_ESXD_ERROR, "Metric '" . $_->{'label'} . "' unavailable.\n");
}
}
return \@filtered_list;
}
sub generic_performance_values_historic {
my ($view, $perfs, $interval) = @_;
my $counter = 0;
my %results;
eval {
my @perf_metric_ids = get_perf_metric_ids($perfs);
my (@t) = gmtime(time() - $interval);
my $start = sprintf("%04d-%02d-%02dT%02d:%02d:00Z",
(1900+$t[5]),(1+$t[4]),$t[3],$t[2],$t[1]);
my $perf_query_spec = PerfQuerySpec->new(entity => $view,
metricId => @perf_metric_ids,
format => 'normal',
intervalId => $interval,
startTime => $start
);
#maxSample => 1);
my $perfdata = $perfmanager_view->QueryPerf(querySpec => $perf_query_spec);
foreach (@{$$perfdata[0]->value}) {
$results{$_->id->counterId . ":" . (defined($_->id->instance) ? $_->id->instance : "")} = $_->value;
}
};
if ($@) {
writeLogFile(LOG_ESXD_ERROR, "$@");
return undef;
}
return \%results;
}
sub cache_perf_counters {
eval {
$perfmanager_view = $session1->get_view(mo_ref => $session1->get_service_content()->perfManager, properties => ['perfCounter', 'historicalInterval']);
foreach (@{$perfmanager_view->perfCounter}) {
my $label = $_->groupInfo->key . "." . $_->nameInfo->key . "." . $_->rollupType->val;
$perfcounter_cache{$label} = {'key' => $_->key, 'unitkey' => $_->unitInfo->key};
$perfcounter_cache_reverse{$_->key} = $label;
}
my $historical_intervals = $perfmanager_view->historicalInterval;
foreach (@$historical_intervals) {
if ($perfcounter_speriod == -1 || $perfcounter_speriod > $_->samplingPeriod) {
$perfcounter_speriod = $_->samplingPeriod;
}
}
};
if ($@) {
writeLogFile(LOG_ESXD_ERROR, "$@");
return 1;
}
return 0;
}
sub get_entities_host {
my ($view_type, $filters, $properties) = @_;
my $entity_views;
eval {
$entity_views = $session1->find_entity_views(view_type => $view_type, properties => $properties, filter => $filters);
};
if ($@ =~ /decryption failed or bad record mac/) {
writeLogFile(LOG_ESXD_ERROR, "$@");
eval {
$entity_views = $session1->find_entity_views(view_type => $view_type, properties => $properties, filter => $filters);
};
if ($@) {
writeLogFile(LOG_ESXD_ERROR, "$@");
my $lerror = $@;
$lerror =~ s/\n/ /g;
print_response("-1|Error: " . Data::Dumper::Dumper($lerror) . "\n");
return undef;
}
} elsif ($@) {
writeLogFile(LOG_ESXD_ERROR, "$@");
my $lerror = $@;
$lerror =~ s/\n/ /g;
print_response("-1|Error: " . $lerror . "\n");
return undef;
}
if (!@$entity_views) {
my $status |= $MYERRORS_MASK{'UNKNOWN'};
print_response($ERRORS{$MYERRORS{$status}} . "|Object $view_type does not exist.\n");
return undef;
}
#eval {
# $$entity_views[0]->update_view_data(properties => $properties);
#};
#if ($@) {
# writeLogFile("$@");
# my $lerror = $@;
# $lerror =~ s/\n/ /g;
# print "-1|Error: " . $lerror . "\n";
# return undef;
#}
return $entity_views;
}
1;