Home
last modified time | relevance | path

Searched refs:c (Results 1 – 25 of 72) sorted by relevance

123

/memcached-1.6.32/
Dproto_bin.c51 if (c->rbytes < sizeof(c->binary_header)) { in try_read_command_binary()
55 memcpy(&c->binary_header, c->rcurr, sizeof(c->binary_header)); in try_read_command_binary()
99 c->cmd = c->binary_header.request.opcode; in try_read_command_binary()
100 c->keylen = c->binary_header.request.keylen; in try_read_command_binary()
101 c->opaque = c->binary_header.request.opaque; in try_read_command_binary()
114 memcpy(extbuf + sizeof(c->binary_header), c->rcurr + sizeof(c->binary_header), in try_read_command_binary()
129 return c->rcurr - (c->binary_header.request.keylen); in binary_get_key()
136 assert(c); in add_bin_header()
654 write_and_free(c, c->stats.buffer, c->stats.offset); in process_bin_stat()
669 write_and_free(c, c->stats.buffer, c->stats.offset); in process_bin_stat()
[all …]
Dproto_text.c182 …ret = store_item(it, comm, c->thread, &nbytes, &cas, c->cas ? c->cas : get_cas_id(), c->set_stale); in complete_nread_ascii()
368 c->rcurr += (el - c->rcurr) + 1; in try_read_command_asciiauth()
391 if (c->rbytes < c->rlbytes) { in try_read_command_asciiauth()
406 c->rbytes -= c->rlbytes; in try_read_command_asciiauth()
407 c->rcurr += c->rlbytes; in try_read_command_asciiauth()
492 process_command_ascii(c, c->rcurr); in try_read_command_ascii()
494 c->rbytes -= (cont - c->rcurr); in try_read_command_ascii()
497 assert(c->rcurr <= (c->rbuf + c->rsize)); in try_read_command_ascii()
817 write_and_free(c, c->stats.buffer, c->stats.offset); in process_stat()
832 write_and_free(c, c->stats.buffer, c->stats.offset); in process_stat()
[all …]
Djenkins_hash.c81 a -= c; a ^= rot(c, 4); c += b; \
83 c -= b; c ^= rot(b, 8); b += a; \
84 a -= c; a ^= rot(c,16); c += b; \
86 c -= b; c ^= rot(b, 4); b += a; \
116 c ^= b; c -= rot(b,14); \
117 a ^= c; a -= rot(c,11); \
119 c ^= b; c -= rot(b,16); \
120 a ^= c; a -= rot(c,4); \
122 c ^= b; c -= rot(b,24); \
148 c += k[2]; in jenkins_hash()
[all …]
Dmemcached.c416 c->rcurr = c->rbuf; in rbuf_alloc()
526 event_set(&c->event, c->sfd, c->ev_flags, event_handler, (void *)c); in _conn_event_readd()
730 c->rcurr = c->rbuf; in conn_new()
2381 assert(c->rcurr <= (c->rbuf + c->rsize));
2403 assert(c->rcurr <= (c->rbuf + c->rsize));
2424 res = recvfrom(c->sfd, c->rbuf, c->rsize,
2501 res = c->read(c, c->rbuf + c->rbytes, avail);
2945 int tocopy = c->rbytes > c->rlbytes ? c->rlbytes : c->rbytes;
3203 res = c->read(c, c->ritem, c->rlbytes);
3271 int tocopy = c->rbytes > c->sbytes ? c->sbytes : c->rbytes;
[all …]
DMakefile.am7 testapp_SOURCES = testapp.c util.c util.h stats_prefix.c stats_prefix.h jenkins_hash.c murmur3_hash…
19 thread.c daemon.c \
61 proxy_ustats.c \
62 proxy_ratelim.c \
63 proxy_jump_hash.c proxy_request.c \
64 proxy_result.c proxy_inspector.c \
65 proxy_mutator.c \
66 proxy_network.c proxy_lua.c \
67 proxy_luafgen.c \
68 proxy_config.c proxy_ring_hash.c \
[all …]
Dmd5.c204 t = a + F(b,c,d) + X[k] + Ti;\ in md5_process()
207 SET(a, b, c, d, 0, 7, T1); in md5_process()
208 SET(d, a, b, c, 1, 12, T2); in md5_process()
209 SET(c, d, a, b, 2, 17, T3); in md5_process()
210 SET(b, c, d, a, 3, 22, T4); in md5_process()
211 SET(a, b, c, d, 4, 7, T5); in md5_process()
212 SET(d, a, b, c, 5, 12, T6); in md5_process()
230 t = a + G(b,c,d) + X[k] + Ti;\ in md5_process()
256 t = a + H(b,c,d) + X[k] + Ti;\ in md5_process()
282 t = a + I(b,c,d) + X[k] + Ti;\ in md5_process()
[all …]
Dcrawler.c133 sidethread_conn_close(c->c); in lru_crawler_close_client()
134 c->c = NULL; in lru_crawler_close_client()
141 redispatch_conn(c->c); in lru_crawler_release_client()
142 c->c = NULL; in lru_crawler_release_client()
149 char *nb = realloc(c->buf, c->buflen); in lru_crawler_expand_buf()
304 if (cm->c.c != NULL) { in crawler_metadump_finalize()
356 if (cm->c.c != NULL) { in crawler_mgdump_finalize()
381 if (c->c == NULL) return -1; in lru_crawler_write()
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()
[all …]
Dproxy_inspector.c57 } c; member
97 struct mcp_ins_flag *c = &s->c.flag; in mcp_inspector_flag_i_g() local
102 c->bit = (uint64_t)1 << (c->f - 65); in mcp_inspector_flag_i_g()
127 struct mcp_ins_string *c = &s->c.string; in mcp_inspector_string_i_g() local
172 struct mcp_ins_sepkey *c = &s->c.sepkey; in mcp_inspector_sepkey_i() local
204 struct mcp_ins_sepkey *c = &s->c.sepkey; in mcp_inspector_sepkey_r() local
268 struct mcp_ins_string *c = &s->c.string; in mcp_inspector_keybegin_r() local
285 struct mcp_ins_string *c = &s->c.string; in mcp_inspector_keyis_r() local
301 struct mcp_ins_flag *c = &s->c.flag; in mcp_inspector_hasflag_r() local
331 struct mcp_ins_flag *c = &s->c.flag; in mcp_inspector_flagtoken_r() local
[all …]
Dtls.c42 if (c->ssl_enabled) { in ssl_accept()
126 if (!c->ssl) { in ssl_get_peer_cn()
162 assert (c != NULL); in ssl_read()
201 assert (c != NULL); in ssl_write()
235 assert (c != NULL); in ssl_sendmsg()
242 assert(c->ssl_wbuf); in ssl_sendmsg()
251 char *bp = c->ssl_wbuf; in ssl_sendmsg()
265 return ssl_write(c, c->ssl_wbuf, bytes); in ssl_sendmsg()
366 c->ssl = (SSL*)ssl; in ssl_init_conn()
367 c->read = ssl_read; in ssl_init_conn()
[all …]
Dproxy_mutator.c102 } c; member
193 c->bit = (uint64_t)1 << (c->f - 65); in _mut_init_flag()
226 struct mcp_mut_string *c = &s->c.string; in mut_step_i() local
243 struct mcp_mut_string *c = &s->c.string; in mut_step_n() local
249 struct mcp_mut_string *c = &s->c.string; in mut_step_r() local
353 struct mcp_mut_string *c = &s->c.string; in mut_step_i() local
371 struct mcp_mut_string *c = &s->c.string; in mut_step_n() local
377 struct mcp_mut_string *c = &s->c.string; in mut_step_r() local
644 struct mcp_mut_flag *c = &s->c.flag; in mut_step_i() local
660 struct mcp_mut_flag *c = &s->c.flag; in mut_step_n() local
[all …]
Dproto_proxy.c602 conn *c = p->c; in proxy_return_rctx_cb() local
642 el = memchr(c->rcurr, '\n', c->rbytes); in try_read_command_proxy()
676 assert(cont <= (c->rcurr + c->rbytes)); in try_read_command_proxy()
679 proxy_process_command(c, c->rcurr, cont - c->rcurr, PROCESS_NORMAL); in try_read_command_proxy()
681 c->rbytes -= (cont - c->rcurr); in try_read_command_proxy()
684 assert(c->rcurr <= (c->rbuf + c->rsize)); in try_read_command_proxy()
1126 resp_add_iov(c->resp, c->resp->wbuf, ENDLEN); in proxy_process_command()
1182 rctx->c = c; in proxy_process_command()
1217 c->ritem = c->item; in proxy_process_command()
1307 conn *c = rctx->c; in mcp_queue_rctx_io() local
[all …]
Dproto_proxy.h4 void proxy_stats(void *arg, ADD_STAT add_stats, void *c);
5 void process_proxy_stats(void *arg, ADD_STAT add_stats, void *c);
6 void process_proxy_funcstats(void *arg, ADD_STAT add_stats, void *c);
7 void process_proxy_bestats(void *arg, ADD_STAT add_stats, void *c);
10 int try_read_command_proxy(conn *c);
11 void complete_nread_proxy(conn *c);
12 void proxy_cleanup_conn(conn *c);
Dtls.h10 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);
23 #define ssl_init_conn(c, ssl) argument
26 #define ssl_accept(c, sfd, fail) NULL argument
Dsasl_defs.h20 #define sasl_server_new(a, b, c, d, e, f, g, h) 1 argument
21 #define sasl_listmech(a, b, c, d, e, f, g, h) 1 argument
22 #define sasl_server_start(a, b, c, d, e, f) 1 argument
23 #define sasl_server_step(a, b, c, d, e) 1 argument
24 #define sasl_getprop(a, b, c) {} argument
Dproto_text.h5 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);
Dmemcached.h815 conn *c; member
957 void conn_io_queue_setup(conn *c);
964 void conn_worker_readd(conn *c);
986 void redispatch_conn(conn *c);
987 void timeout_conn(conn *c);
994 void sidethread_conn_close(conn *c);
1002 void conn_close_idle(conn *c);
1055 bool resp_start(conn *c);
1059 bool resp_has_stack(conn *c);
1060 bool rbuf_switch_to_malloc(conn *c);
[all …]
Dproto_bin.h5 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,
Dstorage.c34 conn *c; member
148 conn *c = p->c; in _storage_get_item_cb() local
189 if (c->protocol == binary_prot) { in _storage_get_item_cb()
283 p->noreply = c->noreply; in storage_get_item()
284 p->thread = c->thread; in storage_get_item()
348 p->c = c; in storage_get_item()
378 c->thread->stats.get_extstore++; in storage_get_item()
397 conn *c = p->c; in recache_or_free() local
401 assert(c != NULL); in recache_or_free()
423 c->thread->stats.miss_from_extstore++; in recache_or_free()
[all …]
Dstorage.h15 void storage_stats(ADD_STAT add_stats, void *c);
16 void process_extstore_stats(ADD_STAT add_stats, void *c);
18 int storage_get_item(conn *c, item *it, mc_resp *resp);
/memcached-1.6.32/t/
Dserver_crt.pem18 b4:42:84:b9:e0:8c:98:61:89:2d:90:c2:0d:68:d4:
19 ea:1c:6f:6d:d3:28:52:29:04:a1:4d:28:8e:38:35:
21 bc:69:88:29:96:93:b4:d1:45:65:ac:7c:88:4c:54:
23 c3:74:c4:96:8c:af:87:34:d7:3b:d7:33:60:e3:16:
24 99:01:06:5e:93:77:8b:6a:c3:3f:ce:9f:e0:44:3c:
25 bc:b6:bc:e8:65:b3:72:94:ee:e4:99:6c:5f:a9:43:
26 e4:0a:8d:13:38:48:dd:08:9c:51:6d:d6:d3:6b:dc:
44 fa:82:5c:c6:1a:b4:4f:36:7b:e6:03:6d:4f:85:ce:43:42:d3:
48 5b:5a:d9:2a:0c:d5:96:61:9e:dd:b5:db:88:61:45:df:29:c1:
49 de:34:e6:fa:25:23:2c:4e:71:c9:ba:d1:53:f9:38:28:6b:5a:
[all …]
Dclient_crt.pem17 b3:76:60:7f:bb:5e:38:e9:25:e4:70:8c:99:63:ad:
18 76:26:b8:06:65:f5:0e:b6:6f:22:66:b7:4b:7a:8c:
21 b6:af:cd:01:2c:a0:c0:bb:58:eb:23:6a:aa:09:e3:
23 a5:44:19:47:b2:3b:1c:7a:f1:f2:24:75:51:6f:13:
24 7e:9a:24:2c:42:e3:23:31:b6:dd:fa:50:36:92:ef:
25 c3:c2:40:fe:45:b9:80:79:d9:64:62:02:f4:de:8c:
32 4f:38:da:f0:3d:68:3c:40:e7:db:fd:7a:79:89:4c:
43 db:77:34:1c:8e:b5:fe:9a:00:9d:bf:9f:5a:1a:51:68:54:47:
44 ef:0c:fb:cd:7f:08:81:01:bd:6e:6a:05:27:1d:66:38:75:7b:
49 5d:d7:68:78:1e:5c:ca:5a:8d:6f:48:f0:ea:92:e3:25:85:9f:
[all …]
Dproxyfuncgen.lua70 o.c = o.c + 1
157 local count = arg.c
173 local count = arg.c
208 local count = arg.c
230 local count = arg.c
280 local count = arg.c
309 o.c = o.c + 1
320 local count = arg.c
390 local count = arg.c
421 local count = arg.c
[all …]
/memcached-1.6.32/vendor/mcmc/
Dexample.c16 static void show_response_buffer(void *c, char *rbuf, size_t bufsize) { in show_response_buffer() argument
22 int bread = recv(mcmc_fd(c), rbuf, bufsize, 0); in show_response_buffer()
47 int read = recv(mcmc_fd(c), buf, toread, 0); in show_response_buffer()
146 void *c = malloc(mcmc_size(MCMC_OPTION_BLANK)); in buffer_mode() local
150 int status = mcmc_connect(c, "127.0.0.1", "11211", MCMC_OPTION_BLANK); in buffer_mode()
159 status = mcmc_send_request(c, requests[x], strlen(requests[x]), 1); in buffer_mode()
167 show_response_buffer(c, rbuf, bufsize); in buffer_mode()
Dmcmc.h122 int mcmc_fd(void *c);
126 int mcmc_connect(void *c, char *host, char *port, int options);
127 int mcmc_check_nonblock_connect(void *c, int *err);
128 int mcmc_send_request(void *c, const char *request, int len, int count);
129 int mcmc_request_writev(void *c, const struct iovec *iov, int iovcnt, ssize_t *sent, int count);
132 int mcmc_disconnect(void *c);
133 void mcmc_get_error(void *c, char *code, size_t clen, char *msg, size_t mlen);
DMakefile5 gcc -g -O2 -Wall -Werror -pedantic -o example example.c mcmc.c
6 gcc -g -O2 -Wall -Werror -pedantic -c mcmc.c

123