@@ -79,7 +79,8 @@ native mod rustrt {
79
79
fn rust_uvtmp_uv_loop_set_data (
80
80
loop : * ctypes:: void ,
81
81
data : * uv_loop_data ) ;
82
- fn rust_uvtmp_uv_bind_op_cb ( loop : * ctypes:: void , cb : * u8 ) -> * ctypes:: void ;
82
+ fn rust_uvtmp_uv_bind_op_cb ( loop : * ctypes:: void , cb : * u8 )
83
+ -> * ctypes:: void ;
83
84
fn rust_uvtmp_uv_stop_op_cb ( handle : * ctypes:: void ) ;
84
85
fn rust_uvtmp_uv_run ( loop_handle : * ctypes:: void ) ;
85
86
fn rust_uvtmp_uv_close ( handle : * ctypes:: void , cb : * u8 ) ;
@@ -162,7 +163,6 @@ mod uv {
162
163
map:: new_bytes_hash ( ) ;
163
164
let close_callbacks: map:: map < [ u8 ] , fn ~( ) > =
164
165
map:: new_bytes_hash ( ) ;
165
-
166
166
let async_cbs: map:: map < [ u8 ] , fn ~( uv_handle ) > =
167
167
map:: new_bytes_hash ( ) ;
168
168
let timer_cbs: map:: map < [ u8 ] , fn ~( uv_handle ) > =
@@ -190,14 +190,14 @@ mod uv {
190
190
comm:: send ( rust_loop_chan, uv_end) ;
191
191
} ;
192
192
}
193
-
193
+
194
194
msg_run_in_bg {
195
195
task : : spawn_sched ( task:: manual_threads ( 1 u) ) { ||
196
196
// this call blocks
197
197
rustrt:: rust_uvtmp_uv_run ( loop_handle) ;
198
198
} ;
199
199
}
200
-
200
+
201
201
msg_close ( handle, cb) {
202
202
let id = get_id_from_handle ( handle) ;
203
203
close_callbacks. insert ( id, cb) ;
@@ -228,7 +228,7 @@ mod uv {
228
228
cb( ) ;
229
229
} ;
230
230
}
231
-
231
+
232
232
msg_async_init ( callback, after_cb) {
233
233
// create a new async handle
234
234
// with the id as the handle's
@@ -308,7 +308,7 @@ mod uv {
308
308
let the_timer = id_to_handle. get ( id) ;
309
309
after_cb ( the_timer) ;
310
310
}
311
-
311
+
312
312
uv_end ( ) {
313
313
keep_going = false ;
314
314
}
@@ -353,7 +353,7 @@ mod uv {
353
353
354
354
fn close ( h : uv_handle , cb : fn ~( ) ) {
355
355
let loop_chan = get_loop_chan_from_handle ( h) ;
356
- comm:: send ( loop_chan, msg_close ( h, cb) ) ;
356
+ comm:: send ( loop_chan, msg_close ( h, cb) ) ;
357
357
}
358
358
359
359
fn timer_init ( loop : uv_loop , after_cb : fn ~( uv_handle ) ) {
@@ -403,7 +403,7 @@ mod uv {
403
403
ret rand:: mk_rng ( ) . gen_bytes ( 16 u) ;
404
404
}
405
405
fn get_handle_id_from ( buf : * u8 ) -> [ u8 ] unsafe {
406
- ret vec:: unsafe:: from_buf ( buf, 16 u) ;
406
+ ret vec:: unsafe:: from_buf ( buf, 16 u) ;
407
407
}
408
408
409
409
fn get_loop_chan_from_data ( data : * uv_loop_data )
@@ -475,7 +475,6 @@ mod uv {
475
475
rustrt:: rust_uvtmp_uv_timer_stop ( handle) ;
476
476
comm:: send ( loop_chan, uv_timer_stop ( id, after_cb) ) ;
477
477
}
478
-
479
478
_ { fail "unknown form of uv_operation received" ; }
480
479
}
481
480
op_pending = comm:: peek ( op_port) ;
@@ -538,7 +537,7 @@ mod uv {
538
537
// close cb
539
538
process_close_common ( id, data) ;
540
539
}
541
-
540
+
542
541
crust fn process_close_timer (
543
542
id_buf : * u8 ,
544
543
handle_ptr : * ctypes:: void ,
@@ -549,7 +548,6 @@ mod uv {
549
548
process_close_common ( id, data) ;
550
549
}
551
550
552
-
553
551
}
554
552
555
553
#[ test]
@@ -588,7 +586,7 @@ fn test_uvtmp_uv_timer() {
588
586
} ;
589
587
} ;
590
588
} ;
591
- } ;
589
+ } ;
592
590
uv:: run ( test_loop) ;
593
591
assert comm:: recv ( exit_port) ;
594
592
}
0 commit comments