Home
last modified time | relevance | path

Searched defs:wq (Results 1 – 13 of 13) sorted by path

/unit/src/
H A Dnxt_conn.c122 nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq) in nxt_conn_work_queue_set()
H A Dnxt_conn.h175 #define nxt_conn_timer_init(ev, c, wq) \ argument
H A Dnxt_conn_close.c22 nxt_work_queue_t *wq; in nxt_conn_close() local
H A Dnxt_cyassl.c479 nxt_work_queue_t *wq; in nxt_cyassl_conn_test_error() local
H A Dnxt_event_engine.c469 nxt_work_queue_t *wq, *last; in nxt_event_engine_queue_pop() local
H A Dnxt_h1proto.c1564 nxt_work_queue_t *wq; in nxt_h1p_request_discard() local
2134 nxt_work_queue_t *wq; in nxt_h1p_peer_connect() local
H A Dnxt_http_static.c789 nxt_work_queue_t *wq; in nxt_http_static_body_handler() local
H A Dnxt_kqueue_engine.c498 nxt_work_queue_t *wq; in nxt_kqueue_error() local
677 nxt_work_queue_t *wq; in nxt_kqueue_poll() local
H A Dnxt_openssl.c1244 nxt_work_queue_t *wq; local
H A Dnxt_port_socket.c376 nxt_work_queue_t *wq; in nxt_port_write_handler() local
618 nxt_port_buf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b, in nxt_port_buf_completion()
1341 nxt_work_queue_t *wq; in nxt_port_error_handler() local
H A Dnxt_sendbuf.c381 nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b) in nxt_sendbuf_completion()
397 nxt_sendbuf_drain(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b) in nxt_sendbuf_drain()
406 nxt_sendbuf_coalesce_completion(nxt_task_t *task, nxt_work_queue_t *wq, in nxt_sendbuf_coalesce_completion()
H A Dnxt_source.h25 #define nxt_source_filter(thr, wq, task, next, out) \ argument
H A Dnxt_work_queue.c38 nxt_work_queue_thread_assert(nxt_work_queue_t *wq) in nxt_work_queue_thread_assert()
62 void nxt_work_queue_thread_adopt(nxt_work_queue_t *wq) in nxt_work_queue_thread_adopt()
74 nxt_work_queue_name(nxt_work_queue_t *wq, const char *name) in nxt_work_queue_name()
83 #define nxt_work_queue_thread_assert(wq) argument
160 nxt_work_queue_add(nxt_work_queue_t *wq, nxt_work_handler_t handler, in nxt_work_queue_add()
197 nxt_work_queue_pop(nxt_work_queue_t *wq, nxt_task_t **task, void **obj, in nxt_work_queue_pop()
290 nxt_work_queue_t *wq) in nxt_locked_work_queue_move()