@@ -96,11 +96,11 @@ impl<Q: Send> &Sem<Q> {
96
96
state. count -= 1 ;
97
97
if state. count < 0 {
98
98
// Create waiter nobe.
99
- let ( signal_end , wait_end ) = pipes:: oneshot ( ) ;
99
+ let ( SignalEnd , WaitEnd ) = pipes:: oneshot ( ) ;
100
100
// Tell outer scope we need to block.
101
- waiter_nobe = Some ( wait_end ) ;
101
+ waiter_nobe = Some ( WaitEnd ) ;
102
102
// Enqueue ourself.
103
- state. waiters . tail . send ( signal_end ) ;
103
+ state. waiters . tail . send ( SignalEnd ) ;
104
104
}
105
105
}
106
106
}
@@ -202,9 +202,9 @@ impl &Condvar {
202
202
*/
203
203
fn wait_on ( condvar_id : uint ) {
204
204
// Create waiter nobe.
205
- let ( signal_end , wait_end ) = pipes:: oneshot ( ) ;
206
- let mut wait_end = Some ( wait_end ) ;
207
- let mut signal_end = Some ( signal_end ) ;
205
+ let ( SignalEnd , WaitEnd ) = pipes:: oneshot ( ) ;
206
+ let mut WaitEnd = Some ( WaitEnd ) ;
207
+ let mut SignalEnd = Some ( SignalEnd ) ;
208
208
let mut reacquire = None ;
209
209
let mut out_of_bounds = None ;
210
210
unsafe {
@@ -218,8 +218,8 @@ impl &Condvar {
218
218
signal_waitqueue ( & state. waiters ) ;
219
219
}
220
220
// Enqueue ourself to be woken up by a signaller.
221
- let signal_end = option:: swap_unwrap ( & mut signal_end ) ;
222
- state. blocked [ condvar_id] . tail . send ( signal_end ) ;
221
+ let SignalEnd = option:: swap_unwrap ( & mut SignalEnd ) ;
222
+ state. blocked [ condvar_id] . tail . send ( SignalEnd ) ;
223
223
} else {
224
224
out_of_bounds = Some ( vec:: len ( state. blocked ) ) ;
225
225
}
@@ -238,7 +238,7 @@ impl &Condvar {
238
238
// Unconditionally "block". (Might not actually block if a
239
239
// signaller already sent -- I mean 'unconditionally' in contrast
240
240
// with acquire().)
241
- let _ = pipes:: recv_one ( option:: swap_unwrap ( & mut wait_end ) ) ;
241
+ let _ = pipes:: recv_one ( option:: swap_unwrap ( & mut WaitEnd ) ) ;
242
242
}
243
243
244
244
// This is needed for a failing condition variable to reacquire the
0 commit comments