@@ -49,7 +49,7 @@ fn ip_to_sbuf(ip: net::ip_addr) -> *u8 unsafe {
49
49
vec:: to_ptr ( str:: bytes ( net:: format_addr ( ip) ) )
50
50
}
51
51
52
- fn # connect_task ( args : ( net:: ip_addr , int , chan < socket_event > ) ) {
52
+ fn connect_task ( args : ( net:: ip_addr , int , chan < socket_event > ) ) {
53
53
let ( ip, portnum, evt) = args;
54
54
let connecter = port ( ) ;
55
55
rustrt:: aio_connect ( ip_to_sbuf ( ip) , portnum, chan ( connecter) ) ;
@@ -84,7 +84,7 @@ fn new_client(client: client, evt: chan<socket_event>) {
84
84
log "close message sent" ;
85
85
}
86
86
87
- fn # accept_task ( args : ( client , chan < server_event > ) ) {
87
+ fn accept_task ( args : ( client , chan < server_event > ) ) {
88
88
let ( client, events) = args;
89
89
log "accept task was spawned" ;
90
90
let p = port ( ) ;
@@ -94,7 +94,7 @@ fn# accept_task(args: (client, chan<server_event>)) {
94
94
log "done accepting" ;
95
95
}
96
96
97
- fn # server_task ( args : ( net:: ip_addr , int , chan < server_event > ,
97
+ fn server_task ( args : ( net:: ip_addr , int , chan < server_event > ,
98
98
chan < server > ) ) {
99
99
let ( ip, portnum, events, server) = args;
100
100
let accepter = port ( ) ;
@@ -111,7 +111,7 @@ fn# server_task(args: (net::ip_addr, int, chan<server_event>,
111
111
}
112
112
}
113
113
114
- fn # request_task ( c : chan < ctx > ) {
114
+ fn request_task ( c : chan < ctx > ) {
115
115
// Create a port to accept IO requests on
116
116
let p = port ( ) ;
117
117
// Hand of its channel to our spawner
@@ -150,7 +150,7 @@ fn# request_task(c: chan<ctx>) {
150
150
}
151
151
}
152
152
153
- fn # iotask ( c : chan < ctx > ) {
153
+ fn iotask ( c : chan < ctx > ) {
154
154
log "io task spawned" ;
155
155
// Initialize before accepting requests
156
156
rustrt:: aio_init ( ) ;
0 commit comments