@@ -13,7 +13,6 @@ Message passing
13
13
*/
14
14
15
15
use cast:: { transmute, transmute_mut} ;
16
- use cast;
17
16
use either:: { Either , Left , Right } ;
18
17
use kinds:: Owned ;
19
18
use option:: { Option , Some , None } ;
@@ -150,7 +149,7 @@ impl<T: Owned> GenericChan<T> for Chan<T> {
150
149
#[ inline( always) ]
151
150
fn send ( & self , x : T ) {
152
151
unsafe {
153
- let mut self_endp = transmute_mut ( & self . endp ) ;
152
+ let self_endp = transmute_mut ( & self . endp ) ;
154
153
let endp = replace ( self_endp, None ) ;
155
154
* self_endp = Some ( streamp:: client:: data ( endp. unwrap ( ) , x) )
156
155
}
@@ -161,7 +160,7 @@ impl<T: Owned> GenericSmartChan<T> for Chan<T> {
161
160
#[ inline( always) ]
162
161
fn try_send ( & self , x : T ) -> bool {
163
162
unsafe {
164
- let mut self_endp = transmute_mut ( & self . endp ) ;
163
+ let self_endp = transmute_mut ( & self . endp ) ;
165
164
let endp = replace ( self_endp, None ) ;
166
165
match streamp:: client:: try_data ( endp. unwrap ( ) , x) {
167
166
Some ( next) => {
@@ -178,7 +177,7 @@ impl<T: Owned> GenericPort<T> for Port<T> {
178
177
#[ inline( always) ]
179
178
fn recv ( & self ) -> T {
180
179
unsafe {
181
- let mut self_endp = transmute_mut ( & self . endp ) ;
180
+ let self_endp = transmute_mut ( & self . endp ) ;
182
181
let endp = replace ( self_endp, None ) ;
183
182
let streamp:: data( x, endp) = recv ( endp. unwrap ( ) ) ;
184
183
* self_endp = Some ( endp) ;
@@ -189,7 +188,7 @@ impl<T: Owned> GenericPort<T> for Port<T> {
189
188
#[ inline( always) ]
190
189
fn try_recv ( & self ) -> Option < T > {
191
190
unsafe {
192
- let mut self_endp = transmute_mut ( & self . endp ) ;
191
+ let self_endp = transmute_mut ( & self . endp ) ;
193
192
let endp = replace ( self_endp, None ) ;
194
193
match try_recv ( endp. unwrap ( ) ) {
195
194
Some ( streamp:: data( x, endp) ) => {
@@ -206,7 +205,7 @@ impl<T: Owned> Peekable<T> for Port<T> {
206
205
#[ inline( always) ]
207
206
fn peek( & self ) -> bool {
208
207
unsafe {
209
- let mut self_endp = transmute_mut ( & self . endp ) ;
208
+ let self_endp = transmute_mut ( & self . endp ) ;
210
209
let mut endp = replace ( self_endp, None ) ;
211
210
let peek = match endp {
212
211
Some ( ref mut endp) => peek ( endp) ,
@@ -220,12 +219,10 @@ impl<T: Owned> Peekable<T> for Port<T> {
220
219
221
220
impl<T: Owned> Selectable for Port<T> {
222
221
fn header(&mut self) -> *mut PacketHeader {
223
- unsafe {
224
222
match self.endp {
225
223
Some(ref mut endp) => endp.header(),
226
224
None => fail!(~" peeking empty stream")
227
225
}
228
- }
229
226
}
230
227
}
231
228
@@ -259,7 +256,7 @@ pub impl<T: Owned> PortSet<T> {
259
256
impl<T:Owned> GenericPort<T> for PortSet<T> {
260
257
fn try_recv(&self) -> Option<T> {
261
258
unsafe {
262
- let mut self_ports = transmute_mut(&self.ports);
259
+ let self_ports = transmute_mut(&self.ports);
263
260
let mut result = None;
264
261
// we have to swap the ports array so we aren't borrowing
265
262
// aliasable mutable memory.
@@ -351,7 +348,7 @@ pub mod oneshot {
351
348
pub fn init<T: Owned>() -> (client::Oneshot<T>, server::Oneshot<T>) {
352
349
pub use core::pipes::HasBuffer;
353
350
354
- let mut buffer = ~::core::pipes::Buffer {
351
+ let buffer = ~::core::pipes::Buffer {
355
352
header: ::core::pipes::BufferHeader(),
356
353
data: __Buffer {
357
354
Oneshot: ::core::pipes::mk_packet::<Oneshot<T>>()
0 commit comments