Update API of recv()

Author: datdenkikniet

src/dma/mod.rs

@@ -214,8 +214,8 @@ impl<'rx, 'tx> EthernetDMA<'rx, 'tx> {
 
     /// Receive a packet.
     #[cfg(feature = "async-await")]
-    pub async fn recv(&mut self) -> RxPacket {
-        self.rx_ring.recv().await
+    pub async fn recv(&mut self, packet_id: Option<PacketId>) -> RxPacket {
+        self.rx_ring.recv(packet_id).await
     }
 
     /// Is Rx DMA currently running?

src/dma/rx/mod.rs

@@ -83,7 +83,7 @@ impl<'a> RxRing<'a> {
 
     /// Demand that the DMA engine polls the current `RxDescriptor`
     /// (when in [`RunningState::Stopped`].)
-    pub fn demand_poll(&self) {
+    fn demand_poll(&self) {
         // SAFETY: we only perform an atomic write to `dmarpdr`.
         let eth_dma = unsafe { &*ETHERNET_DMA::ptr() };
         eth_dma.dmarpdr.write(|w| unsafe { w.rpd().bits(1) });
@@ -163,9 +163,9 @@ impl<'a> RxRing<'a> {
     /// The returned [`RxPacket`] can be used as a slice, and
     /// will contain the ethernet data.
     #[cfg(feature = "async-await")]
-    pub async fn recv(&mut self) -> RxPacket {
+    pub async fn recv(&mut self, packet_id: Option<PacketId>) -> RxPacket {
         let (entry_num, length) = core::future::poll_fn(|ctx| {
-            let res = self.recv_next_impl(None);
+            let res = self.recv_next_impl(packet_id.clone());
 
             match res {
                 Ok(value) => Poll::Ready(value),

src/ptp/mod.rs

@@ -252,6 +252,8 @@ impl EthernetPTP {
     pub async fn wait_until(&mut self, timestamp: Timestamp) {
         self.configure_target_time_interrupt(timestamp);
         core::future::poll_fn(|ctx| {
+            // This is the happy path, the status bits have
+            // usually been reset at this point.
             if EthernetPTP::get_time().raw() >= timestamp.raw() {
                 Poll::Ready(())
             } else if EthernetPTP::interrupt_handler() {