rc= MEMCACHED_SOME_ERRORS;
continue;
}
+
+ /* We just want one pending response per server */
+ memcached_server_response_reset(&ptr->hosts[server_key]);
memcached_server_response_increment(&ptr->hosts[server_key]);
if ((x > 0 && x == ptr->io_key_prefetch) &&
memcached_flush_buffers(ptr) != MEMCACHED_SUCCESS)
memcached_io_reset(&ptr->hosts[x]);
rc= MEMCACHED_SOME_ERRORS;
}
- memcached_server_response_increment(&ptr->hosts[x]);
}
}
success= false;
continue;
}
+ /* we just want one pending response per server */
+ memcached_server_response_reset(&ptr->hosts[server]);
memcached_server_response_increment(&ptr->hosts[server]);
}
dead_servers[x]= true;
success= false;
}
- memcached_server_response_increment(&ptr->hosts[x]);
/* mark all of the messages bound for this server as sent! */
for (x= 0; x < number_of_keys; ++x)