X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Fzookeeper.c;h=1de01d0050ef547a14c57a257f8301c3429d3132;hp=a42b04c83f1ad06a11cff37af69d8b6b4efa1017;hb=a9e50e9e30ecde17e167e271060c8183bfcbf407;hpb=f7e2d82c4d016df72c55e85bb9c5bc9ba08d5f91 diff --git a/src/zookeeper.c b/src/zookeeper.c index a42b04c8..1de01d00 100644 --- a/src/zookeeper.c +++ b/src/zookeeper.c @@ -99,28 +99,22 @@ static int zookeeper_connect(void) { status = getaddrinfo(host, port, &ai_hints, &ai_list); if (status != 0) { - char errbuf[1024]; INFO("getaddrinfo failed: %s", - (status == EAI_SYSTEM) ? sstrerror(errno, errbuf, sizeof(errbuf)) - : gai_strerror(status)); - return (-1); + (status == EAI_SYSTEM) ? STRERRNO : gai_strerror(status)); + return -1; } for (struct addrinfo *ai = ai_list; ai != NULL; ai = ai->ai_next) { sk = socket(ai->ai_family, SOCK_STREAM, 0); if (sk < 0) { - char errbuf[1024]; - WARNING("zookeeper: socket(2) failed: %s", - sstrerror(errno, errbuf, sizeof(errbuf))); + WARNING("zookeeper: socket(2) failed: %s", STRERRNO); continue; } status = (int)connect(sk, ai->ai_addr, ai->ai_addrlen); if (status != 0) { - char errbuf[1024]; close(sk); sk = -1; - WARNING("zookeeper: connect(2) failed: %s", - sstrerror(errno, errbuf, sizeof(errbuf))); + WARNING("zookeeper: connect(2) failed: %s", STRERRNO); continue; } @@ -129,7 +123,7 @@ static int zookeeper_connect(void) { } freeaddrinfo(ai_list); - return (sk); + return sk; } /* int zookeeper_connect */ static int zookeeper_query(char *buffer, size_t buffer_size) { @@ -139,16 +133,14 @@ static int zookeeper_query(char *buffer, size_t buffer_size) { sk = zookeeper_connect(); if (sk < 0) { ERROR("zookeeper: Could not connect to daemon"); - return (-1); + return -1; } status = (int)swrite(sk, "mntr\r\n", strlen("mntr\r\n")); if (status != 0) { - char errbuf[1024]; - ERROR("zookeeper: write(2) failed: %s", - sstrerror(errno, errbuf, sizeof(errbuf))); + ERROR("zookeeper: write(2) failed: %s", STRERRNO); close(sk); - return (-1); + return -1; } memset(buffer, 0, buffer_size); @@ -158,13 +150,11 @@ static int zookeeper_query(char *buffer, size_t buffer_size) { buffer_size - buffer_fill, /* flags = */ 0)) != 0) { if (status < 0) { - char errbuf[1024]; if ((errno == EAGAIN) || (errno == EINTR)) continue; - ERROR("zookeeper: Error reading from socket: %s", - sstrerror(errno, errbuf, sizeof(errbuf))); + ERROR("zookeeper: Error reading from socket: %s", STRERRNO); close(sk); - return (-1); + return -1; } buffer_fill += (size_t)status; @@ -177,7 +167,7 @@ static int zookeeper_query(char *buffer, size_t buffer_size) { } close(sk); - return (status); + return status; } /* int zookeeper_query */ static int zookeeper_read(void) { @@ -188,7 +178,7 @@ static int zookeeper_read(void) { char *fields[2]; if (zookeeper_query(buf, sizeof(buf)) < 0) { - return (-1); + return -1; } ptr = buf; @@ -238,7 +228,7 @@ static int zookeeper_read(void) { } } - return (0); + return 0; } /* zookeeper_read */ void module_register(void) {