Padding in MCS-PDR qnodes (XCC)
[akaros.git] / kern / include / kthread.h
1 /* Copyright (c) 2010 The Regents of the University of California
2  * Barret Rhoden <brho@cs.berkeley.edu>
3  * See LICENSE for details.
4  *
5  * Kernel threading.  These are for blocking within the kernel for whatever
6  * reason, usually during blocking IO operations.  Check out
7  * Documentation/kthreads.txt for more info than you care about. */
8
9 #ifndef ROS_KERN_KTHREAD_H
10 #define ROS_KERN_KTHREAD_H
11
12 #include <ros/common.h>
13 #include <trap.h>
14 #include <sys/queue.h>
15 #include <atomic.h>
16
17 struct proc;
18 struct kthread;
19 TAILQ_HEAD(kthread_tailq, kthread);
20
21 /* This captures the essence of a kernel context that we want to suspend.  When
22  * a kthread is running, we make sure its stacktop is the default kernel stack,
23  * meaning it will receive the interrupts from userspace. */
24 struct kthread {
25         struct trapframe                        context;
26         uintptr_t                                       stacktop;
27         struct proc                                     *proc;
28         struct syscall                          *sysc;
29         TAILQ_ENTRY(kthread)            link;
30         /* ID, other shit, etc */
31 };
32
33 /* Semaphore for kthreads to sleep on.  0 or less means you need to sleep */
34 struct semaphore {
35         struct kthread_tailq            waiters;
36         int                                             nr_signals;
37         spinlock_t                                      lock;
38         bool                                            irq_okay;
39 };
40
41 struct cond_var {
42         struct semaphore                        sem;
43         spinlock_t                                      lock;
44         unsigned long                           nr_waiters;
45         bool                                            irq_okay;
46 };
47
48 void kthread_init(void);
49 void restart_kthread(struct kthread *kthread);
50 void kthread_runnable(struct kthread *kthread);
51 void kthread_yield(void);
52
53 void sem_init(struct semaphore *sem, int signals);
54 void sem_init_irqsave(struct semaphore *sem, int signals);
55 void sem_down(struct semaphore *sem);
56 bool sem_up(struct semaphore *sem);
57 void sem_down_irqsave(struct semaphore *sem, int8_t *irq_state);
58 bool sem_up_irqsave(struct semaphore *sem, int8_t *irq_state);
59
60 void cv_init(struct cond_var *cv);
61 void cv_init_irqsave(struct cond_var *cv);
62 void cv_lock(struct cond_var *cv);
63 void cv_unlock(struct cond_var *cv);
64 void cv_lock_irqsave(struct cond_var *cv, int8_t *irq_state);
65 void cv_unlock_irqsave(struct cond_var *cv, int8_t *irq_state);
66 void cv_wait_and_unlock(struct cond_var *cv);   /* does not mess with irqs */
67 void cv_wait(struct cond_var *cv);
68 void __cv_signal(struct cond_var *cv);
69 void __cv_broadcast(struct cond_var *cv);
70 void cv_signal(struct cond_var *cv);
71 void cv_broadcast(struct cond_var *cv);
72 void cv_signal_irqsave(struct cond_var *cv, int8_t *irq_state);
73 void cv_broadcast_irqsave(struct cond_var *cv, int8_t *irq_state);
74
75 #endif /* ROS_KERN_KTHREAD_H */