Use Dispatchers.IO for IOBridge (#4478)

ktorio · Nov 14, 2024 · ccb920f · ccb920f
1 parent b0fd67c
commit ccb920f
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/ktor-server/ktor-server-cio/posix/src/io/ktor/server/cio/internal/CoroutineUtilsNix.kt b/ktor-server/ktor-server-cio/posix/src/io/ktor/server/cio/internal/CoroutineUtilsNix.kt
@@ -7,4 +7,4 @@ package io.ktor.server.cio.internal
 import kotlinx.coroutines.*
 
 internal actual val Dispatchers.IOBridge: CoroutineDispatcher
-    get() = Default
+    get() = IO
diff --git a/ktor-server/ktor-server-core/posix/src/io/ktor/server/engine/internal/ApplicationUtilsNix.kt b/ktor-server/ktor-server-core/posix/src/io/ktor/server/engine/internal/ApplicationUtilsNix.kt
@@ -9,10 +9,12 @@ import io.ktor.server.engine.*
 import kotlinx.cinterop.*
 import kotlinx.coroutines.*
 import platform.posix.*
+import kotlin.experimental.*
 
-internal actual fun availableProcessorsBridge(): Int = 1
+@OptIn(ExperimentalNativeApi::class)
+internal actual fun availableProcessorsBridge(): Int = Platform.getAvailableProcessors()
 
-internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = Default
+internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = IO
 
 @OptIn(ExperimentalForeignApi::class)
 internal actual fun printError(message: Any?) {

diff --git a/...rver/ktor-server-test-host/posix/src/io/ktor/server/testing/internal/CoroutineUtilsNix.kt b/...rver/ktor-server-test-host/posix/src/io/ktor/server/testing/internal/CoroutineUtilsNix.kt
@@ -6,6 +6,6 @@ package io.ktor.server.testing.internal
 
 import kotlinx.coroutines.*
 
-internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = Default
+internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = IO
 
 internal actual fun <T> maybeRunBlocking(block: suspend CoroutineScope.() -> T): T = runBlocking(block = block)