rres_dispatch_gsd_2.6.h

Go to the documentation of this file.

/*
 * Copyright (C) 2002 Luca Abeni, 2007 Luca Marzario, Tommaso Cucinotta
 * This is Free Software; see GPL.txt for details
 */

#ifndef __DISPATCH_GSD_26_H__
#define __DISPATCH_GSD_26_H__

#include "rres_config.h"

#include <linux/sched.h>

#define GENSCHED_DISABLED 1024     
#define RRES_DISPATCH_PRIORITY 65  
static inline int task_ready(struct task_struct * task) {
  return ((task->state == TASK_RUNNING) || (task->state == GENSCHED_DISABLED));
}

#ifdef __AQUOSA_OLD_PATCH
#define set_task_rr_prio genschedify
#endif

/* Slightly new interface */
#define rres_init_sched_param(task)             \
  set_task_rr_prio(task, RRES_DISPATCH_PRIORITY)

#define rres_task_sched_default(task)           \
  do {                                          \
    if (task->state == GENSCHED_DISABLED)       \
      task->state = TASK_RUNNING;               \
    set_task_rr_prio(task, -1);                 \
  } while (0)

static inline void stop_task(struct task_struct *t) {
  unsigned long flags;
  read_lock_irqsave(&tasklist_lock, flags);
  qos_log_state(t);
  if (t->state == TASK_RUNNING) {
    set_task_state(t, GENSCHED_DISABLED);
  }
  qos_log_state(t);
  read_unlock_irqrestore(&tasklist_lock, flags);
}

static inline void dispatch_task(struct task_struct *t) {
  unsigned long flags;

  read_lock_irqsave(&tasklist_lock, flags);
  qos_log_state(t);
  if (t->state == GENSCHED_DISABLED) {
     if (!t->array) {
        set_task_state(t, TASK_STOPPED); /* To fake wake_up_process() */
        wake_up_process(t);
     } else {
        set_task_state(t, TASK_RUNNING);
     }
   }
   qos_log_state(t);
   read_unlock_irqrestore(&tasklist_lock, flags);
}

static inline void rres_idle_cpu(void) {
  set_tsk_need_resched(kal_task_current());
}

#endif /* __DISPATCH_GSD_26_H__ */

---