Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 23 of 23) sorted by relevance

/memcached-1.6.32/
Dproto_text.c432 c->thread->stats.auth_cmds++; in try_read_command_asciiauth()
437 c->thread->stats.auth_cmds++; in try_read_command_asciiauth()
438 c->thread->stats.auth_errors++; in try_read_command_asciiauth()
898 c->thread->stats.meta_cmds++; in process_meta_command()
1339 c->thread->stats.get_cmds++; in process_mget_command()
1351 c->thread->stats.get_cmds++; in process_mget_command()
1735 c->thread->stats.delete_misses++; in process_mdelete_command()
2123 c->thread->stats.touch_cmds++; in process_touch_command()
2131 c->thread->stats.touch_cmds++; in process_touch_command()
2132 c->thread->stats.touch_misses++; in process_touch_command()
[all …]
Dproto_bin.c492 c->thread->stats.touch_cmds++; in process_bin_get_or_touch()
495 c->thread->stats.get_cmds++; in process_bin_get_or_touch()
576 c->thread->stats.touch_cmds++; in process_bin_get_or_touch()
577 c->thread->stats.touch_misses++; in process_bin_get_or_touch()
579 c->thread->stats.get_cmds++; in process_bin_get_or_touch()
580 c->thread->stats.get_misses++; in process_bin_get_or_touch()
841 c->thread->stats.auth_cmds++; in process_bin_complete_sasl_auth()
857 c->thread->stats.auth_cmds++; in process_bin_complete_sasl_auth()
858 c->thread->stats.auth_errors++; in process_bin_complete_sasl_auth()
1276 c->thread->stats.flush_cmds++; in process_bin_flush()
[all …]
Dthread.c639 c->thread = me; in thread_libevent_process()
643 assert(c->thread && c->thread->ssl_wbuf); in thread_libevent_process()
682 pthread_setname_np(thread, name); in thread_setname()
710 LIBEVENT_THREAD *thread; in reset_threads_napi_id() local
714 thread = threads + i; in reset_threads_napi_id()
715 thread->napi_id = 0; in reset_threads_napi_id()
727 LIBEVENT_THREAD *thread; in select_thread_by_napi_id() local
743 thread = threads + i; in select_thread_by_napi_id()
776 LIBEVENT_THREAD *thread; in dispatch_conn_new() local
802 notify_worker(thread, item); in dispatch_conn_new()
[all …]
Dstorage.c33 LIBEVENT_THREAD *thread; member
284 p->thread = c->thread; in storage_get_item()
305 do_cache_free(c->thread->io_cache, p); in storage_get_item()
377 pthread_mutex_lock(&c->thread->stats.mutex); in storage_get_item()
378 c->thread->stats.get_extstore++; in storage_get_item()
379 pthread_mutex_unlock(&c->thread->stats.mutex); in storage_get_item()
413 pthread_mutex_lock(&c->thread->stats.mutex); in recache_or_free()
414 c->thread->stats.get_aborted_extstore++; in recache_or_free()
422 pthread_mutex_lock(&c->thread->stats.mutex); in recache_or_free()
423 c->thread->stats.miss_from_extstore++; in recache_or_free()
[all …]
Dmemcached.c891 if (c->thread) { in conn_close()
906 if (c->thread) { in conn_close()
1038 LIBEVENT_THREAD *th = c->thread; in resp_allocate()
1085 b->thread = th; in resp_allocate()
1150 THR_STATS_LOCK(c->thread); in resp_start()
1157 THR_STATS_LOCK(c->thread); in resp_start()
1159 THR_STATS_UNLOCK(c->thread); in resp_start()
1182 THR_STATS_LOCK(c->thread); in resp_start_unlinked()
1189 THR_STATS_LOCK(c->thread); in resp_start_unlinked()
1191 THR_STATS_UNLOCK(c->thread); in resp_start_unlinked()
[all …]
Dproto_proxy.c607 do_cache_free(p->thread->io_cache, p); in proxy_return_rctx_cb()
706 LIBEVENT_THREAD *thr = c->thread; in complete_nread_proxy()
1008 LIBEVENT_THREAD *thr = c->thread; in proxy_process_command()
1154 WSTAT_L(c->thread); in proxy_process_command()
1156 c->thread->stats.proxy_conn_requests++; in proxy_process_command()
1158 WSTAT_UL(c->thread); in proxy_process_command()
1238 r->thread = t; in mcp_prep_bare_resobj()
1239 assert(r->thread != NULL); in mcp_prep_bare_resobj()
1252 r->thread = t; in mcp_set_resobj()
1253 assert(r->thread != NULL); in mcp_set_resobj()
[all …]
Dproxy_luafgen.c192 lua_State *L = fgen->thread->L; in _mcplib_funcgen_cache()
201 mcp_funcgen_cleanup(fgen->thread->L, fgen); in _mcplib_funcgen_cache()
326 lua_State *L = fgen->thread->L; in _mcp_funcgen_return_rctx()
338 mcp_request_cleanup(fgen->thread, rctx->request); in _mcp_funcgen_return_rctx()
352 mcp_response_cleanup(fgen->thread, rqu->res_obj); in _mcp_funcgen_return_rctx()
392 WSTAT_DECR(rctx->fgen->thread, proxy_req_active, 1); in mcp_funcgen_return_rctx()
461 WSTAT_INCR(fgen->thread, proxy_req_active, 1); in mcp_funcgen_start()
608 fgen->thread = t; in mcplib_funcgen_new()
973 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_dummy_cb()
1125 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_cb()
[all …]
Dtls.c177 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()
249 assert(pthread_equal(c->thread->thread_id, pthread_self()) != 0); in ssl_sendmsg()
Dproxy_result.c138 assert(r->thread != NULL); in mcp_response_cleanup()
143 resp_free(r->thread, cresp); in mcp_response_cleanup()
Dextstore.c119 static void thread_setname(pthread_t thread, const char *name) { in thread_setname() argument
122 pthread_setname_np(thread, name); in thread_setname()
261 pthread_t thread; in extstore_init() local
412 pthread_create(&thread, NULL, extstore_io_thread, &e->io_threads[i]); in extstore_init()
413 thread_setname(thread, "mc-ext-io"); in extstore_init()
422 pthread_create(&thread, NULL, extstore_io_thread, e->bg_thread); in extstore_init()
423 thread_setname(thread, "mc-ext-bgio"); in extstore_init()
Dmemcached.h804 LIBEVENT_THREAD *thread; member
814 LIBEVENT_THREAD *thread; member
903 LIBEVENT_THREAD *thread; /* Pointer to the thread object serving this connection */ member
1031 void thread_setname(pthread_t thread, const char *name);
DChangeLog51 * Performance: per-thread stats (Trond)
53 * Performance: Hash expansion in its own thread (Trond)
74 * Zero out libevent thread structures before use (Ricky Zhou)
79 * Use a dedicated socket accept thread (Facebook)
217 * Item stats commands weren't thread-safe; wrap them with locks
242 * Add string.h to thread.c to get correctly prototyped strerror()
Dproxy.h496 LIBEVENT_THREAD *thread; // cresp's owner thread needed for extstore cleanup. member
515 LIBEVENT_THREAD *thread; member
651 LIBEVENT_THREAD *thread; // worker thread that created this funcgen. member
Dproxy_network.c573 bool oom = proxy_bufmem_checkadd(r->thread, r->blen + extra_space); in proxy_backend_drive_machine()
586 pthread_mutex_lock(&r->thread->proxy_limit_lock); in proxy_backend_drive_machine()
587 r->thread->proxy_buffer_memory_used -= r->blen + extra_space; in proxy_backend_drive_machine()
588 pthread_mutex_unlock(&r->thread->proxy_limit_lock); in proxy_backend_drive_machine()
DMakefile.am19 thread.c daemon.c \
Dproxy_internal.c161 io->thread = t; in proxy_storage_get()
1658 LIBEVENT_THREAD *t = rctx->c->thread; in mcplib_internal_run()
1748 r->thread = t; in mcplib_internal_run()
Dconfigure.ac698 AC_MSG_ERROR([Can't enable threads without the POSIX thread library.])
/memcached-1.6.32/doc/
Dnapi_ids.txt1 NAPI ID based worker thread selection
5 manner. NAPI ID based worker thread selection enables worker threads to be
15 the RX queue on which they are received. Each worker thread is associated
17 received on a specific RX queue. This mapping between a memcached thread
29 thread selection.
31 During a normal run, each worker thread gets associated with a napi_id and
32 this will establish a 1:1 mapping between the thread and queues. If a new
33 napi_id is received after each thread is associated with its own napi_id
Dthreads.txt3 - One listener thread
7 Each worker thread is assigned connections, and runs its own epoll loop. The
19 thread may read or write against a particular hash table bucket.
25 to avoid deadlocks. If a bucket is in use (and not by that thread) it will
49 thread execution or update settings while the threads are idle. They may call
54 - If you remove the per-thread stats lock, CPU usage goes down by less than a
Dnew_lru.txt22 * A background thread exists which shuffles items between/within the LRU's as
24 * The background thread can also control the lru_crawler, if enabled.
32 most item reads, largely during sets and from the background thread. Also the
33 background thread is likely to find expired items and release them back to the
Dtls.txt36 Unlike a worker thread sets callback on the socket, this uses a “bufferevent” object for
71 network IO. A listener thread does the TCP handshake and initiates the SSL handshake after
73 fatal errors, the listener thread hands over the socket to a worker thread. A worker completes
81 | | Listener thread |
95 | | Worker thread |
Dstorage.txt15 adds it to the end of a queue. It then signals the IO thread to run. Once an
Dprotocol.txt1013 The slabs automove command enables a background thread which decides on its
1026 - <0> means to set the thread on standby
1057 time. If switching from segmented to flat mode, the background thread will
1077 The LRU Crawler is an optional background thread which will walk from the tail
1085 - Enable or disable the LRU Crawler background thread.
1420 | | 64u | Number of times the LRU bg thread woke up |
1449 | | | thread selection. See doc/napi_ids.txt |
1516 | worker_logbuf_size| 32u | Size of internal per-worker-thread buffer |
1517 | | | which the background thread reads from. |
1656 ability was not thread safe and could crash the server. While possible to fix,
[all …]