| /memcached-1.6.32/ |
| D | proto_text.h | 5 void complete_nread_ascii(conn *c);
6 int try_read_command_asciiauth(conn *c);
7 int try_read_command_ascii(conn *c);
8 void process_command_ascii(conn *c, char *command);
|
| D | memcached.h | 810 typedef struct conn conn; typedef
815 conn *c;
826 struct conn { struct
911 extern conn **conns;
964 void conn_worker_readd(conn *c);
986 void redispatch_conn(conn *c);
987 void timeout_conn(conn *c);
1002 void conn_close_idle(conn *c);
1055 bool resp_start(conn *c);
1059 bool resp_has_stack(conn *c);
[all …]
|
| D | proto_bin.h | 5 int try_read_command_binary(conn *c);
6 void complete_nread_binary(conn *c);
7 void write_bin_error(conn *c, protocol_binary_response_status err,
|
| D | tls.h | 10 void *ssl_accept(conn *c, int sfd, bool *fail);
11 const unsigned char *ssl_get_peer_cn(conn *c, int *len);
14 void ssl_init_conn(conn *c, void *ssl);
|
| D | proto_bin.c | 15 static void process_bin_append_prepend(conn *c);
18 static void process_bin_delete(conn *c);
20 static void process_bin_stat(conn *c);
21 static void process_bin_sasl_auth(conn *c);
23 static void complete_update_bin(conn *c);
28 void complete_nread_binary(conn *c) { in complete_nread_binary()
49 int try_read_command_binary(conn *c) { in try_read_command_binary()
128 static char* binary_get_key(conn *c) { in binary_get_key()
606 static void process_bin_stat(conn *c) { in process_bin_stat()
674 static void init_sasl_conn(conn *c) { in init_sasl_conn()
[all …]
|
| D | proto_proxy.h | 10 int try_read_command_proxy(conn *c);
11 void complete_nread_proxy(conn *c);
12 void proxy_cleanup_conn(conn *c);
|
| D | tls.c | 20 static ssize_t ssl_read(conn *c, void *buf, size_t count);
21 static ssize_t ssl_sendmsg(conn *c, struct msghdr *msg, int flags);
22 static ssize_t ssl_write(conn *c, void *buf, size_t count);
40 void *ssl_accept(conn *c, int sfd, bool *fail) { in ssl_accept()
125 const unsigned char *ssl_get_peer_cn(conn *c, int *len) { in ssl_get_peer_cn()
161 static ssize_t ssl_read(conn *c, void *buf, size_t count) { in ssl_read()
200 static ssize_t ssl_write(conn *c, void *buf, size_t count) { in ssl_write()
234 static ssize_t ssl_sendmsg(conn *c, struct msghdr *msg, int flags) { in ssl_sendmsg()
363 void ssl_init_conn(conn *c, void *ssl_in) { in ssl_init_conn()
|
| D | memcached.c | 101 static void conn_free(conn *c);
108 conn **conns;
294 conn *c; in conn_timeout_thread()
632 conn *c; in conn_new()
638 if (!(c = (conn *)calloc(1, sizeof(conn)))) { in conn_new()
870 void conn_free(conn *c) { in conn_free()
1147 bool resp_start(conn *c) { in resp_start()
1403 conn *c = (conn*)cookie; in append_stats()
2547 conn *next;
3397 conn *c;
[all …]
|
| D | proto_text.c | 52 static void _finalize_mset(conn *c, int nbytes, enum store_item_type ret, uint64_t cas) { in _finalize_mset()
132 void complete_nread_ascii(conn *c) { in complete_nread_ascii()
333 int try_read_command_asciiauth(conn *c) { in try_read_command_asciiauth()
445 int try_read_command_ascii(conn *c) { in try_read_command_ascii()
503 static inline bool set_noreply_maybe(conn *c, token_t *tokens, size_t ntokens) in set_noreply_maybe()
721 inline static void process_stats_detail(conn *c, const char *command) { in process_stats_detail()
742 static void process_stat(conn *c, token_t *tokens, const size_t ntokens) { in process_stat()
2261 static void process_misbehave_command(conn *c) { in process_misbehave_command()
2584 static void process_version_command(conn *c) { in process_version_command()
2588 static void process_quit_command(conn *c) { in process_quit_command()
[all …]
|
| D | sizes.c | 24 display("Connection", sizeof(conn)); in main()
|
| D | storage.h | 18 int storage_get_item(conn *c, item *it, mc_resp *resp);
|
| D | testapp.c | 37 struct conn { struct
43 ssize_t (*read)(struct conn *c, void *buf, size_t count); argument
49 static ssize_t tcp_read(struct conn *c, void *buf, size_t count);
52 static ssize_t ssl_read(struct conn *c, void *buf, size_t count);
56 ssize_t tcp_read(struct conn *c, void *buf, size_t count) { in tcp_read()
66 ssize_t ssl_read(struct conn *c, void *buf, size_t count) { in ssl_read()
79 static struct conn *con = NULL;
669 struct conn *c; in connect_server()
670 if (!(c = (struct conn *)calloc(1, sizeof(struct conn)))) { in connect_server()
2172 struct conn *conns[max]; in test_issue_101()
[all …]
|
| D | thread.c | 49 conn *c;
590 conn *c; in thread_libevent_process()
809 void redispatch_conn(conn *c) { in redispatch_conn()
813 void timeout_conn(conn *c) { in timeout_conn()
852 void sidethread_conn_close(conn *c) { in sidethread_conn_close()
|
| D | sasl_defs.c | 47 static int sasl_server_userdb_checkpass(sasl_conn_t *conn, in sasl_server_userdb_checkpass() argument
|
| D | proto_proxy.c | 16 static void proxy_process_command(conn *c, char *command, size_t cmdlen, bool multiget);
602 conn *c = p->c; in proxy_return_rctx_cb()
636 int try_read_command_proxy(conn *c) { in try_read_command_proxy()
692 void proxy_cleanup_conn(conn *c) { in proxy_cleanup_conn()
703 void complete_nread_proxy(conn *c) { in complete_nread_proxy()
1006 static void proxy_process_command(conn *c, char *command, size_t cmdlen, bool multiget) { in proxy_process_command()
1307 conn *c = rctx->c; in mcp_queue_rctx_io()
|
| D | storage.c | 34 conn *c;
148 conn *c = p->c; in _storage_get_item_cb()
249 int storage_get_item(conn *c, item *it, mc_resp *resp) { in storage_get_item()
397 conn *c = p->c; in recache_or_free()
|
| D | crawler.c | 398 int res = ((conn*)c->c)->read(c->c, buf, 1); in lru_crawler_write()
411 int total = ((conn*)c->c)->write(c->c, c->buf + sent, data_size - sent); in lru_crawler_write()
|
| D | proxy.h | 516 conn *c;
751 conn *c; // associated client object.
|
| D | logger.c | 830 int res = ((conn*)w->c)->read(w->c, buf, 1); in logger_thread_poll_watchers()
851 total = ((conn*)w->c)->write(w->c, data, data_size); in logger_thread_poll_watchers()
|
| D | ChangeLog | 272 use of conn *c without checking to see if c is NULL first.
|
| D | proxy_luafgen.c | 15 static inline void _mcp_queue_hack(conn *c) { in _mcp_queue_hack()
|
| /memcached-1.6.32/t/lib/ |
| D | MemcachedTest.pm | 284 my $conn;
295 if ($conn) {
296 return Memcached::Handle->new(conn => $conn,
371 my $conn = IO::Socket::UNIX->new(Peer => $filename);
373 if ($conn) {
375 conn => $conn,
393 my $conn;
404 if ($conn) {
406 conn => $conn,
484 if ($self->{conn} && ($self->{domainsocket} || getpeername($self->{conn}))) {
[all …]
|
| /memcached-1.6.32/doc/ |
| D | protocol.txt | 1518 | read_obj_mem_limit| 32u | Megabyte limit for conn. read/resp buffers. |
|