Lines Matching refs:thread
398 do_cache_free(c->thread->rbuf_cache, c->rbuf); in rbuf_release()
408 c->rbuf = do_cache_alloc(c->thread->rbuf_cache); in rbuf_alloc()
410 THR_STATS_LOCK(c->thread); in rbuf_alloc()
411 c->thread->stats.read_buf_oom++; in rbuf_alloc()
412 THR_STATS_UNLOCK(c->thread); in rbuf_alloc()
432 do_cache_free(c->thread->rbuf_cache, c->rbuf); in rbuf_switch_to_malloc()
513 pthread_mutex_lock(&c->thread->stats.mutex); in conn_close_idle()
514 c->thread->stats.idle_kicks++; in conn_close_idle()
515 pthread_mutex_unlock(&c->thread->stats.mutex); in conn_close_idle()
527 event_base_set(c->thread->base, &c->event); in _conn_event_readd()
580 io_queue_cb_t *qcb = c->thread->io_queues; in conn_io_queue_setup()
891 if (c->thread) { in conn_close()
892 LOGGER_LOG(c->thread->l, LOG_CONNEVENTS, LOGGER_CONNECTION_CLOSE, NULL, in conn_close()
906 if (c->thread) { in conn_close()
997 LIBEVENT_THREAD *t = resp->bundle->thread; in resp_reset()
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()
1151 c->thread->stats.response_obj_oom++; in resp_start()
1152 THR_STATS_UNLOCK(c->thread); in resp_start()
1157 THR_STATS_LOCK(c->thread); in resp_start()
1158 c->thread->stats.response_obj_count++; in resp_start()
1159 THR_STATS_UNLOCK(c->thread); in resp_start()
1182 THR_STATS_LOCK(c->thread); in resp_start_unlinked()
1183 c->thread->stats.response_obj_oom++; in resp_start_unlinked()
1184 THR_STATS_UNLOCK(c->thread); in resp_start_unlinked()
1189 THR_STATS_LOCK(c->thread); in resp_start_unlinked()
1190 c->thread->stats.response_obj_count++; in resp_start_unlinked()
1191 THR_STATS_UNLOCK(c->thread); in resp_start_unlinked()
1214 LIBEVENT_THREAD *t = resp->bundle->thread; in resp_finish()
1227 do_cache_free(c->thread->io_cache, io); in resp_finish()
1236 resp_free(c->thread, resp); in resp_finish()
2429 pthread_mutex_lock(&c->thread->stats.mutex);
2430 c->thread->stats.bytes_read += res;
2431 pthread_mutex_unlock(&c->thread->stats.mutex);
2503 pthread_mutex_lock(&c->thread->stats.mutex);
2504 c->thread->stats.bytes_read += res;
2505 pthread_mutex_unlock(&c->thread->stats.mutex);
2739 pthread_mutex_lock(&c->thread->stats.mutex);
2740 c->thread->stats.bytes_written += res;
2741 pthread_mutex_unlock(&c->thread->stats.mutex);
2875 pthread_mutex_lock(&c->thread->stats.mutex);
2876 c->thread->stats.bytes_written += res;
2877 pthread_mutex_unlock(&c->thread->stats.mutex);
2963 pthread_mutex_lock(&c->thread->stats.mutex);
2964 c->thread->stats.bytes_read += res;
2965 pthread_mutex_unlock(&c->thread->stats.mutex);
3152 pthread_mutex_lock(&c->thread->stats.mutex);
3153 c->thread->stats.conn_yields++;
3154 pthread_mutex_unlock(&c->thread->stats.mutex);
3205 pthread_mutex_lock(&c->thread->stats.mutex);
3206 c->thread->stats.bytes_read += res;
3207 pthread_mutex_unlock(&c->thread->stats.mutex);
3281 pthread_mutex_lock(&c->thread->stats.mutex);
3282 c->thread->stats.bytes_read += res;
3283 pthread_mutex_unlock(&c->thread->stats.mutex);
3318 io_queue_cb_t *qcb = thread_io_queue_get(c->thread, q->type);