Lines Matching refs:threads
92 static LIBEVENT_THREAD *threads; variable
196 notify_worker_fd(&threads[i], 0, queue_pause); in pause_threads()
221 notify_worker_fd(&threads[i], 0, queue_stop); in stop_threads()
261 pthread_join(threads[i].thread_id, NULL); in stop_threads()
690 return &threads[id]; in get_worker_thread()
705 return threads + tid; in select_thread_round_robin()
714 thread = threads + i; in reset_threads_napi_id()
743 thread = threads + i; in select_thread_by_napi_id()
764 return threads + tid; in select_thread_by_napi_id()
986 pthread_mutex_lock(&threads[ii].stats.mutex); in threadlocal_stats_reset()
987 #define X(name) threads[ii].stats.name = 0; in threadlocal_stats_reset()
997 memset(&threads[ii].stats.slab_stats, 0, in threadlocal_stats_reset()
998 sizeof(threads[ii].stats.slab_stats)); in threadlocal_stats_reset()
999 memset(&threads[ii].stats.lru_hits, 0, in threadlocal_stats_reset()
1002 pthread_mutex_unlock(&threads[ii].stats.mutex); in threadlocal_stats_reset()
1014 pthread_mutex_lock(&threads[ii].stats.mutex); in threadlocal_stats_aggregate()
1015 #define X(name) stats->name += threads[ii].stats.name; in threadlocal_stats_aggregate()
1027 threads[ii].stats.slab_stats[sid].name; in threadlocal_stats_aggregate()
1034 threads[ii].stats.lru_hits[sid]; in threadlocal_stats_aggregate()
1036 threads[ii].stats.lru_hits[sid]; in threadlocal_stats_aggregate()
1039 stats->read_buf_count += threads[ii].rbuf_cache->total; in threadlocal_stats_aggregate()
1040 stats->read_buf_bytes += threads[ii].rbuf_cache->total * READ_BUFFER_SIZE; in threadlocal_stats_aggregate()
1041 stats->read_buf_bytes_free += threads[ii].rbuf_cache->freecurr * READ_BUFFER_SIZE; in threadlocal_stats_aggregate()
1042 pthread_mutex_unlock(&threads[ii].stats.mutex); in threadlocal_stats_aggregate()
1129 threads = calloc(nthreads, sizeof(LIBEVENT_THREAD)); in memcached_thread_init()
1130 if (! threads) { in memcached_thread_init()
1136 memcached_thread_notify_init(&threads[i].n); in memcached_thread_init()
1137 memcached_thread_notify_init(&threads[i].ion); in memcached_thread_init()
1139 threads[i].storage = arg; in memcached_thread_init()
1141 threads[i].thread_baseid = i; in memcached_thread_init()
1142 setup_thread(&threads[i]); in memcached_thread_init()
1149 create_worker(worker_libevent, &threads[i]); in memcached_thread_init()