1#ifndef _LINUX_SCHED_H
2#define _LINUX_SCHED_H
3
4#include <asm/param.h>
5
6extern unsigned long event;
7
8#include <linux/config.h>
9#include <linux/binfmts.h>
10#include <linux/threads.h>
11#include <linux/kernel.h>
12#include <linux/types.h>
13#include <linux/times.h>
14#include <linux/timex.h>
15#include <linux/rbtree.h>
16
17#include <asm/system.h>
18#include <asm/semaphore.h>
19#include <asm/page.h>
20#include <asm/ptrace.h>
21#include <asm/mmu.h>
22
23#include <linux/smp.h>
24#include <linux/tty.h>
25#include <linux/sem.h>
26#include <linux/signal.h>
27#include <linux/securebits.h>
28#include <linux/fs_struct.h>
29
30struct exec_domain;
31
32
33
34
35#define CSIGNAL 0x000000ff
36#define CLONE_VM 0x00000100
37#define CLONE_FS 0x00000200
38#define CLONE_FILES 0x00000400
39#define CLONE_SIGHAND 0x00000800
40#define CLONE_PID 0x00001000
41#define CLONE_PTRACE 0x00002000
42#define CLONE_VFORK 0x00004000
43#define CLONE_PARENT 0x00008000
44#define CLONE_THREAD 0x00010000
45#define CLONE_NEWNS 0x00020000
46
47#define CLONE_SIGNAL (CLONE_SIGHAND | CLONE_THREAD)
48
49
50
51
52
53
54
55
56
57
58
59extern unsigned long avenrun[];
60
61#define FSHIFT 11
62#define FIXED_1 (1<<FSHIFT)
63#define LOAD_FREQ (5*HZ)
64#define EXP_1 1884
65#define EXP_5 2014
66#define EXP_15 2037
67
68#define CALC_LOAD(load,exp,n) \
69 load *= exp; \
70 load += n*(FIXED_1-exp); \
71 load >>= FSHIFT;
72
73#define CT_TO_SECS(x) ((x) / HZ)
74#define CT_TO_USECS(x) (((x) % HZ) * 1000000/HZ)
75
76extern int nr_running, nr_threads;
77extern int last_pid;
78
79#include <linux/fs.h>
80#include <linux/time.h>
81#include <linux/param.h>
82#include <linux/resource.h>
83#ifdef __KERNEL__
84#include <linux/timer.h>
85#endif
86
87#include <asm/processor.h>
88
89#define TASK_RUNNING 0
90#define TASK_INTERRUPTIBLE 1
91#define TASK_UNINTERRUPTIBLE 2
92#define TASK_ZOMBIE 4
93#define TASK_STOPPED 8
94
95#define __set_task_state(tsk, state_value) \
96 do { (tsk)->state = (state_value); } while (0)
97#define set_task_state(tsk, state_value) \
98 set_mb((tsk)->state, (state_value))
99
100#define __set_current_state(state_value) \
101 do { current->state = (state_value); } while (0)
102#define set_current_state(state_value) \
103 set_mb(current->state, (state_value))
104
105
106
107
108#define SCHED_OTHER 0
109#define SCHED_FIFO 1
110#define SCHED_RR 2
111
112
113
114
115
116#define SCHED_YIELD 0x10
117
118struct sched_param {
119 int sched_priority;
120};
121
122struct completion;
123
124#ifdef __KERNEL__
125
126#include <linux/spinlock.h>
127
128
129
130
131
132
133
134extern rwlock_t tasklist_lock;
135extern spinlock_t runqueue_lock;
136extern spinlock_t mmlist_lock;
137
138extern void sched_init(void);
139extern void init_idle(void);
140extern void show_state(void);
141extern void cpu_init (void);
142extern void trap_init(void);
143extern void update_process_times(int user);
144extern void update_one_process(struct task_struct *p, unsigned long user,
145 unsigned long system, int cpu);
146
147#define MAX_SCHEDULE_TIMEOUT LONG_MAX
148extern signed long FASTCALL(schedule_timeout(signed long timeout));
149asmlinkage void schedule(void);
150
151extern int schedule_task(struct tq_struct *task);
152extern void flush_scheduled_tasks(void);
153extern int start_context_thread(void);
154extern int current_is_keventd(void);
155
156#if CONFIG_SMP
157extern void set_cpus_allowed(struct task_struct *p, unsigned long new_mask);
158#else
159# define set_cpus_allowed(p, new_mask) do { } while (0)
160#endif
161
162
163
164
165
166#define NR_OPEN_DEFAULT BITS_PER_LONG
167
168struct namespace;
169
170
171
172struct files_struct {
173 atomic_t count;
174 rwlock_t file_lock;
175 int max_fds;
176 int max_fdset;
177 int next_fd;
178 struct file ** fd;
179 fd_set *close_on_exec;
180 fd_set *open_fds;
181 fd_set close_on_exec_init;
182 fd_set open_fds_init;
183 struct file * fd_array[NR_OPEN_DEFAULT];
184};
185
186#define INIT_FILES \
187{ \
188 count: ATOMIC_INIT(1), \
189 file_lock: RW_LOCK_UNLOCKED, \
190 max_fds: NR_OPEN_DEFAULT, \
191 max_fdset: __FD_SETSIZE, \
192 next_fd: 0, \
193 fd: &init_files.fd_array[0], \
194 close_on_exec: &init_files.close_on_exec_init, \
195 open_fds: &init_files.open_fds_init, \
196 close_on_exec_init: { { 0, } }, \
197 open_fds_init: { { 0, } }, \
198 fd_array: { NULL, } \
199}
200
201
202#define DEFAULT_MAX_MAP_COUNT (65536)
203
204extern int max_map_count;
205
206struct mm_struct {
207 struct vm_area_struct * mmap;
208 rb_root_t mm_rb;
209 struct vm_area_struct * mmap_cache;
210 pgd_t * pgd;
211 atomic_t mm_users;
212 atomic_t mm_count;
213 int map_count;
214 struct rw_semaphore mmap_sem;
215 spinlock_t page_table_lock;
216
217 struct list_head mmlist;
218
219
220
221
222 unsigned long start_code, end_code, start_data, end_data;
223 unsigned long start_brk, brk, start_stack;
224 unsigned long arg_start, arg_end, env_start, env_end;
225 unsigned long rss, total_vm, locked_vm;
226 unsigned long def_flags;
227 unsigned long cpu_vm_mask;
228 unsigned long swap_address;
229
230 unsigned dumpable:1;
231
232
233 mm_context_t context;
234};
235
236extern int mmlist_nr;
237
238#define INIT_MM(name) \
239{ \
240 mm_rb: RB_ROOT, \
241 pgd: swapper_pg_dir, \
242 mm_users: ATOMIC_INIT(2), \
243 mm_count: ATOMIC_INIT(1), \
244 mmap_sem: __RWSEM_INITIALIZER(name.mmap_sem), \
245 page_table_lock: SPIN_LOCK_UNLOCKED, \
246 mmlist: LIST_HEAD_INIT(name.mmlist), \
247}
248
249struct signal_struct {
250 atomic_t count;
251 struct k_sigaction action[_NSIG];
252 spinlock_t siglock;
253};
254
255
256#define INIT_SIGNALS { \
257 count: ATOMIC_INIT(1), \
258 action: { {{0,}}, }, \
259 siglock: SPIN_LOCK_UNLOCKED \
260}
261
262
263
264
265struct user_struct {
266 atomic_t __count;
267 atomic_t processes;
268 atomic_t files;
269
270
271 struct user_struct *next, **pprev;
272 uid_t uid;
273};
274
275#define get_current_user() ({ \
276 struct user_struct *__user = current->user; \
277 atomic_inc(&__user->__count); \
278 __user; })
279
280extern struct user_struct root_user;
281#define INIT_USER (&root_user)
282
283struct task_struct {
284
285
286
287 volatile long state;
288 unsigned long flags;
289 int sigpending;
290 mm_segment_t addr_limit;
291
292
293
294 struct exec_domain *exec_domain;
295 volatile long need_resched;
296 unsigned long ptrace;
297
298 int lock_depth;
299
300
301
302
303
304
305 long counter;
306 long nice;
307 unsigned long policy;
308 struct mm_struct *mm;
309 int processor;
310
311
312
313
314
315
316
317
318 unsigned long cpus_runnable, cpus_allowed;
319
320
321
322
323 struct list_head run_list;
324 unsigned long sleep_time;
325
326 struct task_struct *next_task, *prev_task;
327 struct mm_struct *active_mm;
328 struct list_head local_pages;
329 unsigned int allocation_order, nr_local_pages;
330
331
332 struct linux_binfmt *binfmt;
333 int exit_code, exit_signal;
334 int pdeath_signal;
335
336 unsigned long personality;
337 int did_exec:1;
338 unsigned task_dumpable:1;
339 pid_t pid;
340 pid_t pgrp;
341 pid_t tty_old_pgrp;
342 pid_t session;
343 pid_t tgid;
344
345 int leader;
346
347
348
349
350
351 struct task_struct *p_opptr, *p_pptr, *p_cptr, *p_ysptr, *p_osptr;
352 struct list_head thread_group;
353
354
355 struct task_struct *pidhash_next;
356 struct task_struct **pidhash_pprev;
357
358 wait_queue_head_t wait_chldexit;
359 struct completion *vfork_done;
360 unsigned long rt_priority;
361 unsigned long it_real_value, it_prof_value, it_virt_value;
362 unsigned long it_real_incr, it_prof_incr, it_virt_incr;
363 struct timer_list real_timer;
364 struct tms times;
365 unsigned long start_time;
366 long per_cpu_utime[NR_CPUS], per_cpu_stime[NR_CPUS];
367
368 unsigned long min_flt, maj_flt, nswap, cmin_flt, cmaj_flt, cnswap;
369 int swappable:1;
370
371 uid_t uid,euid,suid,fsuid;
372 gid_t gid,egid,sgid,fsgid;
373 int ngroups;
374 gid_t groups[NGROUPS];
375 kernel_cap_t cap_effective, cap_inheritable, cap_permitted;
376 int keep_capabilities:1;
377 struct user_struct *user;
378
379 struct rlimit rlim[RLIM_NLIMITS];
380 unsigned short used_math;
381 char comm[16];
382
383 int link_count, total_link_count;
384 struct tty_struct *tty;
385 unsigned int locks;
386
387 struct sem_undo *semundo;
388 struct sem_queue *semsleeping;
389
390 struct thread_struct thread;
391
392 struct fs_struct *fs;
393
394 struct files_struct *files;
395
396 struct namespace *namespace;
397
398 spinlock_t sigmask_lock;
399 struct signal_struct *sig;
400
401 sigset_t blocked;
402 struct sigpending pending;
403
404 unsigned long sas_ss_sp;
405 size_t sas_ss_size;
406 int (*notifier)(void *priv);
407 void *notifier_data;
408 sigset_t *notifier_mask;
409
410
411 u32 parent_exec_id;
412 u32 self_exec_id;
413
414 spinlock_t alloc_lock;
415
416
417 void *journal_info;
418};
419
420
421
422
423#define PF_ALIGNWARN 0x00000001
424
425#define PF_STARTING 0x00000002
426#define PF_EXITING 0x00000004
427#define PF_FORKNOEXEC 0x00000040
428#define PF_SUPERPRIV 0x00000100
429#define PF_DUMPCORE 0x00000200
430#define PF_SIGNALED 0x00000400
431#define PF_MEMALLOC 0x00000800
432#define PF_MEMDIE 0x00001000
433#define PF_FREE_PAGES 0x00002000
434#define PF_NOIO 0x00004000
435
436#define PF_USEDFPU 0x00100000
437
438
439
440
441
442#define PT_PTRACED 0x00000001
443#define PT_TRACESYS 0x00000002
444#define PT_DTRACE 0x00000004
445#define PT_TRACESYSGOOD 0x00000008
446#define PT_PTRACE_CAP 0x00000010
447
448#define is_dumpable(tsk) ((tsk)->task_dumpable && (tsk)->mm && (tsk)->mm->dumpable)
449
450
451
452
453
454#define _STK_LIM (8*1024*1024)
455
456#define DEF_COUNTER (10*HZ/100)
457#define MAX_COUNTER (20*HZ/100)
458#define DEF_NICE (0)
459
460extern void yield(void);
461
462
463
464
465extern struct exec_domain default_exec_domain;
466
467
468
469
470
471#define INIT_TASK(tsk) \
472{ \
473 state: 0, \
474 flags: 0, \
475 sigpending: 0, \
476 addr_limit: KERNEL_DS, \
477 exec_domain: &default_exec_domain, \
478 lock_depth: -1, \
479 counter: DEF_COUNTER, \
480 nice: DEF_NICE, \
481 policy: SCHED_OTHER, \
482 mm: NULL, \
483 active_mm: &init_mm, \
484 cpus_runnable: ~0UL, \
485 cpus_allowed: ~0UL, \
486 run_list: LIST_HEAD_INIT(tsk.run_list), \
487 next_task: &tsk, \
488 prev_task: &tsk, \
489 p_opptr: &tsk, \
490 p_pptr: &tsk, \
491 thread_group: LIST_HEAD_INIT(tsk.thread_group), \
492 wait_chldexit: __WAIT_QUEUE_HEAD_INITIALIZER(tsk.wait_chldexit),\
493 real_timer: { \
494 function: it_real_fn \
495 }, \
496 cap_effective: CAP_INIT_EFF_SET, \
497 cap_inheritable: CAP_INIT_INH_SET, \
498 cap_permitted: CAP_FULL_SET, \
499 keep_capabilities: 0, \
500 rlim: INIT_RLIMITS, \
501 user: INIT_USER, \
502 comm: "swapper", \
503 thread: INIT_THREAD, \
504 fs: &init_fs, \
505 files: &init_files, \
506 sigmask_lock: SPIN_LOCK_UNLOCKED, \
507 sig: &init_signals, \
508 pending: { NULL, &tsk.pending.head, {{0}}}, \
509 blocked: {{0}}, \
510 alloc_lock: SPIN_LOCK_UNLOCKED, \
511 journal_info: NULL, \
512}
513
514
515#ifndef INIT_TASK_SIZE
516# define INIT_TASK_SIZE 2048*sizeof(long)
517#endif
518
519union task_union {
520 struct task_struct task;
521 unsigned long stack[INIT_TASK_SIZE/sizeof(long)];
522};
523
524extern union task_union init_task_union;
525
526extern struct mm_struct init_mm;
527extern struct task_struct *init_tasks[NR_CPUS];
528
529
530#define PIDHASH_SZ (4096 >> 2)
531extern struct task_struct *pidhash[PIDHASH_SZ];
532
533#define pid_hashfn(x) ((((x) >> 8) ^ (x)) & (PIDHASH_SZ - 1))
534
535static inline void hash_pid(struct task_struct *p)
536{
537 struct task_struct **htable = &pidhash[pid_hashfn(p->pid)];
538
539 if((p->pidhash_next = *htable) != NULL)
540 (*htable)->pidhash_pprev = &p->pidhash_next;
541 *htable = p;
542 p->pidhash_pprev = htable;
543}
544
545static inline void unhash_pid(struct task_struct *p)
546{
547 if(p->pidhash_next)
548 p->pidhash_next->pidhash_pprev = p->pidhash_pprev;
549 *p->pidhash_pprev = p->pidhash_next;
550}
551
552static inline struct task_struct *find_task_by_pid(int pid)
553{
554 struct task_struct *p, **htable = &pidhash[pid_hashfn(pid)];
555
556 for(p = *htable; p && p->pid != pid; p = p->pidhash_next)
557 ;
558
559 return p;
560}
561
562#define task_has_cpu(tsk) ((tsk)->cpus_runnable != ~0UL)
563
564static inline void task_set_cpu(struct task_struct *tsk, unsigned int cpu)
565{
566 tsk->processor = cpu;
567 tsk->cpus_runnable = 1UL << cpu;
568}
569
570static inline void task_release_cpu(struct task_struct *tsk)
571{
572 tsk->cpus_runnable = ~0UL;
573}
574
575
576extern struct user_struct * alloc_uid(uid_t);
577extern void free_uid(struct user_struct *);
578
579#include <asm/current.h>
580
581extern unsigned long volatile jiffies;
582extern unsigned long itimer_ticks;
583extern unsigned long itimer_next;
584extern struct timeval xtime;
585extern void do_timer(struct pt_regs *);
586
587extern unsigned int * prof_buffer;
588extern unsigned long prof_len;
589extern unsigned long prof_shift;
590
591#define CURRENT_TIME (xtime.tv_sec)
592
593extern void FASTCALL(__wake_up(wait_queue_head_t *q, unsigned int mode, int nr));
594extern void FASTCALL(__wake_up_sync(wait_queue_head_t *q, unsigned int mode, int nr));
595extern void FASTCALL(sleep_on(wait_queue_head_t *q));
596extern long FASTCALL(sleep_on_timeout(wait_queue_head_t *q,
597 signed long timeout));
598extern void FASTCALL(interruptible_sleep_on(wait_queue_head_t *q));
599extern long FASTCALL(interruptible_sleep_on_timeout(wait_queue_head_t *q,
600 signed long timeout));
601extern int FASTCALL(wake_up_process(struct task_struct * tsk));
602
603#define wake_up(x) __wake_up((x),TASK_UNINTERRUPTIBLE | TASK_INTERRUPTIBLE, 1)
604#define wake_up_nr(x, nr) __wake_up((x),TASK_UNINTERRUPTIBLE | TASK_INTERRUPTIBLE, nr)
605#define wake_up_all(x) __wake_up((x),TASK_UNINTERRUPTIBLE | TASK_INTERRUPTIBLE, 0)
606#define wake_up_sync(x) __wake_up_sync((x),TASK_UNINTERRUPTIBLE | TASK_INTERRUPTIBLE, 1)
607#define wake_up_sync_nr(x, nr) __wake_up_sync((x),TASK_UNINTERRUPTIBLE | TASK_INTERRUPTIBLE, nr)
608#define wake_up_interruptible(x) __wake_up((x),TASK_INTERRUPTIBLE, 1)
609#define wake_up_interruptible_nr(x, nr) __wake_up((x),TASK_INTERRUPTIBLE, nr)
610#define wake_up_interruptible_all(x) __wake_up((x),TASK_INTERRUPTIBLE, 0)
611#define wake_up_interruptible_sync(x) __wake_up_sync((x),TASK_INTERRUPTIBLE, 1)
612#define wake_up_interruptible_sync_nr(x, nr) __wake_up_sync((x),TASK_INTERRUPTIBLE, nr)
613asmlinkage long sys_wait4(pid_t pid,unsigned int * stat_addr, int options, struct rusage * ru);
614
615extern int in_group_p(gid_t);
616extern int in_egroup_p(gid_t);
617
618extern void proc_caches_init(void);
619extern void flush_signals(struct task_struct *);
620extern void flush_signal_handlers(struct task_struct *);
621extern void sig_exit(int, int, struct siginfo *);
622extern int dequeue_signal(sigset_t *, siginfo_t *);
623extern void block_all_signals(int (*notifier)(void *priv), void *priv,
624 sigset_t *mask);
625extern void unblock_all_signals(void);
626extern int send_sig_info(int, struct siginfo *, struct task_struct *);
627extern int force_sig_info(int, struct siginfo *, struct task_struct *);
628extern int kill_pg_info(int, struct siginfo *, pid_t);
629extern int kill_sl_info(int, struct siginfo *, pid_t);
630extern int kill_proc_info(int, struct siginfo *, pid_t);
631extern void notify_parent(struct task_struct *, int);
632extern void do_notify_parent(struct task_struct *, int);
633extern void force_sig(int, struct task_struct *);
634extern int send_sig(int, struct task_struct *, int);
635extern int kill_pg(pid_t, int, int);
636extern int kill_sl(pid_t, int, int);
637extern int kill_proc(pid_t, int, int);
638extern int do_sigaction(int, const struct k_sigaction *, struct k_sigaction *);
639extern int do_sigaltstack(const stack_t *, stack_t *, unsigned long);
640
641static inline int signal_pending(struct task_struct *p)
642{
643 return (p->sigpending != 0);
644}
645
646
647
648
649
650static inline int has_pending_signals(sigset_t *signal, sigset_t *blocked)
651{
652 unsigned long ready;
653 long i;
654
655 switch (_NSIG_WORDS) {
656 default:
657 for (i = _NSIG_WORDS, ready = 0; --i >= 0 ;)
658 ready |= signal->sig[i] &~ blocked->sig[i];
659 break;
660
661 case 4: ready = signal->sig[3] &~ blocked->sig[3];
662 ready |= signal->sig[2] &~ blocked->sig[2];
663 ready |= signal->sig[1] &~ blocked->sig[1];
664 ready |= signal->sig[0] &~ blocked->sig[0];
665 break;
666
667 case 2: ready = signal->sig[1] &~ blocked->sig[1];
668 ready |= signal->sig[0] &~ blocked->sig[0];
669 break;
670
671 case 1: ready = signal->sig[0] &~ blocked->sig[0];
672 }
673 return ready != 0;
674}
675
676
677
678
679
680static inline void recalc_sigpending(struct task_struct *t)
681{
682 t->sigpending = has_pending_signals(&t->pending.signal, &t->blocked);
683}
684
685
686
687static inline int on_sig_stack(unsigned long sp)
688{
689 return (sp - current->sas_ss_sp < current->sas_ss_size);
690}
691
692static inline int sas_ss_flags(unsigned long sp)
693{
694 return (current->sas_ss_size == 0 ? SS_DISABLE
695 : on_sig_stack(sp) ? SS_ONSTACK : 0);
696}
697
698extern int request_irq(unsigned int,
699 void (*handler)(int, void *, struct pt_regs *),
700 unsigned long, const char *, void *);
701extern void free_irq(unsigned int, void *);
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717static inline int suser(void)
718{
719 if (!issecure(SECURE_NOROOT) && current->euid == 0) {
720 current->flags |= PF_SUPERPRIV;
721 return 1;
722 }
723 return 0;
724}
725
726static inline int fsuser(void)
727{
728 if (!issecure(SECURE_NOROOT) && current->fsuid == 0) {
729 current->flags |= PF_SUPERPRIV;
730 return 1;
731 }
732 return 0;
733}
734
735
736
737
738
739
740
741static inline int capable(int cap)
742{
743#if 1
744 if (cap_raised(current->cap_effective, cap))
745#else
746 if (cap_is_fs_cap(cap) ? current->fsuid == 0 : current->euid == 0)
747#endif
748 {
749 current->flags |= PF_SUPERPRIV;
750 return 1;
751 }
752 return 0;
753}
754
755
756
757
758extern struct mm_struct * mm_alloc(void);
759
760extern struct mm_struct * start_lazy_tlb(void);
761extern void end_lazy_tlb(struct mm_struct *mm);
762
763
764extern inline void FASTCALL(__mmdrop(struct mm_struct *));
765static inline void mmdrop(struct mm_struct * mm)
766{
767 if (atomic_dec_and_test(&mm->mm_count))
768 __mmdrop(mm);
769}
770
771
772extern void mmput(struct mm_struct *);
773
774extern void mm_release(void);
775
776
777
778
779extern struct file ** alloc_fd_array(int);
780extern int expand_fd_array(struct files_struct *, int nr);
781extern void free_fd_array(struct file **, int);
782
783extern fd_set *alloc_fdset(int);
784extern int expand_fdset(struct files_struct *, int nr);
785extern void free_fdset(fd_set *, int);
786
787extern int copy_thread(int, unsigned long, unsigned long, unsigned long, struct task_struct *, struct pt_regs *);
788extern void flush_thread(void);
789extern void exit_thread(void);
790
791extern void exit_mm(struct task_struct *);
792extern void exit_files(struct task_struct *);
793extern void exit_sighand(struct task_struct *);
794
795extern void reparent_to_init(void);
796extern void daemonize(void);
797
798extern int do_execve(char *, char **, char **, struct pt_regs *);
799extern int do_fork(unsigned long, unsigned long, struct pt_regs *, unsigned long);
800
801extern void FASTCALL(add_wait_queue(wait_queue_head_t *q, wait_queue_t * wait));
802extern void FASTCALL(add_wait_queue_exclusive(wait_queue_head_t *q, wait_queue_t * wait));
803extern void FASTCALL(remove_wait_queue(wait_queue_head_t *q, wait_queue_t * wait));
804
805extern long kernel_thread(int (*fn)(void *), void * arg, unsigned long flags);
806
807#define __wait_event(wq, condition) \
808do { \
809 wait_queue_t __wait; \
810 init_waitqueue_entry(&__wait, current); \
811 \
812 add_wait_queue(&wq, &__wait); \
813 for (;;) { \
814 set_current_state(TASK_UNINTERRUPTIBLE); \
815 if (condition) \
816 break; \
817 schedule(); \
818 } \
819 current->state = TASK_RUNNING; \
820 remove_wait_queue(&wq, &__wait); \
821} while (0)
822
823#define wait_event(wq, condition) \
824do { \
825 if (condition) \
826 break; \
827 __wait_event(wq, condition); \
828} while (0)
829
830#define __wait_event_interruptible(wq, condition, ret) \
831do { \
832 wait_queue_t __wait; \
833 init_waitqueue_entry(&__wait, current); \
834 \
835 add_wait_queue(&wq, &__wait); \
836 for (;;) { \
837 set_current_state(TASK_INTERRUPTIBLE); \
838 if (condition) \
839 break; \
840 if (!signal_pending(current)) { \
841 schedule(); \
842 continue; \
843 } \
844 ret = -ERESTARTSYS; \
845 break; \
846 } \
847 current->state = TASK_RUNNING; \
848 remove_wait_queue(&wq, &__wait); \
849} while (0)
850
851#define wait_event_interruptible(wq, condition) \
852({ \
853 int __ret = 0; \
854 if (!(condition)) \
855 __wait_event_interruptible(wq, condition, __ret); \
856 __ret; \
857})
858
859#define REMOVE_LINKS(p) do { \
860 (p)->next_task->prev_task = (p)->prev_task; \
861 (p)->prev_task->next_task = (p)->next_task; \
862 if ((p)->p_osptr) \
863 (p)->p_osptr->p_ysptr = (p)->p_ysptr; \
864 if ((p)->p_ysptr) \
865 (p)->p_ysptr->p_osptr = (p)->p_osptr; \
866 else \
867 (p)->p_pptr->p_cptr = (p)->p_osptr; \
868 } while (0)
869
870#define SET_LINKS(p) do { \
871 (p)->next_task = &init_task; \
872 (p)->prev_task = init_task.prev_task; \
873 init_task.prev_task->next_task = (p); \
874 init_task.prev_task = (p); \
875 (p)->p_ysptr = NULL; \
876 if (((p)->p_osptr = (p)->p_pptr->p_cptr) != NULL) \
877 (p)->p_osptr->p_ysptr = p; \
878 (p)->p_pptr->p_cptr = p; \
879 } while (0)
880
881#define for_each_task(p) \
882 for (p = &init_task ; (p = p->next_task) != &init_task ; )
883
884#define for_each_thread(task) \
885 for (task = next_thread(current) ; task != current ; task = next_thread(task))
886
887#define next_thread(p) \
888 list_entry((p)->thread_group.next, struct task_struct, thread_group)
889
890#define thread_group_leader(p) (p->pid == p->tgid)
891
892static inline void del_from_runqueue(struct task_struct * p)
893{
894 nr_running--;
895 p->sleep_time = jiffies;
896 list_del(&p->run_list);
897 p->run_list.next = NULL;
898}
899
900static inline int task_on_runqueue(struct task_struct *p)
901{
902 return (p->run_list.next != NULL);
903}
904
905static inline void unhash_process(struct task_struct *p)
906{
907 if (task_on_runqueue(p))
908 out_of_line_bug();
909 write_lock_irq(&tasklist_lock);
910 nr_threads--;
911 unhash_pid(p);
912 REMOVE_LINKS(p);
913 list_del(&p->thread_group);
914 write_unlock_irq(&tasklist_lock);
915}
916
917
918static inline void task_lock(struct task_struct *p)
919{
920 spin_lock(&p->alloc_lock);
921}
922
923static inline void task_unlock(struct task_struct *p)
924{
925 spin_unlock(&p->alloc_lock);
926}
927
928
929static inline char * d_path(struct dentry *dentry, struct vfsmount *vfsmnt,
930 char *buf, int buflen)
931{
932 char *res;
933 struct vfsmount *rootmnt;
934 struct dentry *root;
935 read_lock(¤t->fs->lock);
936 rootmnt = mntget(current->fs->rootmnt);
937 root = dget(current->fs->root);
938 read_unlock(¤t->fs->lock);
939 spin_lock(&dcache_lock);
940 res = __d_path(dentry, vfsmnt, root, rootmnt, buf, buflen);
941 spin_unlock(&dcache_lock);
942 dput(root);
943 mntput(rootmnt);
944 return res;
945}
946
947static inline int need_resched(void)
948{
949 return (unlikely(current->need_resched));
950}
951
952extern void __cond_resched(void);
953static inline void cond_resched(void)
954{
955 if (need_resched())
956 __cond_resched();
957}
958
959#endif
960#endif
961