A Rust library for socket.
Add this to your Cargo.toml:
toml
[dependencies]
psocket = "0.1"
and this to your crate root:
rust
extern crate psocket;
How to use ```rust use psocket::TcpSocket; use std::io::prelude::*; use std::time::{Duration, Instant}; use std::io::ErrorKind;
let listener = TcpSocket::bind("127.0.0.1:1234").unwrap(); let addr = listener.local_addr().unwrap();
let mut stream = TcpSocket::connect(&("localhost", addr.port())).expect("connect error"); stream.setreadtimeout(Some(Duration::from_millis(1000))).expect("set read timeout error");
let mut otherend = listener.accept().unwrap().0; otherend.write_all(b"hello world").expect("write error");
let mut buf = [0; 11]; stream.read(&mut buf).expect("read error"); assert_eq!(b"hello world", &buf[..]);
let start = Instant::now(); let kind = stream.read(&mut buf).err().expect("expected error").kind(); assert!(kind == ErrorKind::WouldBlock || kind == ErrorKind::TimedOut); assert!(start.elapsed() > Duration::from_millis(400)); drop(listener);
```
provide more fuction about socket
rust
// The func connect remote host asyn
pub fn connect_asyn(addr: &SocketAddr) -> io::Result<TcpSocket>;
// Get the socket fd
pub fn get_socket_fd(&self) -> i32;
// Moves this TCP stream into or out of liner mode.
pub fn set_liner(&self, enable: bool, time: u16) -> io::Result<()>;
// The Method is set stream recv size kernel cache size.
pub fn set_recv_size(&self, size: u32) -> io::Result<()>;
// The Method is set stream send size kernel cache size.
pub fn set_send_size(&self, size: u32) -> io::Result<()>;
// The Method is set tcp stream SO_REUSEADDR.
pub fn set_reuse_addr(&self) -> io::Result<()>;
/// Provide func dtor the object but will not close socket fd.
pub fn unlink(self) -> io::Result<()>;
Licensed under either of
at your option.
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.