Struct SctpEndpoint

Source

pub struct SctpEndpoint(/* private fields */);

Expand description

One-to-many SCTP endpoint.

Implementations§

Source §

impl SctpEndpoint

Source

pub fn bind<A: ToSocketAddrs>(address: A) -> Result<SctpEndpoint>

Create a one-to-many SCTP endpoint bound to a single address

Examples found in repository ?

examples/one_to_many.rs (line 6)

4fn main() {
5    // Create a new Sctp endpoint, and bind it to one or more socket addresses
6    let sock = match SctpEndpoint::bind("0.0.0.0:3868") {
7        //	let sock = match SctpEndpoint::bindx(&["10.0.2.15:3868", "127.0.0.1:3868"]) {
8        Ok(s) => s,
9        Err(e) => panic!("{:?}", e.kind()),
10    };
11    println!("Bound to {:?}", sock.local_addrs().unwrap());
12
13    let mut buf = [0u8; 1024];
14
15    // Read a message
16    match sock.recv_from(&mut buf) {
17        Ok((len, stream, addr)) => println!(
18            "Received {} bytes from {} on stream {} from {}",
19            len, addr, stream, addr
20        ),
21        Err(e) => println!("{:?}", e.kind()),
22    };
23
24    sock.send_to(&mut buf, "191.168.1.2:3868", 6).unwrap();
25}

Source

pub fn bindx<A: ToSocketAddrs>(addresses: &[A]) -> Result<SctpEndpoint>

Create a one-to-many SCTP endpoint bound to a multiple addresses. Requires at least one address

Source

pub fn recv_from(&self, msg: &mut [u8]) -> Result<(usize, u16, SocketAddr)>

Wait for data to be received. On success, returns a triplet containing the quantity of bytes received, the sctp stream id on which data were received, and the socket address used by the peer to send the data

Examples found in repository ?

examples/one_to_many.rs (line 16)

4fn main() {
5    // Create a new Sctp endpoint, and bind it to one or more socket addresses
6    let sock = match SctpEndpoint::bind("0.0.0.0:3868") {
7        //	let sock = match SctpEndpoint::bindx(&["10.0.2.15:3868", "127.0.0.1:3868"]) {
8        Ok(s) => s,
9        Err(e) => panic!("{:?}", e.kind()),
10    };
11    println!("Bound to {:?}", sock.local_addrs().unwrap());
12
13    let mut buf = [0u8; 1024];
14
15    // Read a message
16    match sock.recv_from(&mut buf) {
17        Ok((len, stream, addr)) => println!(
18            "Received {} bytes from {} on stream {} from {}",
19            len, addr, stream, addr
20        ),
21        Err(e) => println!("{:?}", e.kind()),
22    };
23
24    sock.send_to(&mut buf, "191.168.1.2:3868", 6).unwrap();
25}

Source

pub fn send_to<A: ToSocketAddrs>( &self, msg: &mut [u8], address: A, stream: u16, ) -> Result<usize>

Send data in Sctp style, to the provided address on the stream stream. On success, returns the quantity on bytes sent

Examples found in repository ?

examples/one_to_many.rs (line 24)

4fn main() {
5    // Create a new Sctp endpoint, and bind it to one or more socket addresses
6    let sock = match SctpEndpoint::bind("0.0.0.0:3868") {
7        //	let sock = match SctpEndpoint::bindx(&["10.0.2.15:3868", "127.0.0.1:3868"]) {
8        Ok(s) => s,
9        Err(e) => panic!("{:?}", e.kind()),
10    };
11    println!("Bound to {:?}", sock.local_addrs().unwrap());
12
13    let mut buf = [0u8; 1024];
14
15    // Read a message
16    match sock.recv_from(&mut buf) {
17        Ok((len, stream, addr)) => println!(
18            "Received {} bytes from {} on stream {} from {}",
19            len, addr, stream, addr
20        ),
21        Err(e) => println!("{:?}", e.kind()),
22    };
23
24    sock.send_to(&mut buf, "191.168.1.2:3868", 6).unwrap();
25}

Source

pub fn local_addrs(&self) -> Result<Vec<SocketAddr>>

Get local socket addresses to which this socket is bound

Examples found in repository ?

examples/one_to_many.rs (line 11)

4fn main() {
5    // Create a new Sctp endpoint, and bind it to one or more socket addresses
6    let sock = match SctpEndpoint::bind("0.0.0.0:3868") {
7        //	let sock = match SctpEndpoint::bindx(&["10.0.2.15:3868", "127.0.0.1:3868"]) {
8        Ok(s) => s,
9        Err(e) => panic!("{:?}", e.kind()),
10    };
11    println!("Bound to {:?}", sock.local_addrs().unwrap());
12
13    let mut buf = [0u8; 1024];
14
15    // Read a message
16    match sock.recv_from(&mut buf) {
17        Ok((len, stream, addr)) => println!(
18            "Received {} bytes from {} on stream {} from {}",
19            len, addr, stream, addr
20        ),
21        Err(e) => println!("{:?}", e.kind()),
22    };
23
24    sock.send_to(&mut buf, "191.168.1.2:3868", 6).unwrap();
25}