X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=lib%2Fmemcached_verbosity.c;h=b68fbbd4f3c26c86073e3675776fff4b938d12ce;hb=b8aaaefdcb0b10d22668da2b530b67f55ffa653a;hp=55a51842a8211a12449a3c5132a1ad345642b49f;hpb=557de9b08007dd2b482778ba934574bcf7ee531f;p=m6w6%2Flibmemcached diff --git a/lib/memcached_verbosity.c b/lib/memcached_verbosity.c index 55a51842..b68fbbd4 100644 --- a/lib/memcached_verbosity.c +++ b/lib/memcached_verbosity.c @@ -3,7 +3,7 @@ memcached_return memcached_verbosity(memcached_st *ptr, unsigned int verbosity) { unsigned int x; - size_t send_length, sent_length; + size_t send_length; memcached_return rc; char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE]; @@ -21,19 +21,10 @@ memcached_return memcached_verbosity(memcached_st *ptr, unsigned int verbosity) { memcached_return rc; - sent_length= write(ptr->hosts[x].fd, buffer, send_length); - - if (sent_length == -1) - { - fprintf(stderr, "error %s: write: %m\n", __FUNCTION__); - return MEMCACHED_WRITE_FAILURE; - } - - if (sent_length != send_length) + if ((write(ptr->hosts[x].fd, buffer, send_length) == -1)) { - fprintf(stderr, "error %s: short write %d %d: %m\n", - __FUNCTION__, sent_length, send_length); - return MEMCACHED_WRITE_FAILURE; + continue; + return MEMCACHED_SOME_ERRORS; } rc= memcached_response(ptr, buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, x);