Home
last modified time | relevance | path

Searched refs:wq (Results 1 – 16 of 16) sorted by relevance

/unit/src/
H A Dnxt_work_queue.c51 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 Dnxt_work_queue.h89 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_source.h25 #define nxt_source_filter(thr, wq, task, next, out) \ argument
28 nxt_thread_work_queue_add(thr, wq, nxt_source_filter_handler, \
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() 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 Dnxt_event_engine.c469 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 Dnxt_conn_close.c22 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 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() 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 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_kqueue_engine.c498 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 Dnxt_conn.h176 #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 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() 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 Dnxt_cyassl.c479 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 Dnxt_h1proto.c1574 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 Dnxt_http_static.c799 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 Dnxt_openssl.c1244 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 Dnxt_controller.c683 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()