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;
}