X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Femail.c;h=365af274d4274cb70d42215e04c11e2fb08c3851;hb=0003c4d3c184f0f437499d6073cd023dc7b659c2;hp=c2eab2133f19031234eac618cf7af974f396e1c7;hpb=d6491cfcf52a74498e1becd7ef94fc8e0a5938b9;p=collectd.git diff --git a/src/email.c b/src/email.c index c2eab213..365af274 100644 --- a/src/email.c +++ b/src/email.c @@ -256,8 +256,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 +280,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 +359,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));