Searched defs:wq (Results 1 – 13 of 13) sorted by relevance
| /unit/src/ |
| H A D | nxt_work_queue.c | 38 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()
|
| H A D | nxt_sendbuf.c | 381 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 D | nxt_source.h | 25 #define nxt_source_filter(thr, wq, task, next, out) \ argument
|
| H A D | nxt_conn.c | 122 nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq) in nxt_conn_work_queue_set()
|
| H A D | nxt_conn_close.c | 22 nxt_work_queue_t *wq; in nxt_conn_close() local
|
| H A D | nxt_port_socket.c | 376 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 D | nxt_kqueue_engine.c | 498 nxt_work_queue_t *wq; in nxt_kqueue_error() local
677 nxt_work_queue_t *wq; in nxt_kqueue_poll() local
|
| H A D | nxt_cyassl.c | 479 nxt_work_queue_t *wq; in nxt_cyassl_conn_test_error() local
|
| H A D | nxt_event_engine.c | 469 nxt_work_queue_t *wq, *last; in nxt_event_engine_queue_pop() local
|
| H A D | nxt_http_static.c | 801 nxt_work_queue_t *wq; in nxt_http_static_body_handler() local
|
| H A D | nxt_conn.h | 176 #define nxt_conn_timer_init(ev, c, wq) \ argument
|
| H A D | nxt_h1proto.c | 1574 nxt_work_queue_t *wq; in nxt_h1p_request_discard() local
2145 nxt_work_queue_t *wq; in nxt_h1p_peer_connect() local
|
| H A D | nxt_openssl.c | 1244 nxt_work_queue_t *wq; local
|