Lines Matching refs:io_threads
96 store_io_thread *io_threads; member
150 if (e->io_threads[x].depth == 0) { in _get_io_thread()
153 } else if (e->io_threads[x].depth < low) { in _get_io_thread()
155 low = e->io_threads[x].depth; in _get_io_thread()
160 return &e->io_threads[tid]; in _get_io_thread()
185 pthread_mutex_lock(&e->io_threads[x].mutex); in extstore_get_stats()
186 st->io_queue += e->io_threads[x].depth; in extstore_get_stats()
187 pthread_mutex_unlock(&e->io_threads[x].mutex); in extstore_get_stats()
406 e->io_threads = calloc(cf->io_threadcount, sizeof(store_io_thread)); in extstore_init()
408 pthread_mutex_init(&e->io_threads[i].mutex, NULL); in extstore_init()
409 pthread_cond_init(&e->io_threads[i].cond, NULL); in extstore_init()
410 e->io_threads[i].e = e; in extstore_init()
412 pthread_create(&thread, NULL, extstore_io_thread, &e->io_threads[i]); in extstore_init()