Home
last modified time | relevance | path

Searched refs:timer (Results 1 – 23 of 23) sorted by relevance

/unit/src/
H A Dnxt_timer.c79 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 Dnxt_timer.h58 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 Dnxt_log_moderation.c19 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 Dnxt_h1proto_websocket.c77 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 Dnxt_conn_accept.c62 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 Dnxt_conn_close.c145 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 Dnxt_conn.c106 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 Dnxt_fiber.c391 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 Dnxt_log_moderation.h19 nxt_timer_t timer; member
H A Dnxt_h1proto.c1619 timer = obj; in nxt_h1p_conn_request_timeout()
1650 timer = obj; in nxt_h1p_conn_request_send_timeout()
1869 nxt_timer_t *timer; in nxt_h1p_idle_timeout() local
1871 timer = obj; in nxt_h1p_idle_timeout()
1980 nxt_timer_t *timer; in nxt_h1p_idle_response_timeout() local
1982 timer = obj; in nxt_h1p_idle_response_timeout()
2014 timer = &h1p->websocket_timer->timer; in nxt_h1p_shutdown()
2040 timer = obj; in nxt_h1p_conn_ws_shutdown()
2041 ws_timer = nxt_timer_data(timer, nxt_h1p_websocket_timer_t, timer); in nxt_h1p_conn_ws_shutdown()
2764 timer = obj; in nxt_h1p_peer_send_timeout()
[all …]
H A Dnxt_fiber.h35 nxt_timer_t timer; member
H A Dnxt_conn_proxy.c750 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 Dnxt_cache.h112 nxt_timer_t timer; member
H A Dnxt_conn_write.c150 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 Dnxt_router.c3642 nxt_timer_t *timer; in nxt_router_listen_socket_close() local
3647 timer = obj; in nxt_router_listen_socket_close()
3648 lev = nxt_timer_data(timer, nxt_listen_event_t, timer); in nxt_router_listen_socket_close()
4763 nxt_timer_t *timer; in nxt_router_app_idle_timeout() local
4766 timer = obj; in nxt_router_app_idle_timeout()
4778 nxt_timer_t *timer; in nxt_router_app_joint_release_handler() local
4781 timer = obj; in nxt_router_app_joint_release_handler()
4960 r->timer.task = &engine->task; in nxt_router_process_http_request()
4962 r->timer.log = engine->task.log; in nxt_router_process_http_request()
5463 timer = obj; in nxt_router_app_timeout()
[all …]
H A Dnxt_runtime.h52 nxt_timer_t timer; member
H A Dnxt_http.h79 nxt_timer_t timer; member
169 nxt_timer_t timer; member
H A Dnxt_cache.c352 ev = &cq->timer; in nxt_cache_wait_handler()
372 cq = nxt_event_timer_data(ev, nxt_cache_query_t, timer); in nxt_cache_timeout_handler()
H A Dnxt_controller.c850 nxt_timer_t *timer; in nxt_controller_conn_read_timeout() local
853 timer = obj; in nxt_controller_conn_read_timeout()
855 c = nxt_read_timer_conn(timer); in nxt_controller_conn_read_timeout()
958 nxt_timer_t *timer; in nxt_controller_conn_write_timeout() local
960 timer = obj; in nxt_controller_conn_write_timeout()
962 c = nxt_write_timer_conn(timer); in nxt_controller_conn_write_timeout()
H A Dnxt_conn.h112 nxt_timer_t timer; member
H A Dnxt_file_cache.c249 ev = &q->timer; in nxt_cache_wait_handler()
H A Dnxt_openssl.c1613 nxt_timer_t *timer; local
1615 timer = obj;
1619 c = nxt_write_timer_conn(timer);
/unit/src/nodejs/unit-http/
H A Dunit.cpp35 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()