/unit/src/ |
H A D | nxt_work_queue.c | 51 wq->pid = nxt_pid; in nxt_work_queue_thread_assert() 52 wq->tid = tid; in nxt_work_queue_thread_assert() 68 wq->pid = nxt_pid; in nxt_work_queue_thread_adopt() 78 wq->name = name; in nxt_work_queue_name() 168 work = wq->cache->next; in nxt_work_queue_add() 186 wq->tail = work; in nxt_work_queue_add() 204 work = wq->head; in nxt_work_queue_pop() 206 wq->head = work->next; in nxt_work_queue_pop() 209 wq->tail = NULL; in nxt_work_queue_pop() 221 wq->cache->next = work; in nxt_work_queue_pop() [all …]
|
H A D | nxt_work_queue.h | 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 D | nxt_source.h | 25 #define nxt_source_filter(thr, wq, task, next, out) \ argument 28 nxt_thread_work_queue_add(thr, wq, nxt_source_filter_handler, \
|
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() argument 124 c->read_work_queue = wq; in nxt_conn_work_queue_set() 125 c->write_work_queue = wq; in nxt_conn_work_queue_set() 126 c->read_timer.work_queue = wq; in nxt_conn_work_queue_set() 127 c->write_timer.work_queue = wq; in nxt_conn_work_queue_set()
|
H A D | nxt_event_engine.c | 469 nxt_work_queue_t *wq, *last; in nxt_event_engine_queue_pop() local 471 wq = engine->current_work_queue; in nxt_event_engine_queue_pop() 472 last = wq; in nxt_event_engine_queue_pop() 474 if (wq->head == NULL) { in nxt_event_engine_queue_pop() 475 wq = &engine->fast_work_queue; in nxt_event_engine_queue_pop() 477 if (wq->head == NULL) { in nxt_event_engine_queue_pop() 481 wq = engine->current_work_queue; in nxt_event_engine_queue_pop() 484 wq = &engine->fast_work_queue; in nxt_event_engine_queue_pop() 488 if (wq->head != NULL) { in nxt_event_engine_queue_pop() 492 } while (wq != last); in nxt_event_engine_queue_pop() [all …]
|
H A D | nxt_conn_close.c | 22 nxt_work_queue_t *wq; in nxt_conn_close() local 62 wq = &engine->shutdown_work_queue; in nxt_conn_close() 66 wq = &engine->close_work_queue; in nxt_conn_close() 70 nxt_work_queue_add(wq, handler, c->socket.task, c, engine); in nxt_conn_close()
|
H A D | nxt_sendbuf.c | 13 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() argument 389 b = nxt_sendbuf_coalesce_completion(task, wq, 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() argument 400 b = nxt_sendbuf_coalesce_completion(task, wq, b); in nxt_sendbuf_drain() 406 nxt_sendbuf_coalesce_completion(nxt_task_t *task, nxt_work_queue_t *wq, in nxt_sendbuf_coalesce_completion() argument 442 nxt_work_queue_add(wq, handler, task, start, start->parent); in nxt_sendbuf_coalesce_completion()
|
H A D | nxt_sendbuf.h | 126 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 D | nxt_kqueue_engine.c | 498 nxt_work_queue_t *wq; in nxt_kqueue_error() local 500 wq = &engine->fast_work_queue; in nxt_kqueue_error() 510 nxt_work_queue_add(wq, nxt_kqueue_fd_error_handler, in nxt_kqueue_error() 516 nxt_work_queue_add(wq, nxt_kqueue_file_error_handler, in nxt_kqueue_error() 677 nxt_work_queue_t *wq; in nxt_kqueue_poll() local 738 wq = &engine->fast_work_queue; in nxt_kqueue_poll() 768 wq = ev->read_work_queue; in nxt_kqueue_poll() 799 wq = ev->write_work_queue; in nxt_kqueue_poll() 841 nxt_work_queue_add(wq, handler, task, obj, data); in nxt_kqueue_poll()
|
H A D | nxt_conn.h | 176 #define nxt_conn_timer_init(ev, c, wq) \ argument 178 (ev)->work_queue = (wq); \ 228 NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
|
H A D | nxt_port_socket.c | 28 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() local 387 wq = &task->thread->engine->fast_work_queue; in nxt_port_write_handler() 457 msg->buf = nxt_port_buf_completion(task, wq, msg->buf, plain_size, in nxt_port_write_handler() 549 nxt_work_queue_add(wq, nxt_port_error_handler, task, &port->socket, 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() argument 670 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent); in nxt_port_buf_completion() 1341 nxt_work_queue_t *wq; in nxt_port_error_handler() local 1355 wq = &task->thread->engine->fast_work_queue; in nxt_port_error_handler() 1371 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent); in nxt_port_error_handler()
|
H A D | nxt_cyassl.c | 479 nxt_work_queue_t *wq; in nxt_cyassl_conn_test_error() local 517 wq = c->read_work_queue; in nxt_cyassl_conn_test_error() 521 wq = c->write_work_queue; in nxt_cyassl_conn_test_error() 525 nxt_event_conn_io_handle(thr, wq, handler, c, c->socket.data); in nxt_cyassl_conn_test_error()
|
H A D | nxt_h1proto.c | 1574 nxt_work_queue_t *wq; in nxt_h1p_request_discard() local 1587 nxt_sendbuf_drain(task, wq, b); in nxt_h1p_request_discard() 2145 nxt_work_queue_t *wq; in nxt_h1p_peer_connect() local 2192 wq = socket->read_work_queue; in nxt_h1p_peer_connect() 2193 c->read_work_queue = wq; in nxt_h1p_peer_connect() 2194 c->socket.read_work_queue = wq; in nxt_h1p_peer_connect() 2195 c->read_timer.work_queue = wq; in nxt_h1p_peer_connect() 2197 wq = socket->write_work_queue; in nxt_h1p_peer_connect() 2198 c->write_work_queue = wq; in nxt_h1p_peer_connect() 2199 c->socket.write_work_queue = wq; in nxt_h1p_peer_connect() [all …]
|
H A D | nxt_http_static.c | 799 nxt_work_queue_t *wq; in nxt_http_static_body_handler() local 830 wq = &task->thread->engine->fast_work_queue; in nxt_http_static_body_handler() 832 nxt_sendbuf_drain(task, wq, out); in nxt_http_static_body_handler()
|
H A D | nxt_openssl.c | 1244 nxt_work_queue_t *wq; local 1325 wq = (c->read_state != NULL) ? c->read_work_queue : c->write_work_queue; 1327 nxt_work_queue_add(wq, handler, task, c, data);
|
H A D | nxt_controller.c | 683 wq = nxt_mp_zget(cf->mem_pool, sizeof(nxt_work_queue_t)); in nxt_runtime_controller_socket() 684 if (wq == NULL) { in nxt_runtime_controller_socket() 687 nxt_work_queue_name(wq, "listen"); in nxt_runtime_controller_socket() 690 ls->work_queue = wq; in nxt_runtime_controller_socket()
|