kal_timer_rtsim.h

Go to the documentation of this file.

#ifndef KAL_TIMER_WHEEL_H_
#define KAL_TIMER_WHEEL_H_

#include <linux/time.h>
#ifdef QOS_KS
#  include <linux/timer.h>
#  include <linux/jiffies.h>
#endif

#include "kal_time.h"
#include <linux/aquosa/qos_types.h>

/********************** TIMER RELATED **********************/

//kal_rv kal_timer_init(kal_timer_t *p_tmr, kal_timer_callback_t cb);
//
//kal_rv kal_timer_set_abs(kal_timer_t *p_tmr, kal_time_t abs_time);
//kal_rv kal_timer_set_rel(kal_timer_t *p_tmr, kal_time_t rel_time);
//
//kal_rv kal_timer_forward(kal_timer_t *p_tmr, kal_time_t rel_time);
//
//kal_rv kal_timer_start(kal_timer_t *p_tmr);
//kal_rv kal_timer_stop(kal_timer_t *p_tmr);

#include "kal_arg.h"
typedef void (*linux_timer_cb)(unsigned long cb_data);
typedef void (*kal_timer_cb)(kal_arg_t cb_data);

typedef struct {
  struct timer_list timer;      //< The kernel timer instance
  kal_timer_cb timer_cb;        //< The KAL timer callback
  kal_arg_t timer_cb_data;      //< The opaque data to be supplied to the KAL timer callback
  char handler_running;         //< Whether we are within this timer handler
} kal_timer_t;

#if defined(QOS_KS)
static inline void set_timer_expires(kal_timer_t* p_timer, unsigned long expires) {
  p_timer->expires = expires;
}

static inline unsigned long get_timer_expires(kal_timer_t* p_timer) {
  return p_timer->expires;
}

#else
void setup_timer(void* p_timer, void* p_call_back, kal_arg_t cb_data);
void add_timer(void* p_timer);
void del_timer(void* p_timer);
void set_timer_expires(void* p_timer, unsigned long expires);
unsigned long get_timer_expires(void* p_timer);
int timer_pending(void* p_timer);
static inline void del_timer_sync (void* p_timer) { del_timer(p_timer);}

struct timer_list {
  /* Timers are handled externally, so 
     only a pointer to external data is necessary here */
  void* timer;
};

#endif

void timer_callback(unsigned long cb_data) {
  kal_timer_t p_timer = (kal_timer_t *) cb_data;
  p_timer->handler_running = 1;
  p_timer->timer_cb(p_timer->
}

static inline void kal_timer_init(kal_timer_t * p_timer, kal_timer_cb cb, kal_arg_t cb_data) {
  setup_timer(p_timer, (linux_timer_cb) cb, (unsigned long) cb_data);
}

static inline void kal_timer_init_now(kal_timer_t * p_timer, kal_timer_cb cb, kal_arg_t cb_data) {
  unsigned long expires = get_jiffies();
  kal_timer_init(p_timer, cb, cb_data);
  //printk("Setting expires to %lu (timer unarmed)\n", expires);
  set_timer_expires(p_timer, expires);
}

static inline void kal_timer_set(kal_timer_t * p_timer, kal_time_t t) {
  unsigned long expires = kal_time2jiffies(t);
  //printk("Setting expires to %lu\n", expires);
  del_timer(p_timer);
  set_timer_expires(p_timer, expires);
  add_timer(p_timer);
}

static inline void kal_timer_del(kal_timer_t * p_timer) {
  del_timer_sync(p_timer);
}

static inline void kal_timer_forward(kal_timer_t * p_timer, kal_time_t t) {
  unsigned long expires = get_timer_expires(p_timer) + kal_time2jiffies(t);
  //printk("Forwarding expires from %lu to %lu (delta=%lu)\n",
  //        p_timer->expires, expires, kal_time2jiffies(t));
  kal_timer_del(p_timer);
  set_timer_expires(p_timer, expires);
  add_timer(p_timer);
}

static inline int kal_timer_pending(kal_timer_t *p_timer) {
  return timer_pending(p_timer);
}

#endif /*KAL_TIMER_WHEEL_H_*/

---