qmgr_time.h

Go to the documentation of this file.

#ifndef __QMGR_TIME_H__
#define __QMGR_TIME_H__

#include <linux/aquosa/qos_types.h>

#ifndef QOS_KS
/* US includes */
#  include <aquosa/qres_lib.h>
#  include <time.h>
#  include <sys/time.h>
#else
/* KS includes */
#  include <linux/aquosa/qres_gw_ks.h>
#endif

typedef struct qmgr_time_t {
  struct timespec old_abs_time; 
  qres_time_t old_exec_time;    
  struct timespec abs_time;     
  qres_time_t exec_time;        
} qmgr_time_t;

static inline void timespec_add(struct timespec *dst_ts, struct timespec *src1_ts, struct timespec *src2_ts) {
  dst_ts->tv_sec = src1_ts->tv_sec + src2_ts->tv_sec;
  dst_ts->tv_nsec = src1_ts->tv_nsec + src2_ts->tv_nsec;
  long int delta_ns = dst_ts->tv_nsec - 1000000000lu;
  if (delta_ns >= 0) {
    dst_ts->tv_nsec = delta_ns;
    dst_ts->tv_sec++;
  }
}

static inline void timespec_sub(struct timespec *dst_ts, struct timespec *src1_ts, struct timespec *src2_ts) {
  dst_ts->tv_sec = src1_ts->tv_sec - src2_ts->tv_sec;
  dst_ts->tv_nsec = src1_ts->tv_nsec - src2_ts->tv_nsec;
  if (dst_ts->tv_nsec < 0) {
    dst_ts->tv_nsec = dst_ts->tv_nsec + 1000000000lu;
    dst_ts->tv_sec--;
  }
}

static inline signed long timespec_sub_us(struct timespec *ts2, struct timespec *ts1) {
  return (ts2->tv_sec - ts1->tv_sec) * 1000000l + ((signed long) (ts2->tv_nsec - ts1->tv_nsec)) / 1000l;
}

static void qmgr_time_init(qmgr_time_t *self);

static qres_time_t qmgr_time_get_elapsed(qmgr_time_t *self);

static qres_time_t qmgr_time_get_exec(qmgr_time_t *self);

/************************************************************
 * Implementation of inline functions
 ************************************************************/

static void qmgr_time_tick_xs(qres_time_t *p_exec_time, struct timespec *p_abs_time) {
#ifndef QOS_KS
  qres_sid_t sid;
  qres_get_sid(0, 0, &sid);
  clock_gettime(CLOCK_MONOTONIC, p_abs_time);
  qres_get_exec_time(sid, p_exec_time, NULL);
#else
  struct timespec now;
  qres_atime_t now2;
  qres_server_t *srv = qres_find_by_rres(rres_find_by_task(current));
  clock_gettime(CLOCK_MONOTONIC, &now);
  *p_abs_time = now;
  qres_get_exec_abs_time(srv, p_exec_time, &now2);
#endif
}

static inline void qmgr_time_init(qmgr_time_t *self) {
  self->exec_time = 0;
  self->abs_time.tv_sec = 0;
  self->abs_time.tv_nsec = 0;
}

static inline void qmgr_time_tick(qmgr_time_t *self) {
  self->old_exec_time = self->exec_time;
  self->old_abs_time = self->abs_time;
  qmgr_time_tick_xs(&self->exec_time, &self->abs_time);
}

/* Be sure to have called qmgr_time_tick() at least twice, before calling this function */
static inline qres_time_t qmgr_time_get_elapsed(qmgr_time_t *self) {
  return timespec_sub_us(&self->abs_time, &self->old_abs_time);
}

/* Be sure to have called qmgr_time_tick() at least twice, before calling this function */
static inline qres_time_t qmgr_time_get_exec(qmgr_time_t *self) {
  return self->exec_time - self->old_exec_time;
}

static inline struct timespec qmgr_time_get_abs_time(qmgr_time_t *self) {
  return self->abs_time;
}

#endif

---