From: Sebastian Harl Date: Tue, 12 Dec 2006 10:11:49 +0000 (+0100) Subject: email plugin: Prepend the module name to any syslog messages X-Git-Tag: collectd-3.11.0~14 X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=b54b5ebf3012f180e87000ef45c6cd8387de822d;p=collectd.git email plugin: Prepend the module name to any syslog messages Signed-off-by: Sebastian Harl --- diff --git a/src/email.c b/src/email.c index 0f9c2f3d..7c23e9b4 100644 --- a/src/email.c +++ b/src/email.c @@ -84,6 +84,9 @@ #define MAX_CONNS 5 #define MAX_CONNS_LIMIT 16384 +#define log_err(...) syslog (LOG_ERR, MODULE_NAME": "__VA_ARGS__) +#define log_warn(...) syslog (LOG_WARNING, MODULE_NAME": "__VA_ARGS__) + /* * Private data structures */ @@ -297,7 +300,7 @@ char read_char (conn_t *src) FD_SET (src->socket, &fdset); if (-1 == select (src->socket + 1, &fdset, NULL, NULL, NULL)) { - syslog (LOG_ERR, "select() failed: %s", strerror (errno)); + log_err ("select() failed: %s", strerror (errno)); return '\0'; } @@ -309,7 +312,7 @@ char read_char (conn_t *src) errno = 0; if (0 > (len = read (src->socket, (void *)&ret, 1))) { if (EINTR != errno) { - syslog (LOG_ERR, "read() failed: %s", strerror (errno)); + log_err ("read() failed: %s", strerror (errno)); return '\0'; } } @@ -358,7 +361,7 @@ char *read_line (conn_t *src) FD_SET (src->socket, &fdset); if (-1 == select (src->socket + 1, &fdset, NULL, NULL, NULL)) { - syslog (LOG_ERR, "select() failed: %s", strerror (errno)); + log_err ("select() failed: %s", strerror (errno)); return NULL; } @@ -370,7 +373,7 @@ char *read_line (conn_t *src) (void *)(src->buffer + src->idx), BUFSIZE - src->idx))) { if (EINTR != errno) { - syslog (LOG_ERR, "read() failed: %s", strerror (errno)); + log_err ("read() failed: %s", strerror (errno)); return NULL; } } @@ -442,13 +445,13 @@ static void *collect (void *arg) errno = 0; if (-1 == fcntl (connection->socket, F_GETFL, &flags)) { - syslog (LOG_ERR, "fcntl() failed: %s", strerror (errno)); + log_err ("fcntl() failed: %s", strerror (errno)); loop = 0; } errno = 0; if (-1 == fcntl (connection->socket, F_SETFL, flags | O_NONBLOCK)) { - syslog (LOG_ERR, "fcntl() failed: %s", strerror (errno)); + log_err ("fcntl() failed: %s", strerror (errno)); loop = 0; } } @@ -462,7 +465,7 @@ static void *collect (void *arg) } if (':' != line[1]) { - syslog (LOG_ERR, "email: syntax error in line '%s'", line); + log_err ("syntax error in line '%s'", line); continue; } @@ -473,7 +476,7 @@ static void *collect (void *arg) int bytes = 0; if (NULL == tmp) { - syslog (LOG_ERR, "email: syntax error in line '%s'", line); + log_err ("syntax error in line '%s'", line); continue; } @@ -505,7 +508,7 @@ static void *collect (void *arg) } while (NULL != (type = strtok_r (NULL, ",", &ptr))); } else { - syslog (LOG_ERR, "email: unknown type '%c'", line[0]); + log_err ("unknown type '%c'", line[0]); } } /* while (loop) */ @@ -532,7 +535,7 @@ static void *open_connection (void *arg) errno = 0; if (-1 == (connector_socket = socket (PF_UNIX, SOCK_STREAM, 0))) { disabled = 1; - syslog (LOG_ERR, "socket() failed: %s", strerror (errno)); + log_err ("socket() failed: %s", strerror (errno)); pthread_exit ((void *)1); } @@ -547,14 +550,14 @@ static void *open_connection (void *arg) offsetof (struct sockaddr_un, sun_path) + strlen(addr.sun_path))) { disabled = 1; - syslog (LOG_ERR, "bind() failed: %s", strerror (errno)); + log_err ("bind() failed: %s", strerror (errno)); pthread_exit ((void *)1); } errno = 0; if (-1 == listen (connector_socket, 5)) { disabled = 1; - syslog (LOG_ERR, "listen() failed: %s", strerror (errno)); + log_err ("listen() failed: %s", strerror (errno)); pthread_exit ((void *)1); } @@ -565,20 +568,20 @@ static void *open_connection (void *arg) if (NULL != (grp = getgrnam (sock_group))) { errno = 0; if (0 != chown (SOCK_PATH, (uid_t)-1, grp->gr_gid)) { - syslog (LOG_WARNING, "chown() failed: %s", strerror (errno)); + log_warn ("chown() failed: %s", strerror (errno)); } } else { - syslog (LOG_WARNING, "getgrnam() failed: %s", strerror (errno)); + log_warn ("getgrnam() failed: %s", strerror (errno)); } } else { - syslog (LOG_WARNING, "not running as root"); + log_warn ("not running as root"); } errno = 0; if (0 != chmod (SOCK_PATH, sock_perms)) { - syslog (LOG_WARNING, "chmod() failed: %s", strerror (errno)); + log_warn ("chmod() failed: %s", strerror (errno)); } { /* initialize collector threads */ @@ -604,8 +607,7 @@ static void *open_connection (void *arg) if (0 != (err = pthread_create (&collectors[i]->thread, &ptattr, collect, collectors[i]))) { - syslog (LOG_ERR, "pthread_create() failed: %s", - strerror (err)); + log_err ("pthread_create() failed: %s", strerror (err)); } } @@ -632,7 +634,7 @@ static void *open_connection (void *arg) if (-1 == (remote = accept (connector_socket, NULL, NULL))) { if (EINTR != errno) { disabled = 1; - syslog (LOG_ERR, "accept() failed: %s", strerror (errno)); + log_err ("accept() failed: %s", strerror (errno)); pthread_exit ((void *)1); } } @@ -670,7 +672,7 @@ static void email_init (void) if (0 != (err = pthread_create (&connector, NULL, open_connection, NULL))) { disabled = 1; - syslog (LOG_ERR, "pthread_create() failed: %s", strerror (err)); + log_err ("pthread_create() failed: %s", strerror (err)); return; } #endif /* EMAIL_HAVE_READ */