drivers/event/octeontx2/otx2_tim_worker.c

   1 /* SPDX-License-Identifier: BSD-3-Clause
   2  * Copyright(C) 2019 Marvell International Ltd.
   3  */
   4
   5 #include "otx2_tim_evdev.h"
   6 #include "otx2_tim_worker.h"
   7
   8 static inline int
   9 tim_arm_checks(const struct otx2_tim_ring * const tim_ring,
  10                struct rte_event_timer * const tim)
  11 {
  12         if (unlikely(tim->state)) {
  13                 tim->state = RTE_EVENT_TIMER_ERROR;
  14                 rte_errno = EALREADY;
  15                 goto fail;
  16         }
  17
  18         if (unlikely(!tim->timeout_ticks ||
  19                      tim->timeout_ticks >= tim_ring->nb_bkts)) {
  20                 tim->state = tim->timeout_ticks ? RTE_EVENT_TIMER_ERROR_TOOLATE
  21                         : RTE_EVENT_TIMER_ERROR_TOOEARLY;
  22                 rte_errno = EINVAL;
  23                 goto fail;
  24         }
  25
  26         return 0;
  27
  28 fail:
  29         return -EINVAL;
  30 }
  31
  32 static inline void
  33 tim_format_event(const struct rte_event_timer * const tim,
  34                  struct otx2_tim_ent * const entry)
  35 {
  36         entry->w0 = (tim->ev.event & 0xFFC000000000) >> 6 |
  37                 (tim->ev.event & 0xFFFFFFFFF);
  38         entry->wqe = tim->ev.u64;
  39 }
  40
  41 static inline void
  42 tim_sync_start_cyc(struct otx2_tim_ring *tim_ring)
  43 {
  44         uint64_t cur_cyc = rte_rdtsc();
  45         uint32_t real_bkt;
  46
  47         if (cur_cyc - tim_ring->last_updt_cyc > tim_ring->tot_int) {
  48                 real_bkt = otx2_read64(tim_ring->base + TIM_LF_RING_REL) >> 44;
  49                 cur_cyc = rte_rdtsc();
  50
  51                 tim_ring->ring_start_cyc = cur_cyc -
  52                                                 (real_bkt * tim_ring->tck_int);
  53                 tim_ring->last_updt_cyc = cur_cyc;
  54         }
  55
  56 }
  57
  58 static __rte_always_inline uint16_t
  59 tim_timer_arm_burst(const struct rte_event_timer_adapter *adptr,
  60                     struct rte_event_timer **tim,
  61                     const uint16_t nb_timers,
  62                     const uint8_t flags)
  63 {
  64         struct otx2_tim_ring *tim_ring = adptr->data->adapter_priv;
  65         struct otx2_tim_ent entry;
  66         uint16_t index;
  67         int ret;
  68
  69         tim_sync_start_cyc(tim_ring);
  70         for (index = 0; index < nb_timers; index++) {
  71                 if (tim_arm_checks(tim_ring, tim[index]))
  72                         break;
  73
  74                 tim_format_event(tim[index], &entry);
  75                 if (flags & OTX2_TIM_SP)
  76                         ret = tim_add_entry_sp(tim_ring,
  77                                                tim[index]->timeout_ticks,
  78                                                tim[index], &entry, flags);
  79                 if (flags & OTX2_TIM_MP)
  80                         ret = tim_add_entry_mp(tim_ring,
  81                                                tim[index]->timeout_ticks,
  82                                                tim[index], &entry, flags);
  83
  84                 if (unlikely(ret)) {
  85                         rte_errno = -ret;
  86                         break;
  87                 }
  88         }
  89
  90         if (flags & OTX2_TIM_ENA_STATS)
  91                 rte_atomic64_add(&tim_ring->arm_cnt, index);
  92
  93         return index;
  94 }
  95
  96 static __rte_always_inline uint16_t
  97 tim_timer_arm_tmo_brst(const struct rte_event_timer_adapter *adptr,
  98                        struct rte_event_timer **tim,
  99                        const uint64_t timeout_tick,
 100                        const uint16_t nb_timers, const uint8_t flags)
 101 {
 102         struct otx2_tim_ent entry[OTX2_TIM_MAX_BURST] __rte_cache_aligned;
 103         struct otx2_tim_ring *tim_ring = adptr->data->adapter_priv;
 104         uint16_t set_timers = 0;
 105         uint16_t arr_idx = 0;
 106         uint16_t idx;
 107         int ret;
 108
 109         if (unlikely(!timeout_tick || timeout_tick >= tim_ring->nb_bkts)) {
 110                 const enum rte_event_timer_state state = timeout_tick ?
 111                         RTE_EVENT_TIMER_ERROR_TOOLATE :
 112                         RTE_EVENT_TIMER_ERROR_TOOEARLY;
 113                 for (idx = 0; idx < nb_timers; idx++)
 114                         tim[idx]->state = state;
 115
 116                 rte_errno = EINVAL;
 117                 return 0;
 118         }
 119
 120         tim_sync_start_cyc(tim_ring);
 121         while (arr_idx < nb_timers) {
 122                 for (idx = 0; idx < OTX2_TIM_MAX_BURST && (arr_idx < nb_timers);
 123                      idx++, arr_idx++) {
 124                         tim_format_event(tim[arr_idx], &entry[idx]);
 125                 }
 126                 ret = tim_add_entry_brst(tim_ring, timeout_tick,
 127                                          &tim[set_timers], entry, idx, flags);
 128                 set_timers += ret;
 129                 if (ret != idx)
 130                         break;
 131         }
 132         if (flags & OTX2_TIM_ENA_STATS)
 133                 rte_atomic64_add(&tim_ring->arm_cnt, set_timers);
 134
 135         return set_timers;
 136 }
 137
 138 #define FP(_name, _f4, _f3, _f2, _f1, _flags)                           \
 139 uint16_t __rte_noinline                                                   \
 140 otx2_tim_arm_burst_ ## _name(const struct rte_event_timer_adapter *adptr, \
 141                              struct rte_event_timer **tim,                \
 142                              const uint16_t nb_timers)                    \
 143 {                                                                         \
 144         return tim_timer_arm_burst(adptr, tim, nb_timers, _flags);        \
 145 }
 146 TIM_ARM_FASTPATH_MODES
 147 #undef FP
 148
 149 #define FP(_name, _f3, _f2, _f1, _flags)                                \
 150 uint16_t __rte_noinline                                                 \
 151 otx2_tim_arm_tmo_tick_burst_ ## _name(                                  \
 152                         const struct rte_event_timer_adapter *adptr,    \
 153                                       struct rte_event_timer **tim,     \
 154                                       const uint64_t timeout_tick,      \
 155                                       const uint16_t nb_timers)         \
 156 {                                                                       \
 157         return tim_timer_arm_tmo_brst(adptr, tim, timeout_tick,         \
 158                         nb_timers, _flags);                             \
 159 }
 160 TIM_ARM_TMO_FASTPATH_MODES
 161 #undef FP
 162
 163 uint16_t
 164 otx2_tim_timer_cancel_burst(const struct rte_event_timer_adapter *adptr,
 165                             struct rte_event_timer **tim,
 166                             const uint16_t nb_timers)
 167 {
 168         uint16_t index;
 169         int ret;
 170
 171         RTE_SET_USED(adptr);
 172         for (index = 0; index < nb_timers; index++) {
 173                 if (tim[index]->state == RTE_EVENT_TIMER_CANCELED) {
 174                         rte_errno = EALREADY;
 175                         break;
 176                 }
 177
 178                 if (tim[index]->state != RTE_EVENT_TIMER_ARMED) {
 179                         rte_errno = EINVAL;
 180                         break;
 181                 }
 182                 ret = tim_rm_entry(tim[index]);
 183                 if (ret) {
 184                         rte_errno = -ret;
 185                         break;
 186                 }
 187         }
 188
 189         return index;
 190 }