X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Femail.c;h=1bf9addaea09631f005ec96af2e97c9fdd602a56;hb=7bab45b57d6ef99ae55c499c51478dd63c3b1397;hp=c2eab2133f19031234eac618cf7af974f396e1c7;hpb=d6491cfcf52a74498e1becd7ef94fc8e0a5938b9;p=collectd.git diff --git a/src/email.c b/src/email.c index c2eab213..1bf9adda 100644 --- a/src/email.c +++ b/src/email.c @@ -50,7 +50,6 @@ # include #endif -#include #include #include @@ -256,8 +255,6 @@ static void *collect (void *arg) collector_t *this = (collector_t *)arg; while (1) { - int loop = 1; - conn_t *connection; pthread_mutex_lock (&conns_mutex); @@ -282,15 +279,13 @@ static void *collect (void *arg) log_debug ("collect: handling connection on fd #%i", fileno (this->socket)); - while (loop) { + while (42) { /* 256 bytes ought to be enough for anybody ;-) */ char line[256 + 1]; /* line + '\0' */ int len = 0; errno = 0; if (NULL == fgets (line, sizeof (line), this->socket)) { - loop = 0; - if (0 != errno) { char errbuf[1024]; log_err ("collect: reading from socket (fd #%i) " @@ -363,7 +358,7 @@ static void *collect (void *arg) else { log_err ("collect: unknown type '%c'", line[0]); } - } /* while (loop) */ + } /* while (42) */ log_debug ("Shutting down connection on fd #%i", fileno (this->socket));