Changes to support OOB events

Author: philgweber

Cargo.lock

@@ -33,8 +33,7 @@ defmt = "0.3"
 document-features = "0.2.7"
 embassy-executor = { git = "https://github.com/embassy-rs/embassy" }
 embassy-futures = { git = "https://github.com/embassy-rs/embassy" }
-#embassy-imxrt = { git = "https://github.com/OpenDevicePartnership/embassy-imxrt" }
-embassy-imxrt = { git = "https://github.com/philgweber/embassy-imxrt" }
+embassy-imxrt = { git = "https://github.com/OpenDevicePartnership/embassy-imxrt" }
 embassy-sync = { git = "https://github.com/embassy-rs/embassy" }
 embassy-time = { git = "https://github.com/embassy-rs/embassy" }
 embassy-time-driver = { git = "https://github.com/embassy-rs/embassy" }

Cargo.toml

@@ -176,23 +176,16 @@ pub async fn espi_service(mut espi: espi::Espi<'static>, memory_map_buffer: &'st
         .await
         .unwrap();
 
-    unsafe {
-        let test_mem = 0x2000_0010 as *mut u32;
-        *test_mem = 0xff;
-    };
-
     loop {
         let event = espi.wait_for_event().await;
         match event {
             Ok(espi::Event::PeripheralEvent(port_event)) => {
                 info!(
                     "eSPI PeripheralEvent Port: {}, direction: {}, address: {}, offset: {}, length: {}",
-                    port_event.port, port_event.direction, port_event.offset, 
-                    port_event.base_addr, port_event.length,
+                    port_event.port, port_event.direction, port_event.offset, port_event.base_addr, port_event.length,
                 );
 
                 // If it is a peripheral channel write, then we need to notify the service
-                /*
                 if port_event.direction {
                     let res = espi_service
                         .route_to_service(port_event.offset, port_event.length)
@@ -205,19 +198,16 @@ pub async fn espi_service(mut espi: espi::Espi<'static>, memory_map_buffer: &'st
                         );
                     }
                 }
-                */
 
                 espi.complete_port(port_event.port).await;
             }
 
             Ok(espi::Event::OOBEvent(port_event)) => {
                 info!(
                     "eSPI OOBEvent Port: {}, direction: {}, address: {}, offset: {}, length: {}",
-                    port_event.port, port_event.direction, port_event.offset, 
-                    port_event.base_addr, port_event.length,
+                    port_event.port, port_event.direction, port_event.offset, port_event.base_addr, port_event.length,
                 );
 
-
                 if port_event.direction {
                     unsafe {
                         let src_slice = slice::from_raw_parts(port_event.base_addr as *const u8, port_event.length);
@@ -230,14 +220,14 @@ pub async fn espi_service(mut espi: espi::Espi<'static>, memory_map_buffer: &'st
                                 dest_slice[..src_slice.len()].copy_from_slice(src_slice);
                             }
                             Err(e) => {
-                                error!("Failed to retrieve OOB write buffer: {}",e)
+                                error!("Failed to retrieve OOB write buffer: {}", e)
                             }
                         }
                     };
 
                     // Don't complete event until we read out OOB data
                     espi.complete_port(port_event.port).await;
-                    
+
                     // Test code send same data on loopback
                     let _ = espi.oob_write_data(port_event.port, port_event.length as u8);
                 } else {