MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-02-04 23:39:07 +07:00
Code Issues Packages Projects Releases Wiki Activity

do not use service loader to get default SelectorProvider

Browse Source 
GitOrigin-RevId: 55cf7d248ef805e42086ca8a7c755fe1b498fcef
This commit is contained in:
Vladimir Krivosheev
2021-03-27 19:35:05 +01:00
committed by intellij-monorepo-bot
parent 33a35f24b7
commit 4a0e68480e
1 changed files with 20 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
platform/platform-util-io/src/org/jetbrains/io/BuiltInServer.kt
View File

@@ -10,14 +10,19 @@ import io.netty.channel.*
import io.netty.channel.nio.NioEventLoopGroup
import io.netty.util.concurrent.FastThreadLocalThread
import io.netty.util.internal.logging.InternalLoggerFactory
import java.lang.invoke.MethodHandles
import java.lang.invoke.MethodType
import java.net.InetAddress
import java.net.InetSocketAddress
import java.nio.channels.spi.SelectorProvider
import java.util.*
import java.util.concurrent.ThreadFactory
import java.util.concurrent.atomic.AtomicInteger
import java.util.function.Supplier
class BuiltInServer private constructor(val eventLoopGroup: EventLoopGroup, val port: Int, private val channelRegistrar: ChannelRegistrar) : Disposable {
class BuiltInServer private constructor(val eventLoopGroup: EventLoopGroup,
val port: Int,
private val channelRegistrar: ChannelRegistrar) : Disposable {
val isRunning: Boolean
get() = !channelRegistrar.isEmpty
@@ -131,6 +136,18 @@ private class BuiltInServerThreadFactory : ThreadFactory {
}
}
private val selectorProvider: SelectorProvider? by lazy {
try {
val aClass = ClassLoader.getSystemClassLoader().loadClass("sun.nio.ch.DefaultSelectorProvider")
MethodHandles.lookup()
.findStatic(aClass, "create", MethodType.methodType(SelectorProvider::class.java))
.invokeExact() as SelectorProvider
}
catch (e: Throwable) {
null
}
}
private fun multiThreadEventLoopGroup(workerCount: Int, threadFactory: ThreadFactory): MultithreadEventLoopGroup {
// if (SystemInfo.isMacOSSierra && SystemProperties.getBooleanProperty("native.net.io", false)) {
// try {
@@ -140,6 +157,6 @@ private fun multiThreadEventLoopGroup(workerCount: Int, threadFactory: ThreadFac
// logger<BuiltInServer>().warn("Cannot use native event loop group", e)
// }
// }
return NioEventLoopGroup(workerCount, threadFactory)
// do not use service loader to get default SelectorProvider
return NioEventLoopGroup(workerCount, threadFactory, selectorProvider ?: SelectorProvider.provider())
}