From edb6c3544ab2755c85e8931cbef960e9cedd48cf Mon Sep 17 00:00:00 2001 From: Sebastian Harl Date: Wed, 22 Jul 2009 21:45:59 +0200 Subject: [PATCH] ping plugin: Added "SourceAddress" and "Device" configuration options. As the name suggests, these options may be used to set the source address and the outgoing device for ICMP_ECHO requests, just like oping's -I and -D options. --- src/collectd.conf.pod | 11 ++++++++++ src/ping.c | 58 +++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 69 insertions(+) diff --git a/src/collectd.conf.pod b/src/collectd.conf.pod index d19a8690..163f0eb4 100644 --- a/src/collectd.conf.pod +++ b/src/collectd.conf.pod @@ -2765,6 +2765,17 @@ Default: B<0.9> Sets the Time-To-Live of generated ICMP packets. +=item B I + +Sets the source address to use. I may either be a numerical network +address or a network hostname. + +=item B I + +Sets the outgoing network device to be used. I has to specify an +interface name (e.Eg. C). This might not be supported by all +operating systems. + =back =head2 Plugin C diff --git a/src/ping.c b/src/ping.c index de9c45bb..92783800 100644 --- a/src/ping.c +++ b/src/ping.c @@ -36,6 +36,10 @@ # define NI_MAXHOST 1025 #endif +#if defined(OPING_VERSION) && (OPING_VERSION >= 1003000) +# define HAVE_OPING_1_3 +#endif + /* * Private data types */ @@ -58,6 +62,10 @@ typedef struct hostlist_s hostlist_t; */ static hostlist_t *hostlist_head = NULL; +static char *ping_source = NULL; +#ifdef HAVE_OPING_1_3 +static char *ping_device = NULL; +#endif static int ping_ttl = PING_DEF_TTL; static double ping_interval = 1.0; static double ping_timeout = 0.9; @@ -71,6 +79,10 @@ static pthread_cond_t ping_cond = PTHREAD_COND_INITIALIZER; static const char *config_keys[] = { "Host", + "SourceAddress", +#ifdef HAVE_OPING_1_3 + "Device", +#endif "TTL", "Interval", "Timeout" @@ -150,6 +162,18 @@ static void *ping_thread (void *arg) /* {{{ */ return ((void *) -1); } + if (ping_source != NULL) + if (ping_setopt (pingobj, PING_OPT_SOURCE, (void *) ping_source) != 0) + ERROR ("ping plugin: Failed to set source address: %s", + ping_get_error (pingobj)); + +#ifdef HAVE_OPING_1_3 + if (ping_device != NULL) + if (ping_setopt (pingobj, PING_OPT_DEVICE, (void *) ping_device) != 0) + ERROR ("ping plugin: Failed to set device: %s", + ping_get_error (pingobj)); +#endif + ping_setopt (pingobj, PING_OPT_TIMEOUT, (void *) &ping_timeout); ping_setopt (pingobj, PING_OPT_TTL, (void *) &ping_ttl); @@ -363,6 +387,26 @@ static int ping_init (void) /* {{{ */ return (0); } /* }}} int ping_init */ +static int config_set_string (const char *name, /* {{{ */ + char **var, const char *value) +{ + char *tmp; + + tmp = strdup (value); + if (tmp == NULL) + { + char errbuf[1024]; + ERROR ("ping plugin: Setting `%s' to `%s' failed: strdup failed: %s", + name, value, sstrerror (errno, errbuf, sizeof (errbuf))); + return (1); + } + + if (*var != NULL) + free (*var); + *var = tmp; + return (0); +} /* }}} int config_set_string */ + static int ping_config (const char *key, const char *value) /* {{{ */ { if (strcasecmp (key, "Host") == 0) @@ -397,6 +441,20 @@ static int ping_config (const char *key, const char *value) /* {{{ */ hl->next = hostlist_head; hostlist_head = hl; } + else if (strcasecmp (key, "SourceAddress") == 0) + { + int status = config_set_string (key, &ping_source, value); + if (status != 0) + return (status); + } +#ifdef HAVE_OPING_1_3 + else if (strcasecmp (key, "Device") == 0) + { + int status = config_set_string (key, &ping_device, value); + if (status != 0) + return (status); + } +#endif else if (strcasecmp (key, "TTL") == 0) { int ttl = atoi (value); -- 2.11.0