Lines Matching refs:thread

229     engine = task->thread->engine;  in nxt_http_conn_init()
283 b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size); in nxt_http_idle_io_read_handler()
301 nxt_event_engine_buf_mem_free(task->thread->engine, b); in nxt_http_idle_io_read_handler()
322 engine = task->thread->engine; in nxt_http_conn_test()
422 b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size); in nxt_h1p_idle_io_read_handler()
436 nxt_event_engine_buf_mem_free(task->thread->engine, b); in nxt_h1p_idle_io_read_handler()
481 nxt_conn_active(task->thread->engine, c); in nxt_h1p_conn_request_init()
565 nxt_timer_disable(task->thread->engine, &c->read_timer); in nxt_h1p_conn_request_header_parse()
613 nxt_conn_read(task->thread->engine, c); in nxt_h1p_conn_request_header_parse()
985 nxt_conn_read(task->thread->engine, c); in nxt_h1p_request_body_read()
1042 engine = task->thread->engine; in nxt_h1p_conn_request_body_read()
1388 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_request_header_send()
1395 nxt_conn_write(task->thread->engine, c); in nxt_h1p_request_header_send()
1487 nxt_conn_write(task->thread->engine, c); in nxt_h1p_request_send()
1585 wq = &task->thread->engine->fast_work_queue; in nxt_h1p_request_discard()
1733 engine = task->thread->engine; in nxt_h1p_conn_sent()
1752 nxt_conn_active(task->thread->engine, c); in nxt_h1p_conn_close()
1767 nxt_conn_active(task->thread->engine, c); in nxt_h1p_conn_error()
1813 engine = task->thread->engine; in nxt_h1p_keepalive()
1869 nxt_conn_active(task->thread->engine, c); in nxt_h1p_idle_close()
1888 nxt_conn_active(task->thread->engine, c); in nxt_h1p_idle_timeout()
1921 p = nxt_thread_time_string(task->thread, &nxt_http_date_cache, p); in nxt_h1p_idle_response()
1940 nxt_conn_write(task->thread->engine, c); in nxt_h1p_idle_response()
2028 nxt_timer_add(task->thread->engine, timer, 0); in nxt_h1p_shutdown()
2103 nxt_conn_close(task->thread->engine, c); in nxt_h1p_conn_closing()
2125 engine = task->thread->engine; in nxt_h1p_conn_free()
2203 nxt_conn_connect(task->thread->engine, c); in nxt_h1p_peer_connect()
2355 nxt_conn_write(task->thread->engine, c); in nxt_h1p_peer_header_send()
2397 engine = task->thread->engine; in nxt_h1p_peer_header_sent()
2427 nxt_conn_read(task->thread->engine, c); in nxt_h1p_peer_header_read()
2525 engine = task->thread->engine; in nxt_h1p_peer_header_read_done()
2570 nxt_conn_read(task->thread->engine, c); in nxt_h1p_peer_header_read_done()
2646 nxt_conn_read(task->thread->engine, c); in nxt_h1p_peer_read()
2843 nxt_conn_close(task->thread->engine, c); in nxt_h1p_peer_close()