[f761f1eb] | 1 | /*
|
---|
| 2 | * Copyright (C) 2001-2004 Jakub Jermar
|
---|
| 3 | * All rights reserved.
|
---|
| 4 | *
|
---|
| 5 | * Redistribution and use in source and binary forms, with or without
|
---|
| 6 | * modification, are permitted provided that the following conditions
|
---|
| 7 | * are met:
|
---|
| 8 | *
|
---|
| 9 | * - Redistributions of source code must retain the above copyright
|
---|
| 10 | * notice, this list of conditions and the following disclaimer.
|
---|
| 11 | * - Redistributions in binary form must reproduce the above copyright
|
---|
| 12 | * notice, this list of conditions and the following disclaimer in the
|
---|
| 13 | * documentation and/or other materials provided with the distribution.
|
---|
| 14 | * - The name of the author may not be used to endorse or promote products
|
---|
| 15 | * derived from this software without specific prior written permission.
|
---|
| 16 | *
|
---|
| 17 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
|
---|
| 18 | * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
---|
| 19 | * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
|
---|
| 20 | * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
|
---|
| 21 | * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
|
---|
| 22 | * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
---|
| 23 | * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
---|
| 24 | * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
---|
| 25 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
|
---|
| 26 | * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
---|
| 27 | */
|
---|
| 28 |
|
---|
| 29 | #ifndef __THREAD_H__
|
---|
| 30 | #define __THREAD_H__
|
---|
| 31 |
|
---|
| 32 | #include <arch/thread.h>
|
---|
| 33 | #include <synch/spinlock.h>
|
---|
| 34 | #include <arch/context.h>
|
---|
[0c47db1] | 35 | #include <fpu_context.h>
|
---|
[f761f1eb] | 36 | #include <arch/types.h>
|
---|
| 37 | #include <typedefs.h>
|
---|
| 38 | #include <time/timeout.h>
|
---|
| 39 | #include <synch/rwlock.h>
|
---|
[361635c] | 40 | #include <config.h>
|
---|
[f761f1eb] | 41 | #include <list.h>
|
---|
| 42 |
|
---|
[361635c] | 43 | #define THREAD_STACK_SIZE STACK_SIZE
|
---|
[f761f1eb] | 44 |
|
---|
| 45 | #define THREAD_USER_STACK 1
|
---|
| 46 |
|
---|
| 47 | enum state {
|
---|
[9cefba4] | 48 | Invalid, /**< It is an error, if thread is found in this state. */
|
---|
| 49 | Running, /**< State of a thread that is currently executing on some CPU. */
|
---|
| 50 | Sleeping, /**< Thread in this state is waiting for an event. */
|
---|
| 51 | Ready, /**< State of threads in a run queue. */
|
---|
| 52 | Entering, /**< Threads are in this state before they are first readied. */
|
---|
| 53 | Exiting /**< After a thread calls thread_exit(), it is put into Exiting state. */
|
---|
[f761f1eb] | 54 | };
|
---|
| 55 |
|
---|
| 56 | extern char *thread_states[];
|
---|
| 57 |
|
---|
| 58 | #define X_WIRED (1<<0)
|
---|
| 59 | #define X_STOLEN (1<<1)
|
---|
| 60 |
|
---|
| 61 | struct thread {
|
---|
[9cefba4] | 62 | link_t rq_link; /**< Run queue link. */
|
---|
| 63 | link_t wq_link; /**< Wait queue link. */
|
---|
| 64 | link_t th_link; /**< Links to threads within containing task. */
|
---|
| 65 | link_t threads_link; /**< Link to the list of all threads. */
|
---|
[f761f1eb] | 66 |
|
---|
[05e2a7ad] | 67 | /** Lock protecting thread structure.
|
---|
| 68 | *
|
---|
| 69 | * Protects the whole thread structure except list links above.
|
---|
| 70 | * Must be acquired before T.lock for each T of type task_t.
|
---|
| 71 | *
|
---|
| 72 | */
|
---|
[dc747e3] | 73 | SPINLOCK_DECLARE(lock);
|
---|
[f761f1eb] | 74 |
|
---|
[9cefba4] | 75 | void (* thread_code)(void *); /**< Function implementing the thread. */
|
---|
| 76 | void *thread_arg; /**< Argument passed to thread_code() function. */
|
---|
| 77 |
|
---|
| 78 | context_t saved_context; /**< From here, the stored context is restored when the thread is scheduled. */
|
---|
| 79 | context_t sleep_timeout_context; /**< From here, the stored failover context is restored when sleep times out. */
|
---|
| 80 |
|
---|
| 81 | waitq_t *sleep_queue; /**< Wait queue in which this thread sleeps. */
|
---|
| 82 | timeout_t sleep_timeout; /**< Timeout used for timeoutable sleeping. */
|
---|
| 83 | volatile int timeout_pending; /**< Flag signalling sleep timeout in progress. */
|
---|
[f761f1eb] | 84 |
|
---|
[76cec1e] | 85 | fpu_context_t saved_fpu_context;
|
---|
| 86 | int fpu_context_exists;
|
---|
| 87 |
|
---|
| 88 | /*
|
---|
| 89 | * Defined only if thread doesn't run.
|
---|
| 90 | * It means that fpu context is in CPU that last time executes this thread.
|
---|
| 91 | * This disables migration
|
---|
| 92 | */
|
---|
| 93 | int fpu_context_engaged;
|
---|
| 94 |
|
---|
[f761f1eb] | 95 | rwlock_type_t rwlock_holder_type;
|
---|
| 96 |
|
---|
[9cefba4] | 97 | void (* call_me)(void *); /**< Funtion to be called in scheduler before the thread is put asleep. */
|
---|
| 98 | void *call_me_with; /**< Argument passed to call_me(). */
|
---|
| 99 |
|
---|
| 100 | state_t state; /**< Thread's state. */
|
---|
| 101 | int flags; /**< Thread's flags. */
|
---|
[f761f1eb] | 102 |
|
---|
[9cefba4] | 103 | cpu_t *cpu; /**< Thread's CPU. */
|
---|
| 104 | task_t *task; /**< Containing task. */
|
---|
[f761f1eb] | 105 |
|
---|
[9cefba4] | 106 | __u64 ticks; /**< Ticks before preemption. */
|
---|
[f761f1eb] | 107 |
|
---|
[22f7769] | 108 | int priority; /**< Thread's priority. Implemented as index to CPU->rq */
|
---|
[9cefba4] | 109 | __u32 tid; /**< Thread ID. */
|
---|
[f761f1eb] | 110 |
|
---|
[9cefba4] | 111 | ARCH_THREAD_DATA; /**< Architecture-specific data. */
|
---|
[f761f1eb] | 112 |
|
---|
[9cefba4] | 113 | __u8 *kstack; /**< Thread's kernel stack. */
|
---|
| 114 | __u8 *ustack; /**< Thread's user stack. */
|
---|
[f761f1eb] | 115 | };
|
---|
| 116 |
|
---|
[05e2a7ad] | 117 | /** Thread list lock.
|
---|
| 118 | *
|
---|
| 119 | * This lock protects all link_t structures chained in threads_head.
|
---|
| 120 | * Must be acquired before T.lock for each T of type thread_t.
|
---|
| 121 | *
|
---|
| 122 | */
|
---|
| 123 | extern spinlock_t threads_lock;
|
---|
| 124 |
|
---|
[9cefba4] | 125 | extern link_t threads_head; /**< List of all threads in the system. */
|
---|
[f761f1eb] | 126 |
|
---|
| 127 | extern void thread_init(void);
|
---|
| 128 | extern thread_t *thread_create(void (* func)(void *), void *arg, task_t *task, int flags);
|
---|
| 129 | extern void thread_ready(thread_t *t);
|
---|
| 130 | extern void thread_exit(void);
|
---|
| 131 |
|
---|
| 132 | extern void thread_sleep(__u32 sec);
|
---|
| 133 | extern void thread_usleep(__u32 usec);
|
---|
| 134 |
|
---|
| 135 | extern void thread_register_call_me(void (* call_me)(void *), void *call_me_with);
|
---|
[55ab0f1] | 136 | extern void thread_print_list(void);
|
---|
[f761f1eb] | 137 |
|
---|
| 138 | #endif
|
---|