azalea/kotlin-fork
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Do not use uninterruptible file channels in FileChannelUtil

Browse Source 
To avoid illegal access errors from incremental compilation on JDK 16+.

 #KT-45689 Fixed
 #KT-47152 Fixed
This commit is contained in:
Alexander Udalov
2021-07-23 20:53:48 +02:00
parent 2ca241c82c
commit fe18e3fa31
1 changed files with 4 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files
compiler/cli/src/com/intellij/util/io/FileChannelUtil.java
+4 -57
View File
@@ -1,66 +1,13 @@
// Copyright 2000-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license that can be found in the LICENSE file. // Copyright 2000-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license that can be found in the LICENSE file.
package com.intellij.util.io; package com.intellij.util.io;
import com.intellij.openapi.diagnostic.Logger;
import com.intellij.util.ExceptionUtil;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import java.lang.invoke.MethodHandle;
import java.lang.invoke.MethodHandles;
import java.lang.invoke.MethodType;
import java.nio.channels.FileChannel; import java.nio.channels.FileChannel;
final class FileChannelUtil { public final class FileChannelUtil {
private static final Logger LOG = Logger.getInstance(FileChannelUtil.class); @NotNull
static FileChannel unInterruptible(@NotNull FileChannel channel) {
private static final Class<?> sunNioChFileChannelImpl = setupFileChannelImpl(); return channel;
private static final MethodHandle setUnInterruptible = setupUnInterruptibleHandle();
private static Class<?> setupFileChannelImpl() {
try {
return Class.forName("sun.nio.ch.FileChannelImpl");
} }
catch (ClassNotFoundException ignored) {}
return null;
}
@Nullable
private static MethodHandle setupUnInterruptibleHandle() {
MethodHandle setUnInterruptible = null;
try {
if (sunNioChFileChannelImpl != null) {
// noinspection SpellCheckingInspection
setUnInterruptible = MethodHandles
.lookup()
.findVirtual(sunNioChFileChannelImpl, "setUninterruptible", MethodType.methodType(void.class));
}
}
catch (NoSuchMethodException e) {
LOG.info("interruptible FileChannels will be used for indexes");
}
catch (IllegalAccessException e) {
LOG.error(e);
}
if (setUnInterruptible != null) {
LOG.info("uninterruptible FileChannels will be used for indexes");
}
else {
LOG.info("interruptible FileChannels will be used for indexes");
}
return setUnInterruptible;
}
@NotNull
static FileChannel unInterruptible(@NotNull FileChannel channel) {
try {
if (setUnInterruptible != null && sunNioChFileChannelImpl != null && sunNioChFileChannelImpl.isInstance(channel)) {
setUnInterruptible.invoke(channel);
}
}
catch (Throwable e) {
ExceptionUtil.rethrow(e);
}
return channel;
}
} }