rres_dispatch_new.h

Go to the documentation of this file.

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

/* ChangeLog
 * Moved show_task() to file debug.h
 */

#ifndef __DISPATCH_NEW_H__
#define __DISPATCH_NEW_H__

#include "rres_config.h"
#include <linux/sched.h>
#include <linux/aquosa/qos_debug.h>

static inline int task_ready(struct task_struct * task) {
  return (task->state == TASK_RUNNING);
}

#define rres_init_sched_param(task)             \
  set_task_rr_prio(task, RRES_DISPATCH_PRIORITY)

#define rres_task_sched_default(task)           \
  set_task_rr_prio(task, -1)

#define SCHED_OTHER SCHED_NORMAL

extern void activate_task_local(struct task_struct *task);
extern void deactivate_task_local(struct task_struct *task);

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

  //read_lock_irqsave(&tasklist_lock, flags);
  if (t->array) {
    qos_log_debug("Deactivating task %d", t->pid);
    deactivate_task_local(t);
  } else {
    qos_log_debug("Skipping deactivation of task %d", t->pid);
  }
  //read_unlock_irqrestore(&tasklist_lock, flags);
}

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

  //read_lock_irqsave(&tasklist_lock, flags);
  if (! t->array) {
    qos_log_debug("Activating task %d", t->pid);
    activate_task_local(t);
  } else {
    qos_log_debug("Skipping activation of task %d", t->pid);
  }
  //read_unlock_irqrestore(&tasklist_lock, flags);
}

//static inline void rres_idle_cpu(void) {
//  set_tsk_need_resched(current);
//}

//static inline void rres_dispatch_setup(server_t *srv) {
//  /* Empty on purpose */
//}

#endif /* __DISPATCH_NEW_H__ */

---