Low-level bindings to the libuv library.
This module contains a set of direct, 'bare-metal' wrappers around the libuv C-API.
Also contained herein are a set of rust records that map, in approximate memory-size, to the libuv data structures. The record implementations are adjusted, per-platform, to match their respective representations.
There are also a collection of helper functions to ease interacting with the low-level API (such as a function to return the latest libuv error as a rust-formatted string).
As new functionality, existant in uv.h, is added to the rust stdlib, the mappings should be added in this module.
This module's implementation will hopefully be, eventually, replaced with per-platform, generated source files from rust-bindgen.
addr_inaddrinfohandle_typesockaddr_insockaddr_in6uv_async_tuv_async_t_32bit_unix_ridersuv_buf_tuv_connect_tuv_err_datauv_err_tuv_getaddrinfo_tuv_handle_fieldsuv_ip4_addruv_ip6_addruv_stream_tuv_tcp_tuv_tcp_t_32bit_unix_ridersuv_timer_tuv_timer_t_32bit_unix_ridersuv_write_tuv_write_t_32bit_unix_ridersuv_handle_typeacceptaddrinfo_as_sockaddr_inaddrinfo_as_sockaddr_in6async_initasync_sendasync_tbuf_initcloseconnect_terr_namefree_base_of_buffreeaddrinfoget_INADDR_NONEget_base_from_bufget_data_for_reqget_data_for_uv_handleget_data_for_uv_loopget_last_err_dataget_last_err_infoget_len_from_bufget_loop_for_uv_handleget_next_addrinfoget_stream_handle_from_connect_reqget_stream_handle_from_write_reqgetaddrinfogetaddrinfo_tip4_addrip4_nameip6_addrip6_nameis_ipv4_addrinfois_ipv6_addrinfolast_errorlistenloop_deleteloop_newloop_refcountmalloc_buf_base_ofread_startread_stoprunset_data_for_reqset_data_for_uv_handleset_data_for_uv_loopstrerrortcp_bindtcp_bind6tcp_connecttcp_connect6tcp_inittcp_ttimer_inittimer_starttimer_stoptimer_twritewrite_tuv::ll::addr_in_impluv::ll::addrinfo_impluv::ll::uv_ll_struct_stubgenuv::ll::rustrtaddr_intype addr_in = addr_in_impl::addr_inaddrinfotype addrinfo = addrinfo_impl::addrinfohandle_typetype handle_type = libc::c_uintsockaddr_intype sockaddr_in = {mut sin_family: u16,
mut sin_port: u16,
mut sin_addr: u32,
mut sin_zero: (u8, u8, u8, u8, u8, u8, u8, u8),}sockaddr_in6type sockaddr_in6 = {a0: *u8, a1: *u8, a2: *u8, a3: *u8,}uv_async_ttype uv_async_t = {fields: uv_handle_fields,
a00: *u8,
a01: *u8,
a02: *u8,
a03: *u8,
a04: *u8,
a05: *u8,
a06: *u8,
a07: *u8,
a08: *u8,
a09: *u8,
a11: uv_async_t_32bit_unix_riders,}uv_async_t_32bit_unix_riderstype uv_async_t_32bit_unix_riders = {a10: *u8,}uv_buf_ttype uv_buf_t = {base: *u8, len: libc::size_t,}uv_connect_ttype uv_connect_t = {a00: *u8, a01: *u8, a02: *u8, a03: *u8, a04: *u8, a05: *u8,}uv_err_datatype uv_err_data = {err_name: str, err_msg: str,}uv_err_ttype uv_err_t = {code: libc::c_int, sys_errno_: libc::c_int,}uv_getaddrinfo_ttype uv_getaddrinfo_t = {a00: *u8,
a01: *u8,
a02: *u8,
a03: *u8,
a04: *u8,
a05: *u8,
a06: *u8,
a07: *u8,
a08: *u8,}uv_handle_fieldstype uv_handle_fields = {loop_handle: *libc::c_void,
type_: handle_type,
close_cb: *u8,
mut data: *libc::c_void,}uv_ip4_addrtype uv_ip4_addr = {ip: ~[u8], port: int,}uv_ip6_addrtype uv_ip6_addr = uv_ip4_addruv_stream_ttype uv_stream_t = {fields: uv_handle_fields,}uv_tcp_ttype uv_tcp_t = {fields: uv_handle_fields,
a00: *u8,
a01: *u8,
a02: *u8,
a03: *u8,
a04: *u8,
a05: *u8,
a06: *u8,
a07: *u8,
a08: *u8,
a09: *u8,
a10: *u8,
a11: *u8,
a12: *u8,
a13: *u8,
a14: *u8,
a15: *u8,
a16: *u8,
a17: *u8,
a18: *u8,
a19: *u8,
a20: *u8,
a21: *u8,
a22: *u8,
a23: *u8,
a24: *u8,
a25: *u8,
a26: *u8,
a27: *u8,
a28: *u8,
a30: uv_tcp_t_32bit_unix_riders,}uv_tcp_t_32bit_unix_riderstype uv_tcp_t_32bit_unix_riders = {a29: *u8,}uv_timer_ttype uv_timer_t = {fields: uv_handle_fields,
a00: *u8,
a01: *u8,
a02: *u8,
a03: *u8,
a04: *u8,
a05: *u8,
a06: *u8,
a07: *u8,
a08: *u8,
a09: *u8,
a11: uv_timer_t_32bit_unix_riders,}uv_timer_t_32bit_unix_riderstype uv_timer_t_32bit_unix_riders = {a10: *u8, a11: *u8,}uv_write_ttype uv_write_t = {fields: uv_handle_fields,
a00: *u8,
a01: *u8,
a02: *u8,
a03: *u8,
a04: *u8,
a05: *u8,
a06: *u8,
a07: *u8,
a08: *u8,
a09: *u8,
a10: *u8,
a11: *u8,
a12: *u8,
a14: uv_write_t_32bit_unix_riders,}uv_write_t_32bit_unix_riderstype uv_write_t_32bit_unix_riders = {a13: *u8,}uv_handle_typeUNKNOWN_HANDLE = 0UV_TCPUV_UDPUV_NAMED_PIPEUV_TTYUV_FILEUV_TIMERUV_PREPAREUV_CHECKUV_IDLEUV_ASYNCUV_ARES_TASKUV_ARES_EVENTUV_PROCESSUV_FS_EVENTacceptunsafe fn accept(server: *libc::c_void, client: *libc::c_void) -> libc::c_intaddrinfo_as_sockaddr_inunsafe fn addrinfo_as_sockaddr_in(input: *addrinfo) -> *sockaddr_inaddrinfo_as_sockaddr_in6unsafe fn addrinfo_as_sockaddr_in6(input: *addrinfo) -> *sockaddr_in6async_initunsafe fn async_init(loop_handle: *libc::c_void, async_handle: *uv_async_t,
cb: *u8) -> libc::c_intasync_sendunsafe fn async_send(async_handle: *uv_async_t)async_tunsafe fn async_t() -> uv_async_tbuf_initunsafe fn buf_init(++input: *u8, len: uint) -> uv_buf_tcloseunsafe fn close<T>(handle: *T, cb: *u8)connect_tunsafe fn connect_t() -> uv_connect_terr_nameunsafe fn err_name(err: *uv_err_t) -> *libc::c_charfree_base_of_bufunsafe fn free_base_of_buf(buf: uv_buf_t)freeaddrinfounsafe fn freeaddrinfo(res: *addrinfo)get_INADDR_NONEunsafe fn get_INADDR_NONE() -> u32get_base_from_bufunsafe fn get_base_from_buf(buf: uv_buf_t) -> *u8get_data_for_requnsafe fn get_data_for_req<T>(req: *T) -> *libc::c_voidget_data_for_uv_handleunsafe fn get_data_for_uv_handle<T>(handle: *T) -> *libc::c_voidget_data_for_uv_loopunsafe fn get_data_for_uv_loop(loop_ptr: *libc::c_void) -> *libc::c_voidget_last_err_dataunsafe fn get_last_err_data(uv_loop: *libc::c_void) -> uv_err_dataget_last_err_infounsafe fn get_last_err_info(uv_loop: *libc::c_void) -> strget_len_from_bufunsafe fn get_len_from_buf(buf: uv_buf_t) -> libc::size_tget_loop_for_uv_handleunsafe fn get_loop_for_uv_handle<T>(handle: *T) -> *libc::c_voidget_next_addrinfounsafe fn get_next_addrinfo(input: *addrinfo) -> *addrinfoget_stream_handle_from_connect_requnsafe fn get_stream_handle_from_connect_req(connect: *uv_connect_t) ->
*uv_stream_tget_stream_handle_from_write_requnsafe fn get_stream_handle_from_write_req(write_req: *uv_write_t) ->
*uv_stream_tgetaddrinfounsafe fn getaddrinfo(loop_ptr: *libc::c_void, handle: *uv_getaddrinfo_t,
cb: *u8, node_name_ptr: *u8, service_name_ptr: *u8,
hints: *addrinfo) -> libc::c_intgetaddrinfo_tunsafe fn getaddrinfo_t() -> uv_getaddrinfo_tip4_addrunsafe fn ip4_addr(ip: str, port: int) -> sockaddr_inip4_nameunsafe fn ip4_name(src: &sockaddr_in) -> strip6_addrunsafe fn ip6_addr(ip: str, port: int) -> sockaddr_in6ip6_nameunsafe fn ip6_name(src: &sockaddr_in6) -> stris_ipv4_addrinfounsafe fn is_ipv4_addrinfo(input: *addrinfo) -> boolis_ipv6_addrinfounsafe fn is_ipv6_addrinfo(input: *addrinfo) -> boollast_errorunsafe fn last_error(loop_handle: *libc::c_void) -> uv_err_tlistenunsafe fn listen<T>(stream: *T, backlog: libc::c_int, cb: *u8) -> libc::c_intloop_deleteunsafe fn loop_delete(loop_handle: *libc::c_void)loop_newunsafe fn loop_new() -> *libc::c_voidloop_refcountunsafe fn loop_refcount(loop_ptr: *libc::c_void) -> libc::c_intmalloc_buf_base_ofunsafe fn malloc_buf_base_of(suggested_size: libc::size_t) -> *u8read_startunsafe fn read_start(stream: *uv_stream_t, on_alloc: *u8, on_read: *u8) ->
libc::c_intread_stopunsafe fn read_stop(stream: *uv_stream_t) -> libc::c_intrununsafe fn run(loop_handle: *libc::c_void)set_data_for_requnsafe fn set_data_for_req<T, U>(req: *T, data: *U)set_data_for_uv_handleunsafe fn set_data_for_uv_handle<T, U>(handle: *T, data: *U)set_data_for_uv_loopunsafe fn set_data_for_uv_loop(loop_ptr: *libc::c_void, data: *libc::c_void)strerrorunsafe fn strerror(err: *uv_err_t) -> *libc::c_chartcp_bindunsafe fn tcp_bind(tcp_server_ptr: *uv_tcp_t, addr_ptr: *sockaddr_in) ->
libc::c_inttcp_bind6unsafe fn tcp_bind6(tcp_server_ptr: *uv_tcp_t, addr_ptr: *sockaddr_in6) ->
libc::c_inttcp_connectunsafe fn tcp_connect(connect_ptr: *uv_connect_t, tcp_handle_ptr: *uv_tcp_t,
addr_ptr: *sockaddr_in, ++after_connect_cb: *u8) ->
libc::c_inttcp_connect6unsafe fn tcp_connect6(connect_ptr: *uv_connect_t, tcp_handle_ptr: *uv_tcp_t,
addr_ptr: *sockaddr_in6, ++after_connect_cb: *u8) ->
libc::c_inttcp_initunsafe fn tcp_init(loop_handle: *libc::c_void, handle: *uv_tcp_t) ->
libc::c_inttcp_tunsafe fn tcp_t() -> uv_tcp_ttimer_initunsafe fn timer_init(loop_ptr: *libc::c_void, timer_ptr: *uv_timer_t) ->
libc::c_inttimer_startunsafe fn timer_start(timer_ptr: *uv_timer_t, cb: *u8, timeout: uint,
repeat: uint) -> libc::c_inttimer_stopunsafe fn timer_stop(timer_ptr: *uv_timer_t) -> libc::c_inttimer_tunsafe fn timer_t() -> uv_timer_twriteunsafe fn write<T>(req: *uv_write_t, stream: *T, buf_in: *~[uv_buf_t],
cb: *u8) -> libc::c_intwrite_tunsafe fn write_t() -> uv_write_t