@@ -92,7 +92,7 @@ trait HomingIO {
92
92
// go home
93
93
let old_home = Cell : : new_empty ( ) ;
94
94
let old_home_ptr = & old_home;
95
- let scheduler = Local :: take :: < Scheduler > ( ) ;
95
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
96
96
do scheduler. deschedule_running_task_and_then |_, task| {
97
97
// get the old home first
98
98
do task. wake ( ) . map_move |mut task| {
@@ -102,11 +102,11 @@ trait HomingIO {
102
102
}
103
103
104
104
// do IO
105
- let scheduler = Local :: take :: < Scheduler > ( ) ;
105
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
106
106
let a = io_sched ( self , scheduler) ;
107
107
108
108
// unhome home
109
- let scheduler = Local :: take :: < Scheduler > ( ) ;
109
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
110
110
do scheduler. deschedule_running_task_and_then |scheduler, task| {
111
111
do task. wake ( ) . map_move |mut task| {
112
112
task. give_home ( old_home. take ( ) ) ;
@@ -442,7 +442,7 @@ impl IoFactory for UvIoFactory {
442
442
do stream. close {
443
443
let res = Err ( uv_error_to_io_error ( status. unwrap ( ) ) ) ;
444
444
unsafe { ( * result_cell_ptr) . put_back ( res) ; }
445
- let scheduler = Local :: take :: < Scheduler > ( ) ;
445
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
446
446
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
447
447
}
448
448
}
@@ -539,7 +539,7 @@ impl IoFactory for UvIoFactory {
539
539
IoError > > = & result_cell;
540
540
let path_cell = Cell :: new ( path) ;
541
541
do task:: unkillable { // FIXME(#8674)
542
- let scheduler = Local : : take :: < Scheduler > ( ) ;
542
+ let scheduler : ~ Scheduler = Local :: take ( ) ;
543
543
do scheduler. deschedule_running_task_and_then |_, task | {
544
544
let task_cell = Cell :: new ( task) ;
545
545
let path = path_cell. take ( ) ;
@@ -553,12 +553,12 @@ impl IoFactory for UvIoFactory {
553
553
loop_, fd, true , home) as ~RtioFileStream ;
554
554
let res = Ok ( fs) ;
555
555
unsafe { ( * result_cell_ptr) . put_back ( res) ; }
556
- let scheduler = Local :: take :: < Scheduler > ( ) ;
556
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
557
557
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
558
558
} else {
559
559
let res = Err ( uv_error_to_io_error ( err. unwrap ( ) ) ) ;
560
560
unsafe { ( * result_cell_ptr) . put_back ( res) ; }
561
- let scheduler = Local :: take :: < Scheduler > ( ) ;
561
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
562
562
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
563
563
}
564
564
} ;
@@ -573,7 +573,7 @@ impl IoFactory for UvIoFactory {
573
573
let result_cell_ptr: * Cell < Result < ( ) , IoError > > = & result_cell;
574
574
let path_cell = Cell :: new ( path) ;
575
575
do task:: unkillable { // FIXME(#8674)
576
- let scheduler = Local : : take :: < Scheduler > ( ) ;
576
+ let scheduler : ~ Scheduler = Local :: take ( ) ;
577
577
do scheduler. deschedule_running_task_and_then |_, task | {
578
578
let task_cell = Cell :: new ( task) ;
579
579
let path = path_cell. take ( ) ;
@@ -583,7 +583,7 @@ impl IoFactory for UvIoFactory {
583
583
Some ( err) => Err ( uv_error_to_io_error ( err) )
584
584
} ;
585
585
unsafe { ( * result_cell_ptr) . put_back ( res) ; }
586
- let scheduler = Local :: take :: < Scheduler > ( ) ;
586
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
587
587
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
588
588
} ;
589
589
} ;
@@ -1154,7 +1154,7 @@ impl UvFileStream {
1154
1154
Some ( err) => Err ( uv_error_to_io_error ( err) )
1155
1155
} ;
1156
1156
unsafe { ( * result_cell_ptr) . put_back ( res) ; }
1157
- let scheduler = Local :: take :: < Scheduler > ( ) ;
1157
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
1158
1158
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
1159
1159
} ;
1160
1160
} ;
@@ -1175,7 +1175,7 @@ impl UvFileStream {
1175
1175
Some ( err) => Err ( uv_error_to_io_error ( err) )
1176
1176
} ;
1177
1177
unsafe { ( * result_cell_ptr) . put_back ( res) ; }
1178
- let scheduler = Local :: take :: < Scheduler > ( ) ;
1178
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
1179
1179
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
1180
1180
} ;
1181
1181
} ;
@@ -1208,7 +1208,7 @@ impl Drop for UvFileStream {
1208
1208
do scheduler. deschedule_running_task_and_then |_, task| {
1209
1209
let task_cell = Cell :: new ( task) ;
1210
1210
do self_. fd . close ( & self . loop_ ) |_, _| {
1211
- let scheduler = Local :: take :: < Scheduler > ( ) ;
1211
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
1212
1212
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
1213
1213
} ;
1214
1214
} ;
@@ -1776,7 +1776,7 @@ fn file_test_uvio_full_simple_impl() {
1776
1776
use path:: Path ;
1777
1777
use rt:: io:: { Open , Create , ReadWrite , Read } ;
1778
1778
unsafe {
1779
- let io = Local :: unsafe_borrow :: < IoFactoryObject > ( ) ;
1779
+ let io: * mut IoFactoryObject = Local :: unsafe_borrow ( ) ;
1780
1780
let write_val = "hello uvio!" ;
1781
1781
let path = "./tmp/file_test_uvio_full.txt" ;
1782
1782
{
@@ -1810,7 +1810,7 @@ fn uvio_naive_print(input: &str) {
1810
1810
use str:: StrSlice ;
1811
1811
unsafe {
1812
1812
use libc:: { STDOUT_FILENO } ;
1813
- let io = Local :: unsafe_borrow :: < IoFactoryObject > ( ) ;
1813
+ let io: * mut IoFactoryObject = Local :: unsafe_borrow ( ) ;
1814
1814
{
1815
1815
let mut fd = ( * io) . fs_from_raw_fd ( STDOUT_FILENO , false ) ;
1816
1816
let write_buf = input. as_bytes ( ) ;
0 commit comments