mintmr.h

Go to the documentation of this file.

#ifndef NDNDPDK_CORE_MINTMR_H
#define NDNDPDK_CORE_MINTMR_H

 
#include "../dpdk/tsc.h"

typedef struct MinTmr {
  struct cds_list_head h;
} MinTmr;

__attribute__((nonnull)) static __rte_always_inline void
MinTmr_Init(MinTmr* tmr) {
  CDS_INIT_LIST_HEAD(&tmr->h);
}
 
typedef void (*MinTmrCb)(MinTmr* tmr, uintptr_t ctx);

typedef struct MinSched {
  TscDuration interval;
  TscTime nextTime;
  MinTmrCb cb;
  uintptr_t ctx;
  uint32_t lastSlot;
  uint32_t slotMask;
  uint32_t nSlots;
  struct cds_list_head slot[];
} MinSched;

__attribute__((returns_nonnull)) MinSched*
MinSched_New(int nSlotBits, TscDuration interval, MinTmrCb cb, uintptr_t ctx);

__attribute__((nonnull)) void
MinSched_Clear(MinSched* sched);

__attribute__((nonnull)) void
MinSched_Close(MinSched* sched);
 
__attribute__((nonnull)) void
MinSched_Trigger_(MinSched* sched, TscTime now);

__attribute__((nonnull)) static __rte_always_inline void
MinSched_Trigger(MinSched* sched) {
  TscTime now = rte_get_tsc_cycles();
  if (now >= sched->nextTime) {
    MinSched_Trigger_(sched, now);
  }
}

__attribute__((nonnull)) static inline TscDuration
MinSched_GetMaxDelay(MinSched* sched) {
  return sched->interval * (sched->nSlots - 2);
}
 
__attribute__((nonnull)) void
MinTmr_Cancel_(MinTmr* tmr);

__attribute__((nonnull)) static __rte_always_inline void
MinTmr_Cancel(MinTmr* tmr) {
  if (likely(tmr->h.next != NULL && !cds_list_empty(&tmr->h))) {
    MinTmr_Cancel_(tmr);
  }
}

__attribute__((nonnull)) bool
MinTmr_After(MinTmr* tmr, TscDuration after, MinSched* sched);

__attribute__((nonnull)) static inline bool
MinTmr_At(MinTmr* tmr, TscTime at, MinSched* sched) {
  TscTime now = rte_get_tsc_cycles();
  return MinTmr_After(tmr, at - now, sched);
}
 
#endif // NDNDPDK_CORE_MINTMR_H