X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fquit.c;h=dc11e97fcea5e65356c5775ca5147d2a01b733ad;hb=0c7d432ca4a89f23caa74ff11e5a63fa9e6d3f3f;hp=3c117ade71d79b64c916fb53f3a250456ee5b214;hpb=7c7750f02368b570353ea109f23a0ea26d226e02;p=m6w6%2Flibmemcached diff --git a/libmemcached/quit.c b/libmemcached/quit.c index 3c117ade..dc11e97f 100644 --- a/libmemcached/quit.c +++ b/libmemcached/quit.c @@ -27,9 +27,12 @@ void memcached_quit_server(memcached_server_st *ptr, uint8_t io_death) rc= memcached_do(ptr, request.bytes, sizeof(request.bytes), 1); } else + { rc= memcached_do(ptr, "quit\r\n", 6, 1); + } WATCHPOINT_ASSERT(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_FETCH_NOTFINISHED); + (void)rc; // Shut up ICC /* read until socket is closed, or there is an error * closing the socket before all data is read @@ -50,15 +53,18 @@ void memcached_quit_server(memcached_server_st *ptr, uint8_t io_death) ptr->server_failure_counter= 0; } memcached_io_close(ptr); - - ptr->fd= -1; - ptr->write_buffer_offset= (size_t) ((ptr->type == MEMCACHED_CONNECTION_UDP) ? UDP_DATAGRAM_HEADER_LENGTH : 0); - ptr->read_buffer_length= 0; - ptr->read_ptr= ptr->read_buffer; - memcached_server_response_reset(ptr); } - if(io_death) ptr->server_failure_counter++; + ptr->fd= -1; + ptr->write_buffer_offset= (size_t) ((ptr->type == MEMCACHED_CONNECTION_UDP) ? UDP_DATAGRAM_HEADER_LENGTH : 0); + ptr->read_buffer_length= 0; + ptr->read_ptr= ptr->read_buffer; + memcached_server_response_reset(ptr); + + if(io_death) + { + ptr->server_failure_counter++; + } } void memcached_quit(memcached_st *ptr)