testing

Author: kbalt

media-video/capture/src/wayland/stream.rs

@@ -157,9 +157,14 @@ impl UserStreamState {
         let width = width as usize;
         let height = height as usize;
 
+        println!("{width}x{height}");
+
         let metas = unsafe { from_raw_parts(buffer.metas, buffer.n_metas as usize) };
         let datas = unsafe { from_raw_parts(buffer.datas, buffer.n_datas as usize) };
 
+        println!("Metas: {metas:?}");
+        println!("Datas: {datas:?}");
+
         // First check if memory buffers were sent
         let mem_data: SmallVec<[_; 3]> = datas
             .iter()
@@ -176,7 +181,13 @@ impl UserStreamState {
         } else {
             let dma_data: SmallVec<[_; 3]> = datas
                 .iter()
-                .filter(|data| data.type_ == spa::sys::SPA_DATA_DmaBuf)
+                .filter(|data| {
+                    println!("{data:?}");
+                    println!("\t{:?}", unsafe { data.chunk.read_unaligned() });
+                    data.flags & spa::sys::SPA_DATA_FLAG_READABLE
+                        == spa::sys::SPA_DATA_FLAG_READABLE
+                        && data.type_ == spa::sys::SPA_DATA_DmaBuf
+                })
                 .collect();
 
             if dma_data.is_empty() {
@@ -187,12 +198,12 @@ impl UserStreamState {
             let first_data = dma_data[0];
 
             // check that the fd of all dma buf's are the same, as different ones are currently not supported
-            if dma_data.iter().any(|data| data.fd != first_data.fd) {
-                log::warn!(
-                    "Got dma buffers with different fds, discarding as this is not supported"
-                );
-                return;
-            }
+            // if dma_data.iter().any(|data| data.fd != first_data.fd) {
+            //     log::warn!(
+            //         "Got dma buffers with different fds, discarding as this is not supported"
+            //     );
+            //     return;
+            // }
 
             self.handle_dma_data(metas, datas, dma_data)
         };