| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/ |
| H A D | rabbit_epmd_monitor.erl | 48 {ok, ensure_timer(State)}.
55 {noreply, ensure_timer(State1#state{timer = undefined})};
61 {noreply, ensure_timer(State1#state{timer = undefined})};
74 ensure_timer(State) -> function
75 rabbit_misc:ensure_timer(State, #state.timer, ?CHECK_FREQUENCY, check).
|
| H A D | rabbit_node_monitor.erl | 802 rabbit_misc:ensure_timer(
808 rabbit_misc:ensure_timer(
|
| H A D | rabbit_mirror_queue_slave.erl | 776 rabbit_misc:ensure_timer(State, #state.sync_timer_ref,
782 rabbit_misc:ensure_timer(State, #state.rate_timer_ref,
|
| H A D | rabbit_amqqueue_process.erl | 514 rabbit_misc:ensure_timer(State, #q.sync_timer_ref,
520 rabbit_misc:ensure_timer(State, #q.rate_timer_ref,
535 rabbit_misc:ensure_timer(NewState, #q.expiry_timer_ref,
|
| H A D | rabbit_msg_store.erl | 1058 rabbit_misc:ensure_timer(State, #msstate.sync_timer_ref,
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_shovel/src/ |
| H A D | rabbit_shovel_status.erl | 43 {ok, ensure_timer(#state{})}.
75 {noreply, ensure_timer(State)};
95 ensure_timer(State0) -> function
97 rabbit_misc:ensure_timer(State1, #state.timer, ?CHECK_FREQUENCY, check).
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_top/src/ |
| H A D | rabbit_top_worker.erl | 48 ensure_timer(),
66 ensure_timer(),
81 ensure_timer() -> function
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 969 void ensure_timer(struct ev_loop *loop, ev_timer *w) { in ensure_timer() function
1008 ensure_timer(loop, &upstream_wtimer_); in ensure_upstream_wtimer()
1052 ensure_timer(loop, &downstream_wtimer_); in ensure_downstream_wtimer()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 957 void ensure_timer(struct ev_loop *loop, ev_timer *w) { in ensure_timer() function
996 ensure_timer(loop, &upstream_wtimer_); in ensure_upstream_wtimer()
1040 ensure_timer(loop, &downstream_wtimer_); in ensure_downstream_wtimer()
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libnghttp2-sys-0.1.6+1.43.0/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 957 void ensure_timer(struct ev_loop *loop, ev_timer *w) { in ensure_timer() function
996 ensure_timer(loop, &upstream_wtimer_); in ensure_upstream_wtimer()
1040 ensure_timer(loop, &downstream_wtimer_); in ensure_downstream_wtimer()
|
| /dports/www/libnghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_downstream.cc | 969 void ensure_timer(struct ev_loop *loop, ev_timer *w) { in ensure_timer() function
1008 ensure_timer(loop, &upstream_wtimer_); in ensure_upstream_wtimer()
1052 ensure_timer(loop, &downstream_wtimer_); in ensure_downstream_wtimer()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/ |
| H A D | shrpx_downstream.cc | 957 void ensure_timer(struct ev_loop *loop, ev_timer *w) { in ensure_timer() function
996 ensure_timer(loop, &upstream_wtimer_); in ensure_upstream_wtimer()
1040 ensure_timer(loop, &downstream_wtimer_); in ensure_downstream_wtimer()
|
| /dports/www/nghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_downstream.cc | 969 void ensure_timer(struct ev_loop *loop, ev_timer *w) { in ensure_timer() function
1008 ensure_timer(loop, &upstream_wtimer_); in ensure_upstream_wtimer()
1052 ensure_timer(loop, &downstream_wtimer_); in ensure_downstream_wtimer()
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit_common/src/ |
| H A D | rabbit_misc.erl | 70 -export([ensure_timer/4, stop_timer/2, send_after/3, cancel_timer/1]).
244 -spec ensure_timer(A, non_neg_integer(), non_neg_integer(), any()) -> A.
1281 ensure_timer(State, Idx, After, Msg) -> function
|