Searched refs:poll_at (Results 1 – 12 of 12) sorted by relevance
| /smoltcp-0.9.1/src/socket/ |
| D | mod.rs | 75 pub(crate) fn poll_at(&self, cx: &mut Context) -> PollAt { in poll_at() method
78 Socket::Raw(s) => s.poll_at(cx), in poll_at()
80 Socket::Icmp(s) => s.poll_at(cx), in poll_at()
82 Socket::Udp(s) => s.poll_at(cx), in poll_at()
84 Socket::Tcp(s) => s.poll_at(cx), in poll_at()
86 Socket::Dhcpv4(s) => s.poll_at(cx), in poll_at()
88 Socket::Dns(s) => s.poll_at(cx), in poll_at()
|
| D | tcp.rs | 255 fn poll_at(&self) -> PollAt { in poll_at() method
2240 pub(crate) fn poll_at(&self, cx: &mut Context) -> PollAt { in poll_at() method
2273 *[self.timer.poll_at(), timeout_poll_at, delayed_ack_poll_at] in poll_at()
6026 assert_eq!(s.socket.poll_at(&mut s.cx), PollAt::Ingress); in test_listen_timeout()
6048 s.socket.poll_at(&mut s.cx), in test_connect_timeout()
6067 s.socket.poll_at(&mut s.cx), in test_established_timeout()
6071 assert_eq!(s.socket.poll_at(&mut s.cx), PollAt::Now); in test_established_timeout()
6079 s.socket.poll_at(&mut s.cx), in test_established_timeout()
6089 s.socket.poll_at(&mut s.cx), in test_established_timeout()
6114 s.socket.poll_at(&mut s.cx), in test_established_keep_alive_timeout()
[all …]
|
| D | dhcpv4.rs | 267 pub(crate) fn poll_at(&self, _cx: &mut Context) -> PollAt { in poll_at() method
765 while s.socket.poll_at(&mut s.cx) <= PollAt::Time(timestamp) { in recv()
|
| D | dns.rs | 617 pub(crate) fn poll_at(&self, _cx: &Context) -> PollAt { in poll_at() method
|
| D | udp.rs | 478 pub(crate) fn poll_at(&self, _cx: &mut Context) -> PollAt { in poll_at() method
|
| D | raw.rs | 403 pub(crate) fn poll_at(&self, _cx: &mut Context) -> PollAt { in poll_at() method
|
| D | icmp.rs | 577 pub(crate) fn poll_at(&self, _cx: &mut Context) -> PollAt { in poll_at() method
|
| /smoltcp-0.9.1/examples/ |
| D | benchmark.rs | 151 match iface.poll_at(timestamp, &sockets) { in main()
152 Some(poll_at) if timestamp < poll_at => { in main()
153 phy_wait(fd, Some(poll_at - timestamp)).expect("wait error"); in main()
|
| D | sixlowpan_benchmark.rs | 219 match iface.poll_at(timestamp, &sockets) { in main()
220 Some(poll_at) if timestamp < poll_at => { in main()
221 phy_wait(fd, Some(poll_at - timestamp)).expect("wait error"); in main()
|
| D | ping.rs | 253 match iface.poll_at(timestamp, &sockets) { in main()
254 Some(poll_at) if timestamp < poll_at => { in main()
255 let resume_at = cmp::min(poll_at, send_at); in main()
|
| /smoltcp-0.9.1/src/iface/ |
| D | socket_meta.rs | 48 pub(crate) fn poll_at<F>(&self, socket_poll_at: PollAt, has_neighbor: F) -> PollAt in poll_at() method
|
| /smoltcp-0.9.1/src/iface/interface/ |
| D | mod.rs | 790 pub fn poll_at(&mut self, timestamp: Instant, sockets: &SocketSet<'_>) -> Option<Instant> { in poll_at() method
803 let socket_poll_at = item.socket.poll_at(inner); in poll_at()
806 .poll_at(socket_poll_at, |ip_addr| inner.has_neighbor(&ip_addr)) in poll_at()
825 match self.poll_at(timestamp, sockets) { in poll_delay()
826 Some(poll_at) if timestamp < poll_at => Some(poll_at - timestamp), in poll_delay()
|