*: support abstract UDS (#523)

Abstract UDS is supported in c core with schema `unix-abstract`. This
PR adds supoort for the schema and avoid append additional ":0" suffix.

Signed-off-by: Jay Lee <[email protected]>

Author: BusyJay

src/server.rs

@@ -68,7 +68,7 @@ where
 /// Given a host and port, creates a string of the form "host:port" or
 /// "[host]:port", depending on whether the host is an IPv6 literal.
 fn join_host_port(host: &str, port: u16) -> String {
-    if host.starts_with("unix:") {
+    if host.starts_with("unix:") | host.starts_with("unix-abstract:") {
         format!("{}\0", host)
     } else if let Ok(ip) = host.parse::<IpAddr>() {
         format!("{}\0", SocketAddr::new(ip, port))

tests-and-examples/tests/cases/misc.rs

@@ -164,38 +164,46 @@ fn test_soundness() {
 }
 
 #[cfg(unix)]
-#[test]
-fn test_unix_domain_socket() {
-    struct Defer(&'static str);
+mod unix_domain_socket {
+    use super::*;
+
+    fn test_socket(path: &str) {
+        let env = Arc::new(EnvBuilder::new().build());
+        let service = create_greeter(PeerService);
+
+        let mut server = ServerBuilder::new(env.clone())
+            .register_service(service)
+            .bind(path, 0)
+            .build()
+            .unwrap();
+        server.start();
+        let ch = ChannelBuilder::new(env).connect(path);
+        let client = GreeterClient::new(ch);
 
-    impl Drop for Defer {
-        fn drop(&mut self) {
-            let _ = std::fs::remove_file(self.0);
-        }
-    }
-    let socket_path = Defer("test_socket");
+        let req = HelloRequest::default();
+        let resp = client.say_hello(&req).unwrap();
 
-    let env = Arc::new(EnvBuilder::new().build());
-    let service = create_greeter(PeerService);
+        assert_eq!(resp.get_message(), path, "{:?}", resp);
+    }
 
-    let mut server = ServerBuilder::new(env.clone())
-        .register_service(service)
-        .bind(format!("unix:{}", socket_path.0), 0)
-        .build()
-        .unwrap();
-    server.start();
-    let ch = ChannelBuilder::new(env).connect(&format!("unix:{}", socket_path.0));
-    let client = GreeterClient::new(ch);
+    #[test]
+    fn test_unix_domain_socket() {
+        struct Defer(&'static str);
 
-    let req = HelloRequest::default();
-    let resp = client.say_hello(&req).unwrap();
+        impl Drop for Defer {
+            fn drop(&mut self) {
+                let _ = std::fs::remove_file(&self.0[5..]);
+            }
+        }
+        let socket_path = Defer("unix:test_socket");
+        test_socket(socket_path.0);
+    }
 
-    assert_eq!(
-        resp.get_message(),
-        format!("unix:{}", socket_path.0),
-        "{:?}",
-        resp
-    );
+    #[cfg(target_os = "linux")]
+    #[test]
+    fn test_abstract_unix_domain_socket() {
+        test_socket("unix-abstract:/test_socket");
+    }
 }
 
 #[test]