| /memcached-1.6.32/ |
| D | proxy_network.c | 114 struct mcp_backendconn_s *bec = &be->be[0]; in proxy_choose_beconn()
175 struct mcp_backendconn_s *bec = &be->be[x]; in _cleanup_backend()
213 struct mcp_backendconn_s *bec = &be->be[x]; in _setup_backend()
217 be->be[x].bad = true; in _setup_backend()
532 memmove(be->rbuf, be->rbuf+r->resp.reslen, be->rbufused); in proxy_backend_drive_machine()
648 memmove(be->rbuf, be->rbuf+ENDLEN, be->rbufused); in proxy_backend_drive_machine()
683 memmove(be->rbuf, be->rbuf+tocopy, be->rbufused); in proxy_backend_drive_machine()
742 …int status = mcmc_connect(be->client, be->be_parent->name, be->be_parent->port, be->connect_flags); in _backend_reconnect()
762 …event_assign(&be->write_event, be->event_thread->base, mcmc_fd(be->client), EV_WRITE|EV_TIMEOUT, _… in _backend_reconnect()
1254 … int read = recv(mcmc_fd(be->client), be->rbuf + be->rbufused, READ_BUFFER_SIZE - be->rbufused, 0); in proxy_beconn_handler()
[all …]
|
| D | proxy_tls.c | 54 be->ssl = ssl; in mcp_tls_backend_init()
62 if (!be->ssl) { in mcp_tls_shutdown()
70 SSL_shutdown(be->ssl); in mcp_tls_shutdown()
76 if (!be->ssl) { in mcp_tls_cleanup()
80 SSL_free(be->ssl); in mcp_tls_cleanup()
81 be->ssl = NULL; in mcp_tls_cleanup()
89 SSL_set_fd(be->ssl, mcmc_fd(be->client)); in mcp_tls_connect()
100 SSL_clear(be->ssl); in mcp_tls_connect()
176 int n = SSL_read(be->ssl, be->rbuf + be->rbufused, READ_BUFFER_SIZE - be->rbufused); in mcp_tls_read()
190 be->rbufused += n; in mcp_tls_read()
[all …]
|
| D | proxy_tls.h | 20 int mcp_tls_shutdown(struct mcp_backendconn_s *be);
21 int mcp_tls_cleanup(struct mcp_backendconn_s *be);
22 int mcp_tls_connect(struct mcp_backendconn_s *be);
25 int mcp_tls_read(struct mcp_backendconn_s *be);
29 #define mcp_tls_backend_init(ctx, be) argument
30 #define mcp_tls_shutdown(be); argument
31 #define mcp_tls_cleanup(be); argument
32 #define mcp_tls_connect(be) argument
33 #define mcp_tls_handshake(be) 0 argument
34 #define mcp_tls_send_validate(be) 0 argument
[all …]
|
| D | proxy_lua.c | 252 if (bew->be != NULL) { in mcplib_backend_wrap_gc()
253 mcp_backend_t *be = bew->be; in mcplib_backend_wrap_gc() local
262 proxy_event_thread_t *e = be->be[0].event_thread; in mcplib_backend_wrap_gc()
303 memset(be, 0, sizeof(*be)); in mcplib_backend()
308 memcpy(&be->tunables, &ctx->tunables, sizeof(be->tunables)); in mcplib_backend()
485 be->llen = llen; in mcplib_backend()
529 if (be == NULL) { in _mcplib_make_backendconn()
533 bew->be = be; in _mcplib_make_backendconn()
543 struct mcp_backendconn_s *bec = &be->be[x]; in _mcplib_make_backendconn()
698 mcp_backend_t *be = p->pool[x-1].be; in _mcplib_pool_dist() local
[all …]
|
| D | Doxyfile | 679 # be generated. Documented entities will be cross-referenced with these sources.
742 # in which this list will be split (can be a number in the range [1..20])
810 # will be generated that can be used as input for Apple's Xcode 3
824 # can be grouped.
836 # will be generated that can be used as input for tools like the
985 # The LATEX_CMD_NAME tag can be used to specify the LaTeX command name to be
1210 # compilation will be performed. Macro expansion can be done in a controlled
1235 # be used.
1294 # will be listed.
1300 # be listed.
[all …]
|
| D | HACKING | 27 The pre-commit hook can be used to ensure that your tree passes tests
29 .git/hooks/pre-commit (which must be executable):
39 .git/hooks/post-commit (which must be executable)
56 support, it can be debugged in one of two ways:
71 In strace output those can be seen as:
|
| D | proto_proxy.c | 503 mcp_backend_t *be; in proxy_submit_cb() local
522 be = p->backend; in proxy_submit_cb()
524 if (be->use_io_thread) { in proxy_submit_cb()
530 be->depth++; in proxy_submit_cb()
531 if (!be->stacked) { in proxy_submit_cb()
1286 mcp_set_resobj(r, rq, be, t); in mcp_prep_resobj()
1336 p->backend = be; in mcp_queue_rctx_io()
1633 mcp_backend_t *be = p->pool[x].be; in dump_pool_info() local
1635 if (be != NULL) { in dump_pool_info()
1637 x, be->label, be->name, be->conncount, be->depth); in dump_pool_info()
[all …]
|
| D | README.md | 4 store intended to be used in a distributed system.
28 Be warned that the -k (mlockall) option to memcached might be
44 bug can be posted publicly with credit in our release notes and commit
|
| /memcached-1.6.32/t/ |
| D | proxyunits.t | 36 $be->autoflush(1);
41 return $be;
66 push(@mbe, $be);
201 my $be = $mbe[0];
231 my $be = $mbe[0];
298 print $be "llo";
322 print $be "llo";
1168 print $be $msg;
1181 print $be $msg;
1191 print $be $msg;
[all …]
|
| D | proxylimits.t | 35 $be->autoflush(1);
40 return $be;
77 push(@mbe, $be);
92 my $be = $mbe[0];
98 $s->add($be);
149 my $be = $mbe[0];
151 $s->add($be);
159 print $be "HD\r\n";
186 print $be "HD\r\n";
191 print $be "HD\r\n";
[all …]
|
| D | proxyconfig.t | 43 my $be = $srv->accept();
44 $be->autoflush(1);
49 return $be;
132 $s->add($be);
133 push(@mbe, $be);
143 print $be "EN\r\n";
213 push(@bes, $be);
218 for my $be (@bes) {
219 $s->add($be);
265 for my $be (@bes) {
[all …]
|
| D | proxyantiflap.t | 35 $be->autoflush(1);
40 return $be;
74 $s->add($be);
79 $be->close();
86 $be->close();
94 print $be "HD\r\n";
104 my $oldbe = $be;
114 $be->close();
121 $be->close();
135 print $be "HD\r\n";
[all …]
|
| D | proxyustats.t | 38 my $be = $srv->accept();
39 $be->autoflush(1);
40 ok(defined $be, "mock backend created");
41 like(<$be>, qr/version/, "received version command");
42 print $be "VERSION 1.0.0-mock\r\n";
44 return $be;
|
| D | proxytags.lua | 9 local be = mcp.backend('be', '127.0.0.1', 12050)
10 local p = mcp.pool({ be })
|
| /memcached-1.6.32/doc/ |
| D | Doxyfile | 422 # automatically be disabled.
573 # be generated. Documented entities will be cross-referenced with these sources.
635 # in which this list will be split (can be a number in the range [1..20])
695 # will be generated that can be used as input for tools like the
773 # The LATEX_CMD_NAME tag can be used to specify the LaTeX command name to be
996 # compilation will be performed. Macro expansion can be done in a controlled
1021 # be used.
1036 # this tag can be used to specify a list of macro names that should be expanded.
1078 # will be listed.
1084 # be listed.
[all …]
|
| D | threads.txt | 33 - item_lock must be held while modifying an item.
34 - slabs_lock must be held while modifying the ITEM_SLABBED flag bit within an item.
35 - ITEM_LINKED must not be set before an item has a key copied into it.
48 Various locks exist for background threads. They can be used to pause the
58 Yes, more stats can be moved to threads, and those locks can actually be
|
| D | protocol-binary-range.txt | 36 and may be updated, replaced, or obsoleted by other documents at any
104 document are to be interpreted as described in [KEYWORDS].
148 for which the request was made is larger than can be placed into a
149 single UDP packet (noting that the protocol header must also be
150 counted), a Get Range response packet MUST be sent instead of the Get
153 1. The Status field of the response header MUST be 0x0004.
154 2. The Offset field of the GetR response extras MUST be 0.
156 contained in the Value field of the packet, SHOULD be the maximum
158 header and extras; however it MAY be any amount below this
160 4. The Total value length field of the response extras MUST be the
[all …]
|
| D | protocol.txt | 273 the reply, which may be:
383 The response will be one of:
473 key will also be base64 encoded.
492 Others may be added.
707 is assumed to be 0 length.
773 (EXISTS) will still be returned.
845 be supplied an 'X' flag to show the data is stale and needs to be recached.
860 waiting to be recached.
936 An unsigned 64-bit integer which will be seeded as the value on a miss. Must be
991 The response line could be one of:
[all …]
|
| D | storage.txt | 8 indicates caller can try again another time. IE: it might be busy freeing
28 processing to a minimum. Callbacks may be issued out of order, and it is the
32 With DIRECT_IO support, buffers submitted for read/write will need to be
39 handled overall as a global pool, but writes can be redirected to specific
60 will only be a single active page with write buffers.
73 To get best performance is important that reads can be deeply pipelined.
85 instances of an item being hit twice within ~60s it will be recached into
98 megabytes, pages with less than 28.8 megabytes used would be targeted for
108 busy for some reason, the write is dropped (COW needs to be implemented). This
|
| D | napi_ids.txt | 5 manner. NAPI ID based worker thread selection enables worker threads to be
26 received. The number of napi_ids specified cannot be greater than the number
40 virtual interface like loopback, napi_id returned can be 0. This condition
|
| /memcached-1.6.32/t/lib/ |
| D | MemcachedTest.pm | 574 my $be = $srv->accept();
575 $be->autoflush(1);
578 my $sent = $be->send("VERSION 1.0.0-mock\r\n");
581 return $be;
588 my $be = _accept_backend($srv);
589 push(@{$self->{_be}}, $be);
678 for my $be (@$l) {
692 for my $be (@$l) {
705 for my $be (@$l) {
719 for my $be (@$l) {
[all …]
|
| /memcached-1.6.32/scripts/ |
| D | memcached.sysconfig | 1 # These defaults will be used by every memcached instance, unless overridden
8 # The PORT variable will only be used by memcached.service, not by
|
| D | [email protected] | 1 # It's not recommended to modify this file in-place, because it will be
13 # will be read first, so you can set different parameters for a given
60 # Explicit module loading will be denied. This allows to turn off module
68 # will be made read-only to all processes of the unit. Usually, tunable
69 # kernel variables should only be written at boot-time, with the sysctl.d(5)
75 # /sys/fs/cgroup will be made read-only to all processes of the unit.
|
| D | memcached.service | 1 # It's not recommended to modify this file in-place, because it will be
55 # Explicit module loading will be denied. This allows to turn off module
63 # will be made read-only to all processes of the unit. Usually, tunable
64 # kernel variables should only be written at boot-time, with the sysctl.d(5)
70 # /sys/fs/cgroup will be made read-only to all processes of the unit.
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | README.md | 12 specific servers. The MCMC base client is designed to be an object that
21 MCMC is designed to be a building block for users designing full clients.
30 This should be the same, if not less, code than wrapping a full C client with
32 should!) embed mcmc.c/mcmc.h (and any selector code they want) rather than be
40 * Care should be taken when handling the buffers mcmc requires to operate.
|