X-Git-Url: https://git.octo.it/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmemcached.c;h=635088eb8ce832ea019d879b4acfbc524f26db80;hb=a9e50e9e30ecde17e167e271060c8183bfcbf407;hp=d91454a2010ce61a14c41001f6580aea2d86cf1f;hpb=0b7cd83a5e6bac068ea83a88a5ddcfb07c09fbec;p=collectd.git

diff --git a/src/memcached.c b/src/memcached.c
index d91454a2..635088eb 100644
--- a/src/memcached.c
+++ b/src/memcached.c
@@ -285,6 +285,12 @@ static int memcached_query_daemon(char *buffer, size_t buffer_size,
       close(st->fd);
       st->fd = -1;
       return -1;
+    } else if (status == 0) {
+      ERROR("memcached plugin: Instance \"%s\": Connection closed by peer",
+            st->name);
+      close(st->fd);
+      st->fd = -1;
+      return -1;
     }
 
     buffer_fill += (size_t)status;
@@ -677,9 +683,10 @@ 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