| /dports/net/frr7-pythontools/frr-frr-7.5.1/lib/ |
| H A D | wheel.h | 27 struct timer_wheel { struct
82 struct timer_wheel *wheel_init(struct thread_master *master, int period,
90 void wheel_delete(struct timer_wheel *);
95 int wheel_stop(struct timer_wheel *wheel);
100 int wheel_start(struct timer_wheel *wheel);
110 int wheel_add_item(struct timer_wheel *wheel, void *item);
120 int wheel_remove_item(struct timer_wheel *wheel, void *item);
|
| H A D | wheel.c | 39 struct timer_wheel *wheel; in wheel_timer_thread_helper()
72 struct timer_wheel *wheel; in wheel_timer_thread()
82 struct timer_wheel *wheel_init(struct thread_master *master, int period, in wheel_init()
87 struct timer_wheel *wheel; in wheel_init()
90 wheel = XCALLOC(MTYPE_TIMER_WHEEL, sizeof(struct timer_wheel)); in wheel_init()
113 void wheel_delete(struct timer_wheel *wheel) in wheel_delete()
127 int wheel_stop(struct timer_wheel *wheel) in wheel_stop()
133 int wheel_start(struct timer_wheel *wheel) in wheel_start()
142 int wheel_add_item(struct timer_wheel *wheel, void *item) in wheel_add_item()
156 int wheel_remove_item(struct timer_wheel *wheel, void *item) in wheel_remove_item()
|
| /dports/net/frr7/frr-frr-7.5.1/lib/ |
| H A D | wheel.h | 27 struct timer_wheel { struct
82 struct timer_wheel *wheel_init(struct thread_master *master, int period,
90 void wheel_delete(struct timer_wheel *);
95 int wheel_stop(struct timer_wheel *wheel);
100 int wheel_start(struct timer_wheel *wheel);
110 int wheel_add_item(struct timer_wheel *wheel, void *item);
120 int wheel_remove_item(struct timer_wheel *wheel, void *item);
|
| H A D | wheel.c | 39 struct timer_wheel *wheel; in wheel_timer_thread_helper()
72 struct timer_wheel *wheel; in wheel_timer_thread()
82 struct timer_wheel *wheel_init(struct thread_master *master, int period, in wheel_init()
87 struct timer_wheel *wheel; in wheel_init()
90 wheel = XCALLOC(MTYPE_TIMER_WHEEL, sizeof(struct timer_wheel)); in wheel_init()
113 void wheel_delete(struct timer_wheel *wheel) in wheel_delete()
127 int wheel_stop(struct timer_wheel *wheel) in wheel_stop()
133 int wheel_start(struct timer_wheel *wheel) in wheel_start()
142 int wheel_add_item(struct timer_wheel *wheel, void *item) in wheel_add_item()
156 int wheel_remove_item(struct timer_wheel *wheel, void *item) in wheel_remove_item()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/dbparser/ |
| H A D | groupingby.c | 40 TimerWheel *timer_wheel; member
56 TimerWheel *timer_wheel; member
128 timer_wheel_free(self->timer_wheel); in _free_persist_data()
217 timer_wheel_set_time(self->timer_wheel, now.tv_sec, msg_emitter); in grouping_by_set_time()
219 evt_tag_long("utc", timer_wheel_get_time(self->timer_wheel)), in grouping_by_set_time()
247 …timer_wheel_set_time(self->timer_wheel, timer_wheel_get_time(self->timer_wheel) + diff_sec, &msg_e… in _grouping_by_timer_tick()
430 timer_wheel_del_timer(self->timer_wheel, context->timer); in _perform_groupby()
497 self->timer_wheel = persist_data->timer_wheel; in _load_correlation_state()
503 self->timer_wheel = timer_wheel_new(); in _load_correlation_state()
560 persist_data->timer_wheel = self->timer_wheel; in _store_data_in_persist()
[all …]
|
| H A D | patterndb.c | 69 TimerWheel *timer_wheel; member
227 now = timer_wheel_get_time(db->timer_wheel); in _is_action_within_rate_limit()
460 …timer_wheel_set_time(self->timer_wheel, timer_wheel_get_time(self->timer_wheel) + diff_sec, &proce… in pattern_db_timer_tick()
498 timer_wheel_set_time(self->timer_wheel, now.tv_sec, process_params); in _advance_time_based_on_message()
511 new_time = timer_wheel_get_time(self->timer_wheel) + timeout; in pattern_db_advance_time()
512 timer_wheel_set_time(self->timer_wheel, new_time, &process_params); in pattern_db_advance_time()
738 timer_wheel_expire_all(self->timer_wheel, &process_params); in pattern_db_expire_state()
750 self->timer_wheel = timer_wheel_new(); in _init_state()
751 timer_wheel_set_associated_data(self->timer_wheel, self, NULL); in _init_state()
757 if (self->timer_wheel) in _destroy_state()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/doxygen/dox/so_5/ |
| H A D | so_5_5_0__timer_thread_factories.dox | 25 // Use timer_wheel mechanism with wheel size 10000
35 of timers (millions or tens of millions or even more) then timer_wheel must be
|
| H A D | so_5_5__in_depth_timers.dox | 333 - timer_wheel
337 \subsection so_5_5__in_depth_timers__timer_thread__timer_wheel timer_wheel Mechanism
342 Because of that timer_wheel mechanism should be used when the application needs
378 // Use timer_wheel mechanism with wheel size 10000
|
| /dports/net/olsrd/olsrd-0.9.8/src/ |
| H A D | scheduler.c | 76 static struct list_node timer_wheel[TIMER_WHEEL_SLOTS]; variable
644 list_head_init(&timer_wheel[idx]); in olsr_init_timers()
678 struct list_node *const timer_head_node = &timer_wheel[*last_run & TIMER_WHEEL_MASK]; in walk_timers()
783 timer_head_node = &timer_wheel[wheel_slot & TIMER_WHEEL_MASK]; in olsr_flush_timers()
939 list_add_before(&timer_wheel[timer->timer_clock & TIMER_WHEEL_MASK], &timer->timer_list); in olsr_start_timer()
1040 list_add_before(&timer_wheel[timer->timer_clock & TIMER_WHEEL_MASK], &timer->timer_list); in olsr_change_timer()
|
| /dports/net/frr7/frr-frr-7.5.1/pimd/ |
| H A D | pim_instance.h | 162 struct timer_wheel *upstream_sg_wheel;
|
| /dports/net/frr7-pythontools/frr-frr-7.5.1/pimd/ |
| H A D | pim_instance.h | 162 struct timer_wheel *upstream_sg_wheel;
|
| /dports/www/h2o-devel/h2o-dcc7134/lib/common/ |
| H A D | timerwheel.c | 81 static size_t timer_wheel(size_t num_wheels, uint64_t delta) in timer_wheel() function
213 wheel = timer_wheel(ctx->num_wheels, wheel_abs - ctx->last_run); in link_timer()
|
| /dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/erts/emulator/beam/ |
| H A D | erl_hl_timer.c | 836 erts_twheel_cancel_timer(esdp->timer_wheel, &tmr->u.tw_tmr); in cancel_tw_timer()
944 erts_twheel_set_timer(esdp->timer_wheel, in create_tw_timer()
1206 erts_twheel_cancel_timer(esdp->timer_wheel, in create_hl_timer()
1208 erts_twheel_set_timer(esdp->timer_wheel, in create_hl_timer()
1329 erts_twheel_set_timer(esdp->timer_wheel, in hlt_service_timeout()
1379 erts_twheel_cancel_timer(esdp->timer_wheel, in hlt_delete_timer()
1385 erts_twheel_set_timer(esdp->timer_wheel, in hlt_delete_timer()
2982 erts_aligned_scheduler_data[six].esd.timer_wheel; in erts_debug_callback_timer_foreach()
|
| H A D | erl_time_sup.c | 685 erts_twheel_set_timer(esdp->timer_wheel, in check_time_correction()
735 erts_twheel_set_timer(esdp->timer_wheel, in check_time_offset()
841 erts_twheel_set_timer(esdp->timer_wheel, in late_init_time_correction()
1193 esdp->timer_wheel = erts_create_timer_wheel(esdp); in erts_sched_init_time_sup()
1194 esdp->next_tmo_ref = erts_get_next_timeout_reference(esdp->timer_wheel); in erts_sched_init_time_sup()
|
| /dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/erts/emulator/beam/ |
| H A D | erl_hl_timer.c | 836 erts_twheel_cancel_timer(esdp->timer_wheel, &tmr->u.tw_tmr); in cancel_tw_timer()
944 erts_twheel_set_timer(esdp->timer_wheel, in create_tw_timer()
1206 erts_twheel_cancel_timer(esdp->timer_wheel, in create_hl_timer()
1208 erts_twheel_set_timer(esdp->timer_wheel, in create_hl_timer()
1329 erts_twheel_set_timer(esdp->timer_wheel, in hlt_service_timeout()
1379 erts_twheel_cancel_timer(esdp->timer_wheel, in hlt_delete_timer()
1385 erts_twheel_set_timer(esdp->timer_wheel, in hlt_delete_timer()
2982 erts_aligned_scheduler_data[six].esd.timer_wheel; in erts_debug_callback_timer_foreach()
|
| H A D | erl_time_sup.c | 685 erts_twheel_set_timer(esdp->timer_wheel, in check_time_correction()
735 erts_twheel_set_timer(esdp->timer_wheel, in check_time_offset()
841 erts_twheel_set_timer(esdp->timer_wheel, in late_init_time_correction()
1193 esdp->timer_wheel = erts_create_timer_wheel(esdp); in erts_sched_init_time_sup()
1194 esdp->next_tmo_ref = erts_get_next_timeout_reference(esdp->timer_wheel); in erts_sched_init_time_sup()
|
| /dports/lang/erlang-runtime24/otp-OTP-24.1.7/erts/emulator/beam/ |
| H A D | erl_hl_timer.c | 836 erts_twheel_cancel_timer(esdp->timer_wheel, &tmr->u.tw_tmr); in cancel_tw_timer()
944 erts_twheel_set_timer(esdp->timer_wheel, in create_tw_timer()
1206 erts_twheel_cancel_timer(esdp->timer_wheel, in create_hl_timer()
1208 erts_twheel_set_timer(esdp->timer_wheel, in create_hl_timer()
1329 erts_twheel_set_timer(esdp->timer_wheel, in hlt_service_timeout()
1379 erts_twheel_cancel_timer(esdp->timer_wheel, in hlt_delete_timer()
1385 erts_twheel_set_timer(esdp->timer_wheel, in hlt_delete_timer()
2993 erts_aligned_scheduler_data[six].esd.timer_wheel; in erts_debug_callback_timer_foreach()
|
| H A D | erl_time_sup.c | 685 erts_twheel_set_timer(esdp->timer_wheel, in check_time_correction()
735 erts_twheel_set_timer(esdp->timer_wheel, in check_time_offset()
841 erts_twheel_set_timer(esdp->timer_wheel, in late_init_time_correction()
1193 esdp->timer_wheel = erts_create_timer_wheel(esdp); in erts_sched_init_time_sup()
1194 esdp->next_tmo_ref = erts_get_next_timeout_reference(esdp->timer_wheel); in erts_sched_init_time_sup()
|
| /dports/lang/erlang-wx/otp-OTP-24.1.7/erts/emulator/beam/ |
| H A D | erl_hl_timer.c | 836 erts_twheel_cancel_timer(esdp->timer_wheel, &tmr->u.tw_tmr); in cancel_tw_timer()
944 erts_twheel_set_timer(esdp->timer_wheel, in create_tw_timer()
1206 erts_twheel_cancel_timer(esdp->timer_wheel, in create_hl_timer()
1208 erts_twheel_set_timer(esdp->timer_wheel, in create_hl_timer()
1329 erts_twheel_set_timer(esdp->timer_wheel, in hlt_service_timeout()
1379 erts_twheel_cancel_timer(esdp->timer_wheel, in hlt_delete_timer()
1385 erts_twheel_set_timer(esdp->timer_wheel, in hlt_delete_timer()
2993 erts_aligned_scheduler_data[six].esd.timer_wheel; in erts_debug_callback_timer_foreach()
|
| H A D | erl_time_sup.c | 685 erts_twheel_set_timer(esdp->timer_wheel, in check_time_correction()
735 erts_twheel_set_timer(esdp->timer_wheel, in check_time_offset()
841 erts_twheel_set_timer(esdp->timer_wheel, in late_init_time_correction()
1193 esdp->timer_wheel = erts_create_timer_wheel(esdp); in erts_sched_init_time_sup()
1194 esdp->next_tmo_ref = erts_get_next_timeout_reference(esdp->timer_wheel); in erts_sched_init_time_sup()
|
| /dports/lang/erlang/otp-OTP-24.1.7/erts/emulator/beam/ |
| H A D | erl_hl_timer.c | 836 erts_twheel_cancel_timer(esdp->timer_wheel, &tmr->u.tw_tmr); in cancel_tw_timer()
944 erts_twheel_set_timer(esdp->timer_wheel, in create_tw_timer()
1206 erts_twheel_cancel_timer(esdp->timer_wheel, in create_hl_timer()
1208 erts_twheel_set_timer(esdp->timer_wheel, in create_hl_timer()
1329 erts_twheel_set_timer(esdp->timer_wheel, in hlt_service_timeout()
1379 erts_twheel_cancel_timer(esdp->timer_wheel, in hlt_delete_timer()
1385 erts_twheel_set_timer(esdp->timer_wheel, in hlt_delete_timer()
2993 erts_aligned_scheduler_data[six].esd.timer_wheel; in erts_debug_callback_timer_foreach()
|
| H A D | erl_time_sup.c | 685 erts_twheel_set_timer(esdp->timer_wheel, in check_time_correction()
735 erts_twheel_set_timer(esdp->timer_wheel, in check_time_offset()
841 erts_twheel_set_timer(esdp->timer_wheel, in late_init_time_correction()
1193 esdp->timer_wheel = erts_create_timer_wheel(esdp); in erts_sched_init_time_sup()
1194 esdp->next_tmo_ref = erts_get_next_timeout_reference(esdp->timer_wheel); in erts_sched_init_time_sup()
|
| /dports/lang/erlang-java/otp-OTP-24.1.7/erts/emulator/beam/ |
| H A D | erl_hl_timer.c | 836 erts_twheel_cancel_timer(esdp->timer_wheel, &tmr->u.tw_tmr); in cancel_tw_timer()
944 erts_twheel_set_timer(esdp->timer_wheel, in create_tw_timer()
1206 erts_twheel_cancel_timer(esdp->timer_wheel, in create_hl_timer()
1208 erts_twheel_set_timer(esdp->timer_wheel, in create_hl_timer()
1329 erts_twheel_set_timer(esdp->timer_wheel, in hlt_service_timeout()
1379 erts_twheel_cancel_timer(esdp->timer_wheel, in hlt_delete_timer()
1385 erts_twheel_set_timer(esdp->timer_wheel, in hlt_delete_timer()
2993 erts_aligned_scheduler_data[six].esd.timer_wheel; in erts_debug_callback_timer_foreach()
|
| /dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/erts/emulator/beam/ |
| H A D | erl_hl_timer.c | 836 erts_twheel_cancel_timer(esdp->timer_wheel, &tmr->u.tw_tmr); in cancel_tw_timer()
944 erts_twheel_set_timer(esdp->timer_wheel, in create_tw_timer()
1206 erts_twheel_cancel_timer(esdp->timer_wheel, in create_hl_timer()
1208 erts_twheel_set_timer(esdp->timer_wheel, in create_hl_timer()
1329 erts_twheel_set_timer(esdp->timer_wheel, in hlt_service_timeout()
1379 erts_twheel_cancel_timer(esdp->timer_wheel, in hlt_delete_timer()
1385 erts_twheel_set_timer(esdp->timer_wheel, in hlt_delete_timer()
2975 erts_aligned_scheduler_data[six].esd.timer_wheel; in erts_debug_callback_timer_foreach()
|
| /dports/www/h2o-devel/h2o-dcc7134/t/00unit/lib/common/ |
| H A D | timerwheel.c | 56 wi = timer_wheel(num_wheels, delta); in test_slot_calc()
|