Searched refs:tx_buffer (Results 1 – 8 of 8) sorted by relevance
| /smoltcp-0.9.1/src/socket/ |
| D | raw.rs | 54 tx_buffer: PacketBuffer<'a>, field
68 tx_buffer: PacketBuffer<'a>, in new()
74 tx_buffer, in new()
132 !self.tx_buffer.is_full() in can_send()
150 self.tx_buffer.packet_capacity() in packet_send_capacity()
162 self.tx_buffer.payload_capacity() in payload_send_capacity()
178 .tx_buffer in send()
200 .tx_buffer in send_with()
327 let res = self.tx_buffer.dequeue_with(|&mut (), buffer| { in dispatch()
404 if self.tx_buffer.is_empty() { in poll_at()
[all …]
|
| D | udp.rs | 49 tx_buffer: PacketBuffer<'a>, field
60 pub fn new(rx_buffer: PacketBuffer<'a>, tx_buffer: PacketBuffer<'a>) -> Socket<'a> { in new()
64 tx_buffer, in new()
173 self.tx_buffer.reset(); in close()
192 !self.tx_buffer.is_full() in can_send()
210 self.tx_buffer.packet_capacity() in packet_send_capacity()
222 self.tx_buffer.payload_capacity() in payload_send_capacity()
248 .tx_buffer in send()
286 .tx_buffer in send_with()
431 let res = self.tx_buffer.dequeue_with(|remote_endpoint, payload_buf| { in dispatch()
[all …]
|
| D | icmp.rs | 83 tx_buffer: PacketBuffer<'a>, field
96 pub fn new(rx_buffer: PacketBuffer<'a>, tx_buffer: PacketBuffer<'a>) -> Socket<'a> { in new()
99 tx_buffer: tx_buffer, in new()
249 !self.tx_buffer.is_full() in can_send()
267 self.tx_buffer.packet_capacity() in packet_send_capacity()
279 self.tx_buffer.payload_capacity() in payload_send_capacity()
300 .tx_buffer in send()
327 .tx_buffer in send_with()
488 let res = self.tx_buffer.dequeue_with(|remote_endpoint, packet_buf| { in dispatch()
578 if self.tx_buffer.is_empty() { in poll_at()
[all …]
|
| D | tcp.rs | 360 tx_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()
452 tx_buffer, in new()
673 self.tx_buffer.clear(); in reset()
966 !self.tx_buffer.is_full() in can_send()
978 self.tx_buffer.capacity() in send_capacity()
1003 if self.tx_buffer.is_empty() { in send_impl()
1007 let _old_length = self.tx_buffer.len(); in send_impl()
1008 let (size, result) = f(&mut self.tx_buffer); in send_impl()
[all …]
|
| /smoltcp-0.9.1/src/iface/interface/ |
| D | ipv4.rs | 352 let emit_ethernet = |repr: &IpRepr, tx_buffer: &mut [u8]| { in dispatch_ipv4_frag()
353 let mut frame = EthernetFrame::new_unchecked(tx_buffer); in dispatch_ipv4_frag()
367 tx_token.consume(tx_len, |mut tx_buffer| { in dispatch_ipv4_frag()
370 emit_ethernet(&IpRepr::Ipv4(frag.ipv4.repr), tx_buffer); in dispatch_ipv4_frag()
371 tx_buffer = &mut tx_buffer[EthernetFrame::<&[u8]>::header_len()..]; in dispatch_ipv4_frag()
375 Ipv4Packet::new_unchecked(&mut tx_buffer[..frag.ipv4.repr.buffer_len()]); in dispatch_ipv4_frag()
386 tx_buffer[frag.ipv4.repr.buffer_len()..][..payload_len].copy_from_slice( in dispatch_ipv4_frag()
|
| D | ethernet.rs | 63 tx_token.consume(tx_len, |tx_buffer| { in dispatch_ethernet()
64 debug_assert!(tx_buffer.as_ref().len() == tx_len); in dispatch_ethernet()
65 let mut frame = EthernetFrame::new_unchecked(tx_buffer); in dispatch_ethernet()
|
| D | mod.rs | 1732 let emit_ethernet = |repr: &IpRepr, tx_buffer: &mut [u8]| { in dispatch_ip()
1733 let mut frame = EthernetFrame::new_unchecked(tx_buffer); in dispatch_ip()
1750 let emit_ip = |repr: &IpRepr, mut tx_buffer: &mut [u8]| { in dispatch_ip()
1751 repr.emit(&mut tx_buffer, &self.caps.checksum); in dispatch_ip()
1753 let payload = &mut tx_buffer[repr.header_len()..]; in dispatch_ip()
1814 tx_token.consume(tx_len, |mut tx_buffer| { in dispatch_ip()
1817 emit_ethernet(&ip_repr, tx_buffer)?; in dispatch_ip()
1818 tx_buffer = &mut tx_buffer[EthernetFrame::<&[u8]>::header_len()..]; in dispatch_ip()
1825 tx_buffer[..first_frag_ip_len] in dispatch_ip()
1839 tx_token.consume(total_len, |mut tx_buffer| { in dispatch_ip()
[all …]
|
| D | tests.rs | 430 let tx_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()
946 let tx_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()
1209 let tx_buffer = raw::PacketBuffer::new( 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()
|