X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=clients%2Fexecute.cc;h=47319778e868b7b51efff6b40dffd9acdae552fa;hb=dbc62573e1a6dc8cbcc97d0898e8615b0916d6ab;hp=cf7779e5140c8f2afada67ebc5c1ab8c81e8d45d;hpb=2569efffe16042f47dc5d2c34528a9ec22fc18b0;p=awesomized%2Flibmemcached diff --git a/clients/execute.cc b/clients/execute.cc index cf7779e5..47319778 100644 --- a/clients/execute.cc +++ b/clients/execute.cc @@ -15,36 +15,32 @@ Return the number of rows set. */ -#include +#include #include "clients/execute.h" unsigned int execute_set(memcached_st *memc, pairs_st *pairs, unsigned int number_of) { - unsigned int x; - unsigned int pairs_sent; - - for (x= 0, pairs_sent= 0; x < number_of; x++) + uint32_t count= 0; + for (; count < number_of; ++count) { - memcached_return_t rc= memcached_set(memc, pairs[x].key, pairs[x].key_length, - pairs[x].value, pairs[x].value_length, + memcached_return_t rc= memcached_set(memc, pairs[count].key, pairs[count].key_length, + pairs[count].value, pairs[count].value_length, 0, 0); if (memcached_failed(rc)) { - fprintf(stderr, "%s:%d Failure on insert (%s) of %.*s\n", - __FILE__, __LINE__, + fprintf(stderr, "%s:%d Failure on %u insert (%s) of %.*s\n", + __FILE__, __LINE__, count, memcached_last_error_message(memc), - (unsigned int)pairs[x].key_length, pairs[x].key); + (unsigned int)pairs[count].key_length, pairs[count].key); // We will try to reconnect and see if that fixes the issue memcached_quit(memc); - } - else - { - pairs_sent++; + + return count; } } - return pairs_sent; + return count; } /*