X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fquit.cc;h=77924fb4930ee277bf4c3a506e8bd6d0ca78884c;hb=f5b5250c862c98dadbe30cebc1f92962c76125c3;hp=2cfc44b56dab85abc371502d818ddca1f1caa317;hpb=e62187d9544abeffaa8552742da6c154fb77cf7c;p=awesomized%2Flibmemcached diff --git a/libmemcached/quit.cc b/libmemcached/quit.cc index 2cfc44b5..77924fb4 100644 --- a/libmemcached/quit.cc +++ b/libmemcached/quit.cc @@ -46,7 +46,7 @@ will force data to be completed. */ -void memcached_quit_server(memcached_server_st *ptr, bool io_death) +void memcached_quit_server(org::libmemcached::Instance* ptr, bool io_death) { if (ptr->fd != INVALID_SOCKET) { @@ -58,7 +58,9 @@ void memcached_quit_server(memcached_server_st *ptr, bool io_death) if (ptr->root->flags.binary_protocol) { protocol_binary_request_quit request= {}; // = {.bytes= {0}}; - request.message.header.request.magic = PROTOCOL_BINARY_REQ; + + initialize_binary_request(ptr, request.message.header); + request.message.header.request.opcode = PROTOCOL_BINARY_CMD_QUIT; request.message.header.request.datatype = PROTOCOL_BINARY_RAW_BYTES; @@ -114,7 +116,7 @@ void memcached_quit_server(memcached_server_st *ptr, bool io_death) } ptr->state= MEMCACHED_SERVER_STATE_NEW; - ptr->cursor_active= 0; + ptr->cursor_active_= 0; ptr->io_bytes_sent= 0; ptr->write_buffer_offset= size_t(ptr->root and memcached_is_udp(ptr->root) ? UDP_DATAGRAM_HEADER_LENGTH : 0); ptr->read_buffer_length= 0; @@ -136,8 +138,7 @@ void send_quit(memcached_st *ptr) { for (uint32_t x= 0; x < memcached_server_count(ptr); x++) { - memcached_server_write_instance_st instance= - memcached_server_instance_fetch(ptr, x); + org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, x); memcached_quit_server(instance, false); }