| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.h | 140 int mcmc_tokenize_res(const char *l, size_t len, mcmc_tokenizer_t *t);
142 const char *mcmc_token_get(const char *l, mcmc_tokenizer_t *t, int idx, int *len);
143 int mcmc_token_get_u32(const char *l, mcmc_tokenizer_t *t, int idx, uint32_t *val);
144 int mcmc_token_get_u64(const char *l, mcmc_tokenizer_t *t, int idx, uint64_t *val);
145 int mcmc_token_get_32(const char *l, mcmc_tokenizer_t *t, int idx, int32_t *val);
146 int mcmc_token_get_64(const char *l, mcmc_tokenizer_t *t, int idx, int64_t *val);
147 int mcmc_token_has_flag(const char *l, mcmc_tokenizer_t *t, char flag);
149 const char *mcmc_token_get_flag(const char *l, mcmc_tokenizer_t *t, char flag, int *len);
152 int mcmc_token_get_flag_32(const char *l, mcmc_tokenizer_t *t, char flag, int32_t *val);
153 int mcmc_token_get_flag_64(const char *l, mcmc_tokenizer_t *t, char flag, int64_t *val);
[all …]
|
| D | mcmc.c | 155 size_t l = r->reslen; in _mcmc_parse_value_line() local
160 p = memchr(p, ' ', l - 6); in _mcmc_parse_value_line()
218 size_t l = r->reslen; in _mcmc_parse_stat_line() local
222 p = memchr(p, ' ', l-5); in _mcmc_parse_stat_line()
232 int statlen = l - (p - buf) - 2; in _mcmc_parse_stat_line()
622 return _mcmc_token(l, t, idx, len); in mcmc_token_get()
664 const char *tflag = l + t->tokens[x]; in mcmc_token_get_flag()
684 const char *tok = mcmc_token_get_flag(l, t, flag, &tlen); in mcmc_token_get_flag_u32()
724 const char *tflag = l + t->tokens[x]; in mcmc_token_get_flag_idx()
897 int l = len - ctx->sent_bytes_partial; in mcmc_send_request() local
[all …]
|
| /memcached-1.6.32/ |
| D | logger.c | 587 l->prev = 0; in logger_link_q()
589 if (l->next) l->next->prev = l; in logger_link_q()
633 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_set_flags()
758 l->written = 0; in logger_thread_read()
759 l->dropped = 0; in logger_thread_read()
896 logger *l; in logger_thread() local
911 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_thread()
997 if (l == NULL) { in logger_create()
1003 free(l); in logger_create()
1014 return l; in logger_create()
[all …]
|
| D | util.c | 123 unsigned long l = 0; in safe_strtoul() local
129 l = strtoul(str, &endptr, 10); in safe_strtoul()
135 if ((long) l < 0) { in safe_strtoul()
143 *out = l; in safe_strtoul()
155 long l = strtol(str, &endptr, 10); in safe_strtol() local
161 *out = l; in safe_strtol()
|
| D | logger.h | 231 #define LOGGER_LOG(l, flag, type, ...) \ argument
233 logger *myl = l; \
234 if (l == NULL) \
240 enum logger_ret_type logger_log(logger *l, const enum log_entry_type event, const void *entry, ...);
|
| D | storage.c | 598 logger *l = logger_create(); in storage_write_thread() local
599 if (l == NULL) { in storage_write_thread()
768 static int storage_compact_check(void *storage, logger *l, in storage_compact_check() argument
787 LOGGER_LOG(l, LOG_SYSEVENTS, LOGGER_COMPACT_FRAGINFO, in storage_compact_check()
902 static void storage_compact_readback(void *storage, logger *l, in storage_compact_readback() argument
1035 LOGGER_LOG(l, LOG_SYSEVENTS, LOGGER_COMPACT_READ_END, in storage_compact_readback()
1068 logger *l = logger_create(); in storage_compact_thread() local
1069 if (l == NULL) { in storage_compact_thread()
1093 if (!compacting && storage_compact_check(storage, l, in storage_compact_thread()
1097 LOGGER_LOG(l, LOG_SYSEVENTS, LOGGER_COMPACT_START, in storage_compact_thread()
[all …]
|
| D | tls.c | 177 LOGGER_LOG(c->thread->l, LOG_CONNEVENTS, LOGGER_CONNECTION_TLSERROR, in ssl_read()
184 LOGGER_LOG(c->thread->l, LOG_CONNEVENTS, LOGGER_CONNECTION_TLSERROR, in ssl_read()
213 LOGGER_LOG(c->thread->l, LOG_CONNEVENTS, LOGGER_CONNECTION_TLSERROR, in ssl_write()
220 LOGGER_LOG(c->thread->l, LOG_CONNEVENTS, LOGGER_CONNECTION_TLSERROR, in ssl_write()
|
| D | proxy_lua.c | 1358 LOGGER_LOG(t->l, LOG_PROXYUSER, LOGGER_PROXY_USER, NULL, msg); in mcplib_log()
1365 logger *l = t->l; in mcplib_log_req() local
1368 if (! (l->eflags & LOG_PROXYREQS)) { in mcplib_log_req()
1393 …logger_log(l, LOGGER_PROXY_REQ, NULL, rq->pr.request, rq->pr.reqlen, elapsed, rtype, rcode, rstatu… in mcplib_log_req()
1424 logger *l = t->l; in mcplib_log_reqsample() local
1427 if (! (l->eflags & LOG_PROXYREQS)) { in mcplib_log_reqsample()
1470 …logger_log(l, LOGGER_PROXY_REQ, NULL, rq->pr.request, rq->pr.reqlen, elapsed, rtype, rcode, rstatu… in mcplib_log_reqsample()
1485 #define Y(x, l) \ in proxy_register_defines() argument
1487 lua_setfield(L, -2, l); in proxy_register_defines()
|
| D | items.c | 1056 LOGGER_LOG(t->l, LOG_FETCHERS, LOGGER_ITEM_GET, NULL, was_found, key, in do_item_get()
1476 static void lru_maintainer_crawler_check(struct crawler_expired_data *cdata, logger *l) { in lru_maintainer_crawler_check() argument
1537 LOGGER_LOG(l, LOG_SYSEVENTS, LOGGER_CRAWLER_STATUS, NULL, in lru_maintainer_crawler_check()
1609 logger *l = logger_create(); in lru_maintainer_thread() local
1610 if (l == NULL) { in lru_maintainer_thread()
1672 lru_maintainer_crawler_check(cdata, l); in lru_maintainer_thread()
1686 LOGGER_LOG(l, LOG_SYSEVENTS, LOGGER_SLAB_MOVE, NULL, in lru_maintainer_thread()
|
| D | thread.c | 513 me->l = logger_create(); in worker_libevent()
515 if (me->l == NULL || me->lru_bump_buf == NULL) { in worker_libevent()
|
| D | proto_proxy.c | 933 size_t l = rlen > WRITE_BUFFER_SIZE ? WRITE_BUFFER_SIZE : rlen; in proxy_run_rcontext() local
934 memcpy(resp->wbuf, s, l); in proxy_run_rcontext()
935 resp_add_iov(resp, resp->wbuf, l); in proxy_run_rcontext()
|
| D | testapp.c | 1610 size_t l = ext_command(temp.bytes, sizeof(temp.bytes), cmd, in test_binary_get_impl() local
1613 memcpy(send.bytes + len, temp.bytes, l); in test_binary_get_impl()
1614 len += l; in test_binary_get_impl()
|
| D | memcached.h | 736 logger *l; /* logger buffer */ member
|
| D | proto_text.c | 1555 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_mset_command()
2059 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_update_command()
|
| D | proto_bin.c | 1134 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_bin_update()
|
| D | memcached.c | 892 LOGGER_LOG(c->thread->l, LOG_CONNEVENTS, LOGGER_CONNECTION_CLOSE, NULL, in conn_close()
1732 LOGGER_LOG(t->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, NULL, in do_store_item()
|
| D | Doxyfile | 501 # doxygen's defaults, run doxygen with the -l option. You can optionally specify a
|
| /memcached-1.6.32/t/lib/ |
| D | MemcachedTest.pm | 650 my @l = ();
655 @l = @{$self->{_be}};
664 return \@l;
675 my $l = $self->_be_list($list);
678 for my $be (@$l) {
691 my $l = $self->_be_list($list);
692 for my $be (@$l) {
704 my $l = $self->_be_list($list);
705 for my $be (@$l) {
718 my $l = $self->_be_list($list);
[all …]
|
| /memcached-1.6.32/t/ |
| D | proxyustats.lua | 10 local pfx, f, l = string.match(config, "(%S+)%s*(%S+)%s*(%S+)")
19 local last = tonumber(l)
|
| D | startfile.lua | 231 local l = list
240 route = l[match]
253 local l = list
257 local route = l[string.match(r:key(), p)]
|
| /memcached-1.6.32/doc/ |
| D | protocol-binary.txt | 527 24| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
586 28| 0x57 ('W') | 0x6f ('o') | 0x72 ('r') | 0x6c ('l') |
642 28| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
646 36| 0x6c ('l') | 0x64 ('d') |
756 32| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
760 40| 0x6c ('l') | 0x64 ('d') |
867 24| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
1483 24| 0x48 ('H') | 0x65 ('e') | 0x6c ('l') | 0x6c ('l') |
|
| D | protocol.txt | 548 - l: return time since item was last accessed in seconds
579 - l: return time since item was last accessed in seconds
|
| /memcached-1.6.32/scripts/ |
| D | memcached.service | 9 # Environment=OPTIONS="-l 127.0.0.1,::1"
|
| D | [email protected] | 9 # Environment=OPTIONS="-l 127.0.0.1,::1"
|