rc= MEMCACHED_WRITE_FAILURE;
}
- if (ptr->number_of_replicas > 0)
+ unlikely (ptr->number_of_replicas > 0)
{
request.message.header.request.opcode= PROTOCOL_BINARY_CMD_DELETEQ;
- for (int x= 0; x < ptr->number_of_replicas; ++x)
+ for (uint32_t x= 0; x < ptr->number_of_replicas; ++x)
{
++server_key;
if (server_key == ptr->number_of_hosts)
if ((memcached_do(server, (const char*)request.bytes,
sizeof(request.bytes), 0) != MEMCACHED_SUCCESS) ||
(memcached_io_write(server, key, key_length, flush) == -1))
- memcached_io_reset(server);
+ memcached_io_reset(server);
+ else
+ memcached_server_response_decrement(server);
}
}