Home
last modified time | relevance | path

Searched refs:nxt_work_queue_t (Results 1 – 19 of 19) sorted by relevance

/unit/src/
H A Dnxt_work_queue.h63 typedef struct nxt_work_queue_s nxt_work_queue_t; typedef
89 NXT_EXPORT void nxt_work_queue_add(nxt_work_queue_t *wq,
91 NXT_EXPORT nxt_work_handler_t nxt_work_queue_pop(nxt_work_queue_t *wq,
107 NXT_EXPORT void nxt_work_queue_name(nxt_work_queue_t *wq, const char *name);
108 NXT_EXPORT void nxt_work_queue_thread_adopt(nxt_work_queue_t *wq);
124 nxt_locked_work_queue_t *lwq, nxt_work_queue_t *wq);
H A Dnxt_event_engine.h446 nxt_work_queue_t *current_work_queue;
447 nxt_work_queue_t fast_work_queue;
448 nxt_work_queue_t accept_work_queue;
449 nxt_work_queue_t read_work_queue;
450 nxt_work_queue_t socket_work_queue;
451 nxt_work_queue_t connect_work_queue;
452 nxt_work_queue_t write_work_queue;
453 nxt_work_queue_t shutdown_work_queue;
454 nxt_work_queue_t close_work_queue;
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()
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 Dnxt_fd_event.h108 nxt_work_queue_t *read_work_queue;
110 nxt_work_queue_t *write_work_queue;
H A Dnxt_sendbuf.h126 nxt_buf_t *nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq,
128 void nxt_sendbuf_drain(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b);
H A Dnxt_conn.h110 nxt_work_queue_t *work_queue;
127 nxt_work_queue_t *read_work_queue;
132 nxt_work_queue_t *write_work_queue;
228 NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
H A Dnxt_listen_socket.h16 nxt_work_queue_t *work_queue;
H A Dnxt_sendbuf.c13 nxt_work_queue_t *wq, nxt_buf_t *start);
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 Dnxt_timer.h36 nxt_work_queue_t *work_queue;
H A Dnxt_conn_close.c22 nxt_work_queue_t *wq; in nxt_conn_close()
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_port_socket.c28 nxt_work_queue_t *wq, nxt_buf_t *b, size_t sent, nxt_bool_t mmap_mode);
376 nxt_work_queue_t *wq; in nxt_port_write_handler()
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()
H A Dnxt_kqueue_engine.c498 nxt_work_queue_t *wq; in nxt_kqueue_error()
677 nxt_work_queue_t *wq; in nxt_kqueue_poll()
H A Dnxt_cyassl.c479 nxt_work_queue_t *wq; in nxt_cyassl_conn_test_error()
H A Dnxt_event_engine.c469 nxt_work_queue_t *wq, *last; in nxt_event_engine_queue_pop()
H A Dnxt_http_static.c799 nxt_work_queue_t *wq; in nxt_http_static_body_handler()
H A Dnxt_h1proto.c1574 nxt_work_queue_t *wq; in nxt_h1p_request_discard()
2145 nxt_work_queue_t *wq; in nxt_h1p_peer_connect()
H A Dnxt_openssl.c1244 nxt_work_queue_t *wq;
H A Dnxt_controller.c682 wq = nxt_mp_zget(cf->mem_pool, sizeof(nxt_work_queue_t)); in nxt_runtime_controller_socket()