@@ -147,7 +147,7 @@ impl FileDescriptor {
147
147
}
148
148
149
149
// as per bnoordhuis in #libuv: offset >= 0 uses prwrite instead of write
150
- fn write_common ( & self , loop_ : Loop , buf : Buf , offset : i64 , cb : Option < FsCallback > )
150
+ fn write_common ( & mut self , loop_ : Loop , buf : Buf , offset : i64 , cb : Option < FsCallback > )
151
151
-> int {
152
152
let complete_cb_ptr = match cb {
153
153
Some ( _) => compl_cb,
@@ -166,16 +166,16 @@ impl FileDescriptor {
166
166
if is_sync { req. cleanup_and_delete ( ) ; }
167
167
result
168
168
}
169
- pub fn write ( & self , loop_ : Loop , buf : Buf , offset : i64 , cb : FsCallback )
169
+ pub fn write ( & mut self , loop_ : Loop , buf : Buf , offset : i64 , cb : FsCallback )
170
170
-> int {
171
171
self . write_common ( loop_, buf, offset, Some ( cb) )
172
172
}
173
- pub fn write_sync ( & self , loop_ : Loop , buf : Buf , offset : i64 )
173
+ pub fn write_sync ( & mut self , loop_ : Loop , buf : Buf , offset : i64 )
174
174
-> int {
175
175
self . write_common ( loop_, buf, offset, None )
176
176
}
177
177
178
- fn read_common ( & self , loop_ : Loop , buf : Buf ,
178
+ fn read_common ( & mut self , loop_ : Loop , buf : Buf ,
179
179
offset : i64 , cb : Option < FsCallback > )
180
180
-> int {
181
181
let complete_cb_ptr = match cb {
@@ -194,11 +194,11 @@ impl FileDescriptor {
194
194
if is_sync { req. cleanup_and_delete ( ) ; }
195
195
result
196
196
}
197
- pub fn read ( & self , loop_ : Loop , buf : Buf , offset : i64 , cb : FsCallback )
197
+ pub fn read ( & mut self , loop_ : Loop , buf : Buf , offset : i64 , cb : FsCallback )
198
198
-> int {
199
199
self . read_common ( loop_, buf, offset, Some ( cb) )
200
200
}
201
- pub fn read_sync ( & self , loop_ : Loop , buf : Buf , offset : i64 )
201
+ pub fn read_sync ( & mut self , loop_ : Loop , buf : Buf , offset : i64 )
202
202
-> int {
203
203
self . read_common ( loop_, buf, offset, None )
204
204
}
@@ -294,7 +294,7 @@ mod test {
294
294
|req, uverr| {
295
295
let loop_ = req. get_loop ( ) ;
296
296
assert ! ( uverr. is_none( ) ) ;
297
- let fd = FileDescriptor :: from_open_req ( req) ;
297
+ let mut fd = FileDescriptor :: from_open_req ( req) ;
298
298
let raw_fd = fd. native_handle ( ) ;
299
299
let buf = unsafe { * write_buf_ptr } ;
300
300
do fd. write ( loop_, buf, -1 ) |_, uverr| {
@@ -306,7 +306,7 @@ mod test {
306
306
|req, uverr| {
307
307
assert ! ( uverr. is_none( ) ) ;
308
308
let loop_ = req. get_loop ( ) ;
309
- let fd = FileDescriptor :: from_open_req ( req) ;
309
+ let mut fd = FileDescriptor :: from_open_req ( req) ;
310
310
let raw_fd = fd. native_handle ( ) ;
311
311
let read_buf = unsafe { * read_buf_ptr } ;
312
312
do fd. read ( loop_, read_buf, 0 ) |req, uverr| {
@@ -360,7 +360,7 @@ mod test {
360
360
create_flags as int, mode as int);
361
361
assert!(status_to_maybe_uv_error_with_loop(
362
362
loop_.native_handle(), result as i32).is_none());
363
- let fd = FileDescriptor(result as i32);
363
+ let mut fd = FileDescriptor(result as i32);
364
364
// write
365
365
let result = fd.write_sync(loop_, write_buf, -1);
366
366
assert!(status_to_maybe_uv_error_with_loop(
@@ -375,7 +375,7 @@ mod test {
375
375
assert!(status_to_maybe_uv_error_with_loop(
376
376
loop_.native_handle(), result as i32).is_none());
377
377
let len = 1028;
378
- let fd = FileDescriptor(result as i32);
378
+ let mut fd = FileDescriptor(result as i32);
379
379
// read
380
380
let read_mem: ~[u8] = vec::from_elem(len, 0u8);
381
381
let buf = slice_to_uv_buf(read_mem);
@@ -413,7 +413,7 @@ mod test {
413
413
}
414
414
415
415
fn naive_print(loop_: Loop, input: &str) {
416
- let stdout = FileDescriptor(STDOUT_FILENO);
416
+ let mut stdout = FileDescriptor(STDOUT_FILENO);
417
417
let write_val = input.as_bytes();
418
418
let write_buf = slice_to_uv_buf(write_val);
419
419
stdout.write_sync(loop_, write_buf, -1);
0 commit comments