Home
last modified time | relevance | path

Searched refs:flags (Results 1 – 25 of 37) sorted by relevance

12

/memcached-1.6.32/t/
Dmetaget.t190 is(get_flag($res, 'f'), $flags, "client flags $flags returned");
865 my $flags = $o->{flags};
894 my $flags = shift;
910 my $flags = shift;
929 $r{flags} = $2;
932 $r{flags} = $1;
948 $r{flags} = $2;
957 my @flags = split(/ /, $res->{flags});
958 for my $f (@flags) {
967 my $flags = shift;
[all …]
Dflags.t21 for my $flags (@fset) {
22 print $sock "set foo $flags 0 6\r\nfooval\r\n";
25 flags => $flags }, "foo", "fooval", "got flags $flags back");
Dbinary-extstore.t90 my ($flags, $val, $cas) = $mc->get($key);
91 is($flags, $orig_flags, "Flags is set properly");
474 my $flags = unpack("N", $header);
476 return ($flags, $rv, $cas);
496 my $flags = unpack("N", $header);
498 $return{$keys[$opaque]} = [$flags, $data];
521 my $flags = unpack("N", $header);
523 return ($flags, $rv, $cas);
538 my ($key, $val, $flags, $expire) = @_;
546 my ($key, $val, $flags, $expire, $cas) = @_;
[all …]
Dbinary.t66 my ($flags, $val, $cas) = $mc->get($key);
238 my ($flags, $val, $gcas) = $mc->get("bug220");
244 ($flags, $val, $gcas) = $mc->get("bug220");
268 my ($flags, $val, $i) = $mc->get("x");
753 my $flags = unpack("N", $header);
755 return ($flags, $rv, $cas);
775 my $flags = unpack("N", $header);
800 my $flags = unpack("N", $header);
802 return ($flags, $rv, $cas);
817 my ($key, $val, $flags, $expire) = @_;
[all …]
Dproxyrequest.lua16 local flags = r:token_int(3)
19 flags = flags + ttl + bytes
20 r:token(3, flags)
Dbinary-sasl.t519 my $flags = unpack("N", $header);
542 my $flags = unpack("N", $header);
544 $return{$keys[$opaque]} = [$flags, $data];
563 my ($key, $val, $flags, $expire) = @_;
564 my $extra_header = pack "NN", $flags, $expire;
571 my $flags = 0;
575 my $extra_header = pack "NN", $flags, $expire;
587 my ($key, $val, $flags, $expire) = @_;
588 my $extra_header = pack "NN", $flags, $expire;
Dudp.t85 my ($protocol, $req_id, $key, $value, $flags, $exp) = @_;
90 $req = "set $key $flags $exp $val_len\r\n$value\r\n";
93 my $extra = pack "NN",$flags,$exp;
/memcached-1.6.32/
Dproxy_network.c317 int flags = 0; in proxy_run_backend_queue() local
478 int flags = 0; in proxy_backend_drive_machine() local
490 return flags; in proxy_backend_drive_machine()
738 return flags; in proxy_backend_drive_machine()
1008 int flags = 0; in _flush_pending_write() local
1029 flags = -1; in _flush_pending_write()
1033 return flags; in _flush_pending_write()
1037 int flags = 0; in _flush_pending_tls_write() local
1060 flags = -1; in _flush_pending_tls_write()
1063 return flags; in _flush_pending_tls_write()
[all …]
Dstorage.c263 client_flags_t flags; in storage_get_item() local
264 FLAGS_CONV(it, flags); in storage_get_item()
436 if (((h_it->it_flags & flags) == flags) && in recache_or_free()
507 client_flags_t flags; in storage_write() local
510 FLAGS_CONV(it, flags); in storage_write()
784 flags->drop_unread = 0; in storage_compact_check()
835 flags->has_old = 1; in storage_compact_check()
878 if (flags->drop_unread || flags->has_coldcompact || flags->has_old) { in storage_compact_check()
880 flags->use_old = flags->has_old; in storage_compact_check()
1063 struct _compact_flags flags; in storage_compact_thread() local
[all …]
Ditems.h14 item *do_item_alloc(const char *key, const size_t nkey, const client_flags_t flags, const rel_time_…
18 bool item_size_ok(const size_t nkey, const client_flags_t flags, const int nbytes);
48 const uint64_t total_bytes, const uint8_t flags, const rel_time_t max_age,
Dprotocol_binary.h223 uint32_t flags; member
275 uint32_t flags; member
446 uint8_t flags; member
Ditems.c159 if (flags == 0) { in item_make_header()
162 *nsuffix = sizeof(flags); in item_make_header()
254 item *do_item_alloc(const char *key, const size_t nkey, const client_flags_t flags, in do_item_alloc() argument
263 size_t ntotal = item_make_header(nkey + 1, flags, nbytes, suffix, &nsuffix); in do_item_alloc()
336 memcpy(ITEM_suffix(it), &flags, sizeof(flags)); in do_item_alloc()
373 bool item_size_ok(const size_t nkey, const client_flags_t flags, const int nbytes) { in item_size_ok() argument
379 size_t ntotal = item_make_header(nkey + 1, flags, nbytes, in item_size_ok()
1130 if (flags & LRU_PULL_CRAWL_BLOCKS) { in lru_pull_tail()
1221 if (flags & LRU_PULL_EVICT) { in lru_pull_tail()
1243 } else if (flags & LRU_PULL_RETURN_ITEM) { in lru_pull_tail()
[all …]
Dslabs.h26 void *slabs_alloc(const size_t size, unsigned int id, unsigned int flags);
Dproxy_request.c125 pr->t.meta.flags = 0; // no flags found. in _process_request_metaflags()
144 pr->t.meta.flags |= (uint64_t)1 << (*cur - 65); in _process_request_metaflags()
161 if (pr->t.meta.flags & ((uint64_t)1 << 48)) { in _process_request_metaflags()
824 if (rq->pr.t.meta.flags & flagbit) { in mcplib_request_has_flag()
855 if (rq->pr.t.meta.flags & flagbit) { in mcplib_request_flag_token()
907 if (rq->pr.t.meta.flags & flagbit) { in mcplib_request_flag_token_int()
992 if (rq->pr.t.meta.flags & flagbit) { in mcplib_request_flag_add()
1196 if (rq->pr.t.meta.flags & flagbit) { in _mcp_request_find_flag()
Dproxy_luafgen.c365 rqu->flags = 0; in _mcp_funcgen_return_rctx()
831 rqu->flags |= RQUEUE_R_ERROR|RQUEUE_R_ANY; in _mcp_resume_rctx_process_error()
845 rqu->flags |= RQUEUE_R_ERROR|RQUEUE_R_ANY; in _mcp_start_rctx_process_error()
882 rqu->flags |= RQUEUE_R_ANY; in mcp_start_subrctx()
918 rqu->flags |= RQUEUE_R_ANY; in mcp_resume_rctx_from_cb()
978 int status = rqu->flags; in mcp_process_rctx_wait()
1104 rqu->flags |= flag; in mcp_process_rqueue_return()
1105 return rqu->flags; in mcp_process_rqueue_return()
1377 if (rqu->flags & RQUEUE_R_GOOD) { in mcplib_rcontext_res_good()
1387 if (rqu->flags & (RQUEUE_R_OK|RQUEUE_R_GOOD)) { in mcplib_rcontext_res_ok()
[all …]
Dmemcached.c1578 client_flags_t flags; in do_store_item() local
2342 client_flags_t flags; local
2343 FLAGS_CONV(it, flags);
3420 int flags; local
3498 int flags =1; local
3557 setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags));
3561 error = setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags));
3848 int flags; local
3869 int flags =1; local
3888 setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags));
[all …]
Dproxy_inspector.c305 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_hasflag_r()
335 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_flagtoken_r()
369 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_flagint_r()
441 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_flagis_r()
Dproto_bin.c519 FLAGS_CONV(it, rsp->message.body.flags); in process_bin_get_or_touch()
520 rsp->message.body.flags = htonl(rsp->message.body.flags); in process_bin_get_or_touch()
1093 req->message.body.flags = ntohl(req->message.body.flags); in process_bin_update()
1119 it = item_alloc(key, nkey, req->message.body.flags, in process_bin_update()
1124 if (! item_size_ok(nkey, req->message.body.flags, vlen + 2)) { in process_bin_update()
Dtls.c21 static ssize_t ssl_sendmsg(conn *c, struct msghdr *msg, int flags);
234 static ssize_t ssl_sendmsg(conn *c, struct msghdr *msg, int flags) { in ssl_sendmsg() argument
Dcrawler.c279 client_flags_t flags; in crawler_metadump_eval() local
280 FLAGS_CONV(it, flags); in crawler_metadump_eval()
292 (unsigned long long)flags); in crawler_metadump_eval()
/memcached-1.6.32/doc/
Dprotocol.txt313 - <flags> is the flags value set by the storage command
453 - <flags> is the flags value set by the storage command
501 mg <key> <flags>*\r\n
519 VA <size> <flags>*\r\n
524 - <flags>* are flags returned by the server, based on the command flags.
533 HD <flags>*\r\n
712 <CD> <flags>*\r\n
803 md <key> <flags>*\r\n
812 <CD> <flags> <tokens>*\r\n
876 ma <key> <flags>*\r\n
[all …]
/memcached-1.6.32/scripts/
Dmemcached-tool147 my $flags = $2;
151 print "add $k $flags $keyexp{$k} $len\r\n$val\r\n";
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c172 uint32_t flags = strtoul(p, &n, 10); in _mcmc_parse_value_line() local
206 r->flags = flags; in _mcmc_parse_value_line()
846 int flags = fcntl(sock, F_GETFL); in mcmc_connect() local
847 if (flags < 0) { in mcmc_connect()
852 if (fcntl(sock, F_SETFL, flags | O_NONBLOCK) < 0) { in mcmc_connect()
Dmcmc.h85 uint32_t flags; member
/memcached-1.6.32/t/lib/
DMemcachedTest.pm88 my $expect_flags = $opts->{flags} || 0;
118 my $expect_flags = $opts->{flags} || 0;
128 my $flags = $2;
146 my $expect_flags = $opts->{flags} || 0;

12