- added src/zabbix_snmptrap (Alexei)

git-svn-id: svn://svn.zabbix.com/trunk@879 97f52cf1-0a1b-0410-bd0e-c28be96e8082

2 files changed, 286 insertions, 0 deletions

diff --git a/src/zabbix_snmptrapper/Makefile.in b/src/zabbix_snmptrapper/Makefile.in
new file mode 100644
index 00000000..8d6f5407
--- /dev/null
+++ b/src/zabbix_snmptrapper/Makefile.in
@@ -0,0 +1,10 @@
+# Build rules
+
+all:
+
+	@CC@ -o ../../bin/zabbix_snmptrapper @CFLAGS@ -I../../include zabbix_snmptrapper.c @LIBS@
+
+clean:
+	rm -f *.o 
+	rm -f ../../bin/zabbix_snmptrapper
+
diff --git a/src/zabbix_snmptrapper/zabbix_snmptrapper.c b/src/zabbix_snmptrapper/zabbix_snmptrapper.c
new file mode 100644
index 00000000..d94d6d40
--- /dev/null
+++ b/src/zabbix_snmptrapper/zabbix_snmptrapper.c
@@ -0,0 +1,276 @@
+/* 
+** Zabbix
+** Copyright (C) 2000,2001,2002,2003 Alexei Vladishev
+**
+** 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, or
+** (at your option) any later version.
+**
+** 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, write to the Free Software
+** Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+**/
+
+#include "config.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <netinet/in.h>
+#include <netdb.h>
+
+#include <string.h>
+
+/* OpenBSD*/
+#ifdef HAVE_SYS_SOCKET_H
+	#include <sys/socket.h>
+#endif
+
+#include <signal.h>
+#include <time.h>
+
+#include "common.h"
+
+int     CONFIG_SUCKERD_FORKS            =SUCKER_FORKS;
+int     CONFIG_NOTIMEWAIT               =0;
+int     CONFIG_TIMEOUT                  =SUCKER_TIMEOUT;
+int     CONFIG_HOUSEKEEPING_FREQUENCY   = 1;
+int     CONFIG_SENDER_FREQUENCY         = 30;
+int     CONFIG_PINGER_FREQUENCY         = 60;
+int     CONFIG_DISABLE_HOUSEKEEPING     = 0;
+int     CONFIG_LOG_LEVEL                = LOG_LEVEL_WARNING;
+char    *CONFIG_PID_FILE                = NULL;
+char    *CONFIG_LOG_FILE                = NULL;
+char    *CONFIG_ALERT_SCRIPTS_PATH      = NULL;
+char    *CONFIG_DBHOST                  = NULL;
+char    *CONFIG_DBNAME                  = NULL;
+char    *CONFIG_DBUSER                  = NULL;
+char    *CONFIG_DBPASSWORD              = NULL;
+char    *CONFIG_DBSOCKET                = NULL;
+
+void    signal_handler( int sig )
+{
+	if( SIGALRM == sig )
+	{
+		signal( SIGALRM, signal_handler );
+		fprintf(stderr,"Timeout while executing operation.\n");
+	}
+ 
+	if( SIGQUIT == sig || SIGINT == sig || SIGTERM == sig )
+	{
+/*		fprintf(stderr,"\nGot QUIT or INT or TERM signal. Exiting..." ); */
+	}
+	exit( FAIL );
+}
+
+
+void	init_config(void)
+{
+	static struct cfg_line cfg[]=
+	{
+/*		 PARAMETER	,VAR	,FUNC,	TYPE(0i,1s),MANDATORY,MIN,MAX	*/
+		{"StartSuckers",&CONFIG_SUCKERD_FORKS,0,TYPE_INT,PARM_OPT,5,255},
+		{"HousekeepingFrequency",&CONFIG_HOUSEKEEPING_FREQUENCY,0,TYPE_INT,PARM_OPT,1,24},
+		{"SenderFrequency",&CONFIG_SENDER_FREQUENCY,0,TYPE_INT,PARM_OPT,5,3600},
+		{"PingerFrequency",&CONFIG_PINGER_FREQUENCY,0,TYPE_INT,PARM_OPT,10,3600},
+		{"Timeout",&CONFIG_TIMEOUT,0,TYPE_INT,PARM_OPT,1,30},
+		{"NoTimeWait",&CONFIG_NOTIMEWAIT,0,TYPE_INT,PARM_OPT,0,1},
+		{"DisableHousekeeping",&CONFIG_DISABLE_HOUSEKEEPING,0,TYPE_INT,PARM_OPT,0,1},
+		{"DebugLevel",&CONFIG_LOG_LEVEL,0,TYPE_INT,PARM_OPT,0,4},
+		{"PidFile",&CONFIG_PID_FILE,0,TYPE_STRING,PARM_OPT,0,0},
+		{"LogFile",&CONFIG_LOG_FILE,0,TYPE_STRING,PARM_OPT,0,0},
+		{"AlertScriptsPath",&CONFIG_ALERT_SCRIPTS_PATH,0,TYPE_STRING,PARM_OPT,0,0},
+		{"DBHost",&CONFIG_DBHOST,0,TYPE_STRING,PARM_OPT,0,0},
+		{"DBName",&CONFIG_DBNAME,0,TYPE_STRING,PARM_MAND,0,0},
+		{"DBUser",&CONFIG_DBUSER,0,TYPE_STRING,PARM_OPT,0,0},
+		{"DBPassword",&CONFIG_DBPASSWORD,0,TYPE_STRING,PARM_OPT,0,0},
+		{"DBSocket",&CONFIG_DBSOCKET,0,TYPE_STRING,PARM_OPT,0,0},
+		{0}
+	};
+
+	parse_cfg_file("/etc/zabbix/zabbix_suckerd.conf",cfg);
+
+	if(CONFIG_DBNAME == NULL)
+	{
+		zabbix_log( LOG_LEVEL_CRIT, "DBName not in config file");
+		exit(1);
+	}
+	if(CONFIG_PID_FILE == NULL)
+	{
+		CONFIG_PID_FILE=strdup("/tmp/zabbix_suckerd.pid");
+	}
+	if(CONFIG_ALERT_SCRIPTS_PATH == NULL)
+	{
+		CONFIG_ALERT_SCRIPTS_PATH=strdup("/home/zabbix/bin");
+	}
+}
+
+
+int	send_value(char *server,int port,char *shortname,char *value)
+{
+	int	i,s;
+	char	tosend[1024];
+	char	result[1024];
+	struct hostent *hp;
+
+	struct sockaddr_in myaddr_in;
+	struct sockaddr_in servaddr_in;
+
+/*	struct linger ling;*/
+
+	servaddr_in.sin_family=AF_INET;
+	hp=gethostbyname(server);
+
+	if(hp==NULL)
+	{
+		return	FAIL;
+	}
+
+	servaddr_in.sin_addr.s_addr=((struct in_addr *)(hp->h_addr))->s_addr;
+
+	servaddr_in.sin_port=htons(port);
+
+	s=socket(AF_INET,SOCK_STREAM,0);
+	if(s == -1)
+	{
+		return	FAIL;
+	}
+
+/*	ling.l_onoff=1;*/
+/*	ling.l_linger=0;*/
+/*	if(setsockopt(s,SOL_SOCKET,SO_LINGER,&ling,sizeof(ling))==-1)*/
+/*	{*/
+/* Ignore */
+/*	}*/
+ 
+	myaddr_in.sin_family = AF_INET;
+	myaddr_in.sin_port=0;
+	myaddr_in.sin_addr.s_addr=INADDR_ANY;
+
+	if( connect(s,(struct sockaddr *)&servaddr_in,sizeof(struct sockaddr_in)) == -1 )
+	{
+		close(s);
+		return	FAIL;
+	}
+
+	sprintf(tosend,"%s:%s\n",shortname,value);
+
+	if( sendto(s,tosend,strlen(tosend),0,(struct sockaddr *)&servaddr_in,sizeof(struct sockaddr_in)) == -1 )
+	{
+		perror("sendto");
+		close(s);
+		return	FAIL;
+	} 
+	i=sizeof(struct sockaddr_in);
+/*	i=recvfrom(s,result,1023,0,(struct sockaddr *)&servaddr_in,(size_t *)&i);*/
+	i=recvfrom(s,result,1023,0,(struct sockaddr *)&servaddr_in,(socklen_t *)&i);
+	if(s==-1)
+	{
+		perror("recfrom");
+		close(s);
+		return	FAIL;
+	}
+
+	result[i-1]=0;
+
+	if(strcmp(result,"OK") == 0)
+	{
+		printf("OK\n");
+	}
+ 
+	if( close(s)!=0 )
+	{
+		perror("close");
+		
+	}
+
+	return SUCCEED;
+}
+
+int main(int argc, char **argv)
+{
+	int	port;
+	int	ret=SUCCEED;
+	char	line[MAX_STRING_LEN+1];
+	char	port_str[MAX_STRING_LEN+1];
+	char	zabbix_server[MAX_STRING_LEN+1];
+	char	server_key[MAX_STRING_LEN+1];
+	char	value[MAX_STRING_LEN+1];
+	char	*s;
+
+	signal( SIGINT,  signal_handler );
+	signal( SIGQUIT, signal_handler );
+	signal( SIGTERM, signal_handler );
+	signal( SIGALRM, signal_handler );
+/*
+	read hostname
+	read ip
+	read uptime
+	read oid
+	read address
+	read community
+	read enterprise
+
+	oid=`echo $oid|cut -f2 -d' '`
+	address=`echo $address|cut -f2 -d' '`
+	community=`echo $community|cut -f2 -d' '`
+	enterprise=`echo $enterprise|cut -f2 -d' '`
+
+	oid=`echo $oid|cut -f11 -d'.'`
+	community=`echo $community|cut -f2 -d'"'`
+
+	str="$hostname $address $community $enterprise $oid"
+
+	$ZABBIX_SERVER $ZABBIX_PORT $HOST:$KEY "$str"
+*/
+
+	if(argc == 5)
+	{
+		port=atoi(argv[2]);
+
+		alarm(SENDER_TIMEOUT);
+
+		ret = send_value(argv[1],port,argv[3],argv[4]);
+
+		alarm(0);
+	}
+/* No parameters are given */	
+	else if(argc == 1)
+	{
+		while(fgets(line,MAX_STRING_LEN,stdin) != NULL)
+		{
+/*			printf("[%s]\n",line);*/
+			alarm(SENDER_TIMEOUT);
+
+			s=(char *)strtok(line," ");
+			strncpy(zabbix_server,s,MAX_STRING_LEN);
+			s=(char *)strtok(NULL," ");
+			strncpy(port_str,s,MAX_STRING_LEN);
+			s=(char *)strtok(NULL," ");
+			strncpy(server_key,s,MAX_STRING_LEN);
+			s=(char *)strtok(NULL," ");
+			strncpy(value,s,MAX_STRING_LEN);
+			ret = send_value(zabbix_server,atoi(port_str),server_key,value);
+
+			alarm(0);
+		}
+	}
+	else
+	{
+		printf("Usage: zabbix_sender <Zabbix server> <port> <server:key> <value>\n");
+		printf("If no arguments are given, zabbix_sender expects list of parameters\n");
+		printf("from standard input.\n");
+		
+		ret = FAIL;
+	}
+
+	return ret;
+}