Lines Matching refs:threads
71 static LIBEVENT_THREAD *threads; variable
193 if (write(threads[i].notify_send_fd, buf, 1) != 1) { in pause_threads()
464 LIBEVENT_THREAD *thread = threads + tid; in dispatch_conn_new()
671 pthread_mutex_lock(&threads[ii].stats.mutex); in threadlocal_stats_reset()
672 #define X(name) threads[ii].stats.name = 0; in threadlocal_stats_reset()
676 memset(&threads[ii].stats.slab_stats, 0, in threadlocal_stats_reset()
677 sizeof(threads[ii].stats.slab_stats)); in threadlocal_stats_reset()
679 pthread_mutex_unlock(&threads[ii].stats.mutex); in threadlocal_stats_reset()
691 pthread_mutex_lock(&threads[ii].stats.mutex); in threadlocal_stats_aggregate()
692 #define X(name) stats->name += threads[ii].stats.name; in threadlocal_stats_aggregate()
698 threads[ii].stats.slab_stats[sid].name; in threadlocal_stats_aggregate()
703 pthread_mutex_unlock(&threads[ii].stats.mutex); in threadlocal_stats_aggregate()
771 threads = calloc(nthreads, sizeof(LIBEVENT_THREAD)); in memcached_thread_init()
772 if (! threads) { in memcached_thread_init()
787 threads[i].notify_receive_fd = fds[0]; in memcached_thread_init()
788 threads[i].notify_send_fd = fds[1]; in memcached_thread_init()
790 setup_thread(&threads[i]); in memcached_thread_init()
797 create_worker(worker_libevent, &threads[i]); in memcached_thread_init()