squiid/rust
1
0
Fork 0
Code Issues Pull requests Projects Activity

std: finish impl of io::writer for tcp_socket_buf

Browse source
This commit is contained in:
Jeff Olson 2012-06-07 22:06:42 -07:00 committed by Brian Anderson
parent af3fa5306d
commit 156a4317f6
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/libstd/net_tcp.rs
View file

@ -778,13 +778,17 @@ impl tcp_socket_buf of io::reader for tcp_socket_buf {
} }
} }
/*
#[doc=" #[doc="
Implementation of `io::reader` iface for a buffered `net::tcp::tcp_socket` Implementation of `io::reader` iface for a buffered `net::tcp::tcp_socket`
"] "]
impl tcp_socket_buf of io::writer for tcp_socket_buf { impl tcp_socket_buf of io::writer for tcp_socket_buf {
fn write(data: [const u8]/&) { fn write(data: [const u8]/&) unsafe {
(*self).sock.write(iter::to_vec(data as [u8]/&)); let socket_data_ptr = ptr::addr_of(**((*self).sock));
let write_buf_vec = vec::unpack_const_slice(data) {|ptr, len|
[ uv::ll::buf_init(ptr as *u8, len) ]
};
let write_buf_vec_ptr = ptr::addr_of(write_buf_vec);
write_common_impl(socket_data_ptr, write_buf_vec_ptr);
} }
fn seek(dist: int, seek: io::seek_style) { fn seek(dist: int, seek: io::seek_style) {
log(debug, #fmt("tcp_socket_buf seek stub %? %?", dist, seek)); log(debug, #fmt("tcp_socket_buf seek stub %? %?", dist, seek));
@ -797,7 +801,6 @@ impl tcp_socket_buf of io::writer for tcp_socket_buf {
0 0
} }
} }
*/
// INTERNAL API // INTERNAL API