Home
last modified time | relevance | path

Searched refs:nxt_event_engine_t (Results 1 – 25 of 43) sorted by path

12

/unit/src/
H A Dnxt_buf.c16 nxt_event_engine_t *engine;
H A Dnxt_cache.h72 nxt_event_engine_t *engine;
H A Dnxt_conn.c105 nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_conn_timer()
H A Dnxt_conn.h223 NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
225 NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
260 nxt_bool_t nxt_event_conn_write_delayed(nxt_event_engine_t *engine,
277 nxt_event_engine_t *e = engine; \
288 nxt_event_engine_t *e = engine; \
H A Dnxt_conn_accept.c41 nxt_event_engine_t *engine; in nxt_listen_event()
90 nxt_event_engine_t *engine; in nxt_conn_accept_alloc()
251 nxt_event_engine_t *engine; in nxt_conn_accept_close_idle()
273 nxt_event_engine_t *engine; in nxt_conn_accept_close_idle_handler()
H A Dnxt_conn_close.c19 nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c) in nxt_conn_close()
78 nxt_event_engine_t *engine; in nxt_conn_shutdown_handler()
99 nxt_event_engine_t *engine; in nxt_conn_close_handler()
H A Dnxt_conn_connect.c39 nxt_event_engine_t *engine; in nxt_conn_io_connect()
H A Dnxt_conn_proxy.c943 nxt_event_engine_t *engine; in nxt_conn_proxy_complete()
H A Dnxt_conn_read.c13 nxt_event_engine_t *engine; in nxt_conn_wait()
42 nxt_event_engine_t *engine; in nxt_conn_io_read()
H A Dnxt_conn_write.c23 nxt_event_engine_t *engine; in nxt_conn_io_write()
422 nxt_event_conn_write_delayed(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_event_conn_write_delayed()
H A Dnxt_controller.c676 nxt_event_engine_t *engine; in nxt_controller_conn_init()
H A Dnxt_devpoll_engine.c30 static nxt_int_t nxt_devpoll_create(nxt_event_engine_t *engine,
32 static void nxt_devpoll_free(nxt_event_engine_t *engine);
35 static nxt_bool_t nxt_devpoll_close(nxt_event_engine_t *engine,
37 static void nxt_devpoll_enable_read(nxt_event_engine_t *engine,
39 static void nxt_devpoll_enable_write(nxt_event_engine_t *engine,
45 static void nxt_devpoll_block_read(nxt_event_engine_t *engine,
47 static void nxt_devpoll_block_write(nxt_event_engine_t *engine,
59 static nxt_int_t nxt_devpoll_write(nxt_event_engine_t *engine,
61 static void nxt_devpoll_poll(nxt_event_engine_t *engine,
148 nxt_devpoll_free(nxt_event_engine_t *engine) in nxt_devpoll_free()
[all …]
H A Dnxt_epoll_engine.c40 static nxt_int_t nxt_epoll_create(nxt_event_engine_t *engine,
42 static void nxt_epoll_test_accept4(nxt_event_engine_t *engine,
44 static void nxt_epoll_free(nxt_event_engine_t *engine);
48 static nxt_bool_t nxt_epoll_close(nxt_event_engine_t *engine,
50 static void nxt_epoll_enable_read(nxt_event_engine_t *engine,
58 static void nxt_epoll_block_read(nxt_event_engine_t *engine,
315 nxt_epoll_free(nxt_event_engine_t *engine) in nxt_epoll_free()
609 nxt_epoll_commit_changes(nxt_event_engine_t *engine) in nxt_epoll_commit_changes()
666 nxt_epoll_add_signal(nxt_event_engine_t *engine) in nxt_epoll_add_signal()
813 nxt_event_engine_t *engine; in nxt_epoll_eventfd_handler()
[all …]
H A Dnxt_event_engine.c26 nxt_event_engine_t *engine);
41 nxt_event_engine_t *
48 nxt_event_engine_t *engine; in nxt_event_engine_create()
50 engine = nxt_zalloc(sizeof(nxt_event_engine_t)); in nxt_event_engine_create()
168 nxt_event_engine_post_init(nxt_event_engine_t *engine) in nxt_event_engine_post_init()
333 nxt_event_engine_t *engine; in nxt_event_engine_post_handler()
346 nxt_event_engine_t *engine; in nxt_event_engine_signal_pipe_error()
383 nxt_event_engine_change(nxt_event_engine_t *engine, in nxt_event_engine_change()
448 nxt_event_engine_free(nxt_event_engine_t *engine) in nxt_event_engine_free()
509 nxt_event_engine_start(nxt_event_engine_t *engine) in nxt_event_engine_start()
[all …]
H A Dnxt_event_engine.h34 nxt_int_t (*create)(nxt_event_engine_t *engine,
38 void (*free)(nxt_event_engine_t *engine);
45 void (*enable)(nxt_event_engine_t *engine,
49 void (*disable)(nxt_event_engine_t *engine,
56 void (*delete)(nxt_event_engine_t *engine,
67 nxt_bool_t (*close)(nxt_event_engine_t *engine,
156 void (*poll)(nxt_event_engine_t *engine,
497 NXT_EXPORT void nxt_event_engine_free(nxt_event_engine_t *engine);
498 NXT_EXPORT void nxt_event_engine_start(nxt_event_engine_t *engine);
500 NXT_EXPORT void nxt_event_engine_post(nxt_event_engine_t *engine,
[all …]
H A Dnxt_eventport_engine.c17 static nxt_int_t nxt_eventport_create(nxt_event_engine_t *engine,
19 static void nxt_eventport_free(nxt_event_engine_t *engine);
20 static void nxt_eventport_enable(nxt_event_engine_t *engine,
22 static void nxt_eventport_disable(nxt_event_engine_t *engine,
24 static nxt_bool_t nxt_eventport_close(nxt_event_engine_t *engine,
26 static void nxt_eventport_enable_read(nxt_event_engine_t *engine,
41 static void nxt_eventport_block_read(nxt_event_engine_t *engine,
54 static void nxt_eventport_poll(nxt_event_engine_t *engine,
133 nxt_eventport_free(nxt_event_engine_t *engine) in nxt_eventport_free()
297 nxt_eventport_commit_changes(nxt_event_engine_t *engine) in nxt_eventport_commit_changes()
[all …]
H A Dnxt_fiber.c23 nxt_fiber_main_create(nxt_event_engine_t *engine) in nxt_fiber_main_create()
H A Dnxt_fiber.h42 nxt_event_engine_t *engine;
48 nxt_fiber_main_t *nxt_fiber_main_create(nxt_event_engine_t *engine);
H A Dnxt_h1proto.c216 nxt_event_engine_t *engine; in nxt_http_conn_init()
315 nxt_event_engine_t *engine; in nxt_http_conn_test()
1023 nxt_event_engine_t *engine; in nxt_h1p_conn_request_body_read()
1717 nxt_event_engine_t *engine; in nxt_h1p_conn_sent()
1787 nxt_event_engine_t *engine; in nxt_h1p_keepalive()
2108 nxt_event_engine_t *engine; in nxt_h1p_conn_free()
2379 nxt_event_engine_t *engine; in nxt_h1p_peer_header_sent()
2498 nxt_event_engine_t *engine; in nxt_h1p_peer_header_read_done()
H A Dnxt_h1proto_websocket.c224 nxt_event_engine_t *engine; in nxt_h1p_conn_ws_frame_header_read()
547 nxt_event_engine_t *engine; in nxt_h1p_conn_ws_frame_payload_read()
H A Dnxt_http.h182 nxt_event_engine_t *engine;
H A Dnxt_job.h47 nxt_event_engine_t *engine;
H A Dnxt_kqueue_engine.c54 static nxt_int_t nxt_kqueue_create(nxt_event_engine_t *engine,
56 static void nxt_kqueue_free(nxt_event_engine_t *engine);
60 static nxt_bool_t nxt_kqueue_close(nxt_event_engine_t *engine,
62 static void nxt_kqueue_enable_read(nxt_event_engine_t *engine,
70 static void nxt_kqueue_block_read(nxt_event_engine_t *engine,
82 static void nxt_kqueue_close_file(nxt_event_engine_t *engine,
87 static void nxt_kqueue_error(nxt_event_engine_t *engine);
220 nxt_kqueue_free(nxt_event_engine_t *engine) in nxt_kqueue_free()
464 nxt_kqueue_get_kevent(nxt_event_engine_t *engine) in nxt_kqueue_get_kevent()
493 nxt_kqueue_error(nxt_event_engine_t *engine) in nxt_kqueue_error()
[all …]
H A Dnxt_main.h25 typedef struct nxt_event_engine_s nxt_event_engine_t; typedef
H A Dnxt_poll_engine.c29 static nxt_int_t nxt_poll_create(nxt_event_engine_t *engine,
31 static void nxt_poll_free(nxt_event_engine_t *engine);
33 static void nxt_poll_disable(nxt_event_engine_t *engine,
35 static nxt_bool_t nxt_poll_close(nxt_event_engine_t *engine,
37 static void nxt_poll_enable_read(nxt_event_engine_t *engine,
39 static void nxt_poll_enable_write(nxt_event_engine_t *engine,
41 static void nxt_poll_disable_read(nxt_event_engine_t *engine,
46 static void nxt_poll_block_write(nxt_event_engine_t *engine,
124 nxt_poll_free(nxt_event_engine_t *engine) in nxt_poll_free()
322 nxt_poll_commit_changes(nxt_event_engine_t *engine) in nxt_poll_commit_changes()
[all …]

12