Mercurial > ecos
annotate packages/kernel/current/src/sched/bitmap.cxx @ 177:4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
| author | jlarmour |
|---|---|
| date | Fri, 10 Aug 2001 19:27:55 +0000 |
| parents | 0d0f03f76f6a |
| children | e0c0827131d1 |
| rev | line source |
|---|---|
| 0 | 1 //========================================================================== |
| 2 // | |
| 2 | 3 // sched/bitmap.cxx |
| 0 | 4 // |
| 2 | 5 // Bitmap scheduler class implementation |
| 0 | 6 // |
| 7 //========================================================================== | |
| 8 //####COPYRIGHTBEGIN#### | |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
9 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
10 // ------------------------------------------- |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
11 // The contents of this file are subject to the Red Hat eCos Public License |
|
66
bf00f99aec69
Merge from eCos master repository on 2000-02-02-19:16:44-GMT
jlarmour
parents:
64
diff
changeset
|
12 // Version 1.1 (the "License"); you may not use this file except in |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
13 // compliance with the License. You may obtain a copy of the License at |
|
66
bf00f99aec69
Merge from eCos master repository on 2000-02-02-19:16:44-GMT
jlarmour
parents:
64
diff
changeset
|
14 // http://www.redhat.com/ |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
15 // |
|
66
bf00f99aec69
Merge from eCos master repository on 2000-02-02-19:16:44-GMT
jlarmour
parents:
64
diff
changeset
|
16 // Software distributed under the License is distributed on an "AS IS" |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
17 // basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
18 // License for the specific language governing rights and limitations under |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
19 // the License. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
20 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
21 // The Original Code is eCos - Embedded Configurable Operating System, |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
22 // released September 30, 1998. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
23 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
24 // The Initial Developer of the Original Code is Red Hat. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
25 // Portions created by Red Hat are |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
26 // Copyright (C) 1998, 1999, 2000 Red Hat, Inc. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
27 // All Rights Reserved. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
28 // ------------------------------------------- |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
56
diff
changeset
|
29 // |
| 0 | 30 //####COPYRIGHTEND#### |
| 31 //========================================================================== | |
| 32 //#####DESCRIPTIONBEGIN#### | |
| 33 // | |
| 2 | 34 // Author(s): nickg |
| 35 // Contributors: nickg | |
| 36 // Date: 1997-09-16 | |
| 37 // Purpose: Bitmap scheduler class implementation | |
| 38 // Description: This file contains the implementations of | |
| 0 | 39 // Cyg_Scheduler_Implementation and Cyg_SchedThread_Implementation. |
| 40 // | |
| 41 // | |
| 42 //####DESCRIPTIONEND#### | |
| 43 // | |
| 44 //========================================================================== | |
| 45 | |
| 46 #include <pkgconf/kernel.h> | |
| 47 | |
| 48 #include <cyg/kernel/ktypes.h> // base kernel types | |
| 49 #include <cyg/infra/cyg_trac.h> // tracing macros | |
| 50 #include <cyg/infra/cyg_ass.h> // assertion macros | |
| 51 | |
| 52 #include <cyg/kernel/sched.hxx> // our header | |
| 53 | |
| 54 #include <cyg/hal/hal_arch.h> // Architecture specific definitions | |
| 55 | |
| 56 #include <cyg/kernel/thread.inl> // thread inlines | |
| 57 #include <cyg/kernel/sched.inl> // scheduler inlines | |
| 58 | |
| 59 #ifdef CYGSEM_KERNEL_SCHED_BITMAP | |
| 60 | |
| 61 //========================================================================== | |
| 62 // Cyg_Scheduler_Implementation class members | |
| 63 | |
| 64 // ------------------------------------------------------------------------- | |
| 65 // Constructor. | |
| 66 | |
| 67 Cyg_Scheduler_Implementation::Cyg_Scheduler_Implementation() | |
| 68 { | |
| 69 CYG_REPORT_FUNCTION(); | |
| 70 | |
| 71 // At present we cannot init run_queue here because the absence of | |
| 72 // ordering of static constructors means that we could do this | |
| 73 // after the static idle thread has been created. (Guess how I | |
| 74 // found this out!) | |
| 75 // run_queue = 0; | |
| 76 | |
| 77 } | |
| 78 | |
| 79 // ------------------------------------------------------------------------- | |
| 80 // Choose the best thread to run next | |
| 81 | |
| 82 Cyg_Thread *Cyg_Scheduler_Implementation::schedule() | |
| 83 { | |
| 84 CYG_REPORT_FUNCTION(); | |
| 85 | |
| 86 // The run queue may _never_ be empty, there is always | |
| 87 // an idle thread at the lowest priority. | |
| 88 | |
| 89 CYG_ASSERT(run_queue != 0, "Run queue empty"); | |
| 90 | |
| 91 cyg_uint32 index; | |
| 92 | |
| 93 HAL_LSBIT_INDEX(index, run_queue); | |
| 94 | |
| 95 return thread_table[index]; | |
| 96 } | |
| 97 | |
| 98 // ------------------------------------------------------------------------- | |
| 99 | |
| 100 void Cyg_Scheduler_Implementation::add_thread(Cyg_Thread *thread) | |
| 101 { | |
| 102 CYG_REPORT_FUNCTION(); | |
| 103 | |
|
56
755351606154
Merge from eCos master repository on 1999-12-01-18:03:05-GMT
jlarmour
parents:
46
diff
changeset
|
104 CYG_ASSERT((CYG_THREAD_MIN_PRIORITY >= thread->priority) |
|
755351606154
Merge from eCos master repository on 1999-12-01-18:03:05-GMT
jlarmour
parents:
46
diff
changeset
|
105 && (CYG_THREAD_MAX_PRIORITY <= thread->priority), |
|
755351606154
Merge from eCos master repository on 1999-12-01-18:03:05-GMT
jlarmour
parents:
46
diff
changeset
|
106 "Priority out of range!"); |
|
755351606154
Merge from eCos master repository on 1999-12-01-18:03:05-GMT
jlarmour
parents:
46
diff
changeset
|
107 |
| 0 | 108 CYG_ASSERT( thread_table[thread->priority] == NULL || |
| 109 thread_table[thread->priority] == thread, | |
| 110 "Duplicate thread priorities" ); | |
| 111 | |
| 112 CYG_ASSERT( (run_queue & (1<<thread->priority)) == 0, | |
| 113 "Run queue bit already set" ); | |
| 114 | |
| 115 // If the thread is on some other queue, remove it | |
| 116 // here. | |
| 117 if( thread->queue != NULL ) | |
| 118 { | |
| 119 thread->queue->remove(thread); | |
| 120 thread->queue = NULL; | |
| 121 } | |
| 122 | |
| 123 run_queue |= 1<<thread->priority; | |
| 124 | |
| 125 // If the new thread is higher priority than the | |
| 126 // current thread, request a reschedule. | |
| 127 | |
| 128 if( thread->priority < Cyg_Scheduler::get_current_thread()->priority ) | |
|
177
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
129 set_need_reschedule(); |
| 0 | 130 } |
| 131 | |
| 132 // ------------------------------------------------------------------------- | |
| 133 | |
| 134 void Cyg_Scheduler_Implementation::rem_thread(Cyg_Thread *thread) | |
| 135 { | |
| 136 CYG_REPORT_FUNCTION(); | |
| 137 | |
| 138 CYG_ASSERT( thread_table[thread->priority] == thread, | |
| 139 "Invalid thread priority" ); | |
| 140 | |
| 141 CYG_ASSERT( (run_queue & (1<<thread->priority)) != 0, | |
| 142 "Run queue bit not set" ); | |
| 143 | |
| 144 run_queue &= ~(1<<thread->priority); | |
|
177
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
145 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
146 if( thread == Cyg_Scheduler::get_current_thread() ) |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
147 set_need_reschedule(); |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
148 } |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
149 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
150 // ------------------------------------------------------------------------- |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
151 // Set up initial idle thread |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
152 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
153 void Cyg_Scheduler_Implementation::set_idle_thread( Cyg_Thread *thread, HAL_SMP_CPU_TYPE cpu ) |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
154 { |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
155 CYG_REPORT_FUNCTION(); |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
156 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
157 // Make the thread the current thread for this CPU. |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
158 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
159 current_thread[cpu] = thread; |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
160 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
161 // This will insert the thread in the run queues and make it |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
162 // available to execute. |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
160
diff
changeset
|
163 thread->resume(); |
| 0 | 164 } |
| 165 | |
| 166 // ------------------------------------------------------------------------- | |
| 167 // register thread with scheduler | |
| 168 | |
| 169 void Cyg_Scheduler_Implementation::register_thread(Cyg_Thread *thread) | |
| 170 { | |
| 171 CYG_REPORT_FUNCTION(); | |
| 172 | |
| 173 thread_table[thread->priority] = thread; | |
| 174 } | |
| 175 | |
| 176 // ------------------------------------------------------------------------- | |
| 177 | |
| 178 // deregister thread | |
| 179 void Cyg_Scheduler_Implementation::deregister_thread(Cyg_Thread *thread) | |
| 180 { | |
| 181 CYG_REPORT_FUNCTION(); | |
| 182 | |
| 183 thread_table[thread->priority] = NULL; | |
| 184 } | |
| 185 | |
| 186 // ------------------------------------------------------------------------- | |
| 187 // Test the given priority for uniqueness | |
| 188 | |
| 189 cyg_bool Cyg_Scheduler_Implementation::unique( cyg_priority priority) | |
| 190 { | |
| 191 CYG_REPORT_FUNCTION(); | |
| 192 | |
| 193 return thread_table[priority] == NULL; | |
| 194 } | |
| 195 | |
| 196 | |
| 197 //========================================================================== | |
| 198 // Cyg_Cyg_SchedThread_Implementation class members | |
| 199 | |
| 200 Cyg_SchedThread_Implementation::Cyg_SchedThread_Implementation | |
| 201 ( | |
| 202 CYG_ADDRWORD sched_info | |
| 203 ) | |
| 204 { | |
| 205 CYG_REPORT_FUNCTION(); | |
| 206 | |
| 207 #if 1 | |
| 208 // Assign this thread's priority to the supplied sched_info | |
| 209 // or the next highest priority available. | |
| 210 | |
| 211 priority = cyg_priority(sched_info); | |
| 212 | |
| 213 while( !Cyg_Scheduler::scheduler.unique(priority) ) | |
| 214 priority++; | |
| 215 | |
| 216 #else | |
| 217 // Assign initial priorities to threads in descending order of | |
| 218 // creation. | |
| 219 | |
| 220 static cyg_priority init_priority = 0; | |
| 221 | |
| 222 priority = init_priority++; | |
| 223 #endif | |
| 224 | |
| 225 } | |
| 226 | |
| 227 // ------------------------------------------------------------------------- | |
| 228 | |
| 229 void Cyg_SchedThread_Implementation::yield() | |
| 230 { | |
| 231 CYG_REPORT_FUNCTION(); | |
| 232 | |
| 233 // We cannot yield in this scheduler | |
| 234 } | |
| 235 | |
| 236 //========================================================================== | |
| 237 // Cyg_ThreadQueue_Implementation class members | |
| 238 | |
| 239 Cyg_ThreadQueue_Implementation::Cyg_ThreadQueue_Implementation() | |
| 240 { | |
| 241 CYG_REPORT_FUNCTION(); | |
| 242 | |
| 243 wait_queue = 0; // empty queue | |
| 2 | 244 |
| 245 CYG_REPORT_RETURN(); | |
| 0 | 246 } |
| 247 | |
| 248 | |
| 249 void Cyg_ThreadQueue_Implementation::enqueue(Cyg_Thread *thread) | |
| 250 { | |
| 251 CYG_REPORT_FUNCTION(); | |
| 252 | |
| 253 wait_queue |= 1<<thread->priority; | |
| 254 thread->queue = CYG_CLASSFROMBASE(Cyg_ThreadQueue, | |
| 255 Cyg_ThreadQueue_Implementation, | |
| 256 this); | |
| 257 } | |
| 258 | |
| 259 // ------------------------------------------------------------------------- | |
| 260 | |
| 261 Cyg_Thread *Cyg_ThreadQueue_Implementation::dequeue() | |
| 262 { | |
| 263 CYG_REPORT_FUNCTION(); | |
| 264 | |
| 265 // Isolate ls bit in run_queue. | |
| 266 cyg_sched_bitmap next_thread = wait_queue & -wait_queue; | |
| 267 | |
| 268 if( next_thread == 0 ) return NULL; | |
| 269 | |
| 270 wait_queue &= ~next_thread; | |
| 271 | |
| 272 cyg_uint32 index; | |
| 273 | |
| 274 HAL_LSBIT_INDEX(index, next_thread); | |
| 275 | |
| 276 Cyg_Thread *thread = Cyg_Scheduler::scheduler.thread_table[index]; | |
| 277 | |
| 278 thread->queue = NULL; | |
| 279 | |
| 280 return thread; | |
| 281 } | |
| 282 | |
| 283 // ------------------------------------------------------------------------- | |
| 284 | |
| 285 Cyg_Thread *Cyg_ThreadQueue_Implementation::highpri() | |
| 286 { | |
| 287 CYG_REPORT_FUNCTION(); | |
| 288 | |
| 289 // Isolate ls bit in run_queue. | |
| 290 cyg_sched_bitmap next_thread = wait_queue & -wait_queue; | |
| 291 | |
| 292 if( next_thread == 0 ) return NULL; | |
| 293 | |
| 294 cyg_uint32 index; | |
| 295 | |
| 296 HAL_LSBIT_INDEX(index, next_thread); | |
| 297 | |
| 298 return Cyg_Scheduler::scheduler.thread_table[index]; | |
| 299 } | |
| 300 | |
| 301 // ------------------------------------------------------------------------- | |
| 302 | |
| 303 void Cyg_ThreadQueue_Implementation::remove(Cyg_Thread *thread) | |
| 304 { | |
| 305 CYG_REPORT_FUNCTION(); | |
| 306 | |
| 307 wait_queue &= ~(1<<thread->priority); | |
| 308 thread->queue = NULL; | |
| 309 } | |
| 310 | |
| 311 #endif | |
| 312 | |
| 313 // ------------------------------------------------------------------------- | |
| 314 // EOF sched/bitmap.cxx |