/unit/src/ |
H A D | nxt_timer.c | 79 timer->time, timer->bias, timeout, time); in nxt_timer_add() 108 timer->time, timer->bias); in nxt_timer_delete() 155 ch->timer = timer; in nxt_timer_change() 177 timer = ch->timer; in nxt_timer_changes_commit() 188 add_end->timer = timer; in nxt_timer_changes_commit() 199 timer->time, timer->bias); in nxt_timer_changes_commit() 213 timer = add->timer; in nxt_timer_changes_commit() 216 timer->time, timer->bias); in nxt_timer_changes_commit() 315 timer->time, timer->bias); in nxt_timer_expire() 324 timer->task, timer, NULL); in nxt_timer_expire() [all …]
|
H A D | nxt_timer.h | 58 nxt_timer_t *timer; member 76 #define nxt_timer_data(obj, type, timer) \ argument 77 nxt_container_of(obj, type, timer) 86 ((timer)->node.parent != NULL) 88 #define nxt_timer_in_tree_set(timer) argument 92 (timer)->node.parent = NULL 99 NXT_EXPORT void nxt_timer_add(nxt_event_engine_t *engine, nxt_timer_t *timer, 102 nxt_timer_t *timer); 105 nxt_timer_disable(nxt_event_engine_t *engine, nxt_timer_t *timer) in nxt_timer_disable() argument 107 nxt_debug(timer->task, "timer disable: %M", timer->time); in nxt_timer_disable() [all …]
|
H A D | nxt_log_moderation.c | 19 nxt_bool_t allow, timer; in nxt_log_moderate_allow() local 26 timer = 0; in nxt_log_moderate_allow() 53 timer = 1; in nxt_log_moderate_allow() 60 if (timer) { in nxt_log_moderate_allow() 61 mod->timer.work_queue = &thr->engine->fast_work_queue; in nxt_log_moderate_allow() 62 mod->timer.handler = nxt_log_moderate_timer_handler; in nxt_log_moderate_allow() 63 mod->timer.log = &nxt_main_log; in nxt_log_moderate_allow() 64 mod->timer.task = &nxt_main_task; in nxt_log_moderate_allow() 66 nxt_timer_add(thr->engine, &mod->timer, 1000); in nxt_log_moderate_allow() 82 mod = nxt_timer_data(ev, nxt_log_moderation_t, timer); in nxt_log_moderate_timer_handler()
|
H A D | nxt_h1proto_websocket.c | 77 nxt_timer_t *timer; in nxt_h1p_websocket_first_frame_start() local 104 timer = &h1p->websocket_timer->timer; in nxt_h1p_websocket_first_frame_start() 105 timer->task = &c->task; in nxt_h1p_websocket_first_frame_start() 107 timer->log = &c->log; in nxt_h1p_websocket_first_frame_start() 172 timer = obj; in nxt_h1p_conn_ws_keepalive() 173 ws_timer = nxt_timer_data(timer, nxt_h1p_websocket_timer_t, timer); in nxt_h1p_conn_ws_keepalive() 360 nxt_timer_t *timer; in nxt_h1p_conn_ws_keepalive_disable() local 366 timer = &h1p->websocket_timer->timer; in nxt_h1p_conn_ws_keepalive_disable() 380 nxt_timer_t *timer; in nxt_h1p_conn_ws_keepalive_enable() local 386 timer = &h1p->websocket_timer->timer; in nxt_h1p_conn_ws_keepalive_enable() [all …]
|
H A D | nxt_conn_accept.c | 62 lev->timer.work_queue = &engine->fast_work_queue; in nxt_listen_event() 63 lev->timer.handler = nxt_conn_listen_timer_handler; in nxt_listen_event() 64 lev->timer.log = &nxt_main_log; in nxt_listen_event() 70 lev->timer.task = &lev->task; in nxt_listen_event() 263 nxt_timer_add(engine, &lev->timer, 100); in nxt_conn_accept_close_idle() 360 nxt_timer_t *timer; in nxt_conn_listen_timer_handler() local 363 timer = obj; in nxt_conn_listen_timer_handler() 365 lev = nxt_timer_data(timer, nxt_listen_event_t, timer); in nxt_conn_listen_timer_handler()
|
H A D | nxt_conn_close.c | 145 nxt_timer_t *timer; in nxt_conn_close_timer_handler() local 148 timer = obj; in nxt_conn_close_timer_handler() 150 c = nxt_write_timer_conn(timer); in nxt_conn_close_timer_handler()
|
H A D | nxt_conn.c | 106 const nxt_conn_state_t *state, nxt_timer_t *timer) in nxt_conn_timer() argument 114 timer->handler = state->timer_handler; in nxt_conn_timer() 115 nxt_timer_add(engine, timer, value); in nxt_conn_timer()
|
H A D | nxt_fiber.c | 391 fib->timer.work_queue = &task->thread->engine->fast_work_queue; in nxt_fiber_sleep() 392 fib->timer.handler = nxt_fiber_timer_handler; in nxt_fiber_sleep() 393 fib->timer.log = &nxt_main_log; in nxt_fiber_sleep() 397 nxt_timer_add(task->thread->engine, &fib->timer, timeout); in nxt_fiber_sleep() 422 fib = nxt_timer_data(ev, nxt_fiber_t, timer); in nxt_fiber_timer_handler()
|
H A D | nxt_log_moderation.h | 19 nxt_timer_t timer; member
|
H A D | nxt_h1proto.c | 1629 timer = obj; in nxt_h1p_conn_request_timeout() 1660 timer = obj; in nxt_h1p_conn_request_send_timeout() 1879 nxt_timer_t *timer; in nxt_h1p_idle_timeout() local 1881 timer = obj; in nxt_h1p_idle_timeout() 1990 nxt_timer_t *timer; in nxt_h1p_idle_response_timeout() local 1992 timer = obj; in nxt_h1p_idle_response_timeout() 2024 timer = &h1p->websocket_timer->timer; in nxt_h1p_shutdown() 2050 timer = obj; in nxt_h1p_conn_ws_shutdown() 2051 ws_timer = nxt_timer_data(timer, nxt_h1p_websocket_timer_t, timer); in nxt_h1p_conn_ws_shutdown() 2774 timer = obj; in nxt_h1p_peer_send_timeout() [all …]
|
H A D | nxt_fiber.h | 35 nxt_timer_t timer; member
|
H A D | nxt_conn_proxy.c | 750 nxt_timer_t *timer; in nxt_conn_proxy_read_timeout() local 752 timer = obj; in nxt_conn_proxy_read_timeout() 754 c = nxt_read_timer_conn(timer); in nxt_conn_proxy_read_timeout() 768 nxt_timer_t *timer; in nxt_conn_proxy_write_timeout() local 770 timer = obj; in nxt_conn_proxy_write_timeout() 772 c = nxt_write_timer_conn(timer); in nxt_conn_proxy_write_timeout() 824 nxt_timer_t *timer; in nxt_conn_proxy_reconnect_handler() local 827 timer = obj; in nxt_conn_proxy_reconnect_handler() 831 peer = nxt_write_timer_conn(timer); in nxt_conn_proxy_reconnect_handler()
|
H A D | nxt_conn_write.c | 150 nxt_timer_t *timer; in nxt_conn_write_timer_handler() local 152 timer = obj; in nxt_conn_write_timer_handler() 156 c = nxt_write_timer_conn(timer); in nxt_conn_write_timer_handler()
|
H A D | nxt_router.c | 3814 nxt_timer_t *timer; in nxt_router_listen_socket_close() local 3819 timer = obj; in nxt_router_listen_socket_close() 3820 lev = nxt_timer_data(timer, nxt_listen_event_t, timer); in nxt_router_listen_socket_close() 4972 nxt_timer_t *timer; in nxt_router_app_idle_timeout() local 4975 timer = obj; in nxt_router_app_idle_timeout() 4987 nxt_timer_t *timer; in nxt_router_app_joint_release_handler() local 4990 timer = obj; in nxt_router_app_joint_release_handler() 5169 r->timer.task = &engine->task; in nxt_router_process_http_request() 5171 r->timer.log = engine->task.log; in nxt_router_process_http_request() 5673 timer = obj; in nxt_router_app_timeout() [all …]
|
H A D | nxt_runtime.h | 52 nxt_timer_t timer; member
|
H A D | nxt_http.h | 79 nxt_timer_t timer; member 170 nxt_timer_t timer; member
|
H A D | nxt_conn.h | 112 nxt_timer_t timer; member
|
H A D | nxt_controller.c | 875 nxt_timer_t *timer; in nxt_controller_conn_read_timeout() local 878 timer = obj; in nxt_controller_conn_read_timeout() 880 c = nxt_read_timer_conn(timer); in nxt_controller_conn_read_timeout() 983 nxt_timer_t *timer; in nxt_controller_conn_write_timeout() local 985 timer = obj; in nxt_controller_conn_write_timeout() 987 c = nxt_write_timer_conn(timer); in nxt_controller_conn_write_timeout()
|
H A D | nxt_openssl.c | 1613 nxt_timer_t *timer; local 1615 timer = obj; 1619 c = nxt_write_timer_conn(timer);
|
/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 35 uv_timer_t timer; member 53 timer.type = UV_UNKNOWN_HANDLE; in port_data_t() 68 if (timer.type == UV_UNKNOWN_HANDLE) { in process_port_msg() 69 err = uv_timer_init(poll.loop, &timer); in process_port_msg() 76 timer.data = this; in process_port_msg() 80 uv_timer_start(&timer, timer_callback, 0, 0); in process_port_msg() 96 if (timer.type == UV_UNKNOWN_HANDLE) { in stop() 100 uv_timer_stop(&timer); in stop() 102 uv_close((uv_handle_t *) &timer, delete_data); in stop()
|