annotate packages/kernel/current/src/sync/mutex.cxx @ 62:7a6ac9edc838 ecos-sw-2000-01-24

Merge from eCos master repository on 2000-01-24-19:43:49-GMT
author jlarmour
date Mon, 24 Jan 2000 21:43:17 +0000
parents 18ee5a9c102e
children c38311975d4f
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
1 //==========================================================================
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
2 //
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
3 // sync/mutex.cxx
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
4 //
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
5 // Mutex and condition variable implementation
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
6 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
7 //==========================================================================
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
8 //####COPYRIGHTBEGIN####
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
9 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
10 // -------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
11 // The contents of this file are subject to the Cygnus eCos Public License
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
12 // Version 1.0 (the "License"); you may not use this file except in
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
13 // compliance with the License. You may obtain a copy of the License at
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
14 // http://sourceware.cygnus.com/ecos
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
15 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
16 // Software distributed under the License is distributed on an "AS IS"
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
17 // basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
18 // License for the specific language governing rights and limitations under
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
19 // the License.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
20 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
21 // The Original Code is eCos - Embedded Cygnus Operating System, released
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
22 // September 30, 1998.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
23 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
24 // The Initial Developer of the Original Code is Cygnus. Portions created
62
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
25 // by Cygnus are Copyright (C) 1998,1999,2000 Cygnus Solutions.
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
26 // All Rights Reserved.
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
27 // -------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
28 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
29 //####COPYRIGHTEND####
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
30 //==========================================================================
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
31 //#####DESCRIPTIONBEGIN####
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
32 //
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
33 // Author(s): nickg
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
34 // Contributors: nickg, jlarmour
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
35 // Date: 1999-02-17
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
36 // Purpose: Mutex implementation
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
37 // Description: This file contains the implementations of the mutex
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
38 // and condition variable classes.
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
39 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
40 //####DESCRIPTIONEND####
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
41 //
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
42 //==========================================================================
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
43
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
44 #include <pkgconf/kernel.h>
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
45
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
46 #include <cyg/kernel/ktypes.h> // base kernel types
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
47 #include <cyg/infra/cyg_trac.h> // tracing macros
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
48 #include <cyg/infra/cyg_ass.h> // assertion macros
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
49 #include <cyg/kernel/instrmnt.h> // instrumentation
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
50
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
51 #include <cyg/kernel/mutex.hxx> // our header
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
52
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
53 #include <cyg/kernel/thread.inl> // thread inlines
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
54 #include <cyg/kernel/sched.inl> // scheduler inlines
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
55 #include <cyg/kernel/clock.inl> // clock inlines
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
56
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
57
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
58 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
59 // Constructor
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
60
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
61 Cyg_Mutex::Cyg_Mutex()
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
62 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
63 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
64
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
65 locked = false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
66 owner = NULL;
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
67
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
68 CYG_REPORT_RETURN();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
69 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
70
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
71 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
72 // Destructor
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
73
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
74 Cyg_Mutex::~Cyg_Mutex()
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
75 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
76 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
77
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
78 CYG_ASSERT( owner == NULL, "Deleting mutex with owner");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
79 CYG_ASSERT( queue.empty(), "Deleting mutex with waiting threads");
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
80 CYG_REPORT_RETURN();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
81 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
82
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
83 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
84
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
85 #ifdef CYGDBG_USE_ASSERTS
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
86
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
87 bool
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
88 Cyg_Mutex::check_this( cyg_assert_class_zeal zeal) const
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
89 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
90 // CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
91
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
92 // check that we have a non-NULL pointer first
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
93 if( this == NULL ) return false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
94
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
95 switch( zeal )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
96 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
97 case cyg_system_test:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
98 case cyg_extreme:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
99 case cyg_thorough:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
100 case cyg_quick:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
101 case cyg_trivial:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
102 if( locked && owner == NULL ) return false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
103 if( !locked && owner != NULL ) return false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
104 case cyg_none:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
105 default:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
106 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
107 };
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
108
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
109 return true;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
110 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
111
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
112 #endif
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
113
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
114 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
115 // Lock and/or wait
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
116
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
117 cyg_bool
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
118 Cyg_Mutex::lock(void)
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
119 {
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
120 CYG_REPORT_FUNCTYPE("returning %d");
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
121
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
122 cyg_bool result = true;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
123 Cyg_Thread *self = Cyg_Thread::self();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
124
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
125 // Prevent preemption
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
126 Cyg_Scheduler::lock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
127
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
128 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
129
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
130 CYG_INSTRUMENT_MUTEX(LOCK, this, 0);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
131
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
132 // Loop while the mutex is locked, sleeping each time around
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
133 // the loop. This copes with the possibility of a higher priority
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
134 // thread grabbing the mutex between the wakeup in unlock() and
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
135 // this thread actually starting.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
136
62
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
137 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INHERITANCE
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
138
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
139 self->count_mutex();
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
140
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
141 #endif
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
142
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
143 while( locked && result )
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
144 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
145 CYG_ASSERT( self != owner, "Locking mutex I already own");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
146
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
147 self->set_sleep_reason( Cyg_Thread::WAIT );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
148
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
149 self->sleep();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
150
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
151 queue.enqueue( self );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
152
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
153 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INHERITANCE
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
154
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
155 owner->inherit_priority(self);
28
18ee5a9c102e Merge from eCos master repository on 1999-08-09-17:04:48-BST
jlarmour
parents: 2
diff changeset
156
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
157 #endif
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
158
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
159 CYG_INSTRUMENT_MUTEX(WAIT, this, 0);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
160
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
161 CYG_ASSERT( Cyg_Scheduler::get_sched_lock() == 1, "Called with non-zero scheduler lock");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
162
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
163 // Unlock scheduler and allow other threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
164 // to run
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
165 Cyg_Scheduler::unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
166 Cyg_Scheduler::lock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
167
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
168 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
169
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
170 switch( self->get_wake_reason() )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
171 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
172 case Cyg_Thread::DESTRUCT:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
173 case Cyg_Thread::BREAK:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
174 result = false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
175 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
176
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
177 case Cyg_Thread::EXIT:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
178 self->exit();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
179 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
180
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
181 default:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
182 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
183 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
184
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
185 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
186
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
187 if( result )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
188 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
189 locked = true;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
190 owner = self;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
191
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
192 CYG_INSTRUMENT_MUTEX(LOCKED, this, 0);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
193 }
62
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
194 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INHERITANCE
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
195 else
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
196 {
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
197 self->uncount_mutex();
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
198 self->disinherit_priority();
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
199 }
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
200 #endif
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
201
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
202 // Unlock the scheduler and maybe switch threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
203 Cyg_Scheduler::unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
204
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
205 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
206
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
207 CYG_REPORT_RETVAL(result);
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
208
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
209 return result;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
210 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
211
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
212 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
213 // Try to lock and return success
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
214
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
215 cyg_bool
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
216 Cyg_Mutex::trylock(void)
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
217 {
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
218 CYG_REPORT_FUNCTYPE("returning %d");
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
219
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
220 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
221
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
222 cyg_bool result = true;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
223
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
224 // Prevent preemption
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
225 Cyg_Scheduler::lock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
226
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
227 // If the mutex is not locked, grab it
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
228 // for ourself. Otherwise return failure.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
229 if( !locked )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
230 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
231 Cyg_Thread *self = Cyg_Thread::self();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
232
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
233 locked = true;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
234 owner = self;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
235
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
236 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INHERITANCE
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
237
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
238 self->count_mutex();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
239
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
240 #endif
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
241 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
242 else result = false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
243
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
244 CYG_INSTRUMENT_MUTEX(TRY, this, result);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
245
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
246 // Unlock the scheduler and maybe switch threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
247 Cyg_Scheduler::unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
248
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
249 CYG_REPORT_RETVAL(result);
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
250 return result;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
251 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
252
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
253 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
254 // unlock
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
255
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
256 void
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
257 Cyg_Mutex::unlock(void)
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
258 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
259 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
260
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
261 // Prevent preemption
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
262 Cyg_Scheduler::lock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
263
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
264 CYG_INSTRUMENT_MUTEX(UNLOCK, this, 0);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
265
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
266 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
267 CYG_ASSERT( locked, "Unlock mutex that is not locked");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
268 CYG_ASSERT( owner == Cyg_Thread::self(), "Unlock mutex I do not own");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
269
62
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
270 if( !queue.empty() ) {
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
271
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
272 // 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
273 // 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
274
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
275 Cyg_Thread *thread = queue.dequeue();
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
276
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
277 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
278
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
279 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INHERITANCE
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
280
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
281 // 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
282 // queue or the relinquishing thread:
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
283
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
284 thread->relay_priority(owner, &queue);
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
285
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
286 #endif
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
287
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
288 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
289
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
290 thread->wake();
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
291
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
292 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
293
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
294 }
7a6ac9edc838 Merge from eCos master repository on 2000-01-24-19:43:49-GMT
jlarmour
parents: 28
diff changeset
295
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
296 #ifdef CYGSEM_KERNEL_SYNCH_MUTEX_PRIORITY_INHERITANCE
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
297
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
298 owner->uncount_mutex();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
299 owner->disinherit_priority();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
300
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
301 #endif
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
302
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
303 locked = false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
304 owner = NULL;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
305
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
306 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
307
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
308 // Unlock the scheduler and maybe switch threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
309 Cyg_Scheduler::unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
310
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
311 CYG_REPORT_RETURN();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
312 }
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
313
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
314 // -------------------------------------------------------------------------
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
315 // Release all waiting threads.
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
316
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
317 void Cyg_Mutex::release()
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
318 {
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
319 CYG_REPORT_FUNCTION();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
320
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
321 // Prevent preemption
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
322 Cyg_Scheduler::lock();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
323
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
324 CYG_INSTRUMENT_MUTEX(RELEASE, this, 0);
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
325
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
326 CYG_ASSERTCLASS( this, "Bad this pointer");
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
327
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
328 while( !queue.empty() )
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
329 {
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
330 // The queue is non-empty, so grab each
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
331 // thread from it and release it.
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
332
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
333 Cyg_Thread *thread = queue.dequeue();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
334
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
335 CYG_ASSERTCLASS( thread, "Bad thread pointer");
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
336
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
337 thread->release();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
338
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
339 CYG_INSTRUMENT_MUTEX(RELEASED, this, thread);
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
340
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
341 }
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
342
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
343 CYG_ASSERTCLASS( this, "Bad this pointer");
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
344
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
345 // Unlock the scheduler and maybe switch threads
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
346 Cyg_Scheduler::unlock();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
347
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
348 CYG_REPORT_RETURN();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
349 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
350
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
351 //==========================================================================
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
352 // Condition variables
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
353
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
354 Cyg_Condition_Variable::Cyg_Condition_Variable(
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
355 Cyg_Mutex &mx // linked mutex
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
356 )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
357 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
358 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
359
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
360 mutex = &mx;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
361
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
362 CYG_ASSERTCLASS( mutex, "Invalid mutex argument");
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
363
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
364 CYG_REPORT_RETURN();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
365 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
366
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
367 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
368 // Destructor
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
369
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
370 Cyg_Condition_Variable::~Cyg_Condition_Variable()
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
371 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
372 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
373
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
374 CYG_ASSERT( queue.empty(), "Deleting condvar with waiting threads");
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
375
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
376 CYG_REPORT_RETURN();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
377 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
378
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
379 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
380
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
381 #ifdef CYGDBG_USE_ASSERTS
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
382
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
383 bool
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
384 Cyg_Condition_Variable::check_this( cyg_assert_class_zeal zeal) const
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
385 {
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
386 bool result = true;
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
387
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
388 CYG_REPORT_FUNCTYPE("returning %d");
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
389 CYG_REPORT_FUNCARG1("zeal = %d", zeal);
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
390
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
391 // check that we have a non-NULL pointer first
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
392 if( this == NULL )
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
393 result = false;
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
394 else {
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
395
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
396 switch( zeal )
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
397 {
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
398 case cyg_system_test:
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
399 case cyg_extreme:
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
400 case cyg_thorough:
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
401 if( !mutex->check_this(zeal) )
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
402 result = false;
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
403 case cyg_quick:
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
404 case cyg_trivial:
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
405 case cyg_none:
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
406 default:
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
407 break;
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
408 }
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
409 }
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
410
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
411 CYG_REPORT_RETVAL(result);
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
412 return result;
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
413 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
414
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
415 #endif
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
416
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
417 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
418 // Wait for condition to be true
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
419 // Note: if this function is entered with the scheduler locked (e.g. to
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
420 // suspend DSR processing) then there is no need to take the lock. Also
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
421 // in this case, exit with the scheduler locked, which allows this function
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
422 // to be used in a totally thread-safe manner.
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
423
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
424 void
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
425 Cyg_Condition_Variable::wait(void)
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
426 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
427 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
428
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
429 Cyg_Thread *self = Cyg_Thread::self();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
430
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
431 cyg_int32 current_lock = Cyg_Scheduler::get_sched_lock();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
432
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
433 if (current_lock == 0)
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
434 // Prevent preemption
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
435 Cyg_Scheduler::lock();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
436
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
437 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
438 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
439 CYG_ASSERTCLASS( self, "Bad self thread");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
440
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
441 CYG_INSTRUMENT_CONDVAR(WAIT, this, 0);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
442
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
443 mutex->unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
444
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
445 self->set_sleep_reason( Cyg_Thread::WAIT );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
446
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
447 self->sleep();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
448
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
449 queue.enqueue( self );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
450
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
451 CYG_ASSERT( Cyg_Scheduler::get_sched_lock() == 1, "Called with non-zero scheduler lock");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
452
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
453 // Unlock the scheduler and switch threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
454 Cyg_Scheduler::unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
455
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
456 CYG_INSTRUMENT_CONDVAR(WOKE, this, self->get_wake_reason());
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
457
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
458 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
459 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
460
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
461 switch( self->get_wake_reason() )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
462 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
463 case Cyg_Thread::EXIT:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
464 self->exit();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
465 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
466
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
467 default:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
468 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
469 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
470
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
471
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
472 // When we awake, we must re-acquire the mutex. Note that while
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
473 // it is essential to release the mutex and queue on the CV
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
474 // atomically relative to other threads, to avoid races, it is not
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
475 // necessary for us to re-acquire the mutex in the same atomic
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
476 // action. Hence we can do it after unlocking the scheduler.
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
477 // We need to loop here in case the thread is released while waiting
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
478 // for the mutex. It is essential that we exit this function with the
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
479 // mutex claimed.
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
480
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
481 while ( !mutex->lock() )
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
482 continue;
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
483
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
484 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
485 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
486 CYG_ASSERT( mutex->owner == self, "Not mutex owner");
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
487
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
488 CYG_REPORT_RETURN();
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
489
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
490 if (current_lock)
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
491 // Reacquire the DSR pseudo lock
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
492 Cyg_Scheduler::lock();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
493 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
494
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
495 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
496 // Wake one thread
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
497
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
498 void
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
499 Cyg_Condition_Variable::signal(void)
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
500 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
501 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
502
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
503 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
504 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
505
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
506 // Prevent preemption
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
507 Cyg_Scheduler::lock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
508
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
509 CYG_INSTRUMENT_CONDVAR(SIGNAL, this, 0);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
510
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
511 if( !queue.empty() )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
512 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
513 // The queue is non-empty, so grab the next
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
514 // thread from it and wake it up.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
515
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
516 Cyg_Thread *thread = queue.dequeue();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
517
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
518 CYG_ASSERTCLASS( thread, "Bad thread pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
519
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
520 thread->set_wake_reason( Cyg_Thread::DONE );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
521
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
522 thread->wake();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
523
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
524 CYG_INSTRUMENT_CONDVAR(WAKE, this, thread);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
525
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
526 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
527
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
528 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
529 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
530
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
531 // Unlock the scheduler and maybe switch threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
532 Cyg_Scheduler::unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
533
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
534 CYG_REPORT_RETURN();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
535 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
536
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
537 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
538 // Set cond true, wake all threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
539
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
540 void
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
541 Cyg_Condition_Variable::broadcast(void)
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
542 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
543 CYG_REPORT_FUNCTION();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
544
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
545 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
546 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
547
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
548 // Prevent preemption
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
549 Cyg_Scheduler::lock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
550
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
551 CYG_INSTRUMENT_CONDVAR(BROADCAST, this, 0);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
552
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
553 // Grab all the threads from the queue and let them
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
554 // go.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
555
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
556 while( !queue.empty() )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
557 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
558 Cyg_Thread *thread = queue.dequeue();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
559
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
560 CYG_ASSERTCLASS( thread, "Bad thread pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
561
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
562 thread->set_wake_reason( Cyg_Thread::DONE );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
563
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
564 thread->wake();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
565
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
566 CYG_INSTRUMENT_CONDVAR(WAKE, this, thread);
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
567 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
568
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
569 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
570 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
571
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
572 // Unlock the scheduler and maybe switch threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
573 Cyg_Scheduler::unlock();
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
574
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
575 CYG_REPORT_RETURN();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
576 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
577
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
578 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
579 // Optional timed wait on a CV
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
580
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
581 #if defined(CYGMFN_KERNEL_SYNCH_CONDVAR_TIMED_WAIT)
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
582
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
583 cyg_bool
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
584 Cyg_Condition_Variable::wait( cyg_tick_count timeout )
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
585 {
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
586 CYG_REPORT_FUNCTYPE("returning %d");
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
587 CYG_REPORT_FUNCARG1("timeout = %d", timeout);
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
588
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
589 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
590 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
591
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
592 cyg_bool result = true;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
593
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
594 Cyg_Thread *self = Cyg_Thread::self();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
595
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
596 CYG_ASSERTCLASS( self, "Bad self thread");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
597
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
598 // Prevent preemption
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
599 Cyg_Scheduler::lock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
600
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
601 CYG_INSTRUMENT_CONDVAR(TIMED_WAIT, this, 0 );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
602
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
603 mutex->unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
604
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
605 // The ordering of sleep() and set_timer() here are
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
606 // important. If the timeout is in the past, the thread
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
607 // will be woken up immediately and will not sleep.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
608
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
609 self->sleep();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
610
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
611 // Set the timer and sleep reason
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
612 self->set_timer( timeout, Cyg_Thread::TIMEOUT );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
613
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
614 // Only enqueue if the timeout has not already fired.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
615 if( self->get_wake_reason() == Cyg_Thread::NONE )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
616 queue.enqueue( self );
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
617
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
618 CYG_ASSERT( Cyg_Scheduler::get_sched_lock() == 1, "Called with non-zero scheduler lock");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
619
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
620 // Unlock the scheduler and switch threads
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
621 Cyg_Scheduler::unlock();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
622
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
623 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
624 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
625
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
626 self->clear_timer();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
627
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
628 CYG_INSTRUMENT_CONDVAR(WOKE, this, self->get_wake_reason());
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
629
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
630 switch( self->get_wake_reason() )
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
631 {
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
632 case Cyg_Thread::TIMEOUT:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
633 case Cyg_Thread::DESTRUCT: // which, the cv or the mutex?
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
634 case Cyg_Thread::BREAK:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
635 result = false;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
636 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
637
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
638 case Cyg_Thread::EXIT:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
639 self->exit();
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
640 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
641
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
642 default:
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
643 break;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
644 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
645
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
646
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
647 // When we awake, we must re-acquire the mutex. Note that while
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
648 // it is essential to release the mutex and queue on the CV
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
649 // atomically relative to other threads, to avoid races, it is not
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
650 // necessary for us to re-acquire the mutex in the same atomic
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
651 // action. Hence we can do it after unlocking the scheduler.
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
652
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
653 // FIXME: what if we woke up above due to TIMEOUT/DESTRUCT/BREAK?
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
654 // In that situation is it correct to not lock the mutex?
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
655 if (false != result)
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
656 result = mutex->lock();
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
657
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
658 CYG_ASSERTCLASS( this, "Bad this pointer");
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
659 CYG_ASSERTCLASS( mutex, "Corrupt mutex");
2
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
660
443894e2e912 Block commit of eCos version 1.2.1
jlarmour
parents: 0
diff changeset
661 CYG_REPORT_RETVAL(result);
0
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
662
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
663 return result;
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
664 }
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
665
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
666 #endif
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
667
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
668
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
669 // -------------------------------------------------------------------------
3111d98ba7b3 Initial commit of eCos version 1.1
jlarmour
parents:
diff changeset
670 // EOF sync/mutex.cxx