Change fifo_domain_t to rt_domain_t + bug fixes.

1 files changed, 29 insertions, 0 deletions

diff --git a/include/linux/rt_domain.h b/include/linux/rt_domain.h
index 7157a04ac2..237eac7bb4 100644
--- a/include/linux/rt_domain.h
+++ b/include/linux/rt_domain.h
@@ -38,6 +38,7 @@ void rt_domain_init(rt_domain_t *rt, check_resched_needed_t f,
 void __add_ready(rt_domain_t* rt, struct task_struct *new);
 void __add_release(rt_domain_t* rt, struct task_struct *task);
 
+struct task_struct* __take_ready_rq(rt_domain_t* rt, runqueue_t* rq, int cpu);
 struct task_struct* __take_ready(rt_domain_t* rt);
 struct task_struct* __peek_ready(rt_domain_t* rt);
 
@@ -56,6 +57,18 @@ static inline void add_ready(rt_domain_t* rt, struct task_struct *new)
         write_unlock_irqrestore(&rt->ready_lock, flags);
 }
 
+static inline struct task_struct* take_ready(rt_domain_t* rt)
+{
+        unsigned long flags;    
+        struct task_struct* ret;
+        /* first we need the write lock for rt_ready_queue */   
+        write_lock_irqsave(&rt->ready_lock, flags);
+        ret = __take_ready(rt);
+        write_unlock_irqrestore(&rt->ready_lock, flags);
+        return ret;
+}
+
+
 static inline void add_release(rt_domain_t* rt, struct task_struct *task)
 {
         unsigned long flags;    
@@ -65,5 +78,21 @@ static inline void add_release(rt_domain_t* rt, struct task_struct *task)
         spin_unlock_irqrestore(&rt->release_lock, flags);
 }
 
+static inline int __jobs_pending(rt_domain_t* rt)
+{
+        return !list_empty(&rt->ready_queue);
+}
+
+static inline int jobs_pending(rt_domain_t* rt)
+{
+        unsigned long flags;    
+        int ret;
+        /* first we need the write lock for rt_ready_queue */   
+        read_lock_irqsave(&rt->ready_lock, flags);
+        ret = __jobs_pending(rt);
+        read_unlock_irqrestore(&rt->ready_lock, flags);
+        return ret;
+}
+
 
 #endif