X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Fmemcached.c;h=d91454a2010ce61a14c41001f6580aea2d86cf1f;hb=0b7cd83a5e6bac068ea83a88a5ddcfb07c09fbec;hp=5a9faf32a0a84ff6dfe333ed57dd2e12001dfc35;hpb=cb48bb1590b2953f3d0134f6d6355c61bce7304a;p=collectd.git diff --git a/src/memcached.c b/src/memcached.c index 5a9faf32..d91454a2 100644 --- a/src/memcached.c +++ b/src/memcached.c @@ -99,9 +99,8 @@ static int memcached_connect_unix(memcached_t *st) { /* create our socket descriptor */ int fd = socket(AF_UNIX, SOCK_STREAM, 0); if (fd < 0) { - char errbuf[1024]; ERROR("memcached plugin: memcached_connect_unix: socket(2) failed: %s", - sstrerror(errno, errbuf, sizeof(errbuf))); + STRERRNO); return -1; } @@ -134,12 +133,10 @@ static int memcached_connect_inet(memcached_t *st) { int status = getaddrinfo(st->connhost, st->connport, &ai_hints, &ai_list); if (status != 0) { - char errbuf[1024]; ERROR("memcached plugin: memcached_connect_inet: " "getaddrinfo(%s,%s) failed: %s", st->connhost, st->connport, - (status == EAI_SYSTEM) ? sstrerror(errno, errbuf, sizeof(errbuf)) - : gai_strerror(status)); + (status == EAI_SYSTEM) ? STRERRNO : gai_strerror(status)); return -1; } @@ -148,10 +145,9 @@ static int memcached_connect_inet(memcached_t *st) { /* create our socket descriptor */ fd = socket(ai_ptr->ai_family, ai_ptr->ai_socktype, ai_ptr->ai_protocol); if (fd < 0) { - char errbuf[1024]; WARNING("memcached plugin: memcached_connect_inet: " "socket(2) failed: %s", - sstrerror(errno, errbuf, sizeof(errbuf))); + STRERRNO); continue; } @@ -246,9 +242,8 @@ static int memcached_query_daemon(char *buffer, size_t buffer_size, status = (int)swrite(st->fd, "stats\r\n", strlen("stats\r\n")); if (status != 0) { - char errbuf[1024]; ERROR("memcached plugin: Instance \"%s\": write(2) failed: %s", st->name, - sstrerror(errno, errbuf, sizeof(errbuf))); + STRERRNO); shutdown(st->fd, SHUT_RDWR); close(st->fd); st->fd = -1; @@ -280,13 +275,12 @@ static int memcached_query_daemon(char *buffer, size_t buffer_size, char const end_token[5] = {'E', 'N', 'D', '\r', '\n'}; if (status < 0) { - char errbuf[1024]; if ((errno == EAGAIN) || (errno == EWOULDBLOCK)) continue; ERROR("memcached plugin: Instance \"%s\": Error reading from socket: %s", - st->name, sstrerror(errno, errbuf, sizeof(errbuf))); + st->name, STRERRNO); shutdown(st->fd, SHUT_RDWR); close(st->fd); st->fd = -1; @@ -406,9 +400,12 @@ static gauge_t calculate_ratio_percent(derive_t part, derive_t total, *prev_part = part; *prev_total = total; - if (num == 0 || denom == 0) + if (denom == 0) return NAN; + if (num == 0) + return 0; + return 100.0 * (gauge_t)num / (gauge_t)denom; } @@ -426,9 +423,12 @@ static gauge_t calculate_ratio_percent2(derive_t part1, derive_t part2, *prev1 = part1; *prev2 = part2; - if (num == 0 || denom == 0) + if (denom == 0) return NAN; + if (num == 0) + return 0; + return 100.0 * (gauge_t)num / (gauge_t)denom; } @@ -517,7 +517,7 @@ static int memcached_read(user_data_t *user_data) { else if (FIELD_IS("curr_connections")) { submit_gauge("memcached_connections", "current", atof(fields[2]), st); } else if (FIELD_IS("listen_disabled_num")) { - submit_derive("connections", "listen_disabled", atoll(fields[2]), st); + submit_derive("total_events", "listen_disabled", atoll(fields[2]), st); } /* * Total number of connections opened since the server started running @@ -677,10 +677,9 @@ static int memcached_add_read_callback(memcached_t *st) { /* group = */ "memcached", /* name = */ callback_name, /* callback = */ memcached_read, - /* interval = */ 0, - &(user_data_t){ - .data = st, .free_func = memcached_free, - }); + /* interval = */ 0, &(user_data_t){ + .data = st, .free_func = memcached_free, + }); } /* int memcached_add_read_callback */ /* Configuration handling functiions