| /memcached-1.6.32/t/ |
| D | proxybestats.t | 30 my $s = mem_stats($ps, "proxybe");
31 is(keys %$s, 0, "no bad backends");
36 $s = mem_stats($ps, "proxybe");
37 is($s->{bad_b1}, 1, "b1 is now bad");
47 $s = mem_stats($ps, "proxybe");
48 is(keys %$s, 0, "no bad backends anymore");
53 $s = mem_stats($ps, "proxybe");
54 is($s->{bad_b2}, 1, "b2 is now bad");
55 is($s->{bad_b3}, 1, "b3 is now bad");
61 $s = mem_stats($ps, "proxybe");
[all …]
|
| D | conn-limits.t | 35 my $s = $server->new_sock;
41 print $s $cmd;
42 ok(!defined <$s>, 'sock disconnected after overflow');
54 my $s = $server->new_sock;
58 ok(defined($s), 'new conn made');
60 print $s "set foo 0 0 2\r\n";
61 push(@conns, $s);
64 for my $s (@conns) {
65 $s->close();
|
| D | proxyconfig.t | 129 my $s = IO::Select->new();
132 $s->add($be);
174 my $s = IO::Select->new();
176 $s->add($msrv);
196 @readable = $s->can_read(0.5);
216 my $s = IO::Select->new();
219 $s->add($be);
239 @readable = $s->can_read(0.25);
345 my $s = IO::Select->new();
347 $s->add($msrv);
[all …]
|
| D | slabs-reassign-chunked.t | 14 my $s = shift;
16 for my $k (sort keys %$s) {
20 print STDERR "STAT: $k = ", $s->{$k}, "\n";
53 my $s = mem_stats($sock, 'slabs');
56 for my $k (keys %$s) {
58 $sid = $s->{$k} if $s->{$k} > $1;
|
| D | proxyintstats.lua | 2 local s
4 s = mcp.server_stats(cmd)
6 s = mcp.server_stats()
11 for k, v in pairs(s) do
23 local s = mcp.server_stats(cmd)
27 for k, v in pairs(s) do
|
| D | slabs-reassign2.t | 84 my $s = mem_stats($sock, 'slabs');
87 for my $k (keys %$s) {
89 if ($s->{$k} > $max_pages) {
90 $max_pages = $s->{$k};
99 my $s = mem_stats($sock);
100 last if $s->{slab_reassign_evictions_nomem} > 0;
|
| D | extstore-overdel.t | 28 my $s = mem_stats($sock, "items");
30 for my $key (keys %$s) {
34 $sum += $s->{$key};
43 my $s = shift;
45 for (1 .. $s) {
|
| D | extstore-jbod.t | 80 my $s = shift;
87 while (exists $s->{$x . ':version'}) {
90 my $is_used = $s->{$x . ':version'};
93 $buks[$s->{$x . ':free_bucket'}]++;
|
| D | metaget.t | 781 for my $key (keys %$s) {
864 my $s = $o->{sock};
870 my $line = scalar <$s>;
877 my $body = scalar(<$s>);
883 $body .= scalar(<$s>);
892 my $s = shift;
897 my $header = scalar(<$s>);
900 $val = scalar(<$s>);
908 my $s = shift;
913 my $header = scalar(<$s>);
[all …]
|
| D | extstore-tiered.t | 80 my $s = shift;
84 while (exists $s->{$x . ':version'}) {
85 my $is_used = $s->{$x . ':version'};
88 $buks[$s->{$x . ':free_bucket'}]++;
|
| D | proxylimits.t | 97 my $s = IO::Select->new();
98 $s->add($be);
99 my @readable = $s->can_read(0.25);
150 my $s = IO::Select->new;
151 $s->add($be);
153 my @readable = $s->can_read(1);
|
| D | extstore-tiered2.t | 114 my $s = shift;
118 while (exists $s->{$x . ':version'}) {
121 my $is_used = $s->{$x . ':version'};
124 $buks[$s->{$x . ':free_bucket'}]++;
|
| D | error-extstore.t | 30 my $s = mem_stats($sock, "items");
32 for my $key (keys %$s) {
36 $sum += $s->{$key};
|
| D | proxyinternal2.t | 108 my $s = mem_stats($ps, 'slabs');
109 for my $k (keys %$s) {
111 is($s->{$k}, 0, "class " . $k . " is empty")
|
| D | binary-extstore.t | 75 my %s = $mc->stats("items");
77 for my $key (keys %s) {
81 $sum += $s{$key};
206 my %s = $mc->stats('');
207 cmp_ok($s{extstore_objects_evicted}, '>', 0);
208 cmp_ok($s{miss_from_extstore}, '>', 0);
259 my ($s) = @_;
260 $s = $server unless defined $s;
261 my $sock = $s->sock;
|
| /memcached-1.6.32/scripts/ |
| D | memcached-automove | 37 s = window.get(sid)
38 if s and s.get(key):
39 total += s.get(key) > 0 and 1 or 0
45 s = window.get(sid)
46 if s and s.get(key):
47 total += s.get(key)
126 def run_move(s, decision): argument
128 line = s.readline().rstrip()
165 def read_stats(s): argument
172 line = s.readline().rstrip()
[all …]
|
| D | memcached-automove-extstore | 41 s = window.get(sid)
42 if s and s.get(key):
43 total += s.get(key)
164 def run_move(s, decision): argument
166 line = s.readline().rstrip()
203 def read_slab_stats(s): argument
225 def read_stats(s): argument
227 s.write("stats\r\n")
229 line = s.readline().rstrip()
261 def memfree_check(s, diffs, totals): argument
[all …]
|
| D | damemtop | 233 my $s = $_[1];
234 my $total = $s->{get_hits} + $s->{get_misses};
236 return $s->{get_hits} / $total;
240 my $s = $_[1];
241 return $s->{bytes} / $s->{limit_maxbytes};
301 my %s = ();
303 $s{$stat} = $diff_stat->($stat);
305 return $comp->{code}->($host, \%s);
|
| /memcached-1.6.32/ |
| D | proxy_mutator.c | 61 const char *s; // string name member
268 s->idx = lua_tointeger(L, -1); in mut_step_i()
276 unsigned idx = s->idx; in mut_step_n()
318 unsigned idx = s->idx; in mut_step_n()
443 unsigned idx = s->idx; in mut_step_n()
662 unsigned idx = s->idx; in mut_step_n()
769 unsigned idx = s->idx; in mut_step_n()
776 switch (s->arg) { in mut_step_n()
863 if (e->s && strcmp(type, e->s) == 0) { in mcp_mutator_steptype()
947 int len = s->n(run, s, &parts[x]); in _mcp_mut_run_total()
[all …]
|
| D | proxy_inspector.c | 96 struct mcp_ins_step *s = &ins->steps[sc]; in mcp_inspector_flag_i_g() local
97 struct mcp_ins_flag *c = &s->c.flag; in mcp_inspector_flag_i_g()
127 struct mcp_ins_string *c = &s->c.string; in mcp_inspector_string_i_g()
301 struct mcp_ins_flag *c = &s->c.flag; in mcp_inspector_hasflag_r()
331 struct mcp_ins_flag *c = &s->c.flag; in mcp_inspector_flagtoken_r()
365 struct mcp_ins_flag *c = &s->c.flag; in mcp_inspector_flagint_r()
483 const char *s; // string name member
507 if (e->s && strcmp(type, e->s) == 0) { in mcp_inspector_steptype()
602 ret += mcp_ins_entries[s->type].r(L, ins, s, arg); in mcp_ins_run()
629 switch (s->type) { in mcplib_inspector_gc()
[all …]
|
| D | proxy_request.c | 11 const char *s = pr->request; in _process_tokenize() local
19 const char *end = s + len; in _process_tokenize()
23 while (s != end) { in _process_tokenize()
30 s++; in _process_tokenize()
36 s++; in _process_tokenize()
41 s++; in _process_tokenize()
52 s++; in _process_tokenize()
74 return e - s; in _process_token_len()
110 if (s != NULL) { in _process_request_next_key()
308 if (s != NULL) { in process_request()
[all …]
|
| D | version.sh | 3 if git describe | sed s/-/_/g > version.num.tmp
8 sed s/@VERSION@/`cat version.num`/ < memcached.spec.in > memcached.spec
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.c | 60 const char *s = line; in _mcmc_tokenize_meta() local
79 while (s != end) { in _mcmc_tokenize_meta()
85 if (*s > 64 && *s < 123) { in _mcmc_tokenize_meta()
99 s++; in _mcmc_tokenize_meta()
104 s++; in _mcmc_tokenize_meta()
115 s++; in _mcmc_tokenize_meta()
137 return e - s; in _mcmc_token_len()
147 *len = e - s; in _mcmc_token()
149 return s; in _mcmc_token()
803 int s; in mcmc_connect() local
[all …]
|
| /memcached-1.6.32/doc/ |
| D | storage.txt | 6 extstore_write() is a synchronous call which memcpy's the input buffer into a
20 item has been removed from that page. It's important to call this as items are
27 Callbacks are issued from the IO threads. It's thus important to keep
29 caller's responsibility to know when its stack has been fully processed so it
49 If TTL's are low, mixed sized objects can go together as they are likely to
56 then chunk and look up objects. Then read next 1MB chunk/etc. If there's
65 With the POC: items.c's lru_maintainer_thread calls writes to storage if all
74 As much processing as possible is done ahead of time, IO's are submitted, and
75 once IO's are done processing a minimal amount of code is executed before
85 instances of an item being hit twice within ~60s it will be recached into
[all …]
|
| D | new_lru.txt | 10 * LRU's are now split between HOT, WARM, and COLD LRU's. New items enter the
19 * HOT/WARM are also age capped by ratios of COLD's age. IE: HOT is capped at
22 * A background thread exists which shuffles items between/within the LRU's as
38 slab classes for items with expired TTL's. If your items are always set to
43 stored in TEMP are never bumped within its LRU or moved to other LRU's. They
|