Add Musl import, error if unrecognised platform (#325)

* Add Musl import, error if unrecognised platform

* Add #else #error for all platform checks

Author: adam-fowler

Sources/AsyncAlgorithms/Locking.swift

@@ -13,19 +13,23 @@
 import Darwin
 #elseif canImport(Glibc)
 import Glibc
+#elseif canImport(Musl)
+import Musl
 #elseif canImport(WinSDK)
 import WinSDK
+#else
+#error("Unsupported platform")
 #endif
 
 internal struct Lock {
 #if canImport(Darwin)
   typealias Primitive = os_unfair_lock
-#elseif canImport(Glibc)
+#elseif canImport(Glibc) || canImport(Musl)
   typealias Primitive = pthread_mutex_t
 #elseif canImport(WinSDK)
   typealias Primitive = SRWLOCK
 #else
-  typealias Primitive = Int
+  #error("Unsupported platform")
 #endif
 
   typealias PlatformLock = UnsafeMutablePointer<Primitive>
@@ -38,16 +42,18 @@ internal struct Lock {
   fileprivate static func initialize(_ platformLock: PlatformLock) {
 #if canImport(Darwin)
     platformLock.initialize(to: os_unfair_lock())
-#elseif canImport(Glibc)
+#elseif canImport(Glibc) || canImport(Musl)
     let result = pthread_mutex_init(platformLock, nil)
     precondition(result == 0, "pthread_mutex_init failed")
 #elseif canImport(WinSDK)
     InitializeSRWLock(platformLock)
+#else
+    #error("Unsupported platform")
 #endif
   }
 
   fileprivate static func deinitialize(_ platformLock: PlatformLock) {
-#if canImport(Glibc)
+#if canImport(Glibc) || canImport(Musl)
     let result = pthread_mutex_destroy(platformLock)
     precondition(result == 0, "pthread_mutex_destroy failed")
 #endif
@@ -57,21 +63,25 @@ internal struct Lock {
   fileprivate static func lock(_ platformLock: PlatformLock) {
 #if canImport(Darwin)
     os_unfair_lock_lock(platformLock)
-#elseif canImport(Glibc)
+#elseif canImport(Glibc) || canImport(Musl)
     pthread_mutex_lock(platformLock)
 #elseif canImport(WinSDK)
     AcquireSRWLockExclusive(platformLock)
+#else
+    #error("Unsupported platform")
 #endif
   }
 
   fileprivate static func unlock(_ platformLock: PlatformLock) {
 #if canImport(Darwin)
     os_unfair_lock_unlock(platformLock)
-#elseif canImport(Glibc)
+#elseif canImport(Glibc) || canImport(Musl)
     let result = pthread_mutex_unlock(platformLock)
     precondition(result == 0, "pthread_mutex_unlock failed")
 #elseif canImport(WinSDK)
     ReleaseSRWLockExclusive(platformLock)
+#else
+    #error("Unsupported platform")
 #endif
   }
 

Sources/AsyncSequenceValidation/TaskDriver.swift

@@ -15,16 +15,20 @@ import _CAsyncSequenceValidationSupport
 import Darwin
 #elseif canImport(Glibc)
 import Glibc
+#elseif canImport(Musl)
+import Musl
 #elseif canImport(WinSDK)
 #error("TODO: Port TaskDriver threading to windows")
+#else
+#error("Unsupported platform")
 #endif
 
 #if canImport(Darwin)
 func start_thread(_ raw: UnsafeMutableRawPointer) -> UnsafeMutableRawPointer? {
   Unmanaged<TaskDriver>.fromOpaque(raw).takeRetainedValue().run()
   return nil
 }
-#elseif canImport(Glibc)
+#elseif canImport(Glibc) || canImport(Musl)
 func start_thread(_ raw: UnsafeMutableRawPointer?) -> UnsafeMutableRawPointer? {
   Unmanaged<TaskDriver>.fromOpaque(raw!).takeRetainedValue().run()
   return nil
@@ -38,7 +42,7 @@ final class TaskDriver {
   let queue: WorkQueue
 #if canImport(Darwin)
   var thread: pthread_t?
-#elseif canImport(Glibc)
+#elseif canImport(Glibc) || canImport(Musl)
   var thread = pthread_t()
 #elseif canImport(WinSDK)
 #error("TODO: Port TaskDriver threading to windows")
@@ -50,7 +54,7 @@ final class TaskDriver {
   }
 
   func start() {
-#if canImport(Darwin) || canImport(Glibc)
+#if canImport(Darwin) || canImport(Glibc) || canImport(Musl)
     pthread_create(&thread, nil, start_thread,
       Unmanaged.passRetained(self).toOpaque())
 #elseif canImport(WinSDK)
@@ -68,7 +72,7 @@ final class TaskDriver {
   func join() {
 #if canImport(Darwin)
     pthread_join(thread!, nil)
-#elseif canImport(Glibc)
+#elseif canImport(Glibc) || canImport(Musl)
     pthread_join(thread, nil)
 #elseif canImport(WinSDK)
 #error("TODO: Port TaskDriver threading to windows")