@@ -38,7 +38,7 @@ public enum DeviceApp {
3838 public static func main( ) async throws {
3939 var listenAddress = sockaddr_in ( )
4040 listenAddress. sin_family = sa_family_t ( AF_INET)
41- listenAddress. sin_addr. s_addr = 0 // INADDR_ANY equivalent
41+ listenAddress. sin_addr. s_addr = 0 // INADDR_ANY equivalent
4242 listenAddress. sin_port = port. bigEndian
4343 #if canImport(Darwin) || os(FreeBSD) || os(OpenBSD)
4444 listenAddress. sin_len = UInt8 ( MemoryLayout< sockaddr_in> . size)
@@ -61,7 +61,8 @@ public enum DeviceApp {
6161 }
6262 let delegate = DeviceEventDelegate ( )
6363 await device. setEventDelegate ( delegate)
64- #if os(Linux)
64+
65+ #if os(Linux) && NonEmbeddedBuild
6566 let streamEndpoint = try await Ocp1IORingStreamDeviceEndpoint ( address: listenAddress. data)
6667 let datagramEndpoint = try await Ocp1IORingDatagramDeviceEndpoint ( address: listenAddress. data)
6768 let stream6Endpoint = try await Ocp1IORingStreamDeviceEndpoint ( address: listen6Address. data)
@@ -70,7 +71,7 @@ public enum DeviceApp {
7071 try ? await Ocp1IORingStreamDeviceEndpoint ( path: " /tmp/oca-device.sock " )
7172 let domainSocketDatagramEndpoint =
7273 try ? await Ocp1IORingDatagramDeviceEndpoint ( path: " /tmp/oca-device-dg.sock " )
73- #elseif canImport(FlyingSocks)
74+ #elseif canImport(FlyingSocks) && NonEmbeddedBuild
7475 let streamEndpoint = try await Ocp1FlyingSocksStreamDeviceEndpoint ( address: listenAddress. data)
7576 let datagramEndpoint =
7677 try await Ocp1FlyingSocksDatagramDeviceEndpoint ( address: listenAddress. data)
@@ -87,9 +88,10 @@ public enum DeviceApp {
8788 #else
8889 let streamEndpoint = try await Ocp1StreamDeviceEndpoint ( address: listenAddress. data)
8990 #endif
90- #if canImport(FlyingSocks)
91+
92+ #if canImport(FlyingFox) && NonEmbeddedBuild
9193 listenAddress. sin_family = sa_family_t ( AF_INET)
92- listenAddress. sin_addr. s_addr = 0 // INADDR_ANY equivalent
94+ listenAddress. sin_addr. s_addr = 0 // INADDR_ANY equivalent
9395 listenAddress. sin_port = ( port + 2 ) . bigEndian
9496 #if canImport(Darwin) || os(FreeBSD) || os(OpenBSD)
9597 listenAddress. sin_len = UInt8 ( MemoryLayout< sockaddr_in> . size)
@@ -132,7 +134,9 @@ public enum DeviceApp {
132134 )
133135 try await block. add ( actionObject: gain)
134136
137+ #if NonEmbeddedBuild
135138 try await serializeDeserialize ( device. rootBlock)
139+ #endif
136140
137141 let controlNetwork = try await SwiftOCADevice . OcaControlNetwork ( deviceDelegate: device)
138142 Task { @OcaDevice in controlNetwork. state = . running }
@@ -145,6 +149,7 @@ public enum DeviceApp {
145149 }
146150 }
147151
152+ #if NonEmbeddedBuild
148153 try await withThrowingTaskGroup ( of: Void . self) { taskGroup in
149154 taskGroup. addTask {
150155 print ( " Starting OCP.1 IPv4 stream endpoint \( streamEndpoint) ... " )
@@ -186,9 +191,14 @@ public enum DeviceApp {
186191 #endif
187192 try await taskGroup. next ( )
188193 }
194+ #else
195+ print ( " Starting OCP.1 IPv4 stream endpoint \( streamEndpoint) ... " )
196+ try await streamEndpoint. run ( )
197+ #endif
189198 }
190199}
191200
201+ #if NonEmbeddedBuild
192202func serializeDeserialize(
193203 _ object: SwiftOCADevice
194204 . OcaBlock < SwiftOCADevice . OcaRoot >
@@ -203,3 +213,4 @@ func serializeDeserialize(
203213 debugPrint ( " serialization error: \( error) " )
204214 }
205215}
216+ #endif
0 commit comments