@@ -90,18 +90,22 @@ open class SocketPort: Port {}
90
90
91
91
#else
92
92
93
+ #if canImport(Darwin)
94
+ import Darwin
95
+ fileprivate let FOUNDATION_SOCK_STREAM = SOCK_STREAM
96
+ fileprivate let FOUNDATION_IPPROTO_TCP = IPPROTO_TCP
97
+ #endif
98
+
93
99
#if canImport(Glibc) && !os(Android) && !os(OpenBSD)
94
100
import Glibc
95
- fileprivate let SOCK_STREAM = Int32 ( Glibc . SOCK_STREAM. rawValue)
96
- fileprivate let SOCK_DGRAM = Int32 ( Glibc . SOCK_DGRAM. rawValue)
97
- fileprivate let IPPROTO_TCP = Int32 ( Glibc . IPPROTO_TCP)
101
+ fileprivate let FOUNDATION_SOCK_STREAM = Int32 ( SOCK_STREAM . rawValue)
102
+ fileprivate let FOUNDATION_IPPROTO_TCP = Int32 ( IPPROTO_TCP)
98
103
#endif
99
104
100
105
#if canImport(Glibc) && os(Android) || os(OpenBSD)
101
106
import Glibc
102
- fileprivate let SOCK_STREAM = Int32 ( Glibc . SOCK_STREAM)
103
- fileprivate let SOCK_DGRAM = Int32 ( Glibc . SOCK_DGRAM)
104
- fileprivate let IPPROTO_TCP = Int32 ( Glibc . IPPROTO_TCP)
107
+ fileprivate let FOUNDATION_SOCK_STREAM = Int32 ( SOCK_STREAM)
108
+ fileprivate let FOUNDATION_IPPROTO_TCP = Int32 ( IPPROTO_TCP)
105
109
fileprivate let INADDR_ANY : in_addr_t = 0
106
110
#if os(OpenBSD)
107
111
fileprivate let INADDR_LOOPBACK = 0x7f000001
@@ -123,7 +127,8 @@ import WinSDK
123
127
fileprivate typealias sa_family_t = ADDRESS_FAMILY
124
128
fileprivate typealias in_port_t = USHORT
125
129
fileprivate typealias in_addr_t = UInt32
126
- fileprivate let IPPROTO_TCP = Int32 ( WinSDK . IPPROTO_TCP. rawValue)
130
+ fileprivate let FOUNDATION_SOCK_STREAM = SOCK_STREAM
131
+ fileprivate let FOUNDATION_IPPROTO_TCP = Int32 ( WinSDK . IPPROTO_TCP. rawValue)
127
132
#endif
128
133
129
134
// MARK: Darwin representation of socket addresses
@@ -484,7 +489,7 @@ open class SocketPort : Port {
484
489
485
490
let data = withUnsafeBytes ( of: address) { Data ( $0) }
486
491
487
- self . init ( protocolFamily: PF_INET, socketType: SOCK_STREAM , protocol: IPPROTO_TCP , address: data)
492
+ self . init ( protocolFamily: PF_INET, socketType: FOUNDATION_SOCK_STREAM , protocol: FOUNDATION_IPPROTO_TCP , address: data)
488
493
}
489
494
490
495
private final func createNonuniquedCore( from socket: CFSocket , protocolFamily family: Int32 , socketType type: Int32 , protocol: Int32 ) {
@@ -500,7 +505,7 @@ open class SocketPort : Port {
500
505
var context = CFSocketContext ( )
501
506
context. info = Unmanaged . passUnretained ( self ) . toOpaque ( )
502
507
var s : CFSocket
503
- if type == SOCK_STREAM {
508
+ if type == FOUNDATION_SOCK_STREAM {
504
509
s = CFSocketCreate ( nil , family, type, `protocol`, CFOptionFlags ( kCFSocketAcceptCallBack) , __NSFireSocketAccept, & context)
505
510
} else {
506
511
s = CFSocketCreate ( nil , family, type, `protocol`, CFOptionFlags ( kCFSocketDataCallBack) , __NSFireSocketDatagram, & context)
@@ -519,7 +524,7 @@ open class SocketPort : Port {
519
524
var context = CFSocketContext ( )
520
525
context. info = Unmanaged . passUnretained ( self ) . toOpaque ( )
521
526
var s : CFSocket
522
- if type == SOCK_STREAM {
527
+ if type == FOUNDATION_SOCK_STREAM {
523
528
s = CFSocketCreateWithNative ( nil , CFSocketNativeHandle ( sock) , CFOptionFlags ( kCFSocketAcceptCallBack) , __NSFireSocketAccept, & context)
524
529
} else {
525
530
s = CFSocketCreateWithNative ( nil , CFSocketNativeHandle ( sock) , CFOptionFlags ( kCFSocketDataCallBack) , __NSFireSocketDatagram, & context)
@@ -543,7 +548,7 @@ open class SocketPort : Port {
543
548
sinAddr. sin_addr = inAddr
544
549
545
550
let data = withUnsafeBytes ( of: sinAddr) { Data ( $0) }
546
- self . init ( remoteWithProtocolFamily: PF_INET, socketType: SOCK_STREAM , protocol: IPPROTO_TCP , address: data)
551
+ self . init ( remoteWithProtocolFamily: PF_INET, socketType: FOUNDATION_SOCK_STREAM , protocol: FOUNDATION_IPPROTO_TCP , address: data)
547
552
return
548
553
}
549
554
}
@@ -556,7 +561,7 @@ open class SocketPort : Port {
556
561
sinAddr. sin6_addr = in6Addr
557
562
558
563
let data = withUnsafeBytes ( of: sinAddr) { Data ( $0) }
559
- self . init ( remoteWithProtocolFamily: PF_INET, socketType: SOCK_STREAM , protocol: IPPROTO_TCP , address: data)
564
+ self . init ( remoteWithProtocolFamily: PF_INET, socketType: FOUNDATION_SOCK_STREAM , protocol: FOUNDATION_IPPROTO_TCP , address: data)
560
565
return
561
566
}
562
567
}
@@ -573,7 +578,7 @@ open class SocketPort : Port {
573
578
withUnsafeBytes ( of: in_addr_t ( INADDR_LOOPBACK) . bigEndian) { buffer. copyMemory ( from: $0) }
574
579
}
575
580
let data = withUnsafeBytes ( of: sinAddr) { Data ( $0) }
576
- self . init ( remoteWithProtocolFamily: PF_INET, socketType: SOCK_STREAM , protocol: IPPROTO_TCP , address: data)
581
+ self . init ( remoteWithProtocolFamily: PF_INET, socketType: FOUNDATION_SOCK_STREAM , protocol: FOUNDATION_IPPROTO_TCP , address: data)
577
582
}
578
583
579
584
private static let remoteSocketCoresLock = NSLock ( )
@@ -1049,7 +1054,7 @@ open class SocketPort : Port {
1049
1054
if let connector = core. connectors [ signature] , CFSocketIsValid ( connector) {
1050
1055
return connector
1051
1056
} else {
1052
- if signature. socketType == SOCK_STREAM {
1057
+ if signature. socketType == FOUNDATION_SOCK_STREAM {
1053
1058
if let connector = CFSocketCreate ( nil , socketKind. protocolFamily, socketKind. socketType, socketKind. protocol, CFOptionFlags ( kCFSocketDataCallBack) , __NSFireSocketData, & context) , CFSocketIsValid ( connector) {
1054
1059
var timeout = time - Date. timeIntervalSinceReferenceDate
1055
1060
if timeout < 0 || timeout >= SocketPort . maximumTimeout {
0 commit comments