| /smoltcp-0.9.1/src/socket/ |
| D | dhcpv4.rs | 760 fn recv(s: &mut TestSocket, timestamp: Instant, reprs: &[(Ipv4Repr, UdpRepr, DhcpRepr)]) { in recv() function
802 macro_rules! recv { macro
804 recv!($socket, time 0, $reprs);
807 recv(&mut $socket, Instant::from_millis($time), &$reprs);
1021 recv!(s, [(IP_BROADCAST, UDP_SEND, DHCP_DISCOVER)]); in test_bind()
1025 recv!(s, [(IP_BROADCAST, UDP_SEND, DHCP_REQUEST)]); in test_bind()
1056 recv!(s, [(IP_BROADCAST, UDP_SEND_DIFFERENT_PORT, DHCP_DISCOVER)]); in test_bind_different_ports()
1060 recv!(s, [(IP_BROADCAST, UDP_SEND_DIFFERENT_PORT, DHCP_REQUEST)]); in test_bind_different_ports()
1091 recv!(s, time 0, [(IP_BROADCAST, UDP_SEND, DHCP_DISCOVER)]); in test_discover_retransmit()
1092 recv!(s, time 1_000, []); in test_discover_retransmit()
[all …]
|
| D | tcp.rs | 1089 pub fn recv<'b, F, R>(&'b mut self, f: F) -> Result<R, RecvError> in recv() method
2445 fn recv<F>(socket: &mut TestSocket, timestamp: Instant, mut f: F) in recv() function
2493 macro_rules! recv { macro
2495 $( recv!($socket, Ok($repr)); )*
2499 (recv!($socket, time 0, $result));
2501 (recv(&mut $socket, Instant::from_millis($time), |result| {
2510 (recv(&mut $socket, Instant::from_millis($time), |repr| assert_eq!(repr, $result)));
2648 recv!( in socket_recved()
2719 recv!( in test_listen_sack_option()
2742 recv!( in test_listen_sack_option()
[all …]
|
| D | raw.rs | 228 pub fn recv(&mut self) -> Result<&[u8], RecvError> { in recv() method
244 let buffer = self.recv()?; in recv_slice()
668 assert_eq!(socket.recv(), Err(RecvError::Exhausted)); in test_recv_process()
683 assert_eq!(socket.recv(), Ok(&cksumd_packet[..])); in test_recv_process()
692 assert_eq!(socket.recv(), Err(RecvError::Exhausted)); in test_recv_process()
707 assert_eq!(socket.recv(), Ok(&ipv6_locals::PACKET_BYTES[..])); in test_recv_process()
737 assert_eq!(socket.recv(), Ok(&cksumd_packet[..])); in test_peek_process()
760 assert_eq!(socket.recv(), Ok(&ipv6_locals::PACKET_BYTES[..])); in test_peek_process()
|
| D | udp.rs | 316 pub fn recv(&mut self) -> Result<(&[u8], IpEndpoint), RecvError> { in recv() method
334 let (buffer, endpoint) = self.recv().map_err(|_| RecvError::Exhausted)?; in recv_slice()
680 assert_eq!(socket.recv(), Err(RecvError::Exhausted)); in test_recv_process()
689 assert_eq!(socket.recv(), Ok((&b"abcdef"[..], REMOTE_END))); in test_recv_process()
704 assert_eq!(socket.recv(), Ok((&b"abcdef"[..], REMOTE_END))); in test_peek_process()
820 assert_eq!(socket.recv(), Ok((&[][..], REMOTE_END))); in test_process_empty_payload()
|
| D | icmp.rs | 348 pub fn recv(&mut self) -> Result<(&[u8], IpAddress), RecvError> { in recv() method
364 let (buffer, endpoint) = self.recv()?; in recv_slice()
753 assert_eq!(socket.recv(), Err(RecvError::Exhausted)); in test_recv_process()
769 assert_eq!(socket.recv(), Ok((data, REMOTE_IPV4.into()))); in test_recv_process()
846 socket.recv(), in test_accepts_udp()
1005 assert_eq!(socket.recv(), Err(RecvError::Exhausted)); in test_recv_process()
1026 assert_eq!(socket.recv(), Ok((data, REMOTE_IPV6.into()))); in test_recv_process()
1113 socket.recv(), in test_accepts_udp()
|
| /smoltcp-0.9.1/src/phy/sys/ |
| D | raw_socket.rs | 78 pub fn recv(&mut self, buffer: &mut [u8]) -> io::Result<usize> { in recv() method
80 let len = libc::recv( in recv()
|
| D | tuntap_interface.rs | 84 pub fn recv(&mut self, buffer: &mut [u8]) -> io::Result<usize> { in recv() method
|
| D | bpf.rs | 113 pub fn recv(&mut self, buffer: &mut [u8]) -> io::Result<usize> { in recv() method
|
| /smoltcp-0.9.1/examples/ |
| D | server.rs | 99 let client = match socket.recv() { in main()
141 .recv(|buffer| { in main()
172 .recv(|buffer| { in main()
|
| D | multicast.rs | 98 match socket.recv() { in main()
117 .recv() in main()
|
| D | sixlowpan.rs | 115 let client = match socket.recv() { in main()
145 .recv(|data| { in main()
|
| D | client.rs | 87 .recv(|data| { in main()
|
| D | httpclient.rs | 104 .recv(|data| { in main()
|
| D | loopback.rs | 140 socket.recv(|buffer| { (buffer.len(), str::from_utf8(buffer).unwrap()) }) in main()
|
| D | benchmark.rs | 142 .recv(|buffer| { in main()
|
| D | sixlowpan_benchmark.rs | 211 .recv(|buffer| { in main()
|
| D | ping.rs | 201 let (payload, _) = socket.recv().unwrap(); in main()
|
| /smoltcp-0.9.1/src/phy/ |
| D | tuntap_interface.rs | 57 match lower.recv(&mut buffer[..]) { in receive()
|
| D | raw_socket.rs | 75 match lower.recv(&mut buffer[..]) { in receive()
|
| /smoltcp-0.9.1/src/iface/interface/ |
| D | tests.rs | 499 socket.recv(), in test_handle_udp_broadcast()
1003 socket.recv(), in test_icmpv4_socket()
1358 socket.recv(), in test_raw_socket_with_udp_socket()
1638 socket.recv(), in test_sixlowpan_udp_with_fragmentation()
|
| /smoltcp-0.9.1/ |
| D | CHANGELOG.md | 171 …ng between graceful (FIN) and ungraceful (RST) close. On graceful close, `recv()` now returns `Err…
|