add domain socket datagram client/server

Author: lhoward

…es/IORingUDPClient/IORingUDPClient.swift …atagramClient/IORingDatagramClient.swiftExamples/IORingUDPClient/IORingUDPClient.swift renamed to Examples/IORingDatagramClient/IORingDatagramClient.swift Examples/IORingUDPClient/IORingUDPClient.swift renamed to Examples/IORingDatagramClient/IORingDatagramClient.swift

@@ -17,39 +17,59 @@
 import AsyncExtensions
 import Glibc
 import IORing
+import IORingFoundation
 import IORingUtils
 import SocketAddress
 import struct SystemPackage.Errno
 
+private func usage() -> Never {
+  print("Usage: \(CommandLine.arguments[0]) [address:port|dg-path] [message]")
+  exit(1)
+}
+
 @main
-public struct IORingUDPClient {
+public struct IORingDatagramClient {
   private let socket: Socket
   private let ring: IORing
 
   public static func main() async throws {
-    guard CommandLine.arguments.count == 3,
-          let address = try? sockaddr_storage(
-            family: sa_family_t(AF_INET),
-            presentationAddress: CommandLine.arguments[1]
-          )
-    else {
-      print("Usage: \(CommandLine.arguments[0]) [address:port] [message]")
-      exit(1)
-    }
+    guard CommandLine.arguments.count == 3 else { usage() }
 
+    let family = sa_family_t(CommandLine.arguments[1].hasPrefix("/") ? AF_LOCAL : AF_INET)
+    guard let address = try? sockaddr_storage(
+      family: family,
+      presentationAddress: CommandLine.arguments[1]
+    ) else {
+      usage()
+    }
+    let client = try Self(domain: family)
     let message = CommandLine.arguments[2]
-    let client = try IORingUDPClient()
-    try await client.connect(to: address)
-    try await client.send(message: message)
+
+    do {
+      if family == sa_family_t(AF_LOCAL) {
+        try await client.bind(to: sockaddr_un.ephemeralDatagramDomainSocketName)
+      }
+      try await client.connect(to: address)
+      try await client.send(message: message)
+    } catch {
+      print("error: \(error)")
+    }
   }
 
-  init() throws {
+  init(domain: sa_family_t) throws {
     ring = IORing.shared
-    socket = try Socket(ring: ring, domain: sa_family_t(AF_INET), type: SOCK_DGRAM, protocol: 0)
+    socket = try Socket(ring: ring, domain: domain, type: SOCK_DGRAM, protocol: 0)
+  }
+
+  func bind(to address: any SocketAddress) async throws {
+    debugPrint("binding to local address \(String(describing: try? address.presentationAddress))")
+    try socket.bind(to: address)
   }
 
   func connect(to address: any SocketAddress) async throws {
-    debugPrint("connecting to address \(String(describing: try? address.presentationAddress))")
+    debugPrint(
+      "connecting to remote address \(String(describing: try? address.presentationAddress))"
+    )
     try await socket.connect(to: address)
   }
 

…es/IORingUDPServer/IORingUDPServer.swift …atagramServer/IORingDatagramServer.swiftExamples/IORingUDPServer/IORingUDPServer.swift renamed to Examples/IORingDatagramServer/IORingDatagramServer.swift Examples/IORingUDPServer/IORingUDPServer.swift renamed to Examples/IORingDatagramServer/IORingDatagramServer.swift

@@ -1,5 +1,5 @@
 //
-// Copyright (c) 2023 PADL Software Pty Ltd
+// Copyright (c) 2023-2025 PADL Software Pty Ltd
 //
 // Licensed under the Apache License, Version 2.0 (the License);
 // you may not use this file except in compliance with the License.
@@ -20,33 +20,52 @@ import IORing
 import IORingUtils
 import struct SystemPackage.Errno
 
+private func usage() -> Never {
+  print("Usage: \(CommandLine.arguments[0]) [port|dg-path]")
+  exit(1)
+}
+
 @main
-public struct IORingUDPServer {
+public struct IORingDatagramServer {
   private let socket: Socket
   private let ring: IORing
 
   public static func main() async throws {
-    guard CommandLine.arguments.count == 2,
-          let port = UInt16(CommandLine.arguments[1])
-    else {
-      print("Usage: \(CommandLine.arguments[0]) [port]")
-      exit(1)
+    guard CommandLine.arguments.count == 2 else { usage() }
+
+    var path: String?
+    var port: UInt16?
+
+    if CommandLine.arguments[1].hasPrefix("/") {
+      path = CommandLine.arguments[1]
+    } else if let p = UInt16(CommandLine.arguments[1]) {
+      port = p
+    } else {
+      usage()
     }
 
-    let server = try IORingUDPServer()
-    try await server.bind(port: port)
+    let server = try Self(domain: sa_family_t(path != nil ? AF_LOCAL : AF_INET))
+    if let path {
+      try await server.bind(path: path)
+    } else if let port {
+      try await server.bind(port: port)
+    }
     try await server.run()
   }
 
-  init() throws {
+  init(domain: sa_family_t) throws {
     ring = IORing.shared
-    socket = try Socket(ring: ring, domain: sa_family_t(AF_INET), type: SOCK_DGRAM, protocol: 0)
+    socket = try Socket(ring: ring, domain: domain, type: SOCK_DGRAM, protocol: 0)
   }
 
   func bind(port: UInt16) async throws {
     try socket.bind(port: port)
   }
 
+  func bind(path: String) async throws {
+    try socket.bind(path: path)
+  }
+
   func run() async throws {
     repeat {
       do {

Package.resolved

@@ -132,14 +132,14 @@ let package = Package(
       path: "Examples/IORingTCPEcho"
     ),
     .executableTarget(
-      name: "IORingUDPClient",
-      dependencies: ["IORing", "IORingUtils"],
-      path: "Examples/IORingUDPClient"
+      name: "IORingDatagramClient",
+      dependencies: ["IORing", "IORingUtils", "IORingFoundation"],
+      path: "Examples/IORingDatagramClient"
     ),
     .executableTarget(
-      name: "IORingUDPServer",
+      name: "IORingDatagramServer",
       dependencies: ["IORing", "IORingUtils"],
-      path: "Examples/IORingUDPServer"
+      path: "Examples/IORingDatagramServer"
     ),
     .executableTarget(
       name: "IORingDeviceSpy",