fix windows and miri problems

Author: danielsn

libdd-profiling/src/exporter/file_exporter.rs

@@ -80,7 +80,7 @@ pub(crate) fn spawn_dump_server(output_path: PathBuf) -> anyhow::Result<PathBuf>
 async fn run_dump_server_windows(
     output_path: PathBuf,
     pipe_name: String,
-    mut first_server: tokio::net::windows::named_pipe::NamedPipeServer,
+    first_server: tokio::net::windows::named_pipe::NamedPipeServer,
 ) -> anyhow::Result<()> {
     use tokio::net::windows::named_pipe::ServerOptions;
 
@@ -119,7 +119,7 @@ pub(crate) fn spawn_dump_server(output_path: PathBuf) -> anyhow::Result<PathBuf>
     let pipe_path = PathBuf::from(&pipe_name);
 
     let (tx, rx) = std::sync::mpsc::channel();
-    
+
     std::thread::spawn(move || {
         // Top-level error handler - all errors logged here
         let result = (|| -> anyhow::Result<()> {
@@ -129,12 +129,12 @@ pub(crate) fn spawn_dump_server(output_path: PathBuf) -> anyhow::Result<PathBuf>
                 let first_server = ServerOptions::new()
                     .first_pipe_instance(true)
                     .create(&pipe_name)?;
-                
+
                 tx.send(Ok(()))?;
                 run_dump_server_windows(output_path, pipe_name, first_server).await
             })
         })();
-        
+
         if let Err(e) = result {
             eprintln!("[dump-server] Error: {}", e);
             let _ = tx.send(Err(e));

libdd-profiling/src/exporter/profile_exporter.rs

@@ -86,7 +86,7 @@ impl ProfileExporter {
                 let output_path = libdd_common::decode_uri_path_in_authority(&endpoint.url)
                     .context("Failed to decode file path from URI")?;
                 let pipe_path = spawn_dump_server(output_path)?;
-                builder = builder.windows_named_pipe(pipe_path);
+                builder = builder.windows_named_pipe(pipe_path.to_string_lossy().to_string());
                 "http://localhost/v1/input".to_string()
             }
 
@@ -108,7 +108,7 @@ impl ProfileExporter {
             Some("windows") => {
                 use libdd_common::connector::named_pipe::named_pipe_path_from_uri;
                 let pipe_path = named_pipe_path_from_uri(&endpoint.url)?;
-                builder = builder.windows_named_pipe(pipe_path);
+                builder = builder.windows_named_pipe(pipe_path.to_string_lossy().to_string());
                 format!("http://localhost{}", endpoint.url.path())
             }
             #[cfg(unix)]

libdd-profiling/tests/exporter_e2e.rs

@@ -481,40 +481,47 @@ async fn test_agentless_with_transport(transport: Transport) -> anyhow::Result<(
 }
 
 #[tokio::test]
+#[cfg_attr(miri, ignore)]
 async fn test_export_agent_tcp() -> anyhow::Result<()> {
     test_agent_with_transport(Transport::Tcp).await
 }
 
 #[cfg(unix)]
 #[tokio::test]
+#[cfg_attr(miri, ignore)]
 async fn test_export_agent_uds() -> anyhow::Result<()> {
     test_agent_with_transport(Transport::UnixSocket).await
 }
 
 #[tokio::test]
+#[cfg_attr(miri, ignore)]
 async fn test_export_agentless_tcp() -> anyhow::Result<()> {
     test_agentless_with_transport(Transport::Tcp).await
 }
 
 #[cfg(unix)]
 #[tokio::test]
+#[cfg_attr(miri, ignore)]
 async fn test_export_agentless_uds() -> anyhow::Result<()> {
     test_agentless_with_transport(Transport::UnixSocket).await
 }
 
 #[cfg(windows)]
 #[tokio::test]
+#[cfg_attr(miri, ignore)]
 async fn test_export_agent_named_pipe() -> anyhow::Result<()> {
     test_agent_with_transport(Transport::NamedPipe).await
 }
 
 #[cfg(windows)]
 #[tokio::test]
+#[cfg_attr(miri, ignore)]
 async fn test_export_agentless_named_pipe() -> anyhow::Result<()> {
     test_agentless_with_transport(Transport::NamedPipe).await
 }
 
 #[tokio::test]
+#[cfg_attr(miri, ignore)]
 async fn test_export_file() -> anyhow::Result<()> {
     let file_path = create_temp_file_path("http");
     let endpoint = config::file(file_path.to_string_lossy().as_ref())?;