← Back to branch summary

~brianaker/libmemcached/1251482

« back to all changes in this revision

Viewing changes to libmemcached/get.cc

  • Committer: Continuous Integration
  • Date: 2013-10-11 10:57:29 UTC
  • mfrom: (1169.1.3 key-cleanup)
  • Revision ID: ci@tangent.org-20131011105729-icge7t4g8wr4g380
Merge lp:~brianaker/libmemcached/key-cleanup/ Build: jenkins-Libmemcached-369

Show diffs side-by-side

added added

removed removed

Lines of Context:
libmemcached/get.cc
114
114
  {
115
115
    *error= MEMCACHED_NOTFOUND;
116
116
  }
117
 
 
118
117
  if (value == NULL)
119
118
  {
120
119
    if (ptr->get_key_failure and *error == MEMCACHED_NOTFOUND)
221
220
 
222
221
  if (number_of_keys == 0)
223
222
  {
224
 
    return memcached_set_error(*ptr, MEMCACHED_NOTFOUND, MEMCACHED_AT, memcached_literal_param("number_of_keys was zero"));
 
223
    return memcached_set_error(*ptr, MEMCACHED_INVALID_ARGUMENTS, MEMCACHED_AT, memcached_literal_param("Numbers of keys provided was zero"));
225
224
  }
226
225
 
227
 
  if (memcached_failed(memcached_key_test(*ptr, keys, key_length, number_of_keys)))
 
226
  if (memcached_failed((rc= memcached_key_test(*ptr, keys, key_length, number_of_keys))))
228
227
  {
229
 
    return memcached_last_error(ptr);
 
228
    assert(memcached_last_error(ptr) == rc);
 
229
 
 
230
    return rc;
230
231
  }
231
232
 
232
233
  bool is_group_key_set= false;
463
464
 
464
465
  bool flush= (number_of_keys == 1);
465
466
 
 
467
  if (memcached_failed(rc= memcached_key_test(*ptr, keys, key_length, number_of_keys)))
 
468
  {
 
469
    return rc;
 
470
  }
 
471
 
466
472
  /*
467
473
    If a server fails we warn about errors and start all over with sending keys
468
474
    to the server.
502
508
      request.message.header.request.opcode= PROTOCOL_BINARY_CMD_GETK;
503
509
    }
504
510
 
 
511
#if 0
505
512
    {
506
513
      memcached_return_t vk= memcached_validate_key_length(key_length[x], ptr->flags.binary_protocol);
507
 
      if (vk != MEMCACHED_SUCCESS)
 
514
      if (memcached_failed(rc= memcached_key_test(*memc, (const char **)&key, &key_length, 1)))
508
515
      {
 
516
        memcached_set_error(ptr, vk, MEMCACHED_AT, memcached_literal_param("Key was too long."));
 
517
 
509
518
        if (x > 0)
510
519
        {
511
520
          memcached_io_reset(instance);
514
523
        return vk;
515
524
      }
516
525
    }
 
526
#endif
517
527
 
518
528
    request.message.header.request.keylen= htons((uint16_t)(key_length[x] + memcached_array_size(ptr->_namespace)));
519
529
    request.message.header.request.datatype= PROTOCOL_BINARY_RAW_BYTES;