Mercurial > flash_v2
annotate packages/kernel/current/src/sync/mutex.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 | 0ec04793409a |
| children | d61da071934c |
| rev | line source |
|---|---|
| 0 | 1 //========================================================================== |
| 2 // | |
| 2 | 3 // sync/mutex.cxx |
| 0 | 4 // |
| 2 | 5 // Mutex and condition variable implementation |
| 0 | 6 // |
| 7 //========================================================================== | |
| 8 //####COPYRIGHTBEGIN#### | |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
diff
changeset
|
9 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
diff
changeset
|
10 // ------------------------------------------- |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
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:
62
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:
62
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:
62
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:
62
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:
62
diff
changeset
|
19 // the License. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
diff
changeset
|
20 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
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:
62
diff
changeset
|
22 // released September 30, 1998. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
diff
changeset
|
23 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
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:
62
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:
62
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:
62
diff
changeset
|
27 // All Rights Reserved. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
diff
changeset
|
28 // ------------------------------------------- |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
62
diff
changeset
|
29 // |
| 0 | 30 //####COPYRIGHTEND#### |
| 31 //========================================================================== | |
| 32 //#####DESCRIPTIONBEGIN#### | |
| 33 // | |
| 2 | 34 // Author(s): nickg |
| 35 // Contributors: nickg, jlarmour | |
| 36 // Date: 1999-02-17 | |
| 37 // Purpose: Mutex implementation | |
| 38 // Description: This file contains the implementations of the mutex | |
| 39 // and condition variable classes. | |
| 0 | 40 // |
| 41 //####DESCRIPTIONEND#### | |
| 42 // | |
| 43 //========================================================================== | |
| 44 | |
| 45 #include <pkgconf/kernel.h> | |
| 46 | |
| 47 #include <cyg/kernel/ktypes.h> // base kernel types | |
| 48 #include <cyg/infra/cyg_trac.h> // tracing macros | |
| 49 #include <cyg/infra/cyg_ass.h> // assertion macros | |
| 50 #include <cyg/kernel/instrmnt.h> // instrumentation | |
| 51 | |
| 52 #include <cyg/kernel/mutex.hxx> // our header | |
| 53 | |
| 54 #include <cyg/kernel/thread.inl> // thread inlines | |
| 55 #include <cyg/kernel/sched.inl> // scheduler inlines | |
| 56 #include <cyg/kernel/clock.inl> // clock inlines | |
| 57 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
58 // ------------------------------------------------------------------------- |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
59 // Mutex protocol test macros. |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
60 // If the dynamic protocol option is enabled, then these generate appropriate |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
61 // tests on the protocol field. If there is no dynamic choice then they simply |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
62 // result in empty statements. |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
63 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
64 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DYNAMIC |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
65 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
66 #define IF_PROTOCOL_INHERIT if( protocol == INHERIT ) |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
67 #define IF_PROTOCOL_CEILING if( protocol == CEILING ) |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
68 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
69 #else |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
70 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
71 #define IF_PROTOCOL_INHERIT |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
72 #define IF_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
73 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
74 #endif |
| 0 | 75 |
| 76 // ------------------------------------------------------------------------- | |
| 77 // Constructor | |
| 78 | |
| 79 Cyg_Mutex::Cyg_Mutex() | |
| 80 { | |
| 81 CYG_REPORT_FUNCTION(); | |
| 82 | |
| 83 locked = false; | |
| 84 owner = NULL; | |
| 2 | 85 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
86 #if defined(CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DEFAULT) && \ |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
87 defined(CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DYNAMIC) |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
88 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
89 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DEFAULT_INHERIT |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
90 protocol = INHERIT; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
91 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
92 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DEFAULT_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
93 protocol = CEILING; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
94 ceiling = CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DEFAULT_PRIORITY; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
95 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
96 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DEFAULT_NONE |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
97 protocol = NONE; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
98 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
99 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
100 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
101 |
| 2 | 102 CYG_REPORT_RETURN(); |
| 0 | 103 } |
| 104 | |
| 105 // ------------------------------------------------------------------------- | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
106 // Construct with defined protocol |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
107 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
108 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DYNAMIC |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
109 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
110 Cyg_Mutex::Cyg_Mutex( cyg_protcol protocol_arg ) |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
111 { |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
112 CYG_REPORT_FUNCTION(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
113 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
114 locked = false; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
115 owner = NULL; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
116 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
117 protocol = protocol_arg; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
118 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
119 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
120 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DEFAULT_PRIORITY |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
121 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
122 // if there is a default priority ceiling defined, use that to initialize |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
123 // the ceiling. |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
124 ceiling = CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DEFAULT_PRIORITY; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
125 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
126 #else |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
127 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
128 // Otherwise set it to zero. |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
129 ceiling = 0; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
130 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
131 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
132 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
133 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
134 CYG_REPORT_RETURN(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
135 } |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
136 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
137 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
138 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
139 // ------------------------------------------------------------------------- |
| 0 | 140 // Destructor |
| 141 | |
| 142 Cyg_Mutex::~Cyg_Mutex() | |
| 143 { | |
| 144 CYG_REPORT_FUNCTION(); | |
| 145 | |
| 146 CYG_ASSERT( owner == NULL, "Deleting mutex with owner"); | |
| 147 CYG_ASSERT( queue.empty(), "Deleting mutex with waiting threads"); | |
| 2 | 148 CYG_REPORT_RETURN(); |
| 0 | 149 } |
| 150 | |
| 151 // ------------------------------------------------------------------------- | |
| 152 | |
| 153 #ifdef CYGDBG_USE_ASSERTS | |
| 154 | |
|
78
59d97b6ba612
Merge from eCos master repository on 2000-03-28-19:50:47-BST
jlarmour
parents:
66
diff
changeset
|
155 cyg_bool |
| 2 | 156 Cyg_Mutex::check_this( cyg_assert_class_zeal zeal) const |
| 0 | 157 { |
| 158 // CYG_REPORT_FUNCTION(); | |
| 159 | |
| 160 // check that we have a non-NULL pointer first | |
| 161 if( this == NULL ) return false; | |
| 162 | |
| 163 switch( zeal ) | |
| 164 { | |
| 165 case cyg_system_test: | |
| 166 case cyg_extreme: | |
| 167 case cyg_thorough: | |
| 168 case cyg_quick: | |
| 169 case cyg_trivial: | |
| 170 if( locked && owner == NULL ) return false; | |
| 171 if( !locked && owner != NULL ) return false; | |
| 172 case cyg_none: | |
| 173 default: | |
| 174 break; | |
| 175 }; | |
| 176 | |
| 177 return true; | |
| 178 } | |
| 179 | |
| 180 #endif | |
| 181 | |
| 182 // ------------------------------------------------------------------------- | |
| 183 // Lock and/or wait | |
| 184 | |
| 2 | 185 cyg_bool |
| 186 Cyg_Mutex::lock(void) | |
| 0 | 187 { |
| 2 | 188 CYG_REPORT_FUNCTYPE("returning %d"); |
| 0 | 189 |
| 190 cyg_bool result = true; | |
| 191 Cyg_Thread *self = Cyg_Thread::self(); | |
| 192 | |
| 193 // Prevent preemption | |
| 194 Cyg_Scheduler::lock(); | |
| 195 | |
| 196 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 197 | |
| 198 CYG_INSTRUMENT_MUTEX(LOCK, this, 0); | |
| 199 | |
| 200 // Loop while the mutex is locked, sleeping each time around | |
| 201 // the loop. This copes with the possibility of a higher priority | |
| 202 // thread grabbing the mutex between the wakeup in unlock() and | |
| 203 // this thread actually starting. | |
| 204 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
205 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL |
|
62
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
206 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
207 self->count_mutex(); |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
208 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
209 #endif |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
210 |
| 2 | 211 while( locked && result ) |
| 0 | 212 { |
| 213 CYG_ASSERT( self != owner, "Locking mutex I already own"); | |
| 214 | |
| 215 self->set_sleep_reason( Cyg_Thread::WAIT ); | |
| 216 | |
| 217 self->sleep(); | |
| 218 | |
| 219 queue.enqueue( self ); | |
| 220 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
221 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_INHERIT |
| 0 | 222 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
223 IF_PROTOCOL_INHERIT |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
224 owner->inherit_priority(self); |
|
28
18ee5a9c102e
Merge from eCos master repository on 1999-08-09-17:04:48-BST
jlarmour
parents:
2
diff
changeset
|
225 |
| 0 | 226 #endif |
| 227 | |
| 228 CYG_INSTRUMENT_MUTEX(WAIT, this, 0); | |
| 229 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
230 // Allow other threads to run |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
231 Cyg_Scheduler::reschedule(); |
| 0 | 232 |
| 233 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 234 | |
| 235 switch( self->get_wake_reason() ) | |
| 236 { | |
| 237 case Cyg_Thread::DESTRUCT: | |
| 238 case Cyg_Thread::BREAK: | |
| 239 result = false; | |
| 240 break; | |
| 241 | |
| 242 case Cyg_Thread::EXIT: | |
| 243 self->exit(); | |
| 244 break; | |
| 245 | |
| 246 default: | |
| 247 break; | |
| 248 } | |
| 249 | |
| 250 } | |
| 251 | |
| 252 if( result ) | |
| 253 { | |
| 254 locked = true; | |
| 255 owner = self; | |
| 256 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
257 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
258 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
259 IF_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
260 self->set_priority_ceiling(ceiling); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
261 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
262 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
263 |
| 0 | 264 CYG_INSTRUMENT_MUTEX(LOCKED, this, 0); |
| 265 } | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
266 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_INHERIT |
|
62
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
267 else |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
268 { |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
269 IF_PROTOCOL_INHERIT |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
270 { |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
271 self->uncount_mutex(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
272 self->disinherit_priority(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
273 } |
|
62
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
274 } |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
275 #endif |
| 0 | 276 |
| 277 // Unlock the scheduler and maybe switch threads | |
| 278 Cyg_Scheduler::unlock(); | |
| 279 | |
| 280 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 281 | |
| 2 | 282 CYG_REPORT_RETVAL(result); |
| 283 | |
| 0 | 284 return result; |
| 285 } | |
| 286 | |
| 287 // ------------------------------------------------------------------------- | |
| 288 // Try to lock and return success | |
| 289 | |
| 2 | 290 cyg_bool |
| 291 Cyg_Mutex::trylock(void) | |
| 0 | 292 { |
| 2 | 293 CYG_REPORT_FUNCTYPE("returning %d"); |
| 0 | 294 |
| 295 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 296 | |
| 297 cyg_bool result = true; | |
| 298 | |
| 299 // Prevent preemption | |
| 300 Cyg_Scheduler::lock(); | |
| 301 | |
| 302 // If the mutex is not locked, grab it | |
| 303 // for ourself. Otherwise return failure. | |
| 304 if( !locked ) | |
| 305 { | |
| 306 Cyg_Thread *self = Cyg_Thread::self(); | |
| 307 | |
| 308 locked = true; | |
| 309 owner = self; | |
| 310 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
311 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL |
| 0 | 312 |
| 313 self->count_mutex(); | |
| 314 | |
| 315 #endif | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
316 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
317 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
318 IF_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
319 self->set_priority_ceiling(ceiling); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
320 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
321 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
322 |
| 0 | 323 } |
| 324 else result = false; | |
| 325 | |
| 326 CYG_INSTRUMENT_MUTEX(TRY, this, result); | |
| 327 | |
| 328 // Unlock the scheduler and maybe switch threads | |
| 329 Cyg_Scheduler::unlock(); | |
| 330 | |
| 2 | 331 CYG_REPORT_RETVAL(result); |
| 0 | 332 return result; |
| 333 } | |
| 334 | |
| 335 // ------------------------------------------------------------------------- | |
| 336 // unlock | |
| 337 | |
| 2 | 338 void |
| 339 Cyg_Mutex::unlock(void) | |
| 0 | 340 { |
| 341 CYG_REPORT_FUNCTION(); | |
| 342 | |
| 343 // Prevent preemption | |
| 344 Cyg_Scheduler::lock(); | |
| 345 | |
| 346 CYG_INSTRUMENT_MUTEX(UNLOCK, this, 0); | |
| 347 | |
| 348 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 349 CYG_ASSERT( locked, "Unlock mutex that is not locked"); | |
| 350 CYG_ASSERT( owner == Cyg_Thread::self(), "Unlock mutex I do not own"); | |
| 351 | |
|
62
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
352 if( !queue.empty() ) { |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
353 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
354 // The queue is non-empty, so grab the next |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
355 // thread from it and wake it up. |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
356 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
357 Cyg_Thread *thread = queue.dequeue(); |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
358 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
359 CYG_ASSERTCLASS( thread, "Bad thread pointer"); |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
360 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
361 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_INHERIT |
|
62
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
362 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
363 // Give the owner-to-be a chance to inherit from the remaining |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
364 // queue or the relinquishing thread: |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
365 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
366 IF_PROTOCOL_INHERIT |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
367 thread->relay_priority(owner, &queue); |
|
62
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
368 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
369 #endif |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
370 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
371 thread->set_wake_reason( Cyg_Thread::DONE ); |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
372 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
373 thread->wake(); |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
374 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
375 CYG_INSTRUMENT_MUTEX(WAKE, this, thread); |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
376 |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
377 } |
|
7a6ac9edc838
Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents:
28
diff
changeset
|
378 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
379 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL |
| 0 | 380 |
| 381 owner->uncount_mutex(); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
382 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
383 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
384 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_INHERIT |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
385 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
386 IF_PROTOCOL_INHERIT |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
387 owner->disinherit_priority(); |
| 0 | 388 |
| 389 #endif | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
390 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
391 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
392 IF_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
393 owner->clear_priority_ceiling(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
394 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
395 #endif |
| 0 | 396 |
| 397 locked = false; | |
| 398 owner = NULL; | |
| 399 | |
| 400 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 401 | |
| 402 // Unlock the scheduler and maybe switch threads | |
| 403 Cyg_Scheduler::unlock(); | |
| 404 | |
| 2 | 405 CYG_REPORT_RETURN(); |
| 406 } | |
| 407 | |
| 408 // ------------------------------------------------------------------------- | |
| 409 // Release all waiting threads. | |
| 410 | |
| 411 void Cyg_Mutex::release() | |
| 412 { | |
| 413 CYG_REPORT_FUNCTION(); | |
| 414 | |
| 415 // Prevent preemption | |
| 416 Cyg_Scheduler::lock(); | |
| 417 | |
| 418 CYG_INSTRUMENT_MUTEX(RELEASE, this, 0); | |
| 419 | |
| 420 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 421 | |
| 422 while( !queue.empty() ) | |
| 423 { | |
| 424 // The queue is non-empty, so grab each | |
| 425 // thread from it and release it. | |
| 426 | |
| 427 Cyg_Thread *thread = queue.dequeue(); | |
| 428 | |
| 429 CYG_ASSERTCLASS( thread, "Bad thread pointer"); | |
| 430 | |
| 431 thread->release(); | |
| 432 | |
| 433 CYG_INSTRUMENT_MUTEX(RELEASED, this, thread); | |
| 434 | |
| 435 } | |
| 436 | |
| 437 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 438 | |
| 439 // Unlock the scheduler and maybe switch threads | |
| 440 Cyg_Scheduler::unlock(); | |
| 441 | |
| 442 CYG_REPORT_RETURN(); | |
| 0 | 443 } |
| 444 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
445 // ------------------------------------------------------------------------- |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
446 // Set ceiling priority for priority ceiling protocol |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
447 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
448 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_CEILING |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
449 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
450 void Cyg_Mutex::set_ceiling( cyg_priority priority ) |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
451 { |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
452 CYG_REPORT_FUNCTION(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
453 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
454 // CYG_ASSERT( priority >= CYG_THREAD_MAX_PRIORITY, "Priority out of range"); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
455 // CYG_ASSERT( priority <= CYG_THREAD_MIN_PRIORITY, "Priority out of range"); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
456 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
457 // Prevent preemption |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
458 Cyg_Scheduler::lock(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
459 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
460 ceiling = priority; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
461 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
462 // Unlock the scheduler |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
463 Cyg_Scheduler::unlock(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
464 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
465 CYG_REPORT_RETURN(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
466 } |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
467 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
468 #endif |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
469 |
|
177
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
470 // ------------------------------------------------------------------------- |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
471 // Set priority inversion protocol |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
472 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
473 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INVERSION_PROTOCOL_DYNAMIC |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
474 void Cyg_Mutex::set_protocol( cyg_protcol new_protocol ) |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
475 { |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
476 CYG_REPORT_FUNCTION(); |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
477 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
478 // Prevent preemption |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
479 Cyg_Scheduler::lock(); |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
480 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
481 protocol = new_protocol; |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
482 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
483 // Unlock the scheduler |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
484 Cyg_Scheduler::unlock(); |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
485 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
486 CYG_REPORT_RETURN(); |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
487 } |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
488 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
489 #endif |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
490 |
|
4c750ce71ae3
Merge from eCos master repository on 2001-08-10-19:22:57-BST
jlarmour
parents:
124
diff
changeset
|
491 |
| 0 | 492 //========================================================================== |
| 493 // Condition variables | |
| 494 | |
| 495 Cyg_Condition_Variable::Cyg_Condition_Variable( | |
| 496 Cyg_Mutex &mx // linked mutex | |
| 497 ) | |
| 498 { | |
| 499 CYG_REPORT_FUNCTION(); | |
| 500 | |
| 501 mutex = &mx; | |
| 502 | |
| 503 CYG_ASSERTCLASS( mutex, "Invalid mutex argument"); | |
| 2 | 504 |
| 505 CYG_REPORT_RETURN(); | |
| 0 | 506 } |
| 507 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
508 Cyg_Condition_Variable::Cyg_Condition_Variable() |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
509 { |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
510 CYG_REPORT_FUNCTION(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
511 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
512 mutex = NULL; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
513 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
514 CYG_REPORT_RETURN(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
515 } |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
516 |
| 0 | 517 // ------------------------------------------------------------------------- |
| 518 // Destructor | |
| 519 | |
| 520 Cyg_Condition_Variable::~Cyg_Condition_Variable() | |
| 521 { | |
| 522 CYG_REPORT_FUNCTION(); | |
| 523 | |
| 524 CYG_ASSERT( queue.empty(), "Deleting condvar with waiting threads"); | |
| 2 | 525 |
| 526 CYG_REPORT_RETURN(); | |
| 0 | 527 } |
| 528 | |
| 529 // ------------------------------------------------------------------------- | |
| 530 | |
| 531 #ifdef CYGDBG_USE_ASSERTS | |
| 532 | |
|
78
59d97b6ba612
Merge from eCos master repository on 2000-03-28-19:50:47-BST
jlarmour
parents:
66
diff
changeset
|
533 cyg_bool |
| 2 | 534 Cyg_Condition_Variable::check_this( cyg_assert_class_zeal zeal) const |
| 0 | 535 { |
| 2 | 536 bool result = true; |
| 537 | |
| 538 CYG_REPORT_FUNCTYPE("returning %d"); | |
| 539 CYG_REPORT_FUNCARG1("zeal = %d", zeal); | |
| 0 | 540 |
| 541 // check that we have a non-NULL pointer first | |
| 2 | 542 if( this == NULL ) |
| 543 result = false; | |
| 544 else { | |
| 545 | |
| 546 switch( zeal ) | |
| 547 { | |
| 548 case cyg_system_test: | |
| 549 case cyg_extreme: | |
| 550 case cyg_thorough: | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
551 if( mutex != NULL && !mutex->check_this(zeal) ) |
| 2 | 552 result = false; |
| 553 case cyg_quick: | |
| 554 case cyg_trivial: | |
| 555 case cyg_none: | |
| 556 default: | |
| 557 break; | |
| 558 } | |
| 559 } | |
| 0 | 560 |
| 2 | 561 CYG_REPORT_RETVAL(result); |
| 562 return result; | |
| 0 | 563 } |
| 564 | |
| 565 #endif | |
| 566 | |
| 567 // ------------------------------------------------------------------------- | |
| 568 // Wait for condition to be true | |
| 2 | 569 // Note: if this function is entered with the scheduler locked (e.g. to |
| 570 // suspend DSR processing) then there is no need to take the lock. Also | |
| 571 // in this case, exit with the scheduler locked, which allows this function | |
| 572 // to be used in a totally thread-safe manner. | |
| 0 | 573 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
574 cyg_bool |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
575 Cyg_Condition_Variable::wait_inner( Cyg_Mutex *mx ) |
| 0 | 576 { |
| 577 CYG_REPORT_FUNCTION(); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
578 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
579 cyg_bool result = true; |
| 0 | 580 Cyg_Thread *self = Cyg_Thread::self(); |
| 581 | |
|
124
0ec04793409a
Merge from eCos master repository on 2000-09-11-03:00:13-BST
jlarmour
parents:
115
diff
changeset
|
582 Cyg_Scheduler::lock(); |
| 0 | 583 |
| 584 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
585 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 586 CYG_ASSERTCLASS( self, "Bad self thread"); |
| 587 | |
| 588 CYG_INSTRUMENT_CONDVAR(WAIT, this, 0); | |
| 589 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
590 mx->unlock(); |
| 0 | 591 |
| 592 self->set_sleep_reason( Cyg_Thread::WAIT ); | |
| 593 | |
| 594 self->sleep(); | |
| 595 | |
| 596 queue.enqueue( self ); | |
| 597 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
598 // Avoid calling ASRs during the following unlock. |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
599 self->set_asr_inhibit(); |
| 0 | 600 |
| 601 // Unlock the scheduler and switch threads | |
|
124
0ec04793409a
Merge from eCos master repository on 2000-09-11-03:00:13-BST
jlarmour
parents:
115
diff
changeset
|
602 Cyg_Scheduler::unlock_reschedule(); |
| 0 | 603 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
604 // Allow ASRs again |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
605 self->clear_asr_inhibit(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
606 |
| 0 | 607 CYG_INSTRUMENT_CONDVAR(WOKE, this, self->get_wake_reason()); |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
608 |
| 0 | 609 CYG_ASSERTCLASS( this, "Bad this pointer"); |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
610 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 611 |
| 612 switch( self->get_wake_reason() ) | |
| 613 { | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
614 case Cyg_Thread::DESTRUCT: // which, the cv or the mutex? |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
615 case Cyg_Thread::BREAK: |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
616 result = false; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
617 break; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
618 |
| 0 | 619 case Cyg_Thread::EXIT: |
| 620 self->exit(); | |
| 621 break; | |
| 622 | |
| 623 default: | |
| 624 break; | |
| 625 } | |
| 626 | |
| 627 // When we awake, we must re-acquire the mutex. Note that while | |
| 628 // it is essential to release the mutex and queue on the CV | |
| 629 // atomically relative to other threads, to avoid races, it is not | |
| 630 // necessary for us to re-acquire the mutex in the same atomic | |
| 631 // action. Hence we can do it after unlocking the scheduler. | |
| 2 | 632 // We need to loop here in case the thread is released while waiting |
| 633 // for the mutex. It is essential that we exit this function with the | |
| 634 // mutex claimed. | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
635 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
636 while ( !mx->lock() ) |
| 2 | 637 continue; |
| 0 | 638 |
| 639 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
640 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
641 CYG_ASSERT( mx->owner == self, "Not mutex owner"); |
| 2 | 642 |
| 643 CYG_REPORT_RETURN(); | |
| 644 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
645 return result; |
| 0 | 646 } |
| 647 | |
| 648 // ------------------------------------------------------------------------- | |
| 649 // Wake one thread | |
| 650 | |
| 2 | 651 void |
| 652 Cyg_Condition_Variable::signal(void) | |
| 0 | 653 { |
| 654 CYG_REPORT_FUNCTION(); | |
| 655 | |
| 656 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 657 | |
| 658 // Prevent preemption | |
| 659 Cyg_Scheduler::lock(); | |
| 660 | |
| 661 CYG_INSTRUMENT_CONDVAR(SIGNAL, this, 0); | |
| 662 | |
| 663 if( !queue.empty() ) | |
| 664 { | |
| 665 // The queue is non-empty, so grab the next | |
| 666 // thread from it and wake it up. | |
| 667 | |
| 668 Cyg_Thread *thread = queue.dequeue(); | |
| 669 | |
| 670 CYG_ASSERTCLASS( thread, "Bad thread pointer"); | |
| 671 | |
| 672 thread->set_wake_reason( Cyg_Thread::DONE ); | |
| 673 | |
| 674 thread->wake(); | |
| 675 | |
| 676 CYG_INSTRUMENT_CONDVAR(WAKE, this, thread); | |
| 677 | |
| 678 } | |
| 679 | |
| 680 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 681 | |
| 682 // Unlock the scheduler and maybe switch threads | |
| 683 Cyg_Scheduler::unlock(); | |
| 684 | |
| 2 | 685 CYG_REPORT_RETURN(); |
| 0 | 686 } |
| 687 | |
| 688 // ------------------------------------------------------------------------- | |
| 689 // Set cond true, wake all threads | |
| 690 | |
| 2 | 691 void |
| 692 Cyg_Condition_Variable::broadcast(void) | |
| 0 | 693 { |
| 694 CYG_REPORT_FUNCTION(); | |
| 695 | |
| 696 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 697 | |
| 698 // Prevent preemption | |
| 699 Cyg_Scheduler::lock(); | |
| 700 | |
| 701 CYG_INSTRUMENT_CONDVAR(BROADCAST, this, 0); | |
| 702 | |
| 703 // Grab all the threads from the queue and let them | |
| 704 // go. | |
| 705 | |
| 706 while( !queue.empty() ) | |
| 707 { | |
| 708 Cyg_Thread *thread = queue.dequeue(); | |
| 709 | |
| 710 CYG_ASSERTCLASS( thread, "Bad thread pointer"); | |
| 711 | |
| 712 thread->set_wake_reason( Cyg_Thread::DONE ); | |
| 713 | |
| 714 thread->wake(); | |
| 715 | |
| 716 CYG_INSTRUMENT_CONDVAR(WAKE, this, thread); | |
| 717 } | |
| 718 | |
| 719 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 720 | |
| 721 // Unlock the scheduler and maybe switch threads | |
| 722 Cyg_Scheduler::unlock(); | |
| 2 | 723 |
| 724 CYG_REPORT_RETURN(); | |
| 0 | 725 } |
| 726 | |
| 727 // ------------------------------------------------------------------------- | |
| 728 // Optional timed wait on a CV | |
| 729 | |
| 2 | 730 #if defined(CYGMFN_KERNEL_SYNCH_CONDVAR_TIMED_WAIT) |
| 0 | 731 |
| 2 | 732 cyg_bool |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
733 Cyg_Condition_Variable::wait_inner( Cyg_Mutex *mx, cyg_tick_count timeout ) |
| 0 | 734 { |
| 2 | 735 CYG_REPORT_FUNCTYPE("returning %d"); |
| 736 CYG_REPORT_FUNCARG1("timeout = %d", timeout); | |
| 0 | 737 |
| 738 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
739 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 740 |
| 741 cyg_bool result = true; | |
| 742 | |
| 743 Cyg_Thread *self = Cyg_Thread::self(); | |
| 744 | |
| 745 CYG_ASSERTCLASS( self, "Bad self thread"); | |
| 746 | |
| 747 // Prevent preemption | |
| 748 Cyg_Scheduler::lock(); | |
| 749 | |
| 750 CYG_INSTRUMENT_CONDVAR(TIMED_WAIT, this, 0 ); | |
| 751 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
752 mx->unlock(); |
| 0 | 753 |
| 754 // The ordering of sleep() and set_timer() here are | |
| 755 // important. If the timeout is in the past, the thread | |
| 756 // will be woken up immediately and will not sleep. | |
| 757 | |
| 758 self->sleep(); | |
| 759 | |
| 760 // Set the timer and sleep reason | |
| 761 self->set_timer( timeout, Cyg_Thread::TIMEOUT ); | |
| 762 | |
| 763 // Only enqueue if the timeout has not already fired. | |
| 764 if( self->get_wake_reason() == Cyg_Thread::NONE ) | |
| 765 queue.enqueue( self ); | |
| 766 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
767 // Avoid calling ASRs during the following unlock. |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
768 self->set_asr_inhibit(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
769 |
| 0 | 770 // Unlock the scheduler and switch threads |
|
124
0ec04793409a
Merge from eCos master repository on 2000-09-11-03:00:13-BST
jlarmour
parents:
115
diff
changeset
|
771 Cyg_Scheduler::unlock_reschedule(); |
| 0 | 772 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
773 // Allow ASRs again |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
774 self->clear_asr_inhibit(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
775 |
| 0 | 776 CYG_ASSERTCLASS( this, "Bad this pointer"); |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
777 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 778 |
| 779 self->clear_timer(); | |
| 780 | |
| 781 CYG_INSTRUMENT_CONDVAR(WOKE, this, self->get_wake_reason()); | |
| 782 | |
| 783 switch( self->get_wake_reason() ) | |
| 784 { | |
| 785 case Cyg_Thread::TIMEOUT: | |
| 786 case Cyg_Thread::DESTRUCT: // which, the cv or the mutex? | |
| 787 case Cyg_Thread::BREAK: | |
| 788 result = false; | |
| 789 break; | |
| 790 | |
| 791 case Cyg_Thread::EXIT: | |
| 792 self->exit(); | |
| 793 break; | |
| 794 | |
| 795 default: | |
| 796 break; | |
| 797 } | |
| 798 | |
| 799 | |
| 800 // When we awake, we must re-acquire the mutex. Note that while | |
| 801 // it is essential to release the mutex and queue on the CV | |
| 802 // atomically relative to other threads, to avoid races, it is not | |
| 803 // necessary for us to re-acquire the mutex in the same atomic | |
| 804 // action. Hence we can do it after unlocking the scheduler. | |
| 805 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
806 while ( !mx->lock() ) |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
807 continue; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
808 |
| 0 | 809 CYG_ASSERTCLASS( this, "Bad this pointer"); |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
810 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 2 | 811 |
| 812 CYG_REPORT_RETVAL(result); | |
| 0 | 813 |
| 814 return result; | |
| 815 } | |
| 816 | |
| 817 #endif | |
| 818 | |
| 819 | |
| 820 // ------------------------------------------------------------------------- | |
| 821 // EOF sync/mutex.cxx |
