| /smoltcp-0.9.1/src/iface/interface/ |
| D | igmp.rs | 34 self.inner.now = timestamp; in join_multicast_group()
82 self.inner.now = timestamp; in leave_multicast_group()
127 } if self.inner.now >= timeout => { in igmp_egress()
130 if let Some(tx_token) = device.transmit(self.inner.now) { in igmp_egress()
148 } if self.inner.now >= timeout => { in igmp_egress()
160 if let Some(tx_token) = device.transmit(self.inner.now) { in igmp_egress()
170 let next_timeout = (timeout + interval).max(self.inner.now); in igmp_egress()
245 timeout: self.now + interval, in process_igmp()
257 timeout: self.now + timeout, in process_igmp()
|
| D | mod.rs | 237 now: Instant, field
547 now: Instant::from_secs(0), in new()
736 self.inner.now = timestamp; in poll()
791 self.inner.now = timestamp; in poll_at()
838 while let Some((rx_token, tx_token)) = device.receive(self.inner.now) { in socket_ingress()
904 .egress_permitted(self.inner.now, |ip_addr| self.inner.has_neighbor(&ip_addr)) in socket_egress()
912 let t = device.transmit(inner.now).ok_or_else(|| { in socket_egress()
972 self.inner.now, in socket_egress()
1003 if let Some(tx_token) = device.transmit(self.inner.now) { in ipv4_egress()
1033 if let Some(tx_token) = device.transmit(self.inner.now) { in sixlowpan_egress()
[all …]
|
| D | ipv6.rs | 199 .lookup(&ip_addr, self.now) in process_ndisc()
205 .fill(ip_addr, lladdr, self.now) in process_ndisc()
223 self.now, in process_ndisc()
|
| D | tests.rs | 1140 let timestamp = Instant::now(); in test_handle_igmp()
1162 let timestamp = Instant::now(); in test_handle_igmp()
1183 let timestamp = Instant::now(); in test_handle_igmp()
1378 let now = iface.inner.now(); in test_echo_request_sixlowpan_128_bytes() localVariable
1383 now, in test_echo_request_sixlowpan_128_bytes()
1511 Instant::now(), in test_echo_request_sixlowpan_128_bytes()
1514 let tx_token = device.transmit(Instant::now()).unwrap(); in test_echo_request_sixlowpan_128_bytes()
1537 iface.poll(Instant::now(), &mut device, &mut sockets); in test_echo_request_sixlowpan_128_bytes()
1651 let tx_token = device.transmit(Instant::now()).unwrap(); in test_sixlowpan_udp_with_fragmentation()
1672 iface.poll(Instant::now(), &mut device, &mut sockets); in test_sixlowpan_udp_with_fragmentation()
|
| D | ethernet.rs | 32 EthernetProtocol::Arp => self.process_arp(self.now, ð_frame), in process_ethernet()
|
| D | ipv4.rs | 32 let f = match frag.assembler.get(&key, self.now + frag.reassembly_timeout) { in process_ipv4()
114 .lookup(&IpAddress::Ipv4(ipv4_repr.dst_addr), self.now) in process_ipv4()
|
| D | sixlowpan.rs | 110 let frag_slot = match f.assembler.get(&key, self.now + f.reassembly_timeout) { in process_sixlowpan_fragment()
|
| /smoltcp-0.9.1/src/socket/ |
| D | dhcpv4.rs | 346 retry_at: cx.now(), in process()
357 Self::parse_ack(cx.now(), &dhcp_repr, self.max_lease_duration, state.server) in process()
374 cx.now(), in process()
411 now: Instant, in parse_ack()
484 let renew_at = now + renew_duration; in parse_ack()
485 let expires_at = now + lease_duration; in parse_ack()
560 if cx.now() < state.retry_at { in dispatch()
574 state.retry_at = cx.now() + self.retry_config.discover_timeout; in dispatch()
579 if cx.now() < state.retry_at { in dispatch()
602 state.retry_at = cx.now() in dispatch()
[all …]
|
| D | dns.rs | 528 let v = cx.now() + RETRANSMIT_TIMEOUT; in dispatch()
534 if timeout < cx.now() { in dispatch()
536 pq.timeout_at = Some(cx.now() + RETRANSMIT_TIMEOUT); in dispatch()
557 if pq.retransmit_at > cx.now() { in dispatch()
606 pq.retransmit_at = cx.now() + pq.delay; in dispatch()
|
| D | tcp.rs | 1271 if cx.now() < self.challenge_ack_timer { in challenge_ack_reply()
1276 self.challenge_ack_timer = cx.now() + Duration::from_secs(1); in challenge_ack_reply()
1470 self.timer.set_for_close(cx.now()); in process()
1504 self.rtte.on_ack(cx.now(), ack_number); in process()
1564 self.timer.set_for_idle(cx.now(), self.keep_alive); in process()
1570 self.timer.set_for_idle(cx.now(), self.keep_alive); in process()
1580 self.timer.set_for_idle(cx.now(), self.keep_alive); in process()
1604 self.timer.set_for_idle(cx.now(), self.keep_alive); in process()
1611 self.timer.set_for_idle(cx.now(), self.keep_alive); in process()
1620 self.timer.set_for_idle(cx.now(), self.keep_alive); in process()
[all …]
|
| /smoltcp-0.9.1/examples/ |
| D | benchmark.rs | 33 let start = Instant::now(); in client()
52 let end = Instant::now(); in client()
112 let timestamp = Instant::now(); in main()
|
| D | sixlowpan_benchmark.rs | 97 let start = Instant::now(); in client()
116 let end = Instant::now(); in client()
184 let timestamp = Instant::now(); in main()
|
| D | ping.rs | 150 let timestamp = Instant::now(); in main()
153 let timestamp = Instant::now(); in main()
252 let timestamp = Instant::now(); in main()
|
| D | multicast.rs | 85 Instant::now(), in main()
90 let timestamp = Instant::now(); in main()
|
| D | tcpdump.rs | 13 let (rx_token, _) = socket.receive(Instant::now()).unwrap(); in main()
|
| D | utils.rs | 64 setup_logging_with_clock(filter, Instant::now) in setup_logging()
190 let seed = SystemTime::now() in parse_middleware_options()
|
| D | dns.rs | 77 let timestamp = Instant::now(); in main()
|
| D | dhcp_client.rs | 51 let timestamp = Instant::now(); in main()
|
| D | client.rs | 73 let timestamp = Instant::now(); in main()
|
| D | httpclient.rs | 75 let timestamp = Instant::now(); in main()
|
| D | sixlowpan.rs | 105 let timestamp = Instant::now(); in main()
|
| D | server.rs | 90 let timestamp = Instant::now(); in main()
|
| /smoltcp-0.9.1/ |
| D | CHANGELOG.md | 23 - Consuming `phy::Device` tokens is now infallible.
24 …on since it'd make _smoltcp_ pointlessly spend effort preparing the packet, and is now disallowed).
26 …the `trait Device` now uses Generic Associated Types (GAT) for the TX and RX tokens. The main impa…
29 … - SocketSet and Device are now borrowed in methods that need them, instead of owning them. (#619)
30 …- `Interface` now owns the list of addresses (#719), routes, neighbor cache (#722), 6LoWPAN addres…
31 …- A new compile-time configuration mechanism has been added, to configure the size of the (now own…
52 - socket/tcp: Refactored assembler, now more robust and faster (#726, #735)
88 - Remove `SocketSet`, sockets are owned by `Interface` now. ([#557](https://github.com/smoltcp-rs/s…
171 …een graceful (FIN) and ungraceful (RST) close. On graceful close, `recv()` now returns `Error::Fin…
|
| /smoltcp-0.9.1/src/ |
| D | time.rs | 72 pub fn now() -> Instant { in now() method
73 Self::from(::std::time::SystemTime::now()) in now()
|
| /smoltcp-0.9.1/fuzz/ |
| D | utils.rs | 130 let seed = SystemTime::now() in parse_middleware_options()
|