| /dpdk/drivers/event/octeontx/ |
| H A D | timvf_worker.c | 9 struct rte_event_timer * const tim) in timvf_timer_reg_checks() argument 11 if (unlikely(tim->state)) { in timvf_timer_reg_checks() 12 tim->state = RTE_EVENT_TIMER_ERROR; in timvf_timer_reg_checks() 17 if (unlikely(!tim->timeout_ticks || in timvf_timer_reg_checks() 19 tim->state = tim->timeout_ticks ? RTE_EVENT_TIMER_ERROR_TOOLATE in timvf_timer_reg_checks() 35 (tim->ev.event & 0xFFFFFFFFF); in timvf_format_event() 36 entry->wqe = tim->ev.u64; in timvf_format_event() 57 ret = timvf_rem_entry(tim[index]); in timvf_timer_cancel_burst() 80 tim[index], &entry); in timvf_timer_arm_burst_sp() 116 tim[index], &entry); in timvf_timer_arm_burst_mp() [all …]
|
| H A D | timvf_worker.h | 164 if (tim->impl_opaque[1] == 0 || in timvf_rem_entry() 165 tim->impl_opaque[0] == 0) in timvf_rem_entry() 169 if (entry->wqe != tim->ev.u64) { in timvf_rem_entry() 170 tim->impl_opaque[1] = tim->impl_opaque[0] = 0; in timvf_rem_entry() 178 tim->impl_opaque[1] = tim->impl_opaque[0] = 0; in timvf_rem_entry() 186 tim->impl_opaque[1] = tim->impl_opaque[0] = 0; in timvf_rem_entry() 278 tim->impl_opaque[0] = tim->impl_opaque[1] = 0; in timvf_add_entry_sp() 294 tim->state = RTE_EVENT_TIMER_ARMED; in timvf_add_entry_sp() 331 tim->impl_opaque[0] = tim->impl_opaque[1] = 0; in timvf_add_entry_mp() 413 chunk, tim, ents, bkt); in timvf_add_entry_brst() [all …]
|
| H A D | timvf_evdev.h | 203 struct rte_event_timer **tim, const uint16_t nb_timers); 205 struct rte_event_timer **tim, const uint16_t nb_timers); 208 struct rte_event_timer **tim, const uint16_t nb_timers); 210 struct rte_event_timer **tim, const uint16_t nb_timers); 213 struct rte_event_timer **tim, const uint16_t nb_timers); 215 struct rte_event_timer **tim, const uint64_t timeout_tick, 219 struct rte_event_timer **tim, const uint64_t timeout_tick,
|
| /dpdk/lib/timer/ |
| H A D | rte_timer.c | 514 tim->f = fct; in __rte_timer_reset() 713 for ( ; tim != NULL; tim = next_tim) { in __rte_timer_manage() 735 for (tim = run_first_tim; tim != NULL; tim = next_tim) { in __rte_timer_manage() 741 tim->f(tim, tim->arg); in __rte_timer_manage() 772 __rte_timer_reset(tim, tim->expire + tim->period, in __rte_timer_manage() 773 tim->period, lcore_id, tim->f, tim->arg, 1, in __rte_timer_manage() 874 for ( ; tim != NULL; tim = next_tim) { in rte_timer_alt_manage() 906 if (tim != NULL && tim->expire < min_expire) { in rte_timer_alt_manage() 927 f(tim); in rte_timer_alt_manage() 960 __rte_timer_reset(tim, tim->expire + tim->period, in rte_timer_alt_manage() [all …]
|
| H A D | rte_timer.h | 193 void rte_timer_init(struct rte_timer *tim); 237 int rte_timer_reset(struct rte_timer *tim, uint64_t ticks, 274 rte_timer_reset_sync(struct rte_timer *tim, uint64_t ticks, 301 int rte_timer_stop(struct rte_timer *tim); 318 void rte_timer_stop_sync(struct rte_timer *tim); 333 int rte_timer_pending(struct rte_timer *tim); 415 rte_timer_alt_reset(uint32_t timer_data_id, struct rte_timer *tim, 437 rte_timer_alt_stop(uint32_t timer_data_id, struct rte_timer *tim); 442 typedef void (*rte_timer_alt_manage_cb_t)(struct rte_timer *tim); 476 typedef void (*rte_timer_stop_all_cb_t)(struct rte_timer *tim, void *arg);
|
| /dpdk/drivers/event/cnxk/ |
| H A D | cnxk_tim_worker.c | 10 struct rte_event_timer *const tim) in cnxk_tim_arm_checks() argument 12 if (unlikely(tim->state)) { in cnxk_tim_arm_checks() 13 tim->state = RTE_EVENT_TIMER_ERROR; in cnxk_tim_arm_checks() 18 if (unlikely(!tim->timeout_ticks || in cnxk_tim_arm_checks() 20 tim->state = tim->timeout_ticks ? in cnxk_tim_arm_checks() 38 (tim->ev.event & 0xFFFFFFFFF); in cnxk_tim_format_event() 39 entry->wqe = tim->ev.u64; in cnxk_tim_format_event() 76 tim[index]->timeout_ticks, in cnxk_tim_timer_arm_burst() 80 tim[index]->timeout_ticks, in cnxk_tim_timer_arm_burst() 108 struct rte_event_timer **tim, in cnxk_tim_timer_arm_tmo_brst() argument [all …]
|
| H A D | cnxk_tim_worker.h | 288 tim->impl_opaque[0] = 0; in cnxk_tim_add_entry_sp() 289 tim->impl_opaque[1] = 0; in cnxk_tim_add_entry_sp() 389 tim->impl_opaque[0] = 0; in cnxk_tim_add_entry_mp() 527 tim, ents, bkt); in cnxk_tim_add_entry_brst() 571 if (tim->impl_opaque[1] == 0 || tim->impl_opaque[0] == 0) in cnxk_tim_rm_entry() 576 tim->impl_opaque[0] = 0; in cnxk_tim_rm_entry() 577 tim->impl_opaque[1] = 0; in cnxk_tim_rm_entry() 585 tim->impl_opaque[0] = 0; in cnxk_tim_rm_entry() 586 tim->impl_opaque[1] = 0; in cnxk_tim_rm_entry() 594 tim->impl_opaque[0] = 0; in cnxk_tim_rm_entry() [all …]
|
| H A D | cnxk_tim_evdev.c | 217 rc = roc_tim_lf_alloc(&dev->tim, adptr->data->id, NULL); in cnxk_tim_ring_create() 336 rc = roc_tim_lf_config(&dev->tim, tim_ring->ring_id, clk_src, in cnxk_tim_ring_create() 345 tim_ring->base = roc_tim_lf_base_get(&dev->tim, tim_ring->ring_id); in cnxk_tim_ring_create() 371 roc_tim_lf_free(&dev->tim, tim_ring->ring_id); in cnxk_tim_ring_create() 386 roc_tim_lf_free(&dev->tim, tim_ring->ring_id); in cnxk_tim_ring_free() 429 rc = roc_tim_lf_enable(&dev->tim, tim_ring->ring_id, in cnxk_tim_ring_start() 453 rc = roc_tim_lf_disable(&dev->tim, tim_ring->ring_id); in cnxk_tim_ring_stop() 685 dev->tim.roc_sso = sso; in cnxk_tim_init() 686 dev->tim.nb_lfs = dev->min_ring_cnt; in cnxk_tim_init() 687 rc = roc_tim_init(&dev->tim); in cnxk_tim_init() [all …]
|
| H A D | cnxk_tim_evdev.h | 89 struct roc_tim tim; member 274 struct rte_event_timer **tim, const uint16_t nb_timers); 281 struct rte_event_timer **tim, const uint64_t timeout_tick, \ 288 struct rte_event_timer **tim,
|
| /dpdk/app/test/ |
| H A D | test_timer_racecond.c | 36 static int reload_timer(struct rte_timer *tim); 41 timer_cb(struct rte_timer *tim, void *arg __rte_unused) in timer_cb() argument 45 if (tim == &timer[0]) in timer_cb() 49 PRIuPTR "\n", __func__, rte_lcore_id(), tim - timer); in timer_cb() 50 (void)reload_timer(tim); in timer_cb() 56 reload_timer(struct rte_timer *tim) in reload_timer() argument 64 (tim - timer); in reload_timer() 67 ret = rte_timer_reset(tim, ticks, PERIODICAL, main_lcore, timer_cb, NULL); in reload_timer() 71 rte_lcore_id(), tim - timer); in reload_timer()
|
| H A D | test_timer.c | 119 struct rte_timer tim; member 146 if (rte_timer_pending(tim)) in timer_stress_cb() 160 rte_timer_stop(&mytiminfo[0].tim); in timer_stress_cb() 191 rte_timer_stop_sync(&mytiminfo[0].tim); in timer_stress_main_loop() 407 if (rte_timer_pending(tim)) in timer_basic_cb() 438 rte_timer_stop(tim); in timer_basic_cb() 446 rte_timer_stop_sync(&mytiminfo[3].tim); in timer_basic_cb() 449 rte_timer_init(&mytiminfo[0].tim); in timer_basic_cb() 552 rte_timer_init(&mytiminfo[i].tim); in test_timer() 566 rte_timer_stop_sync(&mytiminfo[0].tim); in test_timer() [all …]
|
| H A D | test_timer_secondary.c | 77 handle_expired_timer(struct rte_timer *tim) in handle_expired_timer() argument 79 struct test_info *test_info = tim->arg; in handle_expired_timer() 82 test_info->expired_timers[test_info->expired_timers_idx++] = tim; in handle_expired_timer() 179 struct rte_timer *tim; in test_timer_secondary() local 188 rte_mempool_get(test_info->tim_mempool, (void **)&tim); in test_timer_secondary() 190 rte_timer_init(tim); in test_timer_secondary() 197 tim, ticks, SINGLE, in test_timer_secondary() 210 tim); in test_timer_secondary() 214 (void *)tim); in test_timer_secondary()
|
| H A D | test_event_timer_adapter.c | 438 const struct rte_event_timer tim = { in test_timer_state() local 449 *ev_tim = tim; in test_timer_state() 495 const struct rte_event_timer tim = { in _arm_timers() local 510 *ev_tim = tim; in _arm_timers() 609 const struct rte_event_timer tim = { in _arm_timers_burst() local 626 *ev_tim[j] = tim; in _arm_timers_burst() 706 *ev_tim = tim; in test_timer_cancel_periodic() 748 *ev_tim = tim; in test_timer_cancel() 791 *ev_tim = tim; in _cancel_producer() 833 *ev_tim[j] = tim; in _cancel_producer_burst() [all …]
|
| /dpdk/drivers/common/cnxk/ |
| H A D | roc_tim.c | 12 struct tim *tim = roc_tim_to_tim_priv(roc_tim); in tim_fill_msix() local 23 tim->tim_msix_offsets[i] = rsp->timlf_msixoff[i]; in tim_fill_msix() 229 struct tim *tim = roc_tim_to_tim_priv(roc_tim); in roc_tim_lf_alloc() local 255 tim->tim_msix_offsets[ring_id]); in roc_tim_lf_alloc() 278 struct tim *tim = roc_tim_to_tim_priv(roc_tim); in roc_tim_lf_free() local 284 tim->tim_msix_offsets[ring_id]); in roc_tim_lf_free() 319 PLT_STATIC_ASSERT(sizeof(struct tim) <= TIM_MEM_SZ); in roc_tim_init() 330 if (nb_lfs && (free_rsrc->tim < nb_lfs)) { in roc_tim_init() 332 free_rsrc->tim); in roc_tim_init() 343 attach_req->timlfs = nb_lfs ? nb_lfs : free_rsrc->tim; in roc_tim_init()
|
| H A D | roc_tim_priv.h | 8 struct tim { struct 16 static inline struct tim * 19 return (struct tim *)&roc_tim->reserved[0]; in roc_tim_to_tim_priv()
|
| H A D | roc_platform.h | 245 #define plt_tim_dbg(fmt, ...) plt_dbg(tim, fmt, ##__VA_ARGS__)
|
| H A D | roc_mbox.h | 417 uint16_t __io tim; member
|
| /dpdk/examples/timer/ |
| H A D | main.c | 27 timer0_cb(__rte_unused struct rte_timer *tim, in timer0_cb() argument 38 rte_timer_stop(tim); in timer0_cb() 44 timer1_cb(__rte_unused struct rte_timer *tim, in timer1_cb() argument 55 rte_timer_reset(tim, hz/3, SINGLE, lcore_id, timer1_cb, NULL); in timer1_cb()
|
| /dpdk/app/test-eventdev/ |
| H A D | test_perf_common.c | 163 struct rte_event_timer tim; in perf_event_timer_producer() local 174 tim.ev.op = RTE_EVENT_OP_NEW; in perf_event_timer_producer() 176 tim.ev.queue_id = p->queue_id; in perf_event_timer_producer() 189 m[i]->tim = tim; in perf_event_timer_producer() 191 m[i]->tim.ev.event_ptr = m[i]; in perf_event_timer_producer() 229 struct rte_event_timer tim; in perf_event_timer_producer_burst() local 240 tim.ev.op = RTE_EVENT_OP_NEW; in perf_event_timer_producer_burst() 242 tim.ev.queue_id = p->queue_id; in perf_event_timer_producer_burst() 255 m[i]->tim = tim; in perf_event_timer_producer_burst() 257 m[i]->tim.ev.event_ptr = m[i]; in perf_event_timer_producer_burst() [all …]
|
| H A D | test_perf_common.h | 78 struct rte_event_timer tim; member
|
| /dpdk/lib/eventdev/ |
| H A D | rte_event_timer_adapter.c | 604 swtim_callback(struct rte_timer *tim) in swtim_callback() argument 606 struct rte_event_timer *evtim = tim->arg; in swtim_callback() 626 ret = rte_timer_alt_reset(sw->timer_data_id, tim, 0, SINGLE, in swtim_callback() 657 sw->expired_timers[sw->n_expired_timers++] = tim; in swtim_callback() 927 swtim_free_tim(struct rte_timer *tim, void *arg) in swtim_free_tim() argument 931 rte_mempool_put(sw->tim_pool, tim); in swtim_free_tim() 1050 struct rte_timer *tim, *tims[nb_evtims]; in __swtim_arm_burst() local 1130 tim = tims[i]; in __swtim_arm_burst() 1131 rte_timer_init(tim); in __swtim_arm_burst() 1133 evtims[i]->impl_opaque[0] = (uintptr_t)tim; in __swtim_arm_burst() [all …]
|
| /dpdk/lib/power/ |
| H A D | rte_power_empty_poll.h | 219 rte_empty_poll_detection(struct rte_timer *tim, void *arg);
|
| H A D | rte_power_empty_poll.c | 353 rte_empty_poll_detection(struct rte_timer *tim, void *arg) in rte_empty_poll_detection() argument 360 RTE_SET_USED(tim); in rte_empty_poll_detection()
|
| /dpdk/examples/l3fwd-power/ |
| H A D | main.c | 438 power_timer_cb(__rte_unused struct rte_timer *tim, in power_timer_cb() argument 2351 update_telemetry(__rte_unused struct rte_timer *tim, in update_telemetry() argument
|