Home
last modified time | relevance | path

Searched refs:e (Results 1 – 25 of 34) sorted by relevance

12

/memcached-1.6.32/
Dextstore.c31 #define STAT_L(e) pthread_mutex_lock(&e->stats_mutex); argument
32 #define STAT_UL(e) pthread_mutex_unlock(&e->stats_mutex); argument
181 st->pages_used = e->page_count - e->page_free; in extstore_get_stats()
367 e->page_free = e->page_count; in extstore_init()
371 e->free_page_buckets[fb] = &e->pages[i]; in extstore_init()
380 e->stats.page_count = e->page_count; in extstore_init()
381 e->stats.page_size = e->page_size; in extstore_init()
410 e->io_threads[i].e = e; in extstore_init()
419 e->bg_thread->e = e; in extstore_init()
469 assert(!e->page_buckets[bucket] || e->page_buckets[bucket]->allocated == e->page_size); in _allocate_page()
[all …]
Dlogger.c229 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ise()
245 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ige()
258 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ee()
280 (int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ide()
294 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_extw()
313 (long long int) e->tv.tv_sec, (int) e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_cne()
331 (long long int) e->tv.tv_sec, (int) e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_cce()
400 (long long int) e->tv.tv_sec, (int) e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_prx_req()
472 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_prx_errbe()
478 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_prx_errbe()
[all …]
Dauthfile.c120 auth_t *e = &main_auth_entries[x]; in authfile_check() local
121 if (ulen == e->ulen && plen == e->plen && in authfile_check()
122 safe_memcmp(user, e->user, e->ulen) && in authfile_check()
123 safe_memcmp(pass, e->pass, e->plen)) { in authfile_check()
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
Dstorage.h4 void storage_delete(void *e, item *it);
6 #define STORAGE_delete(e, it) \ argument
8 storage_delete(e, it); \
17 bool storage_validate_item(void *e, item *it);
Dproxy_config.c166 struct proxy_user_stats_entry *e = &entries[x]; in proxy_config_stats_prep() local
168 if (e->name) { in proxy_config_stats_prep()
170 if (e->name[0]) { in proxy_config_stats_prep()
171 newname = e->name; in proxy_config_stats_prep()
173 } else if (e->cname) { in proxy_config_stats_prep()
175 newname = oldnamebuf + e->cname; in proxy_config_stats_prep()
180 e->cname = p - namebuf; in proxy_config_stats_prep()
189 e->cname = 0; in proxy_config_stats_prep()
192 if (e->name) { in proxy_config_stats_prep()
194 free(e->name); in proxy_config_stats_prep()
[all …]
Dproxy_lua.c263 pthread_mutex_lock(&e->mutex); in mcplib_backend_wrap_gc()
265 pthread_mutex_unlock(&e->mutex); in mcplib_backend_wrap_gc()
276 if (write(e->be_notify_send_fd, "w", 1) <= 0) { in mcplib_backend_wrap_gc()
521 proxy_event_thread_t *e) { in _mcplib_make_backendconn() argument
588 bec->event_thread = e; in _mcplib_make_backendconn()
590 pthread_mutex_lock(&e->mutex); in _mcplib_make_backendconn()
592 pthread_mutex_unlock(&e->mutex); in _mcplib_make_backendconn()
603 if (write(e->be_notify_send_fd, "w", 1) <= 0) { in _mcplib_make_backendconn()
1543 char *e = NULL; in proxy_register_startarg() local
1544 char *name = strtok_r(p, "_", &e); in proxy_register_startarg()
[all …]
Dproxy_inspector.c506 const struct mcp_ins_entry *e = &mcp_ins_entries[x]; in mcp_inspector_steptype() local
507 if (e->s && strcmp(type, e->s) == 0) { in mcp_inspector_steptype()
532 const struct mcp_ins_entry *e = &mcp_ins_entries[st]; in mcp_inspector_new() local
533 if (!(e->t & type)) { in mcp_inspector_new()
536 if ((st == mcp_ins_step_none) || e->c == NULL) { in mcp_inspector_new()
539 size += e->c(L, x); in mcp_inspector_new()
Dproxy_mutator.c829 const char *e = itoa_u64(run->vlen, temp); in mut_step_n() local
831 return e - temp; in mut_step_n()
862 const struct mcp_mut_entry *e = &mcp_mut_entries[x]; in mcp_mutator_steptype() local
863 if (e->s && strcmp(type, e->s) == 0) { in mcp_mutator_steptype()
880 const struct mcp_mut_entry *e = &mcp_mut_entries[st]; in mcp_mutator_new() local
881 if (!(e->t & type)) { in mcp_mutator_new()
884 if ((st == mcp_mut_step_none) || e->c == NULL) { in mcp_mutator_new()
887 size += e->c(L, x); in mcp_mutator_new()
Dlogger.h62 typedef void (*entry_log_cb)(logentry *e, const entry_details *d, const void *entry, va_list ap);
63 typedef int (*entry_parse_cb)(logentry *e, char *scratch);
Dproxy_request.c69 const char *e = pr->request + pr->tokens[token+1]; in _process_token_len() local
71 while (*(e-1) == ' ') { in _process_token_len()
72 e--; in _process_token_len()
74 return e - s; in _process_token_len()
1113 const char *e = p + reresp.rlen; in mcplib_request_match_res() local
1122 while (p != e) { in mcplib_request_match_res()
1145 while (p != e && !isspace(*p)) { in mcplib_request_match_res()
1160 while (p != e && *p != ' ') { in mcplib_request_match_res()
Dproto_proxy.c218 char *e = NULL; // ptr into vbuf in process_proxy_stats() local
237 e = itoa_u64(counters[x], vbuf); in process_proxy_stats()
238 *(e+1) = '\0'; in process_proxy_stats()
239 add_stats(key_str, pfxlen+nlen, vbuf, e-vbuf, c); in process_proxy_stats()
484 proxy_event_thread_t *e = ((proxy_ctx_t *)q->ctx)->proxy_io_thread; in proxy_submit_cb() local
547 pthread_mutex_lock(&e->mutex); in proxy_submit_cb()
548 if (STAILQ_EMPTY(&e->io_head_in)) { in proxy_submit_cb()
551 STAILQ_CONCAT(&e->io_head_in, &head); in proxy_submit_cb()
553 pthread_mutex_unlock(&e->mutex); in proxy_submit_cb()
561 if (write(e->event_fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) { in proxy_submit_cb()
[all …]
Dextstore.h72 typedef void (*obj_io_cb)(void *e, obj_io *io, int ret);
Dproto_text.c291 char *s, *e; in tokenize_command() local
297 s = e = command; in tokenize_command()
299 if (*e == ' ') { in tokenize_command()
300 if (s != e) { in tokenize_command()
304 *e = '\0'; in tokenize_command()
306 e++; in tokenize_command()
311 s = e + 1; in tokenize_command()
313 e++; in tokenize_command()
316 if (s != e) { in tokenize_command()
318 tokens[ntokens].length = e - s; in tokenize_command()
[all …]
Dmemcached.spec.in101 …sed -e 's/^##safer##//g' -i %{buildroot}%{_unitdir}/%{name}.service %{buildroot}%{_unitdir}/%{name…
103 …sed -e 's/^##safer##/#/g' -i %{buildroot}%{_unitdir}/%{name}.service %{buildroot}%{_unitdir}/%{nam…
Dstorage.c54 bool storage_validate_item(void *e, item *it) { in storage_validate_item() argument
56 if (extstore_check(e, hdr->page_id, hdr->page_version) != 0) { in storage_validate_item()
63 void storage_delete(void *e, item *it) { in storage_delete() argument
66 extstore_delete(e, hdr->page_id, hdr->page_version, in storage_delete()
144 static void _storage_get_item_cb(void *e, obj_io *io, int ret) { in _storage_get_item_cb() argument
1041 static void _storage_compact_cb(void *e, obj_io *io, int ret) { in _storage_compact_cb() argument
Dmemcached.c3729 if (e == NULL) {
3735 *e = '\0';
3736 size_t len = e - st;
3737 p = ++e; // skip ']'
3771 if (e == NULL) {
3774 if (e == NULL) {
3780 *e = '\0';
3781 size_t len = e - st;
3782 p = ++e; // skip ']'
3803 if (e == NULL) {
[all …]
Dproxy_internal.c86 static void _storage_get_item_cb(void *e, obj_io *eio, int ret) { in _storage_get_item_cb() argument
549 const char *e = pr->request + pr->tokens[token+1]; in _process_token_len() local
551 while (*(e-1) == ' ') { in _process_token_len()
552 e--; in _process_token_len()
554 return e - s; in _process_token_len()
/memcached-1.6.32/t/
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:
19 4f:3a:fb:0e:ac:c1:0e:6e:76:db:b5:95:83:d4:a2:
20 86:eb:78:63:c5:d3:47:97:d9:6e:0f:39:ee:cd:51:
22 69:31:2e:83:49:88:42:71:7d:25:aa:f1:63:5e:93:
28 20:48:3b:e5:ab:e7:8e:41:6e:9f:f1:3d:34:f6:1a:
30 1e:90:43:40:b1:df:86:cc:dd:1e:35:4f:95:9c:28:
41 6a:cc:38:8b:ee:67:f4:43:7a:63:7e:b7:84:64:23:de:98:eb:
43 db:77:34:1c:8e:b5:fe:9a:00:9d:bf:9f:5a:1a:51:68:54:47:
48 33:2d:1e:0a:17:02:7f:e3:97:10:75:3e:7d:77:48:a6:72:fb:
[all …]
Dserver_crt.pem16 00:c8:9f:ff:4d:a0:6e:9e:ab:6f:0f:5b:7a:67:b7:
17 2d:0b:eb:69:6b:9f:19:7a:6e:f5:b2:91:50:71:d4:
19 ea:1c:6f:6d:d3:28:52:29:04:a1:4d:28:8e:38:35:
20 98:1b:5b:f3:c7:da:41:17:83:c8:d5:32:40:7e:90:
22 dc:b0:b1:06:82:7e:0d:d3:a6:2d:50:e0:cd:6b:0b:
24 99:01:06:5e:93:77:8b:6a:c3:3f:ce:9f:e0:44:3c:
39 0f:ac:cb:a5:b2:13:63:3a:e7:f4:59:a6:ec:ad:ef:2e:61:5d:
41 e0:1e:c6:e6:10:8d:d2:de:90:54:d4:c6:a8:e9:99:7b:62:c4:
43 02:76:3f:1f:d5:3a:0b:ac:9e:b7:13:14:6f:b6:27:ad:34:d5:
45 d3:7d:b4:7e:d1:dc:3b:27:31:94:d4:0a:08:ba:67:ec:e0:75:
[all …]
Ddaemonize.t17 ok(-e $tmpfn, "pid file exists");
Dissue_67.t56 croak("memcached binary doesn't exist. Haven't run 'make' ?\n") unless -e $exe;
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c132 const char *e = line + t->tokens[token+1]; in _mcmc_token_len() local
134 while (*(e-1) == ' ') { in _mcmc_token_len()
135 e--; in _mcmc_token_len()
137 return e - s; in _mcmc_token_len()
143 const char *e = line + t->tokens[token+1]; in _mcmc_token() local
144 while (*(e-1) == ' ') { in _mcmc_token()
145 e--; in _mcmc_token()
147 *len = e - s; in _mcmc_token()
/memcached-1.6.32/scripts/
Dstart-memcached88 if(-e $pidfile)
/memcached-1.6.32/doc/
Dprotocol-binary.txt62 include Simplified BSD License text as described in Section 4.e of
527 24| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
642 28| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
756 32| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
867 24| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
1041 48| 0x74 ('t') | 0x65 ('e') | 0x72 ('r') |
1483 24| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |

12