Searched refs:rx_buffer (Results 1 – 5 of 5) sorted by relevance
| /smoltcp-0.9.1/src/socket/ |
| D | raw.rs | 53 rx_buffer: PacketBuffer<'a>, field
67 rx_buffer: PacketBuffer<'a>, in new()
73 rx_buffer, in new()
138 !self.rx_buffer.is_empty() in can_recv()
144 self.rx_buffer.packet_capacity() in packet_recv_capacity()
156 self.rx_buffer.payload_capacity() in payload_recv_capacity()
229 let ((), packet_buf) = self.rx_buffer.dequeue().map_err(|_| RecvError::Exhausted)?; in recv()
256 let ((), packet_buf) = self.rx_buffer.peek().map_err(|_| RecvError::Exhausted)?; in peek()
304 match self.rx_buffer.enqueue(total_len, ()) { in process()
430 rx_buffer: PacketBuffer<'static>, in socket()
[all …]
|
| D | udp.rs | 48 rx_buffer: PacketBuffer<'a>, field
60 pub fn new(rx_buffer: PacketBuffer<'a>, tx_buffer: PacketBuffer<'a>) -> Socket<'a> { in new()
63 rx_buffer, in new()
174 self.rx_buffer.reset(); in close()
198 !self.rx_buffer.is_empty() in can_recv()
204 self.rx_buffer.packet_capacity() in packet_recv_capacity()
216 self.rx_buffer.payload_capacity() in payload_recv_capacity()
318 self.rx_buffer.dequeue().map_err(|_| RecvError::Exhausted)?; in recv()
347 self.rx_buffer.peek().map_err(|_| RecvError::Exhausted).map( in peek()
411 match self.rx_buffer.enqueue(size, remote_endpoint) { in process()
[all …]
|
| D | icmp.rs | 82 rx_buffer: PacketBuffer<'a>, field
96 pub fn new(rx_buffer: PacketBuffer<'a>, tx_buffer: PacketBuffer<'a>) -> Socket<'a> { in new()
98 rx_buffer: rx_buffer, in new()
255 !self.rx_buffer.is_empty() in can_recv()
261 self.rx_buffer.packet_capacity() in packet_recv_capacity()
273 self.rx_buffer.payload_capacity() in payload_recv_capacity()
349 let (endpoint, packet_buf) = self.rx_buffer.dequeue().map_err(|_| RecvError::Exhausted)?; in recv()
448 .rx_buffer in process()
465 .rx_buffer in process()
597 rx_buffer: PacketBuffer<'static>, in socket()
[all …]
|
| D | tcp.rs | 358 rx_buffer: SocketBuffer<'a>, field
431 pub fn new<T>(rx_buffer: T, tx_buffer: T) -> Socket<'a> in new()
435 let (rx_buffer, tx_buffer) = (rx_buffer.into(), tx_buffer.into()); in new()
436 let rx_capacity = rx_buffer.capacity(); in new()
453 rx_buffer, in new()
549 self.rx_buffer.window() >> self.remote_win_shift as usize, in scaled_window()
667 mem::size_of::<usize>() * 8 - self.rx_buffer.capacity().leading_zeros() as usize; in reset()
674 self.rx_buffer.clear(); in reset()
953 _ if !self.rx_buffer.is_empty() => true, in may_recv()
972 self.rx_buffer.capacity() in recv_capacity()
[all …]
|
| /smoltcp-0.9.1/src/iface/interface/ |
| D | tests.rs | 429 let rx_buffer = udp::PacketBuffer::new(vec![udp::PacketMetadata::EMPTY], vec![0; 15]); in test_handle_udp_broadcast() localVariable
432 let udp_socket = udp::Socket::new(rx_buffer, tx_buffer); in test_handle_udp_broadcast()
945 let rx_buffer = icmp::PacketBuffer::new(vec![icmp::PacketMetadata::EMPTY], vec![0; 24]); in test_icmpv4_socket() localVariable
948 let icmpv4_socket = icmp::Socket::new(rx_buffer, tx_buffer); in test_icmpv4_socket()
1207 let rx_buffer = in test_raw_socket_no_reply() localVariable
1213 let raw_socket = raw::Socket::new(IpVersion::Ipv4, IpProtocol::Udp, rx_buffer, tx_buffer); in test_raw_socket_no_reply()
|