Mercurial > ecos
annotate packages/kernel/current/src/sync/mutex.cxx @ 115:6ed91473a1cd ecos-sw-2000-08-21
Merge from eCos master repository on 2000-08-21-22:40:54-BST
| author | jlarmour |
|---|---|
| date | Fri, 25 Aug 2000 17:32:38 +0000 |
| parents | 59d97b6ba612 |
| children | 0ec04793409a |
| 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 |
| 0 | 470 //========================================================================== |
| 471 // Condition variables | |
| 472 | |
| 473 Cyg_Condition_Variable::Cyg_Condition_Variable( | |
| 474 Cyg_Mutex &mx // linked mutex | |
| 475 ) | |
| 476 { | |
| 477 CYG_REPORT_FUNCTION(); | |
| 478 | |
| 479 mutex = &mx; | |
| 480 | |
| 481 CYG_ASSERTCLASS( mutex, "Invalid mutex argument"); | |
| 2 | 482 |
| 483 CYG_REPORT_RETURN(); | |
| 0 | 484 } |
| 485 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
486 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
|
487 { |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
488 CYG_REPORT_FUNCTION(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
489 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
490 mutex = NULL; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
491 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
492 CYG_REPORT_RETURN(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
493 } |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
494 |
| 0 | 495 // ------------------------------------------------------------------------- |
| 496 // Destructor | |
| 497 | |
| 498 Cyg_Condition_Variable::~Cyg_Condition_Variable() | |
| 499 { | |
| 500 CYG_REPORT_FUNCTION(); | |
| 501 | |
| 502 CYG_ASSERT( queue.empty(), "Deleting condvar with waiting threads"); | |
| 2 | 503 |
| 504 CYG_REPORT_RETURN(); | |
| 0 | 505 } |
| 506 | |
| 507 // ------------------------------------------------------------------------- | |
| 508 | |
| 509 #ifdef CYGDBG_USE_ASSERTS | |
| 510 | |
|
78
59d97b6ba612
Merge from eCos master repository on 2000-03-28-19:50:47-BST
jlarmour
parents:
66
diff
changeset
|
511 cyg_bool |
| 2 | 512 Cyg_Condition_Variable::check_this( cyg_assert_class_zeal zeal) const |
| 0 | 513 { |
| 2 | 514 bool result = true; |
| 515 | |
| 516 CYG_REPORT_FUNCTYPE("returning %d"); | |
| 517 CYG_REPORT_FUNCARG1("zeal = %d", zeal); | |
| 0 | 518 |
| 519 // check that we have a non-NULL pointer first | |
| 2 | 520 if( this == NULL ) |
| 521 result = false; | |
| 522 else { | |
| 523 | |
| 524 switch( zeal ) | |
| 525 { | |
| 526 case cyg_system_test: | |
| 527 case cyg_extreme: | |
| 528 case cyg_thorough: | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
529 if( mutex != NULL && !mutex->check_this(zeal) ) |
| 2 | 530 result = false; |
| 531 case cyg_quick: | |
| 532 case cyg_trivial: | |
| 533 case cyg_none: | |
| 534 default: | |
| 535 break; | |
| 536 } | |
| 537 } | |
| 0 | 538 |
| 2 | 539 CYG_REPORT_RETVAL(result); |
| 540 return result; | |
| 0 | 541 } |
| 542 | |
| 543 #endif | |
| 544 | |
| 545 // ------------------------------------------------------------------------- | |
| 546 // Wait for condition to be true | |
| 2 | 547 // Note: if this function is entered with the scheduler locked (e.g. to |
| 548 // suspend DSR processing) then there is no need to take the lock. Also | |
| 549 // in this case, exit with the scheduler locked, which allows this function | |
| 550 // to be used in a totally thread-safe manner. | |
| 0 | 551 |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
552 cyg_bool |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
553 Cyg_Condition_Variable::wait_inner( Cyg_Mutex *mx ) |
| 0 | 554 { |
| 555 CYG_REPORT_FUNCTION(); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
556 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
557 cyg_bool result = true; |
| 0 | 558 Cyg_Thread *self = Cyg_Thread::self(); |
| 559 | |
| 2 | 560 cyg_int32 current_lock = Cyg_Scheduler::get_sched_lock(); |
| 561 | |
| 562 if (current_lock == 0) | |
| 563 // Prevent preemption | |
| 564 Cyg_Scheduler::lock(); | |
| 0 | 565 |
| 566 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
|
567 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 568 CYG_ASSERTCLASS( self, "Bad self thread"); |
| 569 | |
| 570 CYG_INSTRUMENT_CONDVAR(WAIT, this, 0); | |
| 571 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
572 mx->unlock(); |
| 0 | 573 |
| 574 self->set_sleep_reason( Cyg_Thread::WAIT ); | |
| 575 | |
| 576 self->sleep(); | |
| 577 | |
| 578 queue.enqueue( self ); | |
| 579 | |
| 580 CYG_ASSERT( Cyg_Scheduler::get_sched_lock() == 1, "Called with non-zero scheduler lock"); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
581 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
582 // 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
|
583 self->set_asr_inhibit(); |
| 0 | 584 |
| 585 // Unlock the scheduler and switch threads | |
| 586 Cyg_Scheduler::unlock(); | |
| 587 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
588 // Allow ASRs again |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
589 self->clear_asr_inhibit(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
590 |
| 0 | 591 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
|
592 |
| 0 | 593 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
|
594 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 595 |
| 596 switch( self->get_wake_reason() ) | |
| 597 { | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
598 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
|
599 case Cyg_Thread::BREAK: |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
600 result = false; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
601 break; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
602 |
| 0 | 603 case Cyg_Thread::EXIT: |
| 604 self->exit(); | |
| 605 break; | |
| 606 | |
| 607 default: | |
| 608 break; | |
| 609 } | |
| 610 | |
| 611 // When we awake, we must re-acquire the mutex. Note that while | |
| 612 // it is essential to release the mutex and queue on the CV | |
| 613 // atomically relative to other threads, to avoid races, it is not | |
| 614 // necessary for us to re-acquire the mutex in the same atomic | |
| 615 // action. Hence we can do it after unlocking the scheduler. | |
| 2 | 616 // We need to loop here in case the thread is released while waiting |
| 617 // for the mutex. It is essential that we exit this function with the | |
| 618 // mutex claimed. | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
619 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
620 while ( !mx->lock() ) |
| 2 | 621 continue; |
| 0 | 622 |
| 623 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
|
624 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
625 CYG_ASSERT( mx->owner == self, "Not mutex owner"); |
| 2 | 626 |
| 627 CYG_REPORT_RETURN(); | |
| 628 | |
| 629 if (current_lock) | |
| 630 // Reacquire the DSR pseudo lock | |
| 631 Cyg_Scheduler::lock(); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
632 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
633 return result; |
| 0 | 634 } |
| 635 | |
| 636 // ------------------------------------------------------------------------- | |
| 637 // Wake one thread | |
| 638 | |
| 2 | 639 void |
| 640 Cyg_Condition_Variable::signal(void) | |
| 0 | 641 { |
| 642 CYG_REPORT_FUNCTION(); | |
| 643 | |
| 644 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 645 | |
| 646 // Prevent preemption | |
| 647 Cyg_Scheduler::lock(); | |
| 648 | |
| 649 CYG_INSTRUMENT_CONDVAR(SIGNAL, this, 0); | |
| 650 | |
| 651 if( !queue.empty() ) | |
| 652 { | |
| 653 // The queue is non-empty, so grab the next | |
| 654 // thread from it and wake it up. | |
| 655 | |
| 656 Cyg_Thread *thread = queue.dequeue(); | |
| 657 | |
| 658 CYG_ASSERTCLASS( thread, "Bad thread pointer"); | |
| 659 | |
| 660 thread->set_wake_reason( Cyg_Thread::DONE ); | |
| 661 | |
| 662 thread->wake(); | |
| 663 | |
| 664 CYG_INSTRUMENT_CONDVAR(WAKE, this, thread); | |
| 665 | |
| 666 } | |
| 667 | |
| 668 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 669 | |
| 670 // Unlock the scheduler and maybe switch threads | |
| 671 Cyg_Scheduler::unlock(); | |
| 672 | |
| 2 | 673 CYG_REPORT_RETURN(); |
| 0 | 674 } |
| 675 | |
| 676 // ------------------------------------------------------------------------- | |
| 677 // Set cond true, wake all threads | |
| 678 | |
| 2 | 679 void |
| 680 Cyg_Condition_Variable::broadcast(void) | |
| 0 | 681 { |
| 682 CYG_REPORT_FUNCTION(); | |
| 683 | |
| 684 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 685 | |
| 686 // Prevent preemption | |
| 687 Cyg_Scheduler::lock(); | |
| 688 | |
| 689 CYG_INSTRUMENT_CONDVAR(BROADCAST, this, 0); | |
| 690 | |
| 691 // Grab all the threads from the queue and let them | |
| 692 // go. | |
| 693 | |
| 694 while( !queue.empty() ) | |
| 695 { | |
| 696 Cyg_Thread *thread = queue.dequeue(); | |
| 697 | |
| 698 CYG_ASSERTCLASS( thread, "Bad thread pointer"); | |
| 699 | |
| 700 thread->set_wake_reason( Cyg_Thread::DONE ); | |
| 701 | |
| 702 thread->wake(); | |
| 703 | |
| 704 CYG_INSTRUMENT_CONDVAR(WAKE, this, thread); | |
| 705 } | |
| 706 | |
| 707 CYG_ASSERTCLASS( this, "Bad this pointer"); | |
| 708 | |
| 709 // Unlock the scheduler and maybe switch threads | |
| 710 Cyg_Scheduler::unlock(); | |
| 2 | 711 |
| 712 CYG_REPORT_RETURN(); | |
| 0 | 713 } |
| 714 | |
| 715 // ------------------------------------------------------------------------- | |
| 716 // Optional timed wait on a CV | |
| 717 | |
| 2 | 718 #if defined(CYGMFN_KERNEL_SYNCH_CONDVAR_TIMED_WAIT) |
| 0 | 719 |
| 2 | 720 cyg_bool |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
721 Cyg_Condition_Variable::wait_inner( Cyg_Mutex *mx, cyg_tick_count timeout ) |
| 0 | 722 { |
| 2 | 723 CYG_REPORT_FUNCTYPE("returning %d"); |
| 724 CYG_REPORT_FUNCARG1("timeout = %d", timeout); | |
| 0 | 725 |
| 726 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
|
727 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 728 |
| 729 cyg_bool result = true; | |
| 730 | |
| 731 Cyg_Thread *self = Cyg_Thread::self(); | |
| 732 | |
| 733 CYG_ASSERTCLASS( self, "Bad self thread"); | |
| 734 | |
| 735 // Prevent preemption | |
| 736 Cyg_Scheduler::lock(); | |
| 737 | |
| 738 CYG_INSTRUMENT_CONDVAR(TIMED_WAIT, this, 0 ); | |
| 739 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
740 mx->unlock(); |
| 0 | 741 |
| 742 // The ordering of sleep() and set_timer() here are | |
| 743 // important. If the timeout is in the past, the thread | |
| 744 // will be woken up immediately and will not sleep. | |
| 745 | |
| 746 self->sleep(); | |
| 747 | |
| 748 // Set the timer and sleep reason | |
| 749 self->set_timer( timeout, Cyg_Thread::TIMEOUT ); | |
| 750 | |
| 751 // Only enqueue if the timeout has not already fired. | |
| 752 if( self->get_wake_reason() == Cyg_Thread::NONE ) | |
| 753 queue.enqueue( self ); | |
| 754 | |
| 755 CYG_ASSERT( Cyg_Scheduler::get_sched_lock() == 1, "Called with non-zero scheduler lock"); | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
756 |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
757 // 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
|
758 self->set_asr_inhibit(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
759 |
| 0 | 760 // Unlock the scheduler and switch threads |
| 761 Cyg_Scheduler::unlock(); | |
| 762 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
763 // Allow ASRs again |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
764 self->clear_asr_inhibit(); |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
765 |
| 0 | 766 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
|
767 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 0 | 768 |
| 769 self->clear_timer(); | |
| 770 | |
| 771 CYG_INSTRUMENT_CONDVAR(WOKE, this, self->get_wake_reason()); | |
| 772 | |
| 773 switch( self->get_wake_reason() ) | |
| 774 { | |
| 775 case Cyg_Thread::TIMEOUT: | |
| 776 case Cyg_Thread::DESTRUCT: // which, the cv or the mutex? | |
| 777 case Cyg_Thread::BREAK: | |
| 778 result = false; | |
| 779 break; | |
| 780 | |
| 781 case Cyg_Thread::EXIT: | |
| 782 self->exit(); | |
| 783 break; | |
| 784 | |
| 785 default: | |
| 786 break; | |
| 787 } | |
| 788 | |
| 789 | |
| 790 // When we awake, we must re-acquire the mutex. Note that while | |
| 791 // it is essential to release the mutex and queue on the CV | |
| 792 // atomically relative to other threads, to avoid races, it is not | |
| 793 // necessary for us to re-acquire the mutex in the same atomic | |
| 794 // action. Hence we can do it after unlocking the scheduler. | |
| 795 | |
|
115
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
796 while ( !mx->lock() ) |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
797 continue; |
|
6ed91473a1cd
Merge from eCos master repository on 2000-08-21-22:40:54-BST
jlarmour
parents:
78
diff
changeset
|
798 |
| 0 | 799 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
|
800 CYG_ASSERTCLASS( mx, "Corrupt mutex"); |
| 2 | 801 |
| 802 CYG_REPORT_RETVAL(result); | |
| 0 | 803 |
| 804 return result; | |
| 805 } | |
| 806 | |
| 807 #endif | |
| 808 | |
| 809 | |
| 810 // ------------------------------------------------------------------------- | |
| 811 // EOF sync/mutex.cxx |
