nordic-dev.net/rust
nordic-dev.net/rust
2
0
Fork 0
mirror of https://github.com/rust-lang/rust.git synced 2025-04-28 02:57:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

uv: Provide a helper fn to Result<(), IoError>

Browse Source
This commit is contained in:
Alex Crichton 2013-11-03 11:02:19 -08:00
parent 30c885ea52
commit 4bcde6bc06
2 changed files with 19 additions and 74 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/librustuv/lib.rs
View File

@ -341,9 +341,8 @@ pub fn uv_error_to_io_error(uverr: UvError) -> IoError {
}
}
/// Given a uv handle, convert a callback status to a UvError
pub fn status_to_maybe_uv_error(status: c_int) -> Option<UvError>
{
/// Given a uv error code, convert a callback status to a UvError
pub fn status_to_maybe_uv_error(status: c_int) -> Option<UvError> {
if status >= 0 {
None
} else {
@ -351,6 +350,10 @@ pub fn status_to_maybe_uv_error(status: c_int) -> Option<UvError>
}
}
pub fn status_to_io_result(status: c_int) -> Result<(), IoError> {
if status >= 0 {Ok(())} else {Err(uv_error_to_io_error(UvError(status)))}
}
/// The uv buffer type
pub type Buf = uvll::uv_buf_t;

84
src/librustuv/uvio.rs
View File

@ -992,11 +992,7 @@ fn accept_simultaneously(stream: StreamWatcher, a: int) -> Result<(), IoError> {
let r = unsafe {
uvll::uv_tcp_simultaneous_accepts(stream.native_handle(), a as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
impl RtioTcpAcceptor for UvTcpAcceptor {
@ -1197,11 +1193,7 @@ impl RtioTcpStream for UvTcpStream {
let r = unsafe {
uvll::uv_tcp_nodelay(self_.watcher.native_handle(), 0 as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
@ -1210,11 +1202,7 @@ impl RtioTcpStream for UvTcpStream {
let r = unsafe {
uvll::uv_tcp_nodelay(self_.watcher.native_handle(), 1 as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
@ -1224,11 +1212,7 @@ impl RtioTcpStream for UvTcpStream {
uvll::uv_tcp_keepalive(self_.watcher.native_handle(), 1 as c_int,
delay_in_seconds as c_uint)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
@ -1238,11 +1222,7 @@ impl RtioTcpStream for UvTcpStream {
uvll::uv_tcp_keepalive(self_.watcher.native_handle(),
0 as c_int, 0 as c_uint)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
}
@ -1348,11 +1328,7 @@ impl RtioUdpSocket for UvUdpSocket {
uvll::UV_JOIN_GROUP)
}
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
@ -1365,100 +1341,66 @@ impl RtioUdpSocket for UvUdpSocket {
uvll::UV_LEAVE_GROUP)
}
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
fn loop_multicast_locally(&mut self) -> Result<(), IoError> {
do self.home_for_io |self_| {
let r = unsafe {
uvll::uv_udp_set_multicast_loop(self_.watcher.native_handle(),
1 as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
fn dont_loop_multicast_locally(&mut self) -> Result<(), IoError> {
do self.home_for_io |self_| {
let r = unsafe {
uvll::uv_udp_set_multicast_loop(self_.watcher.native_handle(),
0 as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
fn multicast_time_to_live(&mut self, ttl: int) -> Result<(), IoError> {
do self.home_for_io |self_| {
let r = unsafe {
uvll::uv_udp_set_multicast_ttl(self_.watcher.native_handle(),
ttl as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
fn time_to_live(&mut self, ttl: int) -> Result<(), IoError> {
do self.home_for_io |self_| {
let r = unsafe {
uvll::uv_udp_set_ttl(self_.watcher.native_handle(), ttl as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
fn hear_broadcasts(&mut self) -> Result<(), IoError> {
do self.home_for_io |self_| {
let r = unsafe {
uvll::uv_udp_set_broadcast(self_.watcher.native_handle(),
1 as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
fn ignore_broadcasts(&mut self) -> Result<(), IoError> {
do self.home_for_io |self_| {
let r = unsafe {
uvll::uv_udp_set_broadcast(self_.watcher.native_handle(),
0 as c_int)
};
match status_to_maybe_uv_error(r) {
Some(err) => Err(uv_error_to_io_error(err)),
None => Ok(())
}
status_to_io_result(r)
}
}
}