@@ -66,6 +66,9 @@ pub type uv_fs_t = c_void;
66
66
pub type uv_udp_send_t = c_void ;
67
67
68
68
pub type uv_idle_cb = * u8 ;
69
+ pub type uv_alloc_cb = * u8 ;
70
+ pub type uv_udp_send_cb = * u8 ;
71
+ pub type uv_udp_recv_cb = * u8 ;
69
72
70
73
pub type sockaddr_in = c_void ;
71
74
pub type sockaddr_in6 = c_void ;
@@ -198,27 +201,31 @@ pub unsafe fn udp_bind6(server: *uv_udp_t, addr: *sockaddr_in6, flags: c_uint) -
198
201
}
199
202
200
203
pub unsafe fn udp_send < T > ( req : * uv_udp_send_t , handle : * T , buf_in : & [ uv_buf_t ] ,
201
- addr : * sockaddr_in , cb : * u8 ) -> c_int {
204
+ addr : * sockaddr_in , cb : uv_udp_send_cb ) -> c_int {
202
205
let buf_ptr = vec:: raw:: to_ptr ( buf_in) ;
203
206
let buf_cnt = buf_in. len ( ) as i32 ;
204
207
return rust_uv_udp_send ( req, handle as * c_void , buf_ptr, buf_cnt, addr, cb) ;
205
208
}
206
209
207
210
pub unsafe fn udp_send6 < T > ( req : * uv_udp_send_t , handle : * T , buf_in : & [ uv_buf_t ] ,
208
- addr : * sockaddr_in6 , cb : * u8 ) -> c_int {
211
+ addr : * sockaddr_in6 , cb : uv_udp_send_cb ) -> c_int {
209
212
let buf_ptr = vec:: raw:: to_ptr ( buf_in) ;
210
213
let buf_cnt = buf_in. len ( ) as i32 ;
211
214
return rust_uv_udp_send ( req, handle as * c_void , buf_ptr, buf_cnt, addr, cb) ;
212
215
}
213
216
214
- pub unsafe fn udp_recv_start ( server : * uv_udp_t , on_alloc : * u8 , on_recv : * u8 ) -> c_int {
217
+ pub unsafe fn udp_recv_start ( server : * uv_udp_t , on_alloc : uv_alloc_cb , on_recv : uv_udp_recv_cb ) -> c_int {
215
218
return rust_uv_udp_recv_start ( server, on_alloc, on_recv) ;
216
219
}
217
220
218
221
pub unsafe fn udp_recv_stop ( server : * uv_udp_t ) -> c_int {
219
222
return rust_uv_udp_recv_stop ( server) ;
220
223
}
221
224
225
+ pub unsafe fn get_udp_handle_from_send_req ( send_req : * uv_udp_send_t ) -> * uv_udp_t {
226
+ return rust_uv_get_udp_handle_from_send_req ( send_req) ;
227
+ }
228
+
222
229
pub unsafe fn tcp_init ( loop_handle : * c_void , handle : * uv_tcp_t ) -> c_int {
223
230
return rust_uv_tcp_init ( loop_handle, handle) ;
224
231
}
@@ -269,7 +276,7 @@ pub unsafe fn write<T>(req: *uv_write_t, stream: *T, buf_in: &[uv_buf_t], cb: *u
269
276
let buf_cnt = buf_in. len ( ) as i32 ;
270
277
return rust_uv_write ( req as * c_void , stream as * c_void , buf_ptr, buf_cnt, cb) ;
271
278
}
272
- pub unsafe fn read_start ( stream : * uv_stream_t , on_alloc : * u8 , on_read : * u8 ) -> c_int {
279
+ pub unsafe fn read_start ( stream : * uv_stream_t , on_alloc : uv_alloc_cb , on_read : * u8 ) -> c_int {
273
280
return rust_uv_read_start ( stream as * c_void , on_alloc, on_read) ;
274
281
}
275
282
@@ -463,6 +470,7 @@ extern {
463
470
buf_cnt : c_int , addr : * sockaddr_in6 , cb : * u8 ) -> c_int ;
464
471
fn rust_uv_udp_recv_start ( server : * uv_udp_t , on_alloc : * u8 , on_recv : * u8 ) -> c_int ;
465
472
fn rust_uv_udp_recv_stop ( server : * uv_udp_t ) -> c_int ;
473
+ fn rust_uv_get_udp_handle_from_send_req ( req : * uv_udp_send_t ) -> * uv_udp_t ;
466
474
467
475
fn rust_uv_listen ( stream : * c_void , backlog : c_int , cb : * u8 ) -> c_int ;
468
476
fn rust_uv_accept ( server : * c_void , client : * c_void ) -> c_int ;
0 commit comments