rres_server.h

Go to the documentation of this file.

#ifndef __RRES_SERVER_H__
#define __RRES_SERVER_H__

#ifndef __RRES_READY_QUEUE_H__
#  error "Include rres_ready_queue.h first"
#endif

#include "rres_config.h"
#include "qos_debug.h"
#include "qos_types.h"
#include "qos_list.h"
#include "kal_timer.h"
#include "kal_sched.h"

struct server_t {
  qres_sid_t id;              
  kal_time_t period;          
  qres_time_t period_us;      
  kal_time_t max_budget;      
  qres_time_t max_budget_us;  
  kal_time_t c;               
  kal_time_t deadline;        
  qos_bw_t U_current;         
  struct rres_stat {          
    unsigned long int n_rcg;  
    kal_time_t exec_time;     
  } stat;                     
  struct list_head slist;     
  unsigned int flags;         
  rq_placeholder_t rq_ph;

  qos_bw_t (*get_bandwidth)(struct server_t *srv);

  qos_rv (*cleanup)(struct server_t *srv);

  struct list_head ready_tasks; 
  struct list_head blocked_tasks; 
  kal_timer_t reactive;         
#ifdef CONST_TIME_DISPATCH
  struct list_head disp_tasks;  
#endif

  int forbid_reorder;           
  unsigned int weight;          
};

typedef struct server_t server_t;

extern qos_bw_t U_tot;          
#ifdef SHRUB
extern qos_bw_t U_active_tot;   
#endif

#define U_LUB2 (U_LUB+r2bw_c(1,100))

static inline qos_rv rres_cleanup_server(server_t *srv) {
  if (RRES_PARANOID)
    qos_chk_do(srv != NULL, return QOS_E_INTERNAL_ERROR);
  return srv->cleanup(srv);
}

static inline void rres_set_weight(server_t *srv, unsigned int weight) {
  srv->weight = weight;
}

static inline unsigned int rres_get_weight(server_t *srv) {
  return srv->weight;
}

struct task_list {
  struct task_struct *task;       
  struct list_head node;          
  qos_bool_t is_stopped;          
  server_t *srv;                  
};

#endif

---