From: Sebastian Harl <sh@tokkee.org>
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 <sh@tokkee.org>
---

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 */