| /memcached-1.6.32/t/ |
| D | multiversioning.t | 27 my $read = 0;
29 while ($read < $to_read) {
31 ($to_read - $read > MemcachedTest::MAX_READ_WRITE_SIZE ?
32 MemcachedTest::MAX_READ_WRITE_SIZE : $to_read - $read),
33 $read);
35 $read += $read_bytes;
37 is($read, $size / 2, "read half the answer back");
|
| D | proxyunits.t | 1183 my $read = $be->read($data, 1);
1184 is($read, 0, "backend disconnected");
1193 $read = $be->read($data, 1);
1194 is($read, 0, "backend disconnected");
1204 $read = $be->read($data, 1);
1205 is($read, 0, "backend disconnected");
|
| /memcached-1.6.32/ |
| D | proxy_network.c | 261 if (read(fd, buf, 1) != 1) { in proxy_event_beconn()
380 if (read(fd, buf, 1) != 1) { in proxy_event_handler()
1086 if (read > 0) { in proxy_bevalidate_tls_handler()
1109 } else if (read == 0) { in proxy_bevalidate_tls_handler()
1255 if (read > 0) { in proxy_beconn_handler()
1279 } else if (read == 0) { in proxy_beconn_handler()
1283 } else if (read == -1) { in proxy_beconn_handler()
1352 if (read > 0) { in proxy_backend_tls_handler()
1358 } else if (read == 0) { in proxy_backend_tls_handler()
1413 if (read > 0) { in proxy_backend_handler()
[all …]
|
| D | linux_priv.c | 100 rc |= seccomp_rule_add(ctx, SCMP_ACT_ALLOW, SCMP_SYS(read), 0); in drop_privileges()
146 rc |= seccomp_rule_add(ctx, SCMP_ACT_ALLOW, SCMP_SYS(read), 0); in drop_worker_privileges()
|
| D | testapp.c | 43 ssize_t (*read)(struct conn *c, void *buf, size_t count); member
58 return read(c->sock, buf, count); in tcp_read()
729 c->read = ssl_read; in connect_server()
734 c->read = tcp_read; in connect_server()
813 ssize_t nr = con->read(con, buffer + offset, 1); in read_ascii_response()
892 assert(con->read(con, buffer, sizeof(buffer)) == 0); in test_issue_102()
925 assert(con->read(con, buffer, sizeof(buffer)) == 0); in test_issue_102()
960 assert(con->read(con, buffer, sizeof(buffer)) == 0); in shutdown_memcached_server()
1019 ssize_t nr = con->read(con, ((char*)buf) + offset, len - offset); in safe_recv()
1367 assert(con->read(con, buffer.bytes, sizeof(buffer.bytes)) == 0); in test_binary_quit_impl()
|
| D | thread.c | 553 if (read(fd, &ev_count, sizeof(uint64_t)) != sizeof(uint64_t)) { in thread_libevent_ionotify()
561 ev_count = read(fd, buf, MAX_PIPE_EVENTS); in thread_libevent_ionotify()
596 if (read(fd, &ev_count, sizeof(uint64_t)) != sizeof(uint64_t)) { in thread_libevent_process()
604 ev_count = read(fd, buf, MAX_PIPE_EVENTS); in thread_libevent_process()
|
| D | proxy_lua.c | 407 be->tunables.read.tv_sec = secondsi; in mcplib_backend()
408 be->tunables.read.tv_usec = MICROSECONDS(subseconds); in mcplib_backend()
1111 ctx->tunables.read.tv_sec = secondsi; in mcplib_backend_read_timeout()
1112 ctx->tunables.read.tv_usec = MICROSECONDS(subseconds); in mcplib_backend_read_timeout()
|
| D | tls.c | 367 c->read = ssl_read; in ssl_init_conn()
|
| D | memcached.c | 133 return read(c->sfd, buf, count); in tcp_read()
646 c->read = NULL; in conn_new()
757 c->read = tcp_read; in conn_new()
2501 res = c->read(c, c->rbuf + c->rbytes, avail);
2960 res = c->read(c, ch->data + ch->used,
3203 res = c->read(c, c->ritem, c->rlbytes);
3279 res = c->read(c, c->rbuf, c->rsize > c->sbytes ? c->sbytes : c->rsize);
4345 ssize_t rd = read(pfd, thpb, sizeof(thpb));
|
| D | crawler.c | 398 int res = ((conn*)c->c)->read(c->c, buf, 1); in lru_crawler_write()
|
| D | proxy.h | 216 struct timeval read; member
|
| D | memcached.h | 905 ssize_t (*read)(conn *c, void *buf, size_t count); member
|
| D | extstore.c | 907 ret = read(p->fd, cur_io->buf, cur_io->len); in extstore_io_thread()
|
| D | logger.c | 830 int res = ((conn*)w->c)->read(w->c, buf, 1); in logger_thread_poll_watchers()
|
| D | proto_proxy.c | 374 ctx->tunables.read.tv_sec = 3; in proxy_init()
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | example.c | 47 int read = recv(mcmc_fd(c), buf, toread, 0); in show_response_buffer() local
48 toread -= read; in show_response_buffer()
|
| D | mcmc.c | 152 static int _mcmc_parse_value_line(const char *buf, size_t read, mcmc_resp_t *r) { in _mcmc_parse_value_line() argument
198 int buffer_remain = read - r->reslen; in _mcmc_parse_value_line()
245 static int _mcmc_parse_response(const char *buf, size_t read, mcmc_resp_t *r) { in _mcmc_parse_response() argument
343 int buffer_remain = read - r->reslen; in _mcmc_parse_response()
399 code = _mcmc_parse_value_line(buf, read, r); in _mcmc_parse_response()
736 int mcmc_parse_buf(const char *buf, size_t read, mcmc_resp_t *r) { in mcmc_parse_buf() argument
740 el = memchr(buf, '\n', read); in mcmc_parse_buf()
753 return _mcmc_parse_response(buf, read, r); in mcmc_parse_buf()
|
| D | mcmc.h | 125 int mcmc_parse_buf(const char *buf, size_t read, mcmc_resp_t *r);
|
| D | README.md | 27 * They then call mcmc's functions to send and read the response, parsing and
|
| /memcached-1.6.32/doc/ |
| D | storage.txt | 32 With DIRECT_IO support, buffers submitted for read/write will need to be
53 pages. It also means you can blindly read items back if the system wants to
55 probation. ie; issue a read against page 3 version 1 for byte range 0->1MB,
56 then chunk and look up objects. Then read next 1MB chunk/etc. If there's
111 Objects are read back along the boundaries of a write buffer. If an 8 meg
112 write buffer is used, 8 megs are read back at once and iterated for objects.
|
| D | tls.txt | 43 OpenSSL library provides APIs for us to directly read/write from a socket. With this option,
56 |......|--> read(fd) --> BIO_write(rbio) -->|.....|--> SSL_read(ssl) --> IN
|
| D | threads.txt | 19 thread may read or write against a particular hash table bucket.
|
| D | protocol.txt | 8 the server, read responses, and eventually close the connection.
606 pipeline several mg's together and read all of the responses without the
1328 | read_buf_count | 64u | Total read/resp buffers allocated |
1329 | read_buf_bytes | 64u | Total read/resp buffer bytes allocated |
1330 | read_buf_bytes_free | 64u | Total read/resp buffer bytes cached |
1381 | bytes_read | 64u | Total number of bytes read by this server |
1518 | read_obj_mem_limit| 32u | Megabyte limit for conn. read/resp buffers. |
|
| /memcached-1.6.32/scripts/ |
| D | [email protected] | 13 # will be read first, so you can set different parameters for a given
30 # Mounts the /usr, /boot, and /etc directories read-only for processes
68 # will be made read-only to all processes of the unit. Usually, tunable
75 # /sys/fs/cgroup will be made read-only to all processes of the unit.
|
| D | memcached.service | 25 # Mounts the /usr, /boot, and /etc directories read-only for processes
63 # will be made read-only to all processes of the unit. Usually, tunable
70 # /sys/fs/cgroup will be made read-only to all processes of the unit.
|