X-Git-Url: https://git.octo.it/?p=rrdtool.git;a=blobdiff_plain;f=src%2Frrd_client.c;h=44d4d603b7df5a11208e40f0375389cc383f3c8b;hp=7fa98171a9ed7e72e10e65e42a32eca7b033a91a;hb=afb590e6dbc73ed9e1eb7015071cead52e3692d3;hpb=0f4b0029699613ec41194fe7696a6b10fdeb5c62 diff --git a/src/rrd_client.c b/src/rrd_client.c index 7fa9817..44d4d60 100644 --- a/src/rrd_client.c +++ b/src/rrd_client.c @@ -212,6 +212,8 @@ static int response_read (rrdc_response_t **ret_response) /* {{{ */ if (ret->status <= 0) { + if (ret->status < 0) + rrd_set_error("rrdcached: %s", ret->message); *ret_response = ret; return (0); } @@ -266,6 +268,8 @@ static int request (const char *buffer, size_t buffer_size, /* {{{ */ { close_connection (); pthread_mutex_unlock (&lock); + rrd_set_error("request: socket error (%d) while talking to rrdcached", + status); return (-1); } fflush (sh); @@ -276,7 +280,11 @@ static int request (const char *buffer, size_t buffer_size, /* {{{ */ pthread_mutex_unlock (&lock); if (status != 0) + { + if (status < 0) + rrd_set_error("request: internal error while talking to rrdcached"); return (status); + } *ret_response = res; return (0); @@ -604,7 +612,7 @@ int rrdc_flush_if_daemon (const char *opt_daemon, const char *filename) /* {{{ * rrd_set_error ("rrdc_flush (%s) failed with status %i.", filename, status); } - } /* if (daemon_addr) */ + } /* if (rrdc_is_connected(..)) */ return status; } /* }}} int rrdc_flush_if_daemon */