@@ -647,11 +647,13 @@ unsafe fn accept(server: *libc::c_void, client: *libc::c_void)
647
647
ret rustrt:: rust_uv_accept ( server, client) ;
648
648
}
649
649
650
- unsafe fn write ( req : * libc :: c_void , stream : * libc :: c_void ,
650
+ unsafe fn write < T > ( req : * uv_write_t , stream : * T ,
651
651
buf_in : * [ uv_buf_t ] , cb : * u8 ) -> libc:: c_int {
652
652
let buf_ptr = vec:: unsafe:: to_ptr ( * buf_in) ;
653
653
let buf_cnt = vec:: len ( * buf_in) as i32 ;
654
- ret rustrt:: rust_uv_write ( req, stream, buf_ptr, buf_cnt, cb) ;
654
+ ret rustrt:: rust_uv_write ( req as * libc:: c_void ,
655
+ stream as * libc:: c_void ,
656
+ buf_ptr, buf_cnt, cb) ;
655
657
}
656
658
unsafe fn read_start ( stream : * uv_stream_t , on_alloc : * u8 ,
657
659
on_read : * u8 ) -> libc:: c_int {
@@ -907,7 +909,7 @@ mod test {
907
909
let client_data = get_data_for_req (
908
910
connect_req_ptr as * libc:: c_void )
909
911
as * request_wrapper ;
910
- let write_handle = ( * client_data) . write_req as * libc :: c_void ;
912
+ let write_handle = ( * client_data) . write_req ;
911
913
log ( debug, #fmt ( "on_connect_cb: tcp: %d write_hdl: %d" ,
912
914
stream as int , write_handle as int ) ) ;
913
915
let write_result = write ( write_handle,
@@ -1053,7 +1055,7 @@ mod test {
1053
1055
let server_chan = * ( ( * client_data) . server_chan ) ;
1054
1056
comm:: send ( server_chan, request_str) ;
1055
1057
let write_result = write (
1056
- write_req as * libc :: c_void ,
1058
+ write_req,
1057
1059
client_stream_ptr as * libc:: c_void ,
1058
1060
( * client_data) . server_resp_buf ,
1059
1061
after_server_resp_write) ;
0 commit comments