/3.0.3-GA/testrunner/lib/ |
H A D | sdk_client.py | 52 def append(self, key, value, cas=0, format=None, persist_to=0, replicate_to=0): 54 self.cb.append(key, value, cas=cas, format=format, persist_to=persist_to, replicate_to=replicate_to) 58 def append_multi(self, keys, cas=0, format=None, persist_to=0, replicate_to=0): 60 self.cb.append_multi(keys, cas=cas, format=format, persist_to=persist_to, replicate_to=replicate_to) 64 def prepend(self, key, value, cas=0, format=None, persist_to=0, replicate_to=0): 66 self.cb.prepend(key, value, cas=cas, format=format, persist_to=persist_to, replicate_to=replicate_to) 70 def prepend_multi(self, keys, cas 89 def cas(self, key, value, cas=0, ttl=0, format=None): global() member in SDKClient [all...] |
H A D | mc_bin_server.py | 76 def processCommand(self, cmd, keylen, vb, cas, data): 89 cas, val) 91 def handle_noop(self, cmd, hdrs, key, cas, data): 96 def handle_unknown(self, cmd, hdrs, key, cas, data): 124 def handle_get(self, cmd, hdrs, key, cas, data): 133 def handle_set(self, cmd, hdrs, key, cas, data): 140 return self._withCAS(key, cas, f) 142 def handle_getq(self, cmd, hdrs, key, cas, data): 143 rv = self.handle_get(cmd, hdrs, key, cas, data) 180 def handle_incr(self, cmd, hdrs, key, cas, dat [all...] |
H A D | mc_bin_client.py | 65 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 66 self._sendMsg(cmd, key, val, opaque, extraHeader=extraHeader, cas=cas, 69 def _sendMsg(self, cmd, key, val, opaque, extraHeader='', cas=0, 74 len(key) + len(extraHeader) + len(val), opaque, cas) 93 magic, cmd, keylen, extralen, dtype, errcode, remaining, opaque, cas = \ 109 return cmd, errcode, opaque, cas, keylen, extralen, rv 112 cmd, errcode, opaque, cas, keylen, extralen, rv = self._recvMsg() 118 return cmd, opaque, cas, keylen, extralen, rv 121 cmd, opaque, cas, keyle 232 def cas(self, key, exp, flags, oldVal, val, vbucket= -1): global() member in MemcachedClient [all...] |
/3.0.3-GA/moxi/t/ |
H A D | mc_bin_client.py | 51 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 55 len(key) + len(extraHeader) + len(val), opaque, cas) 63 magic, cmd, keylen, extralen, dtype, errcode, remaining, opaque, cas=\ 77 return cmd, opaque, cas, keylen, extralen, rv 80 cmd, opaque, cas, keylen, extralen, data = self._handleKeyedResponse(myopaque) 81 return opaque, cas, data 83 def _doCmd(self, cmd, key, val, extraHeader='', cas=0): 86 self._sendCmd(cmd, key, val, opaque, extraHeader, cas) 89 def _mutate(self, cmd, key, exp, flags, cas, val): 91 cas) 137 def cas(self, key, exp, flags, oldVal, val): global() member in MemcachedClient [all...] |
H A D | binary.t | 62 my ($flags, $val, $cas) = $mc->get($key); 432 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_; 444 if ($cas) { 445 $ident_hi = int($cas / 2 ** 32); 446 $ident_lo = int($cas % 2 ** 32); 459 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_; 461 my $full_msg = $self->build_command($cmd, $key, $val, $opaque, $extra_header, $cas); 479 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_; 481 $self->send_command($cmd, $key, $val, $opaque, $extra_header, $cas); 528 my $cas [all...] |
/3.0.3-GA/ep-engine/management/ |
H A D | mc_bin_server.py | 75 def processCommand(self, cmd, keylen, vb, cas, data): 88 cas, val) 90 def handle_noop(self, cmd, hdrs, key, cas, data): 95 def handle_unknown(self, cmd, hdrs, key, cas, data): 122 def handle_get(self, cmd, hdrs, key, cas, data): 131 def handle_set(self, cmd, hdrs, key, cas, data): 137 return self._withCAS(key, cas, f) 139 def handle_getq(self, cmd, hdrs, key, cas, data): 140 rv=self.handle_get(cmd, hdrs, key, cas, data) 177 def handle_incr(self, cmd, hdrs, key, cas, dat [all...] |
H A D | mc_bin_client.py | 60 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 61 self._sendMsg(cmd, key, val, opaque, extraHeader=extraHeader, cas=cas, 64 def _sendMsg(self, cmd, key, val, opaque, extraHeader='', cas=0, 69 len(key) + len(extraHeader) + len(val), opaque, cas) 86 magic, cmd, keylen, extralen, dtype, errcode, remaining, opaque, cas=\ 98 return cmd, errcode, opaque, cas, keylen, extralen, rv 101 cmd, errcode, opaque, cas, keylen, extralen, rv = self._recvMsg() 106 return cmd, opaque, cas, keylen, extralen, rv 109 cmd, opaque, cas, keyle 203 def cas(self, key, exp, flags, oldVal, val): global() member in MemcachedClient [all...] |
/3.0.3-GA/couchbase-cli/ |
H A D | cb_bin_client.py | 54 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 55 self._sendMsg(cmd, key, val, opaque, extraHeader=extraHeader, cas=cas, 58 def _sendMsg(self, cmd, key, val, opaque, extraHeader='', cas=0, 63 len(key) + len(extraHeader) + len(val), opaque, cas) 74 magic, cmd, keylen, extralen, dtype, errcode, remaining, opaque, cas=\ 86 return cmd, errcode, opaque, cas, keylen, extralen, rv 89 cmd, errcode, opaque, cas, keylen, extralen, rv = self._recvMsg() 94 return cmd, opaque, cas, keylen, extralen, rv 97 cmd, opaque, cas, keyle 207 def cas(self, key, exp, flags, oldVal, val): global() member in MemcachedClient [all...] |
H A D | pump_mc.py | 145 cmd, vbucket_id_msg, key, flg, exp, cas, meta, val = msg[:8] 165 val, flg, exp, cas = '', 0, 0, 0 167 key, val, flg, exp, cas = '', '', 0, 0, 0 172 exp, cas, meta, i, dtype, nmeta) 191 cmd, vbucket_id_msg, key, flg, exp, cas, meta, val = msg[:8] 345 def cmd_request(self, cmd, vbucket_id, key, val, flg, exp, cas, meta, opaque, dtype, nmeta): 352 ext = struct.pack(">IIQQI", flg, exp, int(meta), cas, cr) 364 struct.pack(">Q", cas) + struct.pack(">I", cr)) 366 ext = struct.pack(">IIQQI", flg, exp, 1, cas, cr) 368 ext = struct.pack(">IIQQI", flg, exp, 1, cas, c [all...] |
/3.0.3-GA/testrunner/pytests/sdk_client_tests/ |
H A D | sdk_client_tests.py | 26 val, flag, cas = client.get("1") 27 self.log.info("val={0},flag={1},cas={2}".format(val, flag, cas)) 30 val, flag, cas = client.get("1") 32 self.log.info("val={0},flag={1},cas={2}".format(val, flag, cas)) 33 client.remove("1",cas = cas) 35 val, flag, cas = client.get("key") 37 self.log.info("val={0},flag={1},cas [all...] |
/3.0.3-GA/memcached/testsuite/ |
H A D | basic_engine_testsuite.c | 68 uint64_t cas = 0; in set_test() local 75 prev_cas = cas; in set_test() 76 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_SET,0) == ENGINE_SUCCESS); in set_test() 77 cb_assert(cas != prev_cas); in set_test() 89 uint64_t cas; in add_test() local 96 ENGINE_ERROR_CODE ret = h1->store(h, NULL, it, &cas, OPERATION_ADD, 0); in add_test() 99 cb_assert(cas != 0); in add_test() 115 uint64_t cas = 0; in replace_test() local 129 prev_cas = cas; in replace_test() 131 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_REPLAC in replace_test() 151 uint64_t cas; append_test() local 186 uint64_t cas; prepend_test() local 222 uint64_t cas = 0; store_test() local 239 uint64_t cas = 0; get_test() local 253 uint64_t cas = 0; expiry_test() local 271 uint64_t cas = 0; release_test() local 286 uint64_t cas = 0; remove_test() local 307 uint64_t cas = 0; incr_test() local 325 uint64_t cas = 0; incr_test_main() local 347 uint64_t cas = 0; mt_incr_test() local 381 uint64_t cas = 0; decr_test() local 402 uint64_t cas = 0; flush_test() local 424 uint64_t cas = 0; get_item_info_test() local 447 uint64_t cas = 0; item_set_cas_test() local 479 uint64_t cas = 0; lru_test() local 551 response_handler(const void *key, uint16_t keylen, const void *ext, uint8_t extlen, const void *body, uint32_t bodylen, uint8_t datatype, uint16_t status, uint64_t cas, const void *cookie) response_handler() argument 808 uint64_t cas = 0; test_datatype() local [all...] |
/3.0.3-GA/testrunner/lib/perf_engines/libobserve/ |
H A D | obs_mcsoda.py | 244 def block_for_persistence(self, key, cas, server="", timeout=0): 257 if new_cas != cas: 259 "cas: %s has been modified"\ 260 % (self.__class__.__name__, key, cas) 270 print "<%s> block_for_persistence: key: %s, cas: %s does not" \ 271 " exist any more" % (self.__class__.__name__, key, cas) 280 def block_for_replication(self, key, cas, num=1, timeout=0, persist=False): 296 if persist and not self.block_for_persistence(key, cas): 302 " key: %s, cas: %s, vbucketid: %s" \ 303 % (self.__class__.__name__, repl_servers, key, cas, vbucketi [all...] |
H A D | obs_res.py | 11 cas=0x0000000000000000): 15 self.cas = cas 20 " key_state: %x, cas = %x \n" %\ 22 self.key, self.key_state, self.cas) 91 key, key_state, cas = struct.unpack(fmt, body[offset:offset+length]) 92 obs_key = ObserveResponseKey(key, vbucket=vbucket, key_state=key_state, cas=cas)
|
H A D | obs_req.py | 46 cas = 0x0000000000000000 variable in ObserveRequest 49 def __init__(self, keys, opaque=0x00000000, cas=0x0000000000000000): 52 self.cas = cas 56 " data_type: %x, vbucket: %d, body_len: %d, opaque: %s, cas: %x\n" %\ 58 self.data_type, self.vbucket, self.body_len, self.opaque, self.cas) 73 self.opaque, self.cas)
|
H A D | obs.py | 10 def __init__(self, key="", cas=0x0000000000000000, 13 self.cas = cas 44 return "<%s> key: %s, cas: %x, status: %x, start_time: %d, "\ 48 (self.__class__.__name__, self.key, self.cas, self.status, 121 if obs.cas == res_key.cas: 130 stats=(obs.cas == res_key.cas))
|
/3.0.3-GA/memcached/extensions/protocol/ |
H A D | fragment_rw.c | 52 uint64_t *cas, in create_object() 77 v1->item_set_cas(v, cookie, item, org->cas); in create_object() 78 r = v1->store(v, cookie, item, cas, OPERATION_CAS, vbucket); in create_object() 95 uint64_t cas; in handle_fragment_rw() local 112 cas = ntohll(request->request.cas); in handle_fragment_rw() 124 } else if (cas != 0 && item_info.cas != cas) { in handle_fragment_rw() 137 item_info.cas, cooki in handle_fragment_rw() 44 create_object(ENGINE_HANDLE_V1 *v1, ENGINE_HANDLE *v, const void *cookie, const item_info *org, uint16_t vbucket, const void *data, uint64_t offset, uint64_t len, uint64_t *cas, uint8_t datatype) create_object() argument [all...] |
/3.0.3-GA/memcached/testsuite/breakdancer/ |
H A D | suite_stubs.c | 35 uint64_t cas = 0; in storeItem() local 64 rv = h1->store(h, cookie, it, &cas, op, 0); in storeItem() 78 uint64_t cas; in decr() local 81 &cas, PROTOCOL_BINARY_RAW_BYTES, &result, in decr() 86 uint64_t cas; in decrWithDefault() local 89 &cas, PROTOCOL_BINARY_RAW_BYTES, &result, in decrWithDefault() 102 uint64_t cas = 0; in del() local 103 hasError = h1->remove(h, NULL, key, strlen(key), &cas, 0) != ENGINE_SUCCESS; in del() 111 uint64_t cas; in incr() local 114 &cas, PROTOCOL_BINARY_RAW_BYTE in incr() 119 uint64_t cas; incrWithDefault() local [all...] |
/3.0.3-GA/testrunner/lib/membase/api/ |
H A D | tap.py | 40 magic, cmd, keylen, extralen, datatype, vb, remaining, opaque, cas =\ 53 magic, cmd, keylen, extralen, datatype, vb, remaining, opaque, cas =\ 66 cmdVal = self.processCommand(cmd, keylen, vb, extralen, cas, data) 70 status, cas, response = cmdVal 79 len(response), opaque, cas) + response 88 cas = 0 97 opaque, cas) 121 def processCommand(self, cmd, klen, vb, extralen, cas, data): 125 self.callback(self.identifier, cmd, extra, key, vb, val, cas) 185 # def cb(identifier, cmd, extra, key, vb, val, cas) [all...] |
/3.0.3-GA/testrunner/pytests/castest/ |
H A D | opschangecas.py | 21 MemcachedClient cas() method to mutate those item values in order 39 self._wait_for_stats_all_buckets([self.master]) #we only need 1 node to do cas test 48 cas vavlue returned by delete(). We should see Memcached Error. Otherwise 62 self.clients[bucket.name].cas(key, 0, 0, cas_old, "{0}-{1}".format("mysql-new-value", x)) 69 self.log.info("Use item cas {0} to mutate the same item with key {1} successfully! Now item cas is {2} " 72 o, cas, d = self.clients[bucket.name].delete(key) 74 self.log.info("Delete operation set item cas with key {0} to {1}".format(key, cas)) 76 self.clients[bucket.name].cas(ke [all...] |
/3.0.3-GA/couchbase-python-client/couchbase/ |
H A D | couchbaseclient.py | 188 # magic, opcode, keylen, extralen, datatype, vbucket, bodylen, opaque, cas 190 # magic, opcode, keylen, extralen, datatype, status, bodylen, opaque, cas 259 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 260 self._sendMsg(cmd, key, val, opaque, extraHeader=extraHeader, cas=cas, 263 def _sendMsg(self, cmd, key, val, opaque, extraHeader='', cas=0, 269 len(key) + len(extraHeader) + len(val), opaque, cas) 282 magic, cmd, keylen, extralen, dtype, errcode, remaining, opaque, cas =\ 297 return cmd, errcode, opaque, cas, keylen, extralen, rv 300 cmd, errcode, opaque, cas, keyle 395 def cas(self, key, exp, flags, oldVal, val, vbucket=-1): global() member in MemcachedClient 907 def cas(self, key, expiry, flags, old_value, value): global() member in CouchbaseClient [all...] |
/3.0.3-GA/memcached/engines/bucket_engine/ |
H A D | mock_engine.c | 41 uint64_t cas; member 74 uint64_t* cas, 93 uint64_t *cas, 105 uint64_t *cas, 184 uint64_t cas, in mock_tap_notify() 202 (void)cas; in mock_tap_notify() 371 uint64_t* cas, in mock_item_delete() 375 (void)cas; in mock_item_delete() 418 uint64_t *cas, in mock_store() 423 (void)cas; in mock_store() 172 mock_tap_notify(ENGINE_HANDLE* handle, const void *cookie, void *engine_specific, uint16_t nengine, uint8_t ttl, uint16_t tap_flags, tap_event_t tap_event, uint32_t tap_seqno, const void *key, size_t nkey, uint32_t flags, uint32_t exptime, uint64_t cas, uint8_t datatype, const void *data, size_t ndata, uint16_t vbucket) mock_tap_notify() argument 367 mock_item_delete(ENGINE_HANDLE* handle, const void* cookie, const void* key, const size_t nkey, uint64_t* cas, uint16_t vbucket) mock_item_delete() argument 415 mock_store(ENGINE_HANDLE* handle, const void *cookie, item* itm, uint64_t *cas, ENGINE_STORE_OPERATION operation, uint16_t vbucket) mock_store() argument 430 mock_arithmetic(ENGINE_HANDLE* handle, const void* cookie, const void* key, const int nkey, const bool increment, const bool create, const uint64_t delta, const uint64_t initial, const rel_time_t exptime, uint64_t *cas, uint8_t datatype, uint64_t *result, uint16_t vbucket) mock_arithmetic() argument [all...] |
/3.0.3-GA/memcached/engines/tap_mock_engine/ |
H A D | tap_mock_engine.cc | 36 uint64_t* cas, 56 uint64_t *cas, 78 uint64_t cas, 127 cas(rand()), datatype(datatype) in Item() 133 exptime(o.exptime), cas(o.cas), datatype(o.datatype) in Item() 161 info->cas = cas; in toItemInfo() 187 uint64_t cas; member in Item 231 uint64_t *cas) { in store() 230 store(const Item *itm, ENGINE_STORE_OPERATION operation, uint64_t *cas) store() argument 270 del(const string &key, uint64_t cas) del() argument 346 del_locked(const string &key, uint64_t cas) del_locked() argument 621 itemDelete(const void* cookie, const void* key, const size_t nkey, uint64_t cas, uint16_t vbucket) itemDelete() argument 698 store(const void *cookie, item* itm, uint64_t *cas, ENGINE_STORE_OPERATION operation, uint16_t vbucket) store() argument 737 tapNotify(const void *cookie, void *engine_specific, uint16_t nengine, uint8_t ttl, uint16_t tap_flags, tap_event_t tap_event, uint32_t tap_seqno, const void *key, size_t nkey, uint32_t flags, uint32_t exptime, uint64_t cas, uint8_t datatype, const void *data, size_t ndata, uint16_t vbucket) tapNotify() argument 921 item_delete(ENGINE_HANDLE* handle, const void* cookie, const void* key, const size_t nkey, uint64_t* cas, uint16_t vbucket) item_delete() argument 960 store(ENGINE_HANDLE* handle, const void *cookie, item* it, uint64_t *cas, ENGINE_STORE_OPERATION operation, uint16_t vbucket) store() argument 984 tap_notify(ENGINE_HANDLE* handle, const void *cookie, void *engine_specific, uint16_t nengine, uint8_t ttl, uint16_t tap_flags, tap_event_t tap_event, uint32_t tap_seqno, const void *key, size_t nkey, uint32_t flags, uint32_t exptime, uint64_t cas, uint8_t datatype, const void *data, size_t ndata, uint16_t vbucket) tap_notify() argument [all...] |
/3.0.3-GA/ep-engine/src/ |
H A D | stored-value.h | 207 cas = itm.getCas(); in setValue() 258 * @return the cas ID for feature items, 0 for small items 261 return cas; in getCas() 270 cas = c; in setCas() 490 cas = itm.getCas(); in StoredValue() 516 uint64_t cas; //!< CAS identifier. member in StoredValue 895 * @param cas This is the cas value for the item <b>in</b> the cache 903 mutation_type_t set(const Item &val, uint64_t cas, in set() argument 910 return unlocked_set(v, val, cas, allowExistin in set() 913 unlocked_set(StoredValue*& v, const Item &val, uint64_t cas, bool allowExisting, bool hasMetaData = true, item_eviction_policy_t policy = VALUE_ONLY, uint8_t nru=0xff, bool isReplication = false) unlocked_set() argument 1097 softDelete(const std::string &key, uint64_t cas, item_eviction_policy_t policy = VALUE_ONLY) softDelete() argument 1106 unlocked_softDelete(StoredValue *v, uint64_t cas, item_eviction_policy_t policy = VALUE_ONLY) unlocked_softDelete() argument 1119 unlocked_softDelete(StoredValue *v, uint64_t cas, ItemMetaData &metadata, item_eviction_policy_t policy, bool use_meta=false) unlocked_softDelete() argument [all...] |
/3.0.3-GA/ep-engine/tests/ |
H A D | ep_test_apis.cc | 53 uint64_t cas, const void *cookie); 82 uint8_t datatype, uint16_t status, uint64_t cas, in add_response() 109 last_cas = cas; in add_response() 116 uint8_t datatype, uint16_t status, uint64_t cas, in add_response_get_meta() 129 last_meta.cas = cas; in add_response_get_meta() 132 status, cas, cookie); in add_response_get_meta() 137 uint8_t datatype, uint16_t status, uint64_t cas, in add_response_ret_meta() 147 last_meta.cas = cas; in add_response_ret_meta() 80 add_response(const void *key, uint16_t keylen, const void *ext, uint8_t extlen, const void *body, uint32_t bodylen, uint8_t datatype, uint16_t status, uint64_t cas, const void *cookie) add_response() argument 114 add_response_get_meta(const void *key, uint16_t keylen, const void *ext, uint8_t extlen, const void *body, uint32_t bodylen, uint8_t datatype, uint16_t status, uint64_t cas, const void *cookie) add_response_get_meta() argument 135 add_response_ret_meta(const void *key, uint16_t keylen, const void *ext, uint8_t extlen, const void *body, uint32_t bodylen, uint8_t datatype, uint16_t status, uint64_t cas, const void *cookie) add_response_ret_meta() argument 175 uint64_t cas = htonll(meta->cas); encodeWithMetaExt() local 183 createPacket(uint8_t opcode, uint16_t vbid, uint64_t cas, const char *ext, uint8_t extlen, const char *key, uint32_t keylen, const char *val, uint32_t vallen, uint8_t datatype) createPacket() argument 273 del(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, uint64_t cas, uint16_t vbucket, const void* cookie) del() argument 544 return_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, const uint64_t cas, const uint32_t flags, const uint32_t exp, const uint32_t type, uint8_t datatype) return_meta() argument 560 set_ret_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, const uint64_t cas, const uint32_t flags, const uint32_t exp, uint8_t datatype) set_ret_meta() argument 568 add_ret_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, const uint64_t cas, const uint32_t flags, const uint32_t exp, uint8_t datatype) add_ret_meta() argument 576 del_ret_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const uint32_t vb, const uint64_t cas) del_ret_meta() argument 641 uint64_t cas = 0; storeCasVb11() local 683 unl(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char* key, uint16_t vb, uint64_t cas) unl() argument [all...] |
/3.0.3-GA/moxi/libmemcached/libmemcached/ |
H A D | storage.c | 39 return "cas "; in storage_op_string() 56 uint64_t cas, 65 uint64_t cas, in memcached_send() 98 flags, cas, verb); in memcached_send() 105 if (cas) in memcached_send() 115 (uint64_t)cas, in memcached_send() 305 uint64_t cas) in memcached_cas() 310 expiration, flags, cas, CAS_OP); in memcached_cas() 397 uint64_t cas) in memcached_cas_by_key() 402 expiration, flags, cas, CAS_O in memcached_cas_by_key() 59 memcached_send(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags, uint64_t cas, memcached_storage_action_t verb) memcached_send() argument 300 memcached_cas(memcached_st *ptr, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags, uint64_t cas) memcached_cas() argument 391 memcached_cas_by_key(memcached_st *ptr, const char *master_key, size_t master_key_length, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags, uint64_t cas) memcached_cas_by_key() argument 464 memcached_send_binary(memcached_st *ptr, memcached_server_write_instance_st server, uint32_t server_key, const char *key, size_t key_length, const char *value, size_t value_length, time_t expiration, uint32_t flags, uint64_t cas, memcached_storage_action_t verb) memcached_send_binary() argument [all...] |