if (ptr->root->options.is_purging || /* already purging */
(memcached_server_response_count(ptr) < ptr->root->io_msg_watermark &&
if (ptr->root->options.is_purging || /* already purging */
(memcached_server_response_count(ptr) < ptr->root->io_msg_watermark &&
ptr->root->options.is_purging= true;
WATCHPOINT_ASSERT(ptr->fd != -1);
/* Force a flush of the buffer to ensure that we don't have the n-1 pending
ptr->root->options.is_purging= true;
WATCHPOINT_ASSERT(ptr->fd != -1);
/* Force a flush of the buffer to ensure that we don't have the n-1 pending
if (memcached_io_write(ptr, NULL, 0, 1) == -1)
{
ptr->root->options.is_purging= true;
if (memcached_io_write(ptr, NULL, 0, 1) == -1)
{
ptr->root->options.is_purging= true;
* We need to increase the timeout, because we might be waiting for
* data to be sent from the server (the commands was in the output buffer
* and just flushed
* We need to increase the timeout, because we might be waiting for
* data to be sent from the server (the commands was in the output buffer
* and just flushed
/*
* Purge doesn't care for what kind of command results that is received.
* The only kind of errors I care about if is I'm out of sync with the
* protocol or have problems reading data from the network..
/*
* Purge doesn't care for what kind of command results that is received.
* The only kind of errors I care about if is I'm out of sync with the
* protocol or have problems reading data from the network..