May 31, 2024 · May 31, 2024 · May 31, 2024 · Jun 1, 2024 · Jun 1, 2024 · Jun 2, 2024
diff --git a/Cargo.toml b/Cargo.toml
 all-features = true

 [features]
 default = ["tcp", "udp", "websocket"] # All features that are crossplatform by default
 default = ["tcp", "udp", "websocket", "unixsocket"] # All features that are crossplatform by default
 tcp = ["mio/net", "socket2"]
 udp = ["mio/net", "socket2"]
 websocket = ["tungstenite", "url", "tcp"]
diff --git a/src/adapters/unix_socket.rs b/src/adapters/unix_socket.rs
 use std::io::{self, ErrorKind, Read, Write};
 use std::ops::Deref;
 use std::path::{Path, PathBuf};
 use std::fs;

 // Note: net.core.rmem_max = 212992 by default on linux systems
 // not used because w euse unixstream I think?
 }

 pub(crate) struct LocalResource {
    listener: UnixListener
    listener: UnixListener,
    bind_path: PathBuf
 }

 impl Resource for LocalResource {
    }
 }

 impl Drop for LocalResource {
    fn drop(&mut self) {
        // this may fail if the file is already removed
        match fs::remove_file(&self.bind_path) {
            Ok(_) => (),
            Err(err) => log::error!("Error removing unix socket file on drop: {}", err),
        }
    }
 }

 impl Local for LocalResource {
    type Remote = RemoteResource;

        };

        // TODO: fallback to ip when we are able to set path to none
        let path_copy = config.path.clone();
        let listener = UnixListener::bind(config.path)?;
        let local_addr = listener.local_addr()?;
        Ok(ListeningInfo {
            local: Self {
                listener
                listener,
                bind_path: path_copy
            },
            // same issue as above my change in https://github.com/tokio-rs/mio/pull/1749
            // relevant issue https://github.com/tokio-rs/mio/issues/1527
Original file line number	Diff line number	Diff line change
Expand Up		@@ -18,7 +18,7 @@ maintenance = { status = "actively-developed" }
		all-features = true

		[features]
		default = ["tcp", "udp", "websocket"] # All features that are crossplatform by default
		default = ["tcp", "udp", "websocket", "unixsocket"] # All features that are crossplatform by default
		tcp = ["mio/net", "socket2"]
		udp = ["mio/net", "socket2"]
		websocket = ["tungstenite", "url", "tcp"]
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -14,6 +14,7 @@ use std::net::{IpAddr, Ipv4Addr, SocketAddr};
		use std::io::{self, ErrorKind, Read, Write};
		use std::ops::Deref;
		use std::path::{Path, PathBuf};
		use std::fs;

		// Note: net.core.rmem_max = 212992 by default on linux systems
		// not used because w euse unixstream I think?
Expand DownExpand Up		@@ -165,7 +166,8 @@ impl Remote for RemoteResource {
		}

		pub(crate) struct LocalResource {
		listener: UnixListener
		listener: UnixListener,
		bind_path: PathBuf
		}

		impl Resource for LocalResource {
Expand All		@@ -174,6 +176,16 @@ impl Resource for LocalResource {
		}
		}

		impl Drop for LocalResource {
		fn drop(&mut self) {
		// this may fail if the file is already removed
		match fs::remove_file(&self.bind_path) {
		Ok(_) => (),
		Err(err) => log::error!("Error removing unix socket file on drop: {}", err),
		}
		}
		}

		impl Local for LocalResource {
		type Remote = RemoteResource;

Expand All		@@ -184,11 +196,13 @@ impl Local for LocalResource {
		};

		// TODO: fallback to ip when we are able to set path to none
		let path_copy = config.path.clone();
		let listener = UnixListener::bind(config.path)?;
		let local_addr = listener.local_addr()?;
		Ok(ListeningInfo {
		local: Self {
		listener
		listener,
		bind_path: path_copy
		},
		// same issue as above my change in https://github.com/tokio-rs/mio/pull/1749
		// relevant issue https://github.com/tokio-rs/mio/issues/1527
Expand Down