| /memcached-1.6.32/ |
| D | xxhash.h | 2004 memset(&state, 0, sizeof(state)); in XXH32_reset()
2010 memcpy(statePtr, &state, sizeof(state) - sizeof(state.reserved)); in XXH32_reset()
2039 XXH_memcpy((xxh_u8*)(state->mem32) + state->memsize, input, 16-state->memsize); in XXH32_update()
2435 memset(&state, 0, sizeof(state)); in XXH64_reset()
2441 memcpy(statePtr, &state, sizeof(state) - sizeof(state.reserved64)); in XXH64_reset()
2469 state->v1 = XXH64_round(state->v1, XXH_readLE64(state->mem64+0)); in XXH64_update()
2470 state->v2 = XXH64_round(state->v2, XXH_readLE64(state->mem64+1)); in XXH64_update()
2471 state->v3 = XXH64_round(state->v3, XXH_readLE64(state->mem64+2)); in XXH64_update()
2472 state->v4 = XXH64_round(state->v4, XXH_readLE64(state->mem64+3)); in XXH64_update()
4689 memcpy(acc, state->acc, sizeof(state->acc)); in XXH3_digest_long()
[all …]
|
| D | proxy_luafgen.c | 364 rqu->state = RQUEUE_IDLE; in _mcp_funcgen_return_rctx()
758 if (rqu->state != RQUEUE_IDLE) { in _mcplib_rcontext_queue()
777 rqu->state = RQUEUE_QUEUED; in _mcplib_rcontext_queue()
883 rqu->state = RQUEUE_COMPLETE; in mcp_start_subrctx()
979 assert(rqu->state == RQUEUE_COMPLETE); in mcp_process_rctx_wait()
1005 rqu->state = RQUEUE_WAITED; in mcp_process_rctx_wait()
1061 assert(rqu->state == RQUEUE_ACTIVE); in mcp_process_rqueue_return()
1062 rqu->state = RQUEUE_COMPLETE; in mcp_process_rqueue_return()
1132 if (rqu->state == RQUEUE_QUEUED) { in mcp_run_rcontext_handle()
1133 rqu->state = RQUEUE_ACTIVE; in mcp_run_rcontext_handle()
[all …]
|
| D | proxy_network.c | 100 be->state = mcp_backend_read; in _proxy_beconn_checkconnect()
469 be->state = mcp_backend_read; in _drive_machine_next()
496 switch(be->state) { in proxy_backend_drive_machine()
500 be->state = mcp_backend_parse; in proxy_backend_drive_machine()
515 be->state = mcp_backend_next; in proxy_backend_drive_machine()
522 be->state = mcp_backend_read_end; in proxy_backend_drive_machine()
535 be->state = mcp_backend_next; in proxy_backend_drive_machine()
606 be->state = mcp_backend_want_read; in proxy_backend_drive_machine()
657 be->state = mcp_backend_next; in proxy_backend_drive_machine()
677 be->state = mcp_backend_next; in proxy_backend_drive_machine()
[all …]
|
| D | proxy_request.c | 22 int state = 0; in _process_tokenize() local
24 switch (state) { in _process_tokenize()
31 state = 2; in _process_tokenize()
34 state = 1; in _process_tokenize()
43 state = 0; in _process_tokenize()
133 int state = 0; in _process_request_metaflags() local
135 switch (state) { in _process_request_metaflags()
145 state = 1; in _process_request_metaflags()
152 state = 0; in _process_request_metaflags()
|
| D | proto_proxy.h | 27 int proxy_register_libs(void *ctx, LIBEVENT_THREAD *t, void *state);
|
| D | memcached.c | 326 if (c->state != conn_new_cmd && c->state != conn_read) in conn_timeout_thread()
503 if (c->state != conn_new_cmd && c->state != conn_read) { in conn_close_idle()
546 switch (c->state) { in conn_worker_readd()
726 c->state = init_state; in conn_new()
960 return statenames[state]; in state_text()
970 assert(state >= conn_listening && state < conn_max_state); in conn_set_state()
972 if (state != c->state) { in conn_set_state()
976 state_text(state)); in conn_set_state()
979 if (state == conn_write || state == conn_mwrite) { in conn_set_state()
982 c->state = state; in conn_set_state()
[all …]
|
| D | proxy_lua.c | 547 bec->state = mcp_backend_read; in _mcplib_make_backendconn()
990 int state = lua_toboolean(L, -1); in mcplib_backend_use_iothread() local
994 ctx->tunables.use_iothread = state; in mcplib_backend_use_iothread()
1002 int state = lua_toboolean(L, -1); in mcplib_backend_use_tls() local
1005 if (state == 1) { in mcplib_backend_use_tls()
1010 ctx->tunables.use_tls = state; in mcplib_backend_use_tls()
1030 int state = lua_toboolean(L, -1); in mcplib_tcp_keepalive() local
1034 ctx->tunables.tcp_keepalive = state; in mcplib_tcp_keepalive()
1560 int proxy_register_libs(void *ctx, LIBEVENT_THREAD *t, void *state) { in proxy_register_libs() argument
1561 lua_State *L = state; in proxy_register_libs()
|
| D | proxy.h | 418 enum mcp_backend_states state; // readback state machine member
728 enum mcp_rqueue_state state; // queued/active/etc member
|
| D | memcached.h | 841 enum conn_states state; member
1062 void conn_set_state(conn *c, enum conn_states state);
|
| D | thread.c | 856 c->state = conn_closing; in sidethread_conn_close()
|
| D | proto_proxy.c | 1641 …i, bec->bad, bec->failed_count, bec->depth, bec->state, bec->can_write, event_pending(&bec->timeou… in dump_pool_info()
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.c | 78 int state = 0; in _mcmc_tokenize_meta() local
80 switch (state) { in _mcmc_tokenize_meta()
94 state = 2; in _mcmc_tokenize_meta()
97 state = 1; in _mcmc_tokenize_meta()
106 state = 0; in _mcmc_tokenize_meta()
|
| /memcached-1.6.32/doc/ |
| D | tls.txt | 70 Memcached uses non blocking sockets and implements a rather complex state machine for
117 for both TLS and non-TLS connections. When the socket is ready, the state machine kicks off
121 library to do it on our behalf. Existing state machine takes care of reading the correct amount
|
| D | protocol.txt | 1733 | state | The current state of the connection. See below. |
1737 | | "state" indicates a command is currently executing, |
1742 The value of the "state" stat may be one of the following:
|