X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Femail.c;h=52e41a70b9b2bfc76992896f434d845dc84de9f0;hb=5ff74d56067ac64db801df5184eb8b97f4b2b645;hp=08d572908b8459ff0e7e7e26097fbfa8a6469312;hpb=b9f877bc827ea4c0097682fc87cc5bcfd0000807;p=collectd.git diff --git a/src/email.c b/src/email.c index 08d57290..52e41a70 100644 --- a/src/email.c +++ b/src/email.c @@ -357,12 +357,10 @@ static void *collect(void *arg) { } /* while (1) */ pthread_exit((void *)0); - return ((void *)0); + return (void *)0; } /* static void *collect (void *) */ static void *open_connection(void __attribute__((unused)) * arg) { - struct sockaddr_un addr; - const char *path = (NULL == sock_file) ? SOCK_PATH : sock_file; const char *group = (NULL == sock_group) ? COLLECTD_GRP_NAME : sock_group; @@ -375,7 +373,9 @@ static void *open_connection(void __attribute__((unused)) * arg) { pthread_exit((void *)1); } - addr.sun_family = AF_UNIX; + struct sockaddr_un addr = { + .sun_family = AF_UNIX + }; sstrncpy(addr.sun_path, path, (size_t)(UNIX_PATH_MAX - 1)); errno = 0; @@ -403,7 +403,7 @@ static void *open_connection(void __attribute__((unused)) * arg) { { struct group sg; struct group *grp; - char grbuf[2048]; + char grbuf[4096]; int status; grp = NULL; @@ -411,7 +411,7 @@ static void *open_connection(void __attribute__((unused)) * arg) { if (status != 0) { char errbuf[1024]; log_warn("getgrnam_r (%s) failed: %s", group, - sstrerror(errno, errbuf, sizeof(errbuf))); + sstrerror(status, errbuf, sizeof(errbuf))); } else if (grp == NULL) { log_warn("No such group: `%s'", group); } else { @@ -527,7 +527,7 @@ static void *open_connection(void __attribute__((unused)) * arg) { } pthread_exit((void *)0); - return ((void *)0); + return (void *)0; } /* static void *open_connection (void *) */ static int email_init(void) { @@ -537,10 +537,10 @@ static int email_init(void) { disabled = 1; log_err("plugin_thread_create() failed: %s", sstrerror(errno, errbuf, sizeof(errbuf))); - return (-1); + return -1; } - return (0); + return 0; } /* int email_init */ static void type_list_free(type_list_t *t) { @@ -609,7 +609,7 @@ static int email_shutdown(void) { sfree(sock_file); sfree(sock_group); - return (0); + return 0; } /* static void email_shutdown (void) */ static void email_submit(const char *type, const char *type_instance, @@ -663,7 +663,7 @@ static int email_read(void) { int score_count_old; if (disabled) - return (-1); + return -1; /* email count */ pthread_mutex_lock(&count_mutex); @@ -710,7 +710,7 @@ static int email_read(void) { for (type_t *ptr = list_check_copy.head; NULL != ptr; ptr = ptr->next) email_submit("spam_check", ptr->name, ptr->value); - return (0); + return 0; } /* int email_read */ void module_register(void) {