~d-ci/libmemcached/pushtest

« back to all changes in this revision

Viewing changes to clients/execute.cc

  • Committer: Continuous Integration
  • Date: 2013-11-04 17:14:31 UTC
  • mfrom: (1079.33.11 workspace)
  • Revision ID: ci@tangent.org-20131104171431-yj69t4kajuanut6c
Merge lp:libmemcached/1.0 Build: jenkins-Libmemcached-377

Show diffs side-by-side

added added

removed removed

Lines of Context:
20
20
 
21
21
unsigned int execute_set(memcached_st *memc, pairs_st *pairs, unsigned int number_of)
22
22
{
23
 
  unsigned int x;
24
 
  unsigned int pairs_sent;
25
 
 
26
 
  for (x= 0, pairs_sent= 0; x < number_of; x++)
 
23
  uint32_t count= 0;
 
24
  for (; count < number_of; ++count)
27
25
  {
28
 
    memcached_return_t rc= memcached_set(memc, pairs[x].key, pairs[x].key_length,
29
 
                                         pairs[x].value, pairs[x].value_length,
 
26
    memcached_return_t rc= memcached_set(memc, pairs[count].key, pairs[count].key_length,
 
27
                                         pairs[count].value, pairs[count].value_length,
30
28
                                         0, 0);
31
29
    if (memcached_failed(rc))
32
30
    {
33
 
      fprintf(stderr, "%s:%d Failure on insert (%s) of %.*s\n",
34
 
              __FILE__, __LINE__,
 
31
      fprintf(stderr, "%s:%d Failure on %u insert (%s) of %.*s\n",
 
32
              __FILE__, __LINE__, count,
35
33
              memcached_last_error_message(memc),
36
 
              (unsigned int)pairs[x].key_length, pairs[x].key);
 
34
              (unsigned int)pairs[count].key_length, pairs[count].key);
37
35
      
38
36
      // We will try to reconnect and see if that fixes the issue
39
37
      memcached_quit(memc);
40
 
    }
41
 
    else
42
 
    {
43
 
      pairs_sent++;
 
38
 
 
39
      return count;
44
40
    }
45
41
  }
46
42
 
47
 
  return pairs_sent;
 
43
  return count;
48
44
}
49
45
 
50
46
/*