Home
last modified time | relevance | path

Searched refs:cas (Results 1 – 20 of 20) sorted by relevance

/memcached-1.6.32/t/
Dmetaget.t203 my $cas = get_flag($res, 'c');
204 my $badcas = $cas + 10;
214 my $cas = "973";
228 my $cas = "9876";
242 my $cas = "1234";
262 my $cas = "4321";
291 my $badcas = $cas + 10;
446 my $cas = get_flag($r, 'c');
528 $cas = get_flag($res, 'c');
631 my ($ttl, $cas, $res);
[all …]
Dbinary-extstore.t282 if ($cas) {
283 $ident_hi = int($cas / 2 ** 32);
284 $ident_lo = int($cas % 2 ** 32);
385 return ($opaque, $rv, $cas, $keylen);
448 my $cas = 0;
476 return ($flags, $rv, $cas);
509 my $cas = 0;
523 return ($flags, $rv, $cas);
540 my $cas = 0;
553 my ($cmd, $key, $val, $cas) = @_;
[all …]
Dbinary.t236 ok($icas != $cas);
242 ok($icas != $cas);
562 if ($cas) {
563 $ident_hi = int($cas / 2 ** 32);
727 my $cas = 0;
755 return ($flags, $rv, $cas);
788 my $cas = 0;
802 return ($flags, $rv, $cas);
819 my $cas = 0;
832 my ($cmd, $key, $val, $cas) = @_;
[all …]
Dbinary-sasl.t101 my ($status, $val, $cas) = $mc->get($key);
352 if ($cas) {
353 $ident_hi = int($cas / 2 ** 32);
354 $ident_lo = int($cas % 2 ** 32);
429 my $cas = ($ident_hi * 2 ** 32) + $ident_lo;
435 return ($opaque, $status, $rv, $cas, $keylen);
492 my $cas = 0;
565 my $cas = 0;
572 my $cas = 0;
581 my ($cmd, $key, $val, $cas) = @_;
[all …]
Dextstore-cas.t37 my ($cas, $val) = mem_gets($sock, "foo");
38 isnt($cas, 0, "got a real cas value back");
49 is($cas, $cas2, "cas still matches");
67 is($cas, $cas3, "CAS values still match");
Dslabs-cas.t29 my ($cas, $val) = mem_gets($sock, "bfoo5");
30 isnt($cas, 0, "got a real CAS back for one of the keys");
46 is($cas, $cas_after, "CAS value match after page move");
/memcached-1.6.32/
Dproto_bin.c75 c->binary_header.request.cas = ntohll(req->request.cas); in try_read_command_binary()
103 c->cas = 0; in try_read_command_binary()
152 header->response.cas = htonll(c->cas); in add_bin_header()
263 uint64_t cas = 0; in complete_incr_bin() local
292 cas = c->binary_header.request.cas; in complete_incr_bin()
299 if (cas) { in complete_incr_bin()
300 c->cas = cas; in complete_incr_bin()
329 c->cas = cas; in complete_incr_bin()
387 c->cas = cas; in complete_update_bin()
1305 uint64_t cas = c->binary_header.request.cas; in process_bin_delete() local
[all …]
Ditems.h20 int do_item_link(item *it, const uint32_t hv, const uint64_t cas); /** may fail if transgresse…
26 int do_item_replace(item *it, item *new_it, const uint32_t hv, const uint64_t cas);
Dmemcached.h127 (i)->data->cas : (uint64_t)0)
131 (i)->data->cas = v; \
606 uint64_t cas; member
897 uint64_t cas; /* the cas to return */ member
953 uint64_t *cas, const uint32_t hv,
955 …m, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int *nbytes, uint64_t *cas, const uint64_t cas…
1000 uint64_t *cas);
1038 …tore_item(item *item, int comm, LIBEVENT_THREAD *t, int *nbytes, uint64_t *cas, const uint64_t cas…
Dprotocol_binary.h161 uint64_t cas; member
180 uint64_t cas; member
Dproto_text.c104 p = itoa_u64(cas, p); in _finalize_mset()
180 uint64_t cas = 0; in complete_nread_ascii() local
182 …ret = store_item(it, comm, c->thread, &nbytes, &cas, c->cas ? c->cas : get_cas_id(), c->set_stale); in complete_nread_ascii()
183 c->cas = 0; in complete_nread_ascii()
189 (ret == 1) ? it->nbytes : -1, cas); in complete_nread_ascii()
193 (ret == 1) ? it->nbytes : -1, cas); in complete_nread_ascii()
197 (ret == 1) ? it->nbytes : -1, cas); in complete_nread_ascii()
205 (ret == 1) ? it->nbytes : -1, cas); in complete_nread_ascii()
209 cas); in complete_nread_ascii()
215 _finalize_mset(c, nbytes, ret, cas); in complete_nread_ascii()
[all …]
Dtestapp.c1266 assert(response->message.header.response.cas != 0); in validate_response_header()
1275 assert(response->message.header.response.cas == 0); in validate_response_header()
1283 assert(response->message.header.response.cas != 0); in validate_response_header()
1289 assert(response->message.header.response.cas == 0); in validate_response_header()
1296 assert(response->message.header.response.cas == 0); in validate_response_header()
1305 assert(response->message.header.response.cas != 0); in validate_response_header()
1314 assert(response->message.header.response.cas != 0); in validate_response_header()
1322 assert(response->message.header.response.cas == 0); in validate_response_header()
1409 send.request.message.header.request.cas = receive.response.message.header.response.cas; in test_binary_set_impl()
1415 … assert(receive.response.message.header.response.cas != send.request.message.header.request.cas); in test_binary_set_impl()
Dproxy_internal.c1188 uint64_t cas = 0; in process_mset_cmd() local
1190 …int ret = store_item(it, comm, t, &nbytes, &cas, of.has_cas_in ? of.cas_id_in : get_cas_id(), set_… in process_mset_cmd()
1232 p = itoa_u64(cas, p); in process_mset_cmd()
1478 uint64_t cas = 0; in process_marithmetic_cmd() local
1489 cas = ITEM_get_cas(it); in process_marithmetic_cmd()
1508 if (do_store_item(it, NREAD_ADD, t, hv, NULL, &cas, in process_marithmetic_cmd()
1556 p = itoa_u64(cas, p); in process_marithmetic_cmd()
Dthread.c948 uint64_t *cas) { in add_delta() argument
954 ret = do_add_delta(t, key, nkey, incr, delta, buf, cas, hv, NULL); in add_delta()
962 …tore_item(item *item, int comm, LIBEVENT_THREAD *t, int *nbytes, uint64_t *cas, const uint64_t cas… in store_item() argument
968 ret = do_store_item(item, comm, t, hv, nbytes, cas, cas_in, cas_stale); in store_item()
Ditems.c491 int do_item_link(item *it, const uint32_t hv, const uint64_t cas) { in do_item_link() argument
504 ITEM_set_cas(it, cas); in do_item_link()
584 int do_item_replace(item *it, item *new_it, const uint32_t hv, const uint64_t cas) { in do_item_replace() argument
590 return do_item_link(new_it, hv, cas); in do_item_replace()
Dmemcached.c1570 …t, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int *nbytes, uint64_t *cas, uint64_t cas_in, b… in do_store_item() argument
1729 if (stored == STORED && cas != NULL) { in do_store_item()
1730 *cas = ITEM_get_cas(it); in do_store_item()
2267 char *buf, uint64_t *cas, argument
2291 if (cas != NULL && *cas != 0 && ITEM_get_cas(it) != *cas) {
2367 if (cas) {
2368 *cas = ITEM_get_cas(it); /* swap the incoming CAS value */
DChangeLog177 * Incorporate "cas" operation developed by Dustin
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c186 uint64_t cas = 0; in _mcmc_parse_value_line() local
189 cas = strtoull(p, &n, 10); in _mcmc_parse_value_line()
207 r->cas = cas; in _mcmc_parse_value_line()
Dmcmc.h86 uint64_t cas; member
/memcached-1.6.32/doc/
Dprotocol.txt210 cas <key> <flags> <exptime> <bytes> <cas unique> [noreply]\r\n
255 - <cas unique> is a unique 64-bit value of an existing entry.
257 when issuing "cas" updates.
282 a "cas" command has been modified since you last fetched it.
285 with a "cas" command did not exist.
308 VALUE <key> <flags> <bytes> [<cas unique>]\r\n
448 VALUE <key> <flags> <bytes> [<cas unique>]\r\n
487 cas = CAS ID
544 - c: return item cas token
786 The "cas" command is supplanted by specifying the cas value with the 'C' flag.
[all …]