Introduce rt_domain_t.

1 files changed, 69 insertions, 0 deletions

diff --git a/include/linux/rt_domain.h b/include/linux/rt_domain.h
new file mode 100644
index 0000000000..7157a04ac2
--- /dev/null
+++ b/include/linux/rt_domain.h
@@ -0,0 +1,69 @@
+/* CLEANUP: Add comments and make it less messy.
+ *
+ */
+
+#ifndef __UNC_RT_DOMAIN_H__
+#define __UNC_RT_DOMAIN_H__
+
+struct _rt_domain;
+
+typedef int (*check_resched_needed_t)(struct _rt_domain *rt);
+typedef void (*release_at_t)(struct task_struct *t, jiffie_t start);
+
+typedef struct _rt_domain {
+        /* runnable rt tasks are in here */
+        rwlock_t                        ready_lock;
+        struct list_head                ready_queue; 
+
+        /* real-time tasks waiting for release are in here */
+        spinlock_t                      release_lock;
+        struct list_head                release_queue;
+
+        /* how do we check if we need to kick another CPU? */
+        check_resched_needed_t          check_resched;
+
+        /* how are tasks ordered in the ready queue? */
+        list_cmp_t                      order;
+} rt_domain_t;
+
+#define next_ready(rt) \
+        (list_entry((rt)->ready_queue.next, struct task_struct, rt_list))
+
+#define ready_jobs_pending(rt) \
+        (!list_empty(&(rt)->ready_queue))
+
+void rt_domain_init(rt_domain_t *rt, check_resched_needed_t f, 
+                    list_cmp_t order);
+
+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(rt_domain_t* rt);
+struct task_struct* __peek_ready(rt_domain_t* rt);
+
+void try_release_pending(rt_domain_t* rt);
+void __release_pending(rt_domain_t* rt);
+
+void rerelease_all(rt_domain_t *rt, release_at_t release);
+void __rerelease_all(rt_domain_t *rt, release_at_t release);
+
+static inline void add_ready(rt_domain_t* rt, struct task_struct *new)
+{
+        unsigned long flags;    
+        /* first we need the write lock for rt_ready_queue */   
+        write_lock_irqsave(&rt->ready_lock, flags);
+        __add_ready(rt, new);
+        write_unlock_irqrestore(&rt->ready_lock, flags);
+}
+
+static inline void add_release(rt_domain_t* rt, struct task_struct *task)
+{
+        unsigned long flags;    
+        /* first we need the write lock for rt_ready_queue */   
+        spin_lock_irqsave(&rt->release_lock, flags);
+        __add_release(rt, task);
+        spin_unlock_irqrestore(&rt->release_lock, flags);
+}
+
+
+#endif