Lines Matching refs:th
1038 LIBEVENT_THREAD *th = c->thread; in resp_allocate() local
1040 mc_resp_bundle *b = th->open_bundle; in resp_allocate()
1061 th->open_bundle = b->next; in resp_allocate()
1072 assert(th->open_bundle == NULL); in resp_allocate()
1073 b = do_cache_alloc(th->rbuf_cache); in resp_allocate()
1075 THR_STATS_LOCK(th); in resp_allocate()
1076 th->stats.response_obj_bytes += READ_BUFFER_SIZE; in resp_allocate()
1077 THR_STATS_UNLOCK(th); in resp_allocate()
1085 b->thread = th; in resp_allocate()
1086 th->open_bundle = b; in resp_allocate()
1099 void resp_free(LIBEVENT_THREAD *th, mc_resp *resp) { in resp_free() argument
1105 if (b == th->open_bundle && b->next == 0) { in resp_free()
1111 assert((b->next || b->prev) || b == th->open_bundle); in resp_free()
1114 mc_resp_bundle **head = &th->open_bundle; in resp_free()
1123 do_cache_free(th->rbuf_cache, b); in resp_free()
1124 THR_STATS_LOCK(th); in resp_free()
1125 th->stats.response_obj_bytes -= READ_BUFFER_SIZE; in resp_free()
1126 THR_STATS_UNLOCK(th); in resp_free()
1129 mc_resp_bundle **head = &th->open_bundle; in resp_free()
1131 if (b == th->open_bundle || (b->prev || b->next)) { in resp_free()
1142 THR_STATS_LOCK(th); in resp_free()
1143 th->stats.response_obj_count--; in resp_free()
1144 THR_STATS_UNLOCK(th); in resp_free()