fix: revert accidental deletion

Author: AstrickHarren

esp-hal/src/dma/mod.rs

@@ -2745,6 +2745,63 @@ pub(crate) mod asynch {
 
     use super::*;
 
+    #[must_use = "futures do nothing unless you `.await` or poll them"]
+    pub struct DmaTxFuture<'a, CH>
+    where
+        CH: DmaTxChannel,
+    {
+        pub(crate) tx: &'a mut ChannelTx<Async, CH>,
+    }
+
+    impl<'a, CH> DmaTxFuture<'a, CH>
+    where
+        CH: DmaTxChannel,
+    {
+        #[cfg_attr(esp32c2, allow(dead_code))]
+        pub fn new(tx: &'a mut ChannelTx<Async, CH>) -> Self {
+            Self { tx }
+        }
+    }
+
+    impl<CH> core::future::Future for DmaTxFuture<'_, CH>
+    where
+        CH: DmaTxChannel,
+    {
+        type Output = Result<(), DmaError>;
+
+        fn poll(
+            self: core::pin::Pin<&mut Self>,
+            cx: &mut core::task::Context<'_>,
+        ) -> Poll<Self::Output> {
+            if self.tx.is_done() {
+                self.tx.clear_interrupts();
+                Poll::Ready(Ok(()))
+            } else if self
+                .tx
+                .pending_out_interrupts()
+                .contains(DmaTxInterrupt::DescriptorError)
+            {
+                self.tx.clear_interrupts();
+                Poll::Ready(Err(DmaError::DescriptorError))
+            } else {
+                self.tx.waker().register(cx.waker());
+                self.tx
+                    .listen_out(DmaTxInterrupt::TotalEof | DmaTxInterrupt::DescriptorError);
+                Poll::Pending
+            }
+        }
+    }
+
+    impl<CH> Drop for DmaTxFuture<'_, CH>
+    where
+        CH: DmaTxChannel,
+    {
+        fn drop(&mut self) {
+            self.tx
+                .unlisten_out(DmaTxInterrupt::TotalEof | DmaTxInterrupt::DescriptorError);
+        }
+    }
+
     #[must_use = "futures do nothing unless you `.await` or poll them"]
     pub struct DmaRxFuture<'a, CH>
     where

esp-hal/src/i2s/master.rs

@@ -435,6 +435,7 @@ where
         self.i2s.reset_tx();
 
         // Enable corresponding interrupts if needed
+        #[cfg(not(any(esp32, esp32s2)))]
         self.i2s.listen(I2sInterrupt::TxDone);
 
         // configure DMA outlink
@@ -497,6 +498,7 @@ where
         self.i2s.reset_rx();
 
         // Enable corresponding interrupts if needed
+        #[cfg(not(any(esp32, esp32s2)))]
         self.i2s.listen(I2sInterrupt::RxDone);
 
         // configure DMA inlink
@@ -558,6 +560,7 @@ impl<'d, Dm: DriverMode, BUFFER: DmaTxBuffer> I2sWriteDmaTransfer<'d, Dm, BUFFER
     }
 
     /// Checks if the DMA transfer is done.
+    #[cfg(not(any(esp32, esp32s2)))]
     pub fn is_done(&self) -> bool {
         self.i2s_tx.i2s.interrupts().contains(I2sInterrupt::TxDone)
     }
@@ -633,6 +636,7 @@ impl<'d, Dm: DriverMode, BUFFER: DmaRxBuffer> I2sReadDmaTransfer<'d, Dm, BUFFER>
     }
 
     /// Returns true if the transfer is done.
+    #[cfg(not(any(esp32, esp32s2)))]
     pub fn is_done(&self) -> bool {
         self.i2s_rx.i2s.interrupts().contains(I2sInterrupt::RxDone)
     }