@@ -53,11 +53,11 @@ enum uv_loop {
53
53
#[ nolink]
54
54
native mod rustrt {
55
55
fn rust_uv_loop_new ( ) -> * ctypes:: void ;
56
- fn rust_uv_loop_delete ( loop : * ctypes:: void ) ;
56
+ fn rust_uv_loop_delete ( lp : * ctypes:: void ) ;
57
57
fn rust_uv_loop_set_data (
58
- loop : * ctypes:: void ,
58
+ lp : * ctypes:: void ,
59
59
data : * uv_loop_data ) ;
60
- fn rust_uv_bind_op_cb ( loop : * ctypes:: void , cb : * u8 )
60
+ fn rust_uv_bind_op_cb ( lp : * ctypes:: void , cb : * u8 )
61
61
-> * ctypes:: void ;
62
62
fn rust_uv_stop_op_cb ( handle : * ctypes:: void ) ;
63
63
fn rust_uv_run ( loop_handle : * ctypes:: void ) ;
@@ -317,37 +317,37 @@ fn loop_new() -> uv_loop unsafe {
317
317
ret comm:: recv ( ret_recv_port) ;
318
318
}
319
319
320
- fn loop_delete ( loop : uv_loop ) {
321
- let loop_ptr = get_loop_ptr_from_uv_loop ( loop ) ;
320
+ fn loop_delete ( lp : uv_loop ) {
321
+ let loop_ptr = get_loop_ptr_from_uv_loop ( lp ) ;
322
322
rustrt:: rust_uv_loop_delete ( loop_ptr) ;
323
323
}
324
324
325
- fn run ( loop : uv_loop ) {
325
+ fn run ( lp : uv_loop ) {
326
326
let end_port = comm:: port :: < bool > ( ) ;
327
327
let end_chan = comm:: chan :: < bool > ( end_port) ;
328
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
328
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
329
329
comm:: send ( loop_chan, msg_run ( end_chan) ) ;
330
330
comm:: recv ( end_port) ;
331
331
}
332
332
333
- fn run_in_bg ( loop : uv_loop ) {
334
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
333
+ fn run_in_bg ( lp : uv_loop ) {
334
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
335
335
comm:: send ( loop_chan, msg_run_in_bg) ;
336
336
}
337
337
338
338
fn async_init (
339
- loop : uv_loop ,
339
+ lp : uv_loop ,
340
340
async_cb : fn ~( uv_handle ) ,
341
341
after_cb : fn ~( uv_handle ) ) {
342
342
let msg = msg_async_init ( async_cb, after_cb) ;
343
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
343
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
344
344
comm:: send ( loop_chan, msg) ;
345
345
}
346
346
347
347
fn async_send ( async : uv_handle ) {
348
348
alt async {
349
- uv_async ( id, loop ) {
350
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
349
+ uv_async ( id, lp ) {
350
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
351
351
comm:: send ( loop_chan, msg_async_send ( id) ) ;
352
352
}
353
353
_ {
@@ -362,18 +362,18 @@ fn close(h: uv_handle, cb: fn~()) {
362
362
comm:: send ( loop_chan, msg_close ( h, cb) ) ;
363
363
}
364
364
365
- fn timer_init ( loop : uv_loop , after_cb : fn ~( uv_handle ) ) {
365
+ fn timer_init ( lp : uv_loop , after_cb : fn ~( uv_handle ) ) {
366
366
let msg = msg_timer_init ( after_cb) ;
367
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
367
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
368
368
comm:: send ( loop_chan, msg) ;
369
369
}
370
370
371
371
fn timer_start ( the_timer : uv_handle , timeout : u32 , repeat : u32 ,
372
372
timer_cb : fn ~( uv_handle ) ) {
373
373
alt the_timer {
374
- uv_timer( id, loop ) {
374
+ uv_timer( id, lp ) {
375
375
let msg = msg_timer_start ( id, timeout, repeat, timer_cb) ;
376
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
376
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
377
377
comm:: send ( loop_chan, msg) ;
378
378
}
379
379
_ {
@@ -385,8 +385,8 @@ fn timer_start(the_timer: uv_handle, timeout: u32, repeat:u32,
385
385
386
386
fn timer_stop ( the_timer : uv_handle , after_cb : fn ~( uv_handle ) ) {
387
387
alt the_timer {
388
- uv_timer( id, loop ) {
389
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
388
+ uv_timer( id, lp ) {
389
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
390
390
let msg = msg_timer_stop ( id, after_cb) ;
391
391
comm:: send ( loop_chan, msg) ;
392
392
}
@@ -423,8 +423,8 @@ fn get_loop_chan_from_data(data: *uv_loop_data)
423
423
fn get_loop_chan_from_handle ( handle : uv_handle )
424
424
-> comm:: chan < uv_msg > {
425
425
alt handle {
426
- uv_async( id, loop ) | uv_timer( id, loop ) {
427
- let loop_chan = get_loop_chan_from_uv_loop ( loop ) ;
426
+ uv_async( id, lp ) | uv_timer ( id, lp ) {
427
+ let loop_chan = get_loop_chan_from_uv_loop ( lp ) ;
428
428
ret loop_chan;
429
429
}
430
430
_ {
@@ -434,15 +434,15 @@ fn get_loop_chan_from_handle(handle: uv_handle)
434
434
}
435
435
}
436
436
437
- fn get_loop_ptr_from_uv_loop ( loop : uv_loop ) -> * ctypes:: void {
438
- alt loop {
437
+ fn get_loop_ptr_from_uv_loop ( lp : uv_loop ) -> * ctypes:: void {
438
+ alt lp {
439
439
uv_loop_new( loop_chan, loop_ptr) {
440
440
ret loop_ptr;
441
441
}
442
442
}
443
443
}
444
- fn get_loop_chan_from_uv_loop ( loop : uv_loop ) -> comm:: chan < uv_msg > {
445
- alt loop {
444
+ fn get_loop_chan_from_uv_loop ( lp : uv_loop ) -> comm:: chan < uv_msg > {
445
+ alt lp {
446
446
uv_loop_new( loop_chan, loop_ptr) {
447
447
ret loop_chan;
448
448
}
@@ -451,7 +451,7 @@ fn get_loop_chan_from_uv_loop(loop: uv_loop) -> comm::chan<uv_msg> {
451
451
452
452
fn get_id_from_handle ( handle : uv_handle ) -> [ u8 ] {
453
453
alt handle {
454
- uv_async( id, loop ) | uv_timer( id, loop ) {
454
+ uv_async( id, lp ) | uv_timer ( id, lp ) {
455
455
ret id;
456
456
}
457
457
_ {
@@ -462,7 +462,7 @@ fn get_id_from_handle(handle: uv_handle) -> [u8] {
462
462
463
463
// crust
464
464
crust fn process_operation (
465
- loop : * ctypes:: void,
465
+ lp : * ctypes:: void ,
466
466
data : * uv_loop_data ) unsafe {
467
467
let op_port = ( * data) . operation_port ;
468
468
let loop_chan = get_loop_chan_from_data ( data) ;
@@ -472,7 +472,7 @@ crust fn process_operation(
472
472
op_async_init ( id) {
473
473
let id_ptr = vec:: unsafe:: to_ptr ( id) ;
474
474
let async_handle = rustrt:: rust_uv_async_init (
475
- loop ,
475
+ lp ,
476
476
process_async_send,
477
477
id_ptr) ;
478
478
comm:: send ( loop_chan, uv_async_init (
@@ -485,7 +485,7 @@ crust fn process_operation(
485
485
op_timer_init ( id) {
486
486
let id_ptr = vec:: unsafe:: to_ptr ( id) ;
487
487
let timer_handle = rustrt:: rust_uv_timer_init (
488
- loop ,
488
+ lp ,
489
489
process_timer_call,
490
490
id_ptr) ;
491
491
comm:: send ( loop_chan, uv_timer_init (
@@ -515,12 +515,12 @@ crust fn process_operation(
515
515
fn handle_op_close ( handle : uv_handle , handle_ptr : * ctypes:: void ) {
516
516
// it's just like im doing C
517
517
alt handle {
518
- uv_async( id, loop ) {
518
+ uv_async( id, lp ) {
519
519
let cb = process_close_async;
520
520
rustrt:: rust_uv_close (
521
521
handle_ptr, cb) ;
522
522
}
523
- uv_timer( id, loop ) {
523
+ uv_timer ( id, lp ) {
524
524
let cb = process_close_timer;
525
525
rustrt:: rust_uv_close (
526
526
handle_ptr, cb) ;
0 commit comments