X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;ds=sidebyside;f=lib%2Fmemcached_do.c;h=cfc00ccdcc2683f44138fcae34706fa93a525b22;hb=b1daf61bf1665041f30fff7c96d61de4658f8db3;hp=f310a5bc3f9306e46392e2fa691e3f278e3d32dc;hpb=311bd0fafe1da7b5cc770a2ff4fac5472a801a40;p=m6w6%2Flibmemcached diff --git a/lib/memcached_do.c b/lib/memcached_do.c index f310a5bc..cfc00ccd 100644 --- a/lib/memcached_do.c +++ b/lib/memcached_do.c @@ -9,23 +9,15 @@ memcached_return memcached_do(memcached_st *ptr, unsigned int server_key, char * WATCHPOINT_ASSERT(command_length); WATCHPOINT_ASSERT(command); - if (ptr->hosts[server_key].cursor_active) - { - memcached_return rc; - rc= memcached_finish_server(ptr, server_key); - ptr->hosts[server_key].cursor_active= 0; - } - if ((rc= memcached_connect(ptr, server_key)) != MEMCACHED_SUCCESS) return rc; sent_length= memcached_io_write(ptr, server_key, command, command_length, with_flush); if (sent_length == -1 || sent_length != command_length) - { - memcached_quit_server(ptr, server_key); rc= MEMCACHED_WRITE_FAILURE; - } + else + memcached_server_response_increment(ptr, server_key); return rc; }