From b19fd3393a7376b0691002afdc6e85bf3e36a238 Mon Sep 17 00:00:00 2001
From: Natanael Copa <ncopa@alpinelinux.org>
Date: Fri, 8 Jul 2011 10:04:04 +0200
Subject: pingu: move config reading to pingu_host and make host_list global

---
 pingu_host.c | 146 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 144 insertions(+), 2 deletions(-)

(limited to 'pingu_host.c')

diff --git a/pingu_host.c b/pingu_host.c
index a7640ed..e184576 100644
--- a/pingu_host.c
+++ b/pingu_host.c
@@ -1,12 +1,148 @@
 
+#include <ctype.h>
+#include <stdio.h>
 #include <stdlib.h>
+#include <string.h>
 #include <unistd.h>
 #include <ev.h>
 
+#include "list.h"
 #include "log.h"
 #include "pingu_burst.h"
 #include "pingu_host.h"
+#include "pingu_iface.h"
 #include "pingu_ping.h"
+#include "xlib.h"
+
+static struct list_head host_list = LIST_INITIALIZER(host_list);
+float default_burst_interval = 30.0;
+float default_timeout = 1.0;
+int default_max_retries = 5;
+int default_required_replies = 2;
+char *default_up_action = NULL;
+char *default_down_action = NULL;
+char *default_route_script = NULL;
+
+/* note: this overwrite the line buffer */
+static void parse_line(char *line, char **key, char **value)
+{
+	char *p;
+
+	/* strip comments and trailng \n */
+	p = strpbrk(line, "#\n");
+	if (p)
+		*p = '\0';
+
+	(*value) = NULL;
+	if (line[0] == '\0') {
+		(*key) = NULL;
+		return;
+	}
+	
+	/* skip leading whitespace */
+	while (isspace(*p)) {
+		if (*p == '\0')
+			return;
+		p++;
+	}
+	(*key) = line;
+
+	/* find space between keyword and value */
+	p = line;
+	while (!isspace(*p)) {
+		if (*p == '\0')
+			return;
+		p++;
+	}
+	*p++ = '\0';
+
+	/* find value */
+	while (isspace(*p)) {
+		if (*p == '\0')
+			return;
+		p++;
+	}
+	(*value) = p;
+}
+
+int pingu_host_read_config(const char *file)
+{
+	FILE *f = fopen(file, "r");
+	struct pingu_host *p = NULL;
+	int lineno = 0;
+	char line[256];
+	if (f == NULL) {
+		log_perror(file);
+		return -1;
+	}
+	while (fgets(line, sizeof(line), f)) {
+		char *key, *value;
+		lineno++;
+		parse_line(line, &key, &value);
+		if (key == NULL)
+			continue;
+
+		if (strcmp(key, "host") == 0) {
+			p = xmalloc(sizeof(struct pingu_host));
+			memset(p, 0, sizeof(struct pingu_host));
+			p->host = xstrdup(value);
+			p->gateway = xstrdup(value);
+			p->status = 1; /* online by default */
+			p->max_retries = default_max_retries;
+			p->timeout = default_timeout;
+			p->up_action = default_up_action;
+			p->down_action = default_down_action;
+			p->required_replies = default_required_replies;
+			p->burst_interval = default_burst_interval;
+			list_add(&p->host_list_entry, &host_list);
+			continue;
+		}
+		if (p == NULL) {
+			if (strcmp(key, "interval") == 0) {
+				default_burst_interval = atof(value);
+			} else if (strcmp(key, "retry") == 0) {
+				default_max_retries = atoi(value);
+			} else if (strcmp(key, "required") == 0) {
+				default_required_replies = atoi(value);
+			} else if (strcmp(key, "timeout") == 0) {
+				default_timeout = atof(value);
+			} else if (strcmp(key, "up-action") == 0) {
+				default_up_action = xstrdup(value);
+			} else if (strcmp(key, "down-action") == 0) {
+				default_down_action = xstrdup(value);
+			} else if (strcmp(key, "route-script") == 0) {
+				default_route_script = xstrdup(value);
+			} else 
+				log_error("host not specified");
+		} else if (strcmp(key, "interface") == 0) {
+			p->interface = xstrdup(value);
+		} else if (strcmp(key, "gateway") == 0) {
+			if (p->gateway)
+				free(p->gateway);
+			p->gateway = xstrdup(value);
+		} else if ((strcmp(key, "name") == 0) || (strcmp(key, "label") == 0)) {
+			p->label = xstrdup(value);
+		} else if (strcmp(key, "up-action") == 0) {
+			p->up_action = xstrdup(value);
+		} else if (strcmp(key, "down-action") == 0) {
+			p->down_action = xstrdup(value);
+		} else if (strcmp(key, "retry") == 0) {
+			p->max_retries = atoi(value);
+		} else if (strcmp(key, "required") == 0) {
+			p->required_replies = atoi(value);
+		} else if (strcmp(key, "timeout") == 0) {
+			p->timeout = atof(value);
+		} else if (strcmp(key, "source-ip") == 0) {
+			p->source_ip = xstrdup(value);
+		} else if (strcmp(key, "interval") == 0) {
+			p->burst_interval = atof(value);
+		} else {
+			log_error("Unknown keyword '%s' on line %i", key,
+				  lineno);
+		}
+	}
+	return 0;
+}
 
 static void execute_action(const char *action)
 {
@@ -61,10 +197,16 @@ int pingu_host_verify_status(struct ev_loop *loop, struct pingu_host *host)
 	return 0;
 }
 
-int pingu_host_init(struct ev_loop *loop, struct list_head *host_list)
+int pingu_host_init(struct ev_loop *loop, const char *config)
 {
 	struct pingu_host *host;
-	list_for_each_entry(host, host_list, host_list_entry) {
+	if (pingu_host_read_config(config) < 0)
+		return -1;
+
+	if (pingu_iface_init(loop, &host_list) < 0)
+		return -1;
+	
+	list_for_each_entry(host, &host_list, host_list_entry) {
 		ev_timer_init(&host->burst_timeout_watcher,
 			      pingu_burst_timeout_cb, 0, host->burst_interval);
 		ev_timer_start(loop, &host->burst_timeout_watcher);
-- 
cgit v1.2.3