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

revert old traphandler for centreon 1.4.2

Browse Source 
git-svn-id: http://svn.centreon.com/trunk/plugins@3608 6bcd3966-0018-0410-8128-fd23d134de7e
This commit is contained in:
Julien Mathis 2007-12-20 20:27:53 +00:00
parent 3e0b7dc7af
commit c1635bebad
2 changed files with 74 additions and 85 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/traps/conf/snmptt.ini
View File

@ -479,11 +479,10 @@ DEBUGGING_FILE_HANDLER = /var/log/snmptthandler.debug
# A list of snmptt.conf files (this is NOT the snmptrapd.conf file). The COMPLETE path # A list of snmptt.conf files (this is NOT the snmptrapd.conf file). The COMPLETE path
# and filename. Ex: '/etc/snmp/snmptt.conf' # and filename. Ex: '/etc/snmp/snmptt.conf'
snmptt_conf_files = <<END snmptt_conf_files = <<END
/etc/snmp/oreon_traps/snmptt-cisco.conf /etc/snmp/centreon_traps/snmptt-cisco.conf
/etc/snmp/oreon_traps/snmptt-hp.conf /etc/snmp/centreon_traps/snmptt-hp.conf
/etc/snmp/oreon_traps/snmptt-3com.conf /etc/snmp/centreon_traps/snmptt-3com.conf
/etc/snmp/oreon_traps/snmptt-ciscolinksys.conf /etc/snmp/centreon_traps/snmptt-ciscolinksys.conf
/etc/snmp/oreon_traps/snmptt-dell.conf /etc/snmp/centreon_traps/snmptt-dell.conf
/etc/snmp/oreon_traps/snmptt-Generic.conf /etc/snmp/centreon_traps/snmptt-Generic.conf
/etc/snmp/oreon_traps/snmptt-Zebra.conf
END END

146
src/traps/plugins/trapHandler
View File

@ -2,7 +2,7 @@
################################################################### ###################################################################
# Oreon is developped with GPL Licence 2.0 # Oreon is developped with GPL Licence 2.0
# #
# GPL License: http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt # GPL License: http://www.gnu.org/licenses/gpl.txt
# #
# Developped by : Mathavarajan Sugumaran - msugumaran@merethis.com # Developped by : Mathavarajan Sugumaran - msugumaran@merethis.com
# Julien Mathis - Romain Le Merlus # Julien Mathis - Romain Le Merlus
@ -39,7 +39,7 @@ sub get_hostinfos($$$){
$sth->execute(); $sth->execute();
my @host; my @host;
while (my $temp = $sth->fetchrow_array()) { while (my $temp = $sth->fetchrow_array()) {
$host[scalar(@host)] = $temp; $host[scalar(@host)] = $temp;
} }
$sth -> finish; $sth -> finish;
return @host; return @host;
@ -54,76 +54,78 @@ sub getServicesIncludeTemplate($$$$) {
my @service; my @service;
$sth_st->execute(); $sth_st->execute();
while (my @temp = $sth_st -> fetchrow_array()) { while (my @temp = $sth_st -> fetchrow_array()) {
my $tr_query = "SELECT `traps_id` FROM `traps_service_relation` WHERE `service_id` = '".$temp[0]."' AND `traps_id` = '".$trap_id."'"; my $tr_query = "select traps_id from traps_service_relation where service_id ='".$temp[0]."' and traps_id='".$trap_id."'";
my $sth_st3 = $dbh->prepare($tr_query); my $sth_st3 = $dbh->prepare($tr_query);
$sth_st3->execute(); $sth_st3->execute();
my @trap = $sth_st3 -> fetchrow_array(); my @trap = $sth_st3 -> fetchrow_array();
if (defined($trap[0])) { if (defined($trap[0])) {
$service[scalar(@service)] = $temp[1]; $service[scalar(@service)] = $temp[1];
} else { }else {
if (defined($temp[2])) { if (defined($temp[2])) {
my $found = 0; my $found = 0;
my $service_template = $temp[2]; my $service_template = $temp[2];
while (!$found) { while (!$found) {
my $st1_query = "SELECT `service_id`, `service_template_model_stm_id`, `service_description` FROM service s WHERE `service_id` = '".$service_template."'"; my $st1_query = "select service_id, service_template_model_stm_id, service_description from service s where service_id ='".$service_template."'";
my $sth_st1 = $dbh->prepare($st1_query); my $sth_st1 = $dbh->prepare($st1_query);
$sth_st1 -> execute(); $sth_st1 -> execute();
my @st1_result = $sth_st1 -> fetchrow_array(); my @st1_result = $sth_st1 -> fetchrow_array();
if (defined($st1_result[0])) { if (defined($st1_result[0])) {
my $sth_st2 = $dbh->prepare("SELECT `traps_id` FROM `traps_service_relation` WHERE `service_id` = '".$service_template."' AND `traps_id` = '".$trap_id."'"); my $st2_query = "select traps_id from traps_service_relation where service_id ='".$service_template."' and traps_id='".$trap_id."'";
$sth_st2 -> execute(); my $sth_st2 = $dbh->prepare($st2_query);
my @st2_result = $sth_st2 -> fetchrow_array(); $sth_st2 -> execute();
if (defined($st2_result[0])) { my @st2_result = $sth_st2 -> fetchrow_array();
$found = 1; if (defined($st2_result[0])) {
$service[scalar(@service)] = $temp[1]; $found = 1;
} else { $service[scalar(@service)] = $temp[1];
$found = 1; }else {
if (defined($st1_result[1]) && $st1_result[1]) { $found = 1;
$service_template = $st1_result[1]; if (defined($st1_result[1]) && $st1_result[1]) {
$found = 0; $service_template = $st1_result[1];
} $found = 0;
} }
$sth_st2->finish; }
} $sth_st2->finish;
$sth_st1->finish;
}
} }
$sth_st1->finish;
} }
$sth_st3->finish; }
}
$sth_st3->finish;
} }
return (@service); return (@service);
} }
########################## ##########################
# GET SERVICE DESCRIPTION ## GET SERVICE DESCRIPTION
# #
sub getServiceInformations($$$) { sub get_servicename($$$) {
my $query_host = "SELECT host_id from host WHERE host_name ='$_[2]'";
my $sth = $_[0]->prepare("SELECT `host_id` FROM `host` WHERE `host_name` = '$_[2]'"); my $sth = $_[0]->prepare($query_host);
$sth->execute(); $sth->execute();
my $host_id = $sth->fetchrow_array(); my $host_id = $sth -> fetchrow_array();
exit if (!defined $host_id); exit if (!defined $host_id);
$sth->finish(); $sth->finish();
$sth = $_[0]->prepare("SELECT `traps_id`, `traps_status`, `traps_submit_result_enable`, `traps_execution_command`, `traps_reschedule_svc_enable`, `traps_execution_command_enable` FROM `traps` WHERE `traps_oid` = '$_[1]'"); my $query_trap = "SELECT traps_id, traps_status from traps where traps_oid='$_[1]'";
$sth = $_[0]->prepare($query_trap);
$sth->execute(); $sth->execute();
my ($trap_id, $trap_status, $traps_submit_result_enable, $traps_execution_command, $traps_reschedule_svc_enable, $traps_reschedule_svc_enable) = $sth->fetchrow_array(); my ($trap_id, $trap_status) = $sth->fetchrow_array();
exit if (!defined $trap_id); exit if (!defined $trap_id);
$sth->finish(); $sth->finish();
# ##
## getting all "services by host" for given host ### getting all "services by host" for given host
# ##
my $st_query = "SELECT s.service_id, service_description, service_template_model_stm_id FROM service s, host_service_relation h"; my $st_query = "SELECT s.service_id, service_description, service_template_model_stm_id FROM service s, host_service_relation h";
$st_query .= " where s.service_id=h.service_service_id and h.host_host_id='$host_id'"; $st_query .= " where s.service_id=h.service_service_id and h.host_host_id='$host_id'";
my $sth_st = $_[0]->prepare($st_query); my $sth_st = $_[0]->prepare($st_query);
my @service = getServicesIncludeTemplate($_[0], $sth_st, $host_id, $trap_id); my @service = getServicesIncludeTemplate($_[0], $sth_st, $host_id, $trap_id);
$sth_st->finish; $sth_st->finish;
# ##
## getting all "services by hostgroup" for given host ### getting all "services by hostgroup" for given host
# ##
my $query_hostgroup_services = "SELECT s.service_id, service_description, service_template_model_stm_id FROM hostgroup_relation hgr, service s, host_service_relation hsr"; my $query_hostgroup_services = "SELECT s.service_id, service_description, service_template_model_stm_id FROM hostgroup_relation hgr, service s, host_service_relation hsr";
$query_hostgroup_services .= " WHERE hgr.host_host_id = '".$host_id."' AND hsr.hostgroup_hg_id = hgr.hostgroup_hg_id"; $query_hostgroup_services .= " WHERE hgr.host_host_id = '".$host_id."' AND hsr.hostgroup_hg_id = hgr.hostgroup_hg_id";
$query_hostgroup_services .= " AND s.service_id = hsr.service_service_id"; $query_hostgroup_services .= " AND s.service_id = hsr.service_service_id";
@ -131,11 +133,11 @@ sub getServiceInformations($$$) {
$sth_st->execute(); $sth_st->execute();
@service = (@service,getServicesIncludeTemplate($_[0], $sth_st, $host_id, $trap_id)); @service = (@service,getServicesIncludeTemplate($_[0], $sth_st, $host_id, $trap_id));
$sth_st->finish; $sth_st->finish;
return $trap_status, (@service), $traps_submit_result_enable, $traps_execution_command, $traps_reschedule_svc_enable, $traps_execution_command_enable; return $trap_status, (@service);
} }
####################################### #######################################
# GET HOSTNAME AND SERVICE DESCRIPTION ## GET HOSTNAME AND SERVICE DESCRIPTION
# #
sub getTrapsInfos($$$$){ sub getTrapsInfos($$$$){
@ -144,41 +146,30 @@ sub getTrapsInfos($$$$){
my $oid = shift; my $oid = shift;
my $arguments_line = shift; my $arguments_line = shift;
my $dbh = DBI->connect("dbi:mysql:$mysql_database_oreon", $mysql_user, $mysql_passwd) or die "Echec de la connexion\n"; my $dsn = "dbi:mysql:$mysql_database_oreon";
my $dbh = DBI->connect($dsn, $mysql_user, $mysql_passwd) or die "Echec de la connexion\n";
my @host = get_hostinfos($dbh, $ip, $hostname); my @host = get_hostinfos($dbh, $ip, $hostname);
foreach(@host) { foreach(@host) {
my $this_host = $_; my $this_host = $_;
my ($status, @servicename, $traps_submit_result_enable, $traps_execution_command, $traps_reschedule_svc_enable, $traps_execution_command_enable) = getServiceInformations($dbh, $oid, $_); my ($status, @servicename) = get_servicename($dbh, $oid, $_);
foreach (@servicename) { foreach (@servicename) {
my $this_service = $_; my $this_service = $_;
my $datetime = `date +%s`; my $datetime=`date +%s`;
chomp($datetime); chomp($datetime);
my $sth = $dbh->prepare("SELECT `command_file` FROM `cfg_nagios` WHERE `nagios_activate` = '1' LIMIT 1"); my $sth = $dbh->prepare("SELECT command_file FROM cfg_nagios WHERE nagios_activate = '1' LIMIT 1");
$sth->execute(); $sth->execute();
my @conf = $sth->fetchrow_array(); my @conf = $sth->fetchrow_array();
$sth->finish(); $sth->finish();
if (defined($traps_submit_result_enable) && $traps_submit_result_enable eq 1){ my $submit = `/bin/echo "[$datetime] PROCESS_SERVICE_CHECK_RESULT;$this_host;$this_service;$status;$arguments_line" >> $conf[0]`;
my $submit = `/bin/echo "[$datetime] PROCESS_SERVICE_CHECK_RESULT;$this_host;$this_service;$status;$arguments_line" >> $conf[0]`; }
}
if (defined($traps_reschedule_svc_enable) && $traps_reschedule_svc_enable eq 1){
my $time_now = time();
my $submit = `/bin/echo "[$datetime] SCHEDULE_FORCED_SVC_CHECK;$this_host;$this_service;$time_now" >> $conf[0]`;
undef($time_now);
}
if (defined($traps_execution_command_enable) && $traps_execution_command_enable){
system($traps_execution_command);
}
undef($sth);
}
} }
$dbh->disconnect(); $dbh->disconnect();
exit; exit;
} }
########################## ##########################
# PARSE TRAP INFORMATIONS ## PARSE TRAP INFORMATIONS
# #
if (scalar(@ARGV)) { if (scalar(@ARGV)) {
my $ip = $ARGV[0]; my $ip = $ARGV[0];
my $hostname = $ARGV[1]; my $hostname = $ARGV[1];
@ -186,4 +177,3 @@ if (scalar(@ARGV)) {
my $arguments = $ARGV[3]; my $arguments = $ARGV[3];
getTrapsInfos($ip, $hostname, $oid, $arguments); getTrapsInfos($ip, $hostname, $oid, $arguments);
} }