Minor changes.

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

3 files changed, 325 insertions, 0 deletions

diff --git a/src/zabbix_server/housekeeper/Makefile.am b/src/zabbix_server/housekeeper/Makefile.am
new file mode 100644
index 00000000..2723f333
--- /dev/null
+++ b/src/zabbix_server/housekeeper/Makefile.am
@@ -0,0 +1,4 @@
+SUBDIRS=.
+INCLUDES=-I@top_srcdir@/include @MYSQL_INCLUDE@
+lib_LIBRARIES=libzbxhousekeeper.a
+libzbxhousekeeper_a_SOURCES=housekeeper.c
diff --git a/src/zabbix_server/housekeeper/housekeeper.c b/src/zabbix_server/housekeeper/housekeeper.c
new file mode 100644
index 00000000..54e488c5
--- /dev/null
+++ b/src/zabbix_server/housekeeper/housekeeper.c
@@ -0,0 +1,287 @@
+/* 
+** ZABBIX
+** Copyright (C) 2000-2005 SIA Zabbix
+**
+** 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 <sys/socket.h>
+#include <netinet/in.h>
+
+#include <sys/wait.h>
+
+#include <string.h>
+
+#ifdef HAVE_NETDB_H
+	#include <netdb.h>
+#endif
+
+/* Required for getpwuid */
+#include <pwd.h>
+
+#include <signal.h>
+#include <errno.h>
+
+#include <time.h>
+
+#include "common.h"
+#include "cfg.h"
+#include "db.h"
+#include "log.h"
+
+#include "housekeeper.h"
+
+/* Remove items having status 'deleted' */
+int housekeeping_items(void)
+{
+	char		sql[MAX_STRING_LEN];
+	DB_RESULT	*result;
+	int		i,itemid;
+
+	snprintf(sql,sizeof(sql)-1,"select itemid from items where status=%d", ITEM_STATUS_DELETED);
+	result = DBselect(sql);
+	for(i=0;i<DBnum_rows(result);i++)
+	{
+		itemid=atoi(DBget_field(result,i,0));
+		DBdelete_item(itemid);
+	}
+	DBfree_result(result);
+	return SUCCEED;
+}
+
+/* Remove hosts having status 'deleted' */
+int housekeeping_hosts(void)
+{
+	char		sql[MAX_STRING_LEN];
+	DB_RESULT	*result;
+	int		i,hostid;
+
+	snprintf(sql,sizeof(sql)-1,"select hostid from hosts where status=%d", HOST_STATUS_DELETED);
+	result = DBselect(sql);
+	for(i=0;i<DBnum_rows(result);i++)
+	{
+		hostid=atoi(DBget_field(result,i,0));
+		DBdelete_host(hostid);
+	}
+	DBfree_result(result);
+	return SUCCEED;
+}
+
+int housekeeping_history_and_trends(int now)
+{
+	char		sql[MAX_STRING_LEN];
+	DB_ITEM		item;
+
+	DB_RESULT	*result;
+
+	int		i;
+
+/* How lastdelete is used ??? */
+/*	snprintf(sql,sizeof(sql)-1,"select itemid,lastdelete,history,delay,trends from items where lastdelete<=%d", now);*/
+	snprintf(sql,sizeof(sql)-1,"select itemid,history,delay,trends from items");
+	result = DBselect(sql);
+
+	for(i=0;i<DBnum_rows(result);i++)
+	{
+		item.itemid=atoi(DBget_field(result,i,0));
+		item.history=atoi(DBget_field(result,i,1));
+		item.delay=atoi(DBget_field(result,i,2));
+		item.trends=atoi(DBget_field(result,i,3));
+
+		if(item.delay==0)
+		{
+			item.delay=1;
+		}
+
+/* Delete HISTORY */
+#ifdef HAVE_MYSQL
+		snprintf(sql,sizeof(sql)-1,"delete from history where itemid=%d and clock<%d limit %d",item.itemid,now-24*3600*item.history,2*CONFIG_HOUSEKEEPING_FREQUENCY*3600/item.delay);
+#else
+		snprintf(sql,sizeof(sql)-1,"delete from history where itemid=%d and clock<%d",item.itemid,now-24*3600*item.history);
+#endif
+		DBexecute(sql);
+
+/* Delete HISTORY_STR */
+#ifdef HAVE_MYSQL
+		snprintf(sql,sizeof(sql)-1,"delete from history_str where itemid=%d and clock<%d limit %d",item.itemid,now-24*3600*item.history,2*CONFIG_HOUSEKEEPING_FREQUENCY*3600/item.delay);
+#else
+		snprintf(sql,sizeof(sql)-1,"delete from history_str where itemid=%d and clock<%d",item.itemid,now-24*3600*item.history);
+#endif
+		DBexecute(sql);
+
+/* Delete HISTORY_LOG */
+#ifdef HAVE_MYSQL
+		snprintf(sql,sizeof(sql)-1,"delete from history_log where itemid=%d and clock<%d limit %d",item.itemid,now-24*3600*item.history,2*CONFIG_HOUSEKEEPING_FREQUENCY*3600/item.delay);
+#else
+		snprintf(sql,sizeof(sql)-1,"delete from history_log where itemid=%d and clock<%d",item.itemid,now-24*3600*item.history);
+#endif
+		DBexecute(sql);
+
+/* Delete HISTORY_TRENDS */
+#ifdef HAVE_MYSQL
+		snprintf(sql,sizeof(sql)-1,"delete from trends where itemid=%d and clock<%d limit %d",item.itemid,now-24*3600*item.trends,2*CONFIG_HOUSEKEEPING_FREQUENCY*3600/item.delay);
+#else
+		snprintf(sql,sizeof(sql)-1,"delete from trends where itemid=%d and clock<%d",item.itemid,now-24*3600*item.trends);
+#endif
+		DBexecute(sql);
+	}
+	DBfree_result(result);
+	return SUCCEED;
+}
+
+int housekeeping_sessions(int now)
+{
+	char	sql[MAX_STRING_LEN];
+
+	snprintf(sql,sizeof(sql)-1,"delete from sessions where lastaccess<%d",now-24*3600);
+	DBexecute(sql);
+
+	return SUCCEED;
+}
+
+int housekeeping_alerts(int now)
+{
+	char		sql[MAX_STRING_LEN];
+	int		alert_history;
+	DB_RESULT	*result;
+	int		res = SUCCEED;
+
+	snprintf(sql,sizeof(sql)-1,"select alert_history from config");
+	result = DBselect(sql);
+
+	if(DBnum_rows(result) == 0)
+	{
+		zabbix_log( LOG_LEVEL_ERR, "No records in table 'config'.");
+		res = FAIL;
+	}
+	else
+	{
+		alert_history=atoi(DBget_field(result,0,0));
+
+		snprintf(sql,sizeof(sql)-1,"delete from alerts where clock<%d",now-24*3600*alert_history);
+		DBexecute(sql);
+	}
+
+	DBfree_result(result);
+	return res;
+}
+
+int housekeeping_alarms(int now)
+{
+	char		sql[MAX_STRING_LEN];
+	int		alarm_history;
+	DB_RESULT	*result;
+	int		res = SUCCEED;
+
+	snprintf(sql,sizeof(sql)-1,"select alarm_history from config");
+	result = DBselect(sql);
+	if(DBnum_rows(result) == 0)
+	{
+		zabbix_log( LOG_LEVEL_ERR, "No records in table 'config'.");
+		res = FAIL;
+	}
+	else
+	{
+		alarm_history=atoi(DBget_field(result,0,0));
+
+		snprintf(sql,sizeof(sql)-1,"delete from alarms where clock<%d",now-24*3600*alarm_history);
+		DBexecute(sql);
+	}
+	
+	DBfree_result(result);
+	return res;
+}
+
+int main_housekeeper_loop()
+{
+	int	now;
+
+	if(CONFIG_DISABLE_HOUSEKEEPING == 1)
+	{
+		for(;;)
+		{
+/* Do nothing */
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+			setproctitle("do nothing");
+#endif
+			sleep(3600);
+		}
+	}
+
+	for(;;)
+	{
+		now = time(NULL);
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("connecting to the database");
+#endif
+		DBconnect();
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [removing deleted hosts]");
+#endif
+		housekeeping_hosts();
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [removing deleted items]");
+#endif
+
+		housekeeping_items();
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [removing old values]");
+#endif
+
+		housekeeping_history_and_trends(now);
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [removing old alarms]");
+#endif
+
+		housekeeping_alarms(now);
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [removing old alerts]");
+#endif
+
+		housekeeping_alerts(now);
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [removing old sessions]");
+#endif
+
+		housekeeping_sessions(now);
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [vacuuming database]");
+#endif
+		DBvacuum();
+
+		zabbix_log( LOG_LEVEL_DEBUG, "Sleeping for %d hours", CONFIG_HOUSEKEEPING_FREQUENCY);
+
+#ifdef HAVE_FUNCTION_SETPROCTITLE
+		setproctitle("housekeeper [sleeping for %d hour(s)]", CONFIG_HOUSEKEEPING_FREQUENCY);
+#endif
+
+		DBclose();
+		sleep(3660*CONFIG_HOUSEKEEPING_FREQUENCY);
+	}
+}
diff --git a/src/zabbix_server/housekeeper/housekeeper.h b/src/zabbix_server/housekeeper/housekeeper.h
new file mode 100644
index 00000000..987c23fe
--- /dev/null
+++ b/src/zabbix_server/housekeeper/housekeeper.h
@@ -0,0 +1,34 @@
+/* 
+** ZABBIX
+** Copyright (C) 2000-2005 SIA Zabbix
+**
+** 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.
+**/
+
+#ifndef ZABBIX_HOUSEKEEPER_H
+#define ZABBIX_HOUSEKEEPER_H
+
+extern	int	CONFIG_DISABLE_HOUSEKEEPING;
+extern	int	CONFIG_HOUSEKEEPING_FREQUENCY;
+extern	char	*CONFIG_DBHOST;
+extern	char	*CONFIG_DBNAME;
+extern	char	*CONFIG_DBUSER;
+extern	char	*CONFIG_DBPASSWORD;
+extern	char	*CONFIG_DBSOCKET;
+extern	char	*CONFIG_FPING_LOCATION;
+
+int main_housekeeper_loop();
+
+#endif