mirror of
https://gitflic.ru/project/openide/openide.git
synced 2026-09-27 10:03:11 +07:00
[platform] improving SystemHealthMonitor logging
GitOrigin-RevId: 2d1bd4e1f70662021b59e9a6556b6ae7432f7923
This commit is contained in:
Roman Shevchenko
committed by
intellij-monorepo-bot
intellij-monorepo-bot
parent
e1b081a0e7
commit
617b47e26e
@@ -278,7 +278,7 @@ private fun CoroutineScope.postOpenUiTasks() {
|
||||
}
|
||||
|
||||
launch {
|
||||
startSystemHealthMonitor()
|
||||
SystemHealthMonitor.start()
|
||||
}
|
||||
|
||||
launch {
|
||||
|
||||
@@ -16,7 +16,10 @@ import com.intellij.notification.NotificationType
|
||||
import com.intellij.notification.Notifications
|
||||
import com.intellij.notification.impl.NotificationFullContent
|
||||
import com.intellij.openapi.actionSystem.AnActionEvent
|
||||
import com.intellij.openapi.application.*
|
||||
import com.intellij.openapi.application.ApplicationManager
|
||||
import com.intellij.openapi.application.ApplicationNamesInfo
|
||||
import com.intellij.openapi.application.EDT
|
||||
import com.intellij.openapi.application.PathManager
|
||||
import com.intellij.openapi.application.ex.ApplicationManagerEx
|
||||
import com.intellij.openapi.components.service
|
||||
import com.intellij.openapi.diagnostic.logger
|
||||
@@ -49,387 +52,393 @@ import java.util.concurrent.TimeUnit
|
||||
import kotlin.time.Duration
|
||||
import kotlin.time.Duration.Companion.seconds
|
||||
|
||||
internal suspend fun startSystemHealthMonitor() {
|
||||
withContext(Dispatchers.IO) {
|
||||
checkInstallationIntegrity()
|
||||
}
|
||||
checkCorruptedVmOptionsFile()
|
||||
checkIdeDirectories()
|
||||
withContext(Dispatchers.IO) {
|
||||
checkRuntime()
|
||||
}
|
||||
checkReservedCodeCacheSize()
|
||||
checkEnvironment()
|
||||
withContext(Dispatchers.IO) {
|
||||
checkLauncher()
|
||||
checkTempDirSanity()
|
||||
checkTempDirEnvVars()
|
||||
checkAncientOs()
|
||||
}
|
||||
checkEelVmOptions()
|
||||
internal object SystemHealthMonitor {
|
||||
private const val NOTIFICATION_GROUP_ID = "System Health"
|
||||
|
||||
startDiskSpaceMonitoring()
|
||||
}
|
||||
private val LOG = logger<SystemHealthMonitor>()
|
||||
|
||||
private val LOG = logger<Application>()
|
||||
internal suspend fun start() {
|
||||
withContext(Dispatchers.IO) {
|
||||
checkInstallationIntegrity()
|
||||
}
|
||||
|
||||
private const val NOTIFICATION_GROUP_ID = "System Health"
|
||||
checkCorruptedVmOptionsFile()
|
||||
checkIdeDirectories()
|
||||
|
||||
private class MyNotification(
|
||||
content: @NlsContexts.NotificationContent String,
|
||||
type: NotificationType,
|
||||
displayId: String?
|
||||
) : Notification(NOTIFICATION_GROUP_ID, content, type), NotificationFullContent {
|
||||
init {
|
||||
displayId?.let { setDisplayId(it) }
|
||||
}
|
||||
}
|
||||
withContext(Dispatchers.IO) {
|
||||
checkRuntime()
|
||||
}
|
||||
|
||||
private fun checkInstallationIntegrity() {
|
||||
if (!SystemInfo.isUnix || SystemInfo.isMac) {
|
||||
return
|
||||
checkReservedCodeCacheSize()
|
||||
checkEnvironment()
|
||||
|
||||
withContext(Dispatchers.IO) {
|
||||
checkLauncher()
|
||||
checkTempDirSanity()
|
||||
checkTempDirEnvVars()
|
||||
checkAncientOs()
|
||||
}
|
||||
|
||||
checkEelVmOptions()
|
||||
|
||||
startDiskSpaceMonitoring()
|
||||
}
|
||||
|
||||
try {
|
||||
Files.list(Path.of(PathManager.getLibPath())).use { stream ->
|
||||
// see `LinuxDistributionBuilder#generateVersionMarker`
|
||||
val markers = stream.filter { it.fileName.toString().startsWith("build-marker-") }.count()
|
||||
if (markers > 1) {
|
||||
showNotification("mixed.bag.installation", suppressable = false, action = null, ApplicationNamesInfo.getInstance().fullProductName)
|
||||
private fun checkInstallationIntegrity() {
|
||||
if (!SystemInfo.isUnix || SystemInfo.isMac) {
|
||||
return
|
||||
}
|
||||
|
||||
try {
|
||||
Files.list(Path.of(PathManager.getLibPath())).use { stream ->
|
||||
// see `LinuxDistributionBuilder#generateVersionMarker`
|
||||
val markers = stream.filter { it.fileName.toString().startsWith("build-marker-") }.count()
|
||||
if (markers > 1) {
|
||||
showNotification("mixed.bag.installation", suppressable = false, action = null, ApplicationNamesInfo.getInstance().fullProductName)
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (e: IOException) {
|
||||
LOG.warn("${e.javaClass.name}: ${e.message}")
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkCorruptedVmOptionsFile() {
|
||||
if (System.getProperty("jb.vmOptionsFile.corrupted").toBoolean()) {
|
||||
val file = VMOptions.getUserOptionsFile()
|
||||
if (file != null) {
|
||||
showNotification("vm.options.file.corrupted", suppressable = false, editVmOptionsAction(), shorten(file.toString()))
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (e: IOException) {
|
||||
LOG.warn("${e.javaClass.name}: ${e.message}")
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkCorruptedVmOptionsFile() {
|
||||
if (System.getProperty("jb.vmOptionsFile.corrupted").toBoolean()) {
|
||||
val file = VMOptions.getUserOptionsFile()
|
||||
if (file != null) {
|
||||
showNotification("vm.options.file.corrupted", suppressable = false, editVmOptionsAction(), shorten(file.toString()))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkIdeDirectories() {
|
||||
if (System.getProperty(PathManager.PROPERTY_PATHS_SELECTOR) != null) {
|
||||
if (System.getProperty(PathManager.PROPERTY_CONFIG_PATH) != null && System.getProperty(PathManager.PROPERTY_PLUGINS_PATH) == null) {
|
||||
showNotification("implicit.plugin.directory.path", suppressable = true, action = null, shorten(PathManager.getPluginsPath()))
|
||||
}
|
||||
if (System.getProperty(PathManager.PROPERTY_SYSTEM_PATH) != null && System.getProperty(PathManager.PROPERTY_LOG_PATH) == null) {
|
||||
showNotification("implicit.log.directory.path", suppressable = true, action = null, shorten(PathManager.getLogPath()))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun shorten(pathStr: String): String {
|
||||
val path = Path.of(pathStr).toAbsolutePath()
|
||||
val userHome = Path.of(SystemProperties.getUserHome())
|
||||
return if (path.startsWith(userHome)) {
|
||||
val relative = userHome.relativize(path)
|
||||
if (SystemInfo.isWindows) "%USERPROFILE%\\${relative}" else "~/${relative}"
|
||||
}
|
||||
else {
|
||||
pathStr
|
||||
}
|
||||
}
|
||||
|
||||
private suspend fun checkRuntime() {
|
||||
if (!CpuArch.isEmulated()) {
|
||||
return
|
||||
}
|
||||
|
||||
LOG.info("${CpuArch.CURRENT} appears to be emulated")
|
||||
if (SystemInfo.isMac && CpuArch.isIntel64()) {
|
||||
val downloadAction = ExternalProductResourceUrls.getInstance().downloadPageUrl?.let { downloadPageUrl ->
|
||||
NotificationAction.createSimpleExpiring(IdeBundle.message("bundled.jre.m1.arch.message.download")) {
|
||||
BrowserUtil.browse(downloadPageUrl.toExternalForm())
|
||||
private fun checkIdeDirectories() {
|
||||
if (System.getProperty(PathManager.PROPERTY_PATHS_SELECTOR) != null) {
|
||||
if (System.getProperty(PathManager.PROPERTY_CONFIG_PATH) != null && System.getProperty(PathManager.PROPERTY_PLUGINS_PATH) == null) {
|
||||
showNotification("implicit.plugin.directory.path", suppressable = true, action = null, shorten(PathManager.getPluginsPath()))
|
||||
}
|
||||
if (System.getProperty(PathManager.PROPERTY_SYSTEM_PATH) != null && System.getProperty(PathManager.PROPERTY_LOG_PATH) == null) {
|
||||
showNotification("implicit.log.directory.path", suppressable = true, action = null, shorten(PathManager.getLogPath()))
|
||||
}
|
||||
}
|
||||
showNotification("bundled.jre.m1.arch.message", suppressable = true, downloadAction, ApplicationNamesInfo.getInstance().fullProductName)
|
||||
}
|
||||
var jreHome = SystemProperties.getJavaHome()
|
||||
|
||||
if (PathManager.isUnderHomeDirectory(jreHome) || isModernJBR()) {
|
||||
return
|
||||
}
|
||||
|
||||
// boot JRE is non-bundled and is either non-JB or older than bundled
|
||||
var switchAction: NotificationAction? = null
|
||||
val directory = PathManager.getCustomOptionsDirectory()
|
||||
if (directory != null && (SystemInfo.isWindows || SystemInfo.isMac || SystemInfo.isLinux) && isJbrOperational()) {
|
||||
val scriptName = ApplicationNamesInfo.getInstance().scriptName
|
||||
val configName = scriptName + (if (!SystemInfo.isWindows) "" else if (CpuArch.isIntel64()) "64.exe" else ".exe") + ".jdk"
|
||||
val configFile = Path.of(directory, configName)
|
||||
if (Files.isRegularFile(configFile)) {
|
||||
switchAction = NotificationAction.createSimpleExpiring(IdeBundle.message("action.SwitchToJBR.text")) {
|
||||
runWithModalProgressBlocking(ModalTaskOwner.guess(), IdeBundle.message("deleting.jre.config"), TaskCancellation.cancellable()) {
|
||||
try {
|
||||
Files.delete(configFile)
|
||||
ApplicationManagerEx.getApplicationEx().restart(true)
|
||||
}
|
||||
catch (e: IOException) {
|
||||
LOG.warn("cannot delete $configFile", e)
|
||||
val content = IdeBundle.message("cannot.delete.jre.config", configFile, IoErrorText.message(e))
|
||||
Notification(NOTIFICATION_GROUP_ID, content, NotificationType.ERROR).notify(null)
|
||||
private fun shorten(pathStr: String): String {
|
||||
val path = Path.of(pathStr).toAbsolutePath()
|
||||
val userHome = Path.of(SystemProperties.getUserHome())
|
||||
return if (path.startsWith(userHome)) {
|
||||
val relative = userHome.relativize(path)
|
||||
if (SystemInfo.isWindows) "%USERPROFILE%\\${relative}" else "~/${relative}"
|
||||
}
|
||||
else {
|
||||
pathStr
|
||||
}
|
||||
}
|
||||
|
||||
private suspend fun checkRuntime() {
|
||||
if (!CpuArch.isEmulated()) {
|
||||
return
|
||||
}
|
||||
|
||||
LOG.info("${CpuArch.CURRENT} appears to be emulated")
|
||||
if (SystemInfo.isMac && CpuArch.isIntel64()) {
|
||||
val downloadAction = ExternalProductResourceUrls.getInstance().downloadPageUrl?.let { downloadPageUrl ->
|
||||
NotificationAction.createSimpleExpiring(IdeBundle.message("bundled.jre.m1.arch.message.download")) {
|
||||
BrowserUtil.browse(downloadPageUrl.toExternalForm())
|
||||
}
|
||||
}
|
||||
showNotification("bundled.jre.m1.arch.message", suppressable = true, downloadAction, ApplicationNamesInfo.getInstance().fullProductName)
|
||||
}
|
||||
var jreHome = SystemProperties.getJavaHome()
|
||||
|
||||
if (PathManager.isUnderHomeDirectory(jreHome) || isModernJBR()) {
|
||||
return
|
||||
}
|
||||
|
||||
// boot JRE is non-bundled and is either non-JB or older than bundled
|
||||
var switchAction: NotificationAction? = null
|
||||
val directory = PathManager.getCustomOptionsDirectory()
|
||||
if (directory != null && (SystemInfo.isWindows || SystemInfo.isMac || SystemInfo.isLinux) && isJbrOperational()) {
|
||||
val scriptName = ApplicationNamesInfo.getInstance().scriptName
|
||||
val configName = scriptName + (if (!SystemInfo.isWindows) "" else if (CpuArch.isIntel64()) "64.exe" else ".exe") + ".jdk"
|
||||
val configFile = Path.of(directory, configName)
|
||||
if (Files.isRegularFile(configFile)) {
|
||||
switchAction = NotificationAction.createSimpleExpiring(IdeBundle.message("action.SwitchToJBR.text")) {
|
||||
runWithModalProgressBlocking(ModalTaskOwner.guess(), IdeBundle.message("deleting.jre.config"), TaskCancellation.cancellable()) {
|
||||
try {
|
||||
Files.delete(configFile)
|
||||
ApplicationManagerEx.getApplicationEx().restart(true)
|
||||
}
|
||||
catch (e: IOException) {
|
||||
LOG.warn("cannot delete $configFile", e)
|
||||
val content = IdeBundle.message("cannot.delete.jre.config", configFile, IoErrorText.message(e))
|
||||
Notification(NOTIFICATION_GROUP_ID, content, NotificationType.ERROR).notify(null)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
jreHome = jreHome.removeSuffix("/Contents/Home")
|
||||
showNotification("bundled.jre.version.message", suppressable = false, switchAction,
|
||||
JavaVersion.current(), System.getProperty("java.vendor"), jreHome)
|
||||
}
|
||||
|
||||
// when can't detect a JBR version, give a user the benefit of the doubt
|
||||
private fun isModernJBR(): Boolean {
|
||||
if (!SystemInfo.isJetBrainsJvm) {
|
||||
return false
|
||||
jreHome = jreHome.removeSuffix("/Contents/Home")
|
||||
showNotification("bundled.jre.version.message", suppressable = false, switchAction,
|
||||
JavaVersion.current(), System.getProperty("java.vendor"), jreHome)
|
||||
}
|
||||
|
||||
// when can't detect a JBR version, give a user the benefit of the doubt
|
||||
val jbrVersion = JdkVersionDetector.getInstance().detectJdkVersionInfo(PathManager.getBundledRuntimePath())
|
||||
return jbrVersion == null || JavaVersion.current() >= jbrVersion.version
|
||||
}
|
||||
private fun isModernJBR(): Boolean {
|
||||
if (!SystemInfo.isJetBrainsJvm) {
|
||||
return false
|
||||
}
|
||||
|
||||
private suspend fun isJbrOperational(): Boolean {
|
||||
val bin = Path.of(PathManager.getBundledRuntimePath(), if (SystemInfo.isWindows) "bin/java.exe" else "bin/java")
|
||||
if (Files.isRegularFile(bin) && (SystemInfo.isWindows || Files.isExecutable(bin))) {
|
||||
try {
|
||||
return withTimeout(30.seconds) {
|
||||
@Suppress("UsePlatformProcessAwaitExit")
|
||||
ProcessBuilder(bin.toString(), "-version")
|
||||
.redirectError(ProcessBuilder.Redirect.DISCARD)
|
||||
.redirectOutput(ProcessBuilder.Redirect.DISCARD)
|
||||
.start()
|
||||
.onExit()
|
||||
.asDeferred()
|
||||
.await()
|
||||
.exitValue() == 0
|
||||
// when can't detect a JBR version, give a user the benefit of the doubt
|
||||
val jbrVersion = JdkVersionDetector.getInstance().detectJdkVersionInfo(PathManager.getBundledRuntimePath())
|
||||
return jbrVersion == null || JavaVersion.current() >= jbrVersion.version
|
||||
}
|
||||
|
||||
private suspend fun isJbrOperational(): Boolean {
|
||||
val bin = Path.of(PathManager.getBundledRuntimePath(), if (SystemInfo.isWindows) "bin/java.exe" else "bin/java")
|
||||
if (Files.isRegularFile(bin) && (SystemInfo.isWindows || Files.isExecutable(bin))) {
|
||||
try {
|
||||
return withTimeout(30.seconds) {
|
||||
@Suppress("UsePlatformProcessAwaitExit")
|
||||
ProcessBuilder(bin.toString(), "-version")
|
||||
.redirectError(ProcessBuilder.Redirect.DISCARD)
|
||||
.redirectOutput(ProcessBuilder.Redirect.DISCARD)
|
||||
.start()
|
||||
.onExit()
|
||||
.asDeferred()
|
||||
.await()
|
||||
.exitValue() == 0
|
||||
}
|
||||
}
|
||||
catch (e: ExecutionException) {
|
||||
LOG.debug(e)
|
||||
}
|
||||
}
|
||||
catch (e: ExecutionException) {
|
||||
LOG.debug(e)
|
||||
return false
|
||||
}
|
||||
|
||||
private fun checkReservedCodeCacheSize() {
|
||||
val reservedCodeCacheSize = VMOptions.readOption(VMOptions.MemoryKind.CODE_CACHE, true)
|
||||
val minReservedCodeCacheSize = if (Runtime.version().feature() >= 21 || PluginManagerCore.isRunningFromSources()) 240 else 512
|
||||
if (reservedCodeCacheSize in 1 until minReservedCodeCacheSize) {
|
||||
showNotification("code.cache.warn.message", suppressable = true, editVmOptionsAction(), reservedCodeCacheSize, minReservedCodeCacheSize)
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
private fun checkReservedCodeCacheSize() {
|
||||
val reservedCodeCacheSize = VMOptions.readOption(VMOptions.MemoryKind.CODE_CACHE, true)
|
||||
val minReservedCodeCacheSize = if (Runtime.version().feature() >= 21 || PluginManagerCore.isRunningFromSources()) 240 else 512
|
||||
if (reservedCodeCacheSize in 1 until minReservedCodeCacheSize) {
|
||||
showNotification("code.cache.warn.message", suppressable = true, editVmOptionsAction(), reservedCodeCacheSize, minReservedCodeCacheSize)
|
||||
}
|
||||
}
|
||||
private fun editVmOptionsAction(): NotificationAction? =
|
||||
EditCustomVmOptionsAction()
|
||||
.takeIf { it.isEnabled() }
|
||||
?.let { NotificationAction.createExpiring(IdeBundle.message("vm.options.edit.action.cap")) { e, _ -> it.actionPerformed(e!!) } }
|
||||
|
||||
private fun editVmOptionsAction(): NotificationAction? =
|
||||
EditCustomVmOptionsAction()
|
||||
.takeIf { it.isEnabled() }
|
||||
?.let { NotificationAction.createExpiring(IdeBundle.message("vm.options.edit.action.cap")) { e, _ -> it.actionPerformed(e!!) } }
|
||||
|
||||
private suspend fun checkEnvironment() {
|
||||
val usedVars = sequenceOf("_JAVA_OPTIONS", "JDK_JAVA_OPTIONS", "JAVA_TOOL_OPTIONS")
|
||||
.filter { `var` -> !System.getenv(`var`).isNullOrEmpty() }
|
||||
.toList()
|
||||
if (!usedVars.isEmpty()) {
|
||||
showNotification("vm.options.env.vars", suppressable = true, action = null, usedVars.joinToString(separator = ", "))
|
||||
}
|
||||
|
||||
try {
|
||||
if (shellEnvDeferred!!.await() == false) {
|
||||
val action = NotificationAction.createSimpleExpiring(IdeBundle.message("shell.env.loading.learn.more")) { BrowserUtil.browse("https://intellij.com/shell-env") }
|
||||
val appName = ApplicationNamesInfo.getInstance().fullProductName
|
||||
val shell = System.getenv("SHELL")
|
||||
showNotification("shell.env.loading.failed", suppressable = true, action, appName, shell)
|
||||
private suspend fun checkEnvironment() {
|
||||
val usedVars = sequenceOf("_JAVA_OPTIONS", "JDK_JAVA_OPTIONS", "JAVA_TOOL_OPTIONS")
|
||||
.filter { `var` -> !System.getenv(`var`).isNullOrEmpty() }
|
||||
.toList()
|
||||
if (!usedVars.isEmpty()) {
|
||||
showNotification("vm.options.env.vars", suppressable = true, action = null, usedVars.joinToString(separator = ", "))
|
||||
}
|
||||
}
|
||||
catch (e: Exception) {
|
||||
LOG.error(e)
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkLauncher() {
|
||||
if (
|
||||
(SystemInfoRt.isWindows || SystemInfoRt.isLinux) &&
|
||||
System.getProperty("ide.native.launcher") == null &&
|
||||
!ExternalUpdateManager.isCreatingDesktopEntries()
|
||||
) {
|
||||
val baseName = ApplicationNamesInfo.getInstance().scriptName
|
||||
val binName = baseName + if (SystemInfo.isWindows) "64.exe" else ""
|
||||
val scriptName = baseName + if (SystemInfo.isWindows) ".bat" else ".sh"
|
||||
if (Files.isRegularFile(Path.of(PathManager.getBinPath(), binName))) {
|
||||
@Suppress("IO_FILE_USAGE") val prefix = "bin" + java.io.File.separatorChar
|
||||
val action = NotificationAction.createSimpleExpiring(IdeBundle.message("shell.env.loading.learn.more")) { BrowserUtil.browse("https://intellij.com/launcher") }
|
||||
showNotification("ide.script.launcher.used", suppressable = true, action, prefix + scriptName, prefix + binName)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkTempDirSanity() {
|
||||
if (SystemInfo.isUnix && !SystemInfo.isMac) {
|
||||
try {
|
||||
val probe = Files.createTempFile(Path.of(PathManager.getTempPath()), "ij-exec-check-", ".sh")
|
||||
NioFiles.setExecutable(probe)
|
||||
val process = ProcessBuilder(probe.toString()).start()
|
||||
if (!process.waitFor(1, TimeUnit.MINUTES)) throw IOException("${probe} timed out")
|
||||
if (process.exitValue() != 0) throw IOException("${probe} returned ${process.exitValue()}")
|
||||
}
|
||||
catch (_: Exception) {
|
||||
showNotification("temp.dir.exec.failed", suppressable = false, action = null, shorten(PathManager.getTempPath()))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkTempDirEnvVars() {
|
||||
val envVars = if (SystemInfo.isWindows) sequenceOf("TMP", "TEMP") else sequenceOf("TMPDIR")
|
||||
for (name in envVars) {
|
||||
val value = System.getenv(name) ?: continue
|
||||
try {
|
||||
if (!Files.isDirectory(Path.of(value))) {
|
||||
showNotification("temp.dir.env.invalid", suppressable = false, action = null, name, value)
|
||||
if (shellEnvDeferred!!.await() == false) {
|
||||
val action = NotificationAction.createSimpleExpiring(IdeBundle.message("shell.env.loading.learn.more")) { BrowserUtil.browse("https://intellij.com/shell-env") }
|
||||
val appName = ApplicationNamesInfo.getInstance().fullProductName
|
||||
val shell = System.getenv("SHELL")
|
||||
showNotification("shell.env.loading.failed", suppressable = true, action, appName, shell)
|
||||
}
|
||||
}
|
||||
catch (e: Exception) {
|
||||
LOG.warn(e)
|
||||
showNotification("temp.dir.env.invalid", suppressable = false, action = null, name, value)
|
||||
LOG.error(e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkAncientOs() {
|
||||
if (SystemInfoRt.isWindows) {
|
||||
val buildNumber = SystemInfo.getWinBuildNumber()
|
||||
if (buildNumber != null && buildNumber < 10000) { // 10 1507 = 10240, Server 2016 = 14393
|
||||
showNotification("unsupported.windows", suppressable = true, action = null)
|
||||
private fun checkLauncher() {
|
||||
if (
|
||||
(SystemInfoRt.isWindows || SystemInfoRt.isLinux) &&
|
||||
System.getProperty("ide.native.launcher") == null &&
|
||||
!ExternalUpdateManager.isCreatingDesktopEntries()
|
||||
) {
|
||||
val baseName = ApplicationNamesInfo.getInstance().scriptName
|
||||
val binName = baseName + if (SystemInfo.isWindows) "64.exe" else ""
|
||||
val scriptName = baseName + if (SystemInfo.isWindows) ".bat" else ".sh"
|
||||
if (Files.isRegularFile(Path.of(PathManager.getBinPath(), binName))) {
|
||||
@Suppress("IO_FILE_USAGE") val prefix = "bin" + java.io.File.separatorChar
|
||||
val action = NotificationAction.createSimpleExpiring(IdeBundle.message("shell.env.loading.learn.more")) { BrowserUtil.browse("https://intellij.com/launcher") }
|
||||
showNotification("ide.script.launcher.used", suppressable = true, action, prefix + scriptName, prefix + binName)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun showNotification(
|
||||
key: @PropertyKey(resourceBundle = "messages.IdeBundle") String,
|
||||
suppressable: Boolean,
|
||||
action: NotificationAction?,
|
||||
vararg params: Any
|
||||
) {
|
||||
if (suppressable) {
|
||||
val ignored = PropertiesComponent.getInstance().isValueSet("ignore.${key}")
|
||||
LOG.warn("issue detected: ${key}${if (ignored) " (ignored)" else ""}")
|
||||
if (ignored) {
|
||||
private fun checkTempDirSanity() {
|
||||
if (SystemInfo.isUnix && !SystemInfo.isMac) {
|
||||
try {
|
||||
val probe = Files.createTempFile(Path.of(PathManager.getTempPath()), "ij-exec-check-", ".sh")
|
||||
NioFiles.setExecutable(probe)
|
||||
val process = ProcessBuilder(probe.toString()).start()
|
||||
if (!process.waitFor(1, TimeUnit.MINUTES)) throw IOException("${probe} timed out")
|
||||
if (process.exitValue() != 0) throw IOException("${probe} returned ${process.exitValue()}")
|
||||
}
|
||||
catch (_: Exception) {
|
||||
showNotification("temp.dir.exec.failed", suppressable = false, action = null, shorten(PathManager.getTempPath()))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkTempDirEnvVars() {
|
||||
val envVars = if (SystemInfo.isWindows) sequenceOf("TMP", "TEMP") else sequenceOf("TMPDIR")
|
||||
for (name in envVars) {
|
||||
val value = System.getenv(name) ?: continue
|
||||
try {
|
||||
if (!Files.isDirectory(Path.of(value))) {
|
||||
showNotification("temp.dir.env.invalid", suppressable = false, action = null, name, value)
|
||||
}
|
||||
}
|
||||
catch (e: Exception) {
|
||||
LOG.warn(e)
|
||||
showNotification("temp.dir.env.invalid", suppressable = false, action = null, name, value)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun checkAncientOs() {
|
||||
if (SystemInfoRt.isWindows) {
|
||||
val buildNumber = SystemInfo.getWinBuildNumber()
|
||||
if (buildNumber != null && buildNumber < 10000) { // 10 1507 = 10240, Server 2016 = 14393
|
||||
showNotification("unsupported.windows", suppressable = true, action = null)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private suspend fun checkEelVmOptions() {
|
||||
if (!WslIjentAvailabilityService.getInstance().useIjentForWslNioFileSystem()) return
|
||||
|
||||
val changedOptions = MultiRoutingFileSystemVmOptionsSetter.ensureInVmOptions()
|
||||
when {
|
||||
changedOptions.isEmpty() -> {
|
||||
IjentWslNioFsToggler.instanceAsync().enableForAllWslDistributions()
|
||||
}
|
||||
|
||||
PluginManagerCore.isRunningFromSources() || AppMode.isDevServer() -> {
|
||||
logger<MultiRoutingFileSystemVmOptionsSetter>().warn(
|
||||
changedOptions.joinToString(
|
||||
prefix = "This message is seen only in Dev Mode/Run from sources.\n" +
|
||||
"The value of the registry flag for Eel FS doesn't match the VM options.\n" +
|
||||
"Add the following VM options to the Run Configuration:\n",
|
||||
separator = "\n",
|
||||
) { (k, v) -> " $k${v.orEmpty()}" }
|
||||
)
|
||||
}
|
||||
|
||||
else -> {
|
||||
val actionName = IdeBundle.message(
|
||||
if (ApplicationManager.getApplication().isRestartCapable) "ijent.wsl.fs.dialog.restart.button"
|
||||
else "ijent.wsl.fs.dialog.shutdown.button"
|
||||
)
|
||||
showNotification(
|
||||
key = "ijent.wsl.fs.dialog.message",
|
||||
suppressable = false,
|
||||
action = object : NotificationAction(actionName) {
|
||||
override fun actionPerformed(e: AnActionEvent, notification: Notification) {
|
||||
ApplicationManagerEx.getApplicationEx().restart(true)
|
||||
}
|
||||
}
|
||||
)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun showNotification(
|
||||
key: @PropertyKey(resourceBundle = "messages.IdeBundle") String,
|
||||
suppressable: Boolean,
|
||||
action: NotificationAction?,
|
||||
vararg params: Any
|
||||
) {
|
||||
if (suppressable) {
|
||||
val ignored = PropertiesComponent.getInstance().isValueSet("ignore.${key}")
|
||||
LOG.warn("issue detected: ${key}${if (ignored) " (ignored)" else ""}")
|
||||
if (ignored) {
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
val notification = MyNotification(IdeBundle.message(key, *params), NotificationType.WARNING, key)
|
||||
if (action != null) {
|
||||
notification.addAction(action)
|
||||
}
|
||||
if (suppressable) {
|
||||
notification.addAction(NotificationAction.createSimpleExpiring(IdeBundle.message("sys.health.acknowledge.action")) {
|
||||
PropertiesComponent.getInstance().setValue("ignore.${key}", "true")
|
||||
})
|
||||
}
|
||||
notification.isImportant = true
|
||||
notification.isSuggestionType = true
|
||||
Notifications.Bus.notify(notification)
|
||||
}
|
||||
|
||||
private class MyNotification(
|
||||
content: @NlsContexts.NotificationContent String,
|
||||
type: NotificationType,
|
||||
displayId: String?
|
||||
) : Notification(NOTIFICATION_GROUP_ID, content, type), NotificationFullContent {
|
||||
init {
|
||||
displayId?.let { setDisplayId(it) }
|
||||
}
|
||||
}
|
||||
|
||||
private const val NO_DISK_SPACE_THRESHOLD = (1 shl 20).toLong()
|
||||
private const val LOW_DISK_SPACE_THRESHOLD = (50 shl 20).toLong()
|
||||
private const val MAX_WRITE_SPEED_IN_BPS = (500 shl 20).toLong() // 500 MB/s is (somewhat outdated) peak SSD write speed
|
||||
|
||||
private fun startDiskSpaceMonitoring() {
|
||||
if (System.getProperty("idea.no.system.path.space.monitoring").toBoolean()) {
|
||||
return
|
||||
}
|
||||
|
||||
val (dir, store) = runCatching {
|
||||
val dir = Path.of(PathManager.getSystemPath())
|
||||
val store = Files.getFileStore(dir)
|
||||
dir to store
|
||||
}.getOrElse {
|
||||
LOG.error(it)
|
||||
return
|
||||
}
|
||||
|
||||
monitorDiskSpace(service<CoreUiCoroutineScopeHolder>().coroutineScope, dir, store, initialDelay = 1.seconds)
|
||||
}
|
||||
|
||||
val notification = MyNotification(IdeBundle.message(key, *params), NotificationType.WARNING, key)
|
||||
if (action != null) {
|
||||
notification.addAction(action)
|
||||
}
|
||||
if (suppressable) {
|
||||
notification.addAction(NotificationAction.createSimpleExpiring(IdeBundle.message("sys.health.acknowledge.action")) {
|
||||
PropertiesComponent.getInstance().setValue("ignore.${key}", "true")
|
||||
})
|
||||
}
|
||||
notification.isImportant = true
|
||||
notification.isSuggestionType = true
|
||||
Notifications.Bus.notify(notification)
|
||||
}
|
||||
private fun monitorDiskSpace(scope: CoroutineScope, dir: Path, store: FileStore, initialDelay: Duration) {
|
||||
scope.launch {
|
||||
delay(initialDelay)
|
||||
|
||||
|
||||
private const val NO_DISK_SPACE_THRESHOLD = (1 shl 20).toLong()
|
||||
private const val LOW_DISK_SPACE_THRESHOLD = (50 shl 20).toLong()
|
||||
private const val MAX_WRITE_SPEED_IN_BPS = (500 shl 20).toLong() // 500 MB/s is (somewhat outdated) peak SSD write speed
|
||||
|
||||
private fun startDiskSpaceMonitoring() {
|
||||
if (System.getProperty("idea.no.system.path.space.monitoring").toBoolean()) {
|
||||
return
|
||||
}
|
||||
|
||||
val (dir, store) = runCatching {
|
||||
val dir = Path.of(PathManager.getSystemPath())
|
||||
val store = Files.getFileStore(dir)
|
||||
dir to store
|
||||
}.getOrElse {
|
||||
LOG.error(it)
|
||||
return
|
||||
}
|
||||
|
||||
monitorDiskSpace(service<CoreUiCoroutineScopeHolder>().coroutineScope, dir, store, initialDelay = 1.seconds)
|
||||
}
|
||||
|
||||
private fun monitorDiskSpace(scope: CoroutineScope, dir: Path, store: FileStore, initialDelay: Duration) {
|
||||
scope.launch {
|
||||
delay(initialDelay)
|
||||
|
||||
while (isActive) {
|
||||
val usableSpace = withContext(Dispatchers.IO) {
|
||||
if (Files.exists(dir)) store.usableSpace else -1
|
||||
}
|
||||
if (usableSpace < 0) {
|
||||
delay(60.seconds) // unknown; retry in a minute
|
||||
}
|
||||
else if (usableSpace < NO_DISK_SPACE_THRESHOLD) {
|
||||
LOG.warn("Extremely low disk space: ${usableSpace}")
|
||||
withContext(Dispatchers.EDT) {
|
||||
Messages.showErrorDialog(IdeBundle.message("no.disk.space.message", storeName(store)), IdeBundle.message("no.disk.space.title"))
|
||||
while (isActive) {
|
||||
val usableSpace = withContext(Dispatchers.IO) {
|
||||
if (Files.exists(dir)) store.usableSpace else -1
|
||||
}
|
||||
delay(5.seconds)
|
||||
}
|
||||
else if (usableSpace < LOW_DISK_SPACE_THRESHOLD) {
|
||||
LOG.warn("Low disk space: ${usableSpace}")
|
||||
MyNotification(IdeBundle.message("low.disk.space.message", storeName(store)), NotificationType.WARNING, "low.disk")
|
||||
.setTitle(IdeBundle.message("low.disk.space.title"))
|
||||
.whenExpired { monitorDiskSpace(scope, dir, store, initialDelay = 5.seconds) }
|
||||
.notify(null)
|
||||
return@launch
|
||||
}
|
||||
else {
|
||||
delay(((usableSpace - LOW_DISK_SPACE_THRESHOLD) / MAX_WRITE_SPEED_IN_BPS).coerceIn(5, 3600).seconds)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun storeName(store: FileStore): String =
|
||||
if (store.name().isBlank()) store.toString().trim().trimStart('(').trimEnd(')')
|
||||
else store.toString()
|
||||
|
||||
private suspend fun checkEelVmOptions() {
|
||||
if (!WslIjentAvailabilityService.getInstance().useIjentForWslNioFileSystem()) return
|
||||
|
||||
val changedOptions = MultiRoutingFileSystemVmOptionsSetter.ensureInVmOptions()
|
||||
when {
|
||||
changedOptions.isEmpty() -> {
|
||||
IjentWslNioFsToggler.instanceAsync().enableForAllWslDistributions()
|
||||
}
|
||||
|
||||
PluginManagerCore.isRunningFromSources() || AppMode.isDevServer() -> {
|
||||
logger<MultiRoutingFileSystemVmOptionsSetter>().warn(
|
||||
changedOptions.joinToString(
|
||||
prefix = "This message is seen only in Dev Mode/Run from sources.\n" +
|
||||
"The value of the registry flag for Eel FS doesn't match the VM options.\n" +
|
||||
"Add the following VM options to the Run Configuration:\n",
|
||||
separator = "\n",
|
||||
) { (k, v) -> " $k${v.orEmpty()}" }
|
||||
)
|
||||
}
|
||||
|
||||
else -> {
|
||||
val actionName = IdeBundle.message(
|
||||
if (ApplicationManager.getApplication().isRestartCapable) "ijent.wsl.fs.dialog.restart.button"
|
||||
else "ijent.wsl.fs.dialog.shutdown.button"
|
||||
)
|
||||
showNotification(
|
||||
key = "ijent.wsl.fs.dialog.message",
|
||||
suppressable = false,
|
||||
action = object : NotificationAction(actionName) {
|
||||
override fun actionPerformed(e: AnActionEvent, notification: Notification) {
|
||||
ApplicationManagerEx.getApplicationEx().restart(true)
|
||||
if (usableSpace < 0) {
|
||||
delay(60.seconds) // unknown; retry in a minute
|
||||
}
|
||||
else if (usableSpace < NO_DISK_SPACE_THRESHOLD) {
|
||||
LOG.warn("Extremely low disk space: ${usableSpace} on ${store}")
|
||||
withContext(Dispatchers.EDT) {
|
||||
Messages.showErrorDialog(IdeBundle.message("no.disk.space.message", storeName(store)), IdeBundle.message("no.disk.space.title"))
|
||||
}
|
||||
delay(5.seconds)
|
||||
}
|
||||
)
|
||||
else if (usableSpace < LOW_DISK_SPACE_THRESHOLD) {
|
||||
LOG.warn("Low disk space: ${usableSpace} on ${store}")
|
||||
MyNotification(IdeBundle.message("low.disk.space.message", storeName(store)), NotificationType.WARNING, "low.disk")
|
||||
.setTitle(IdeBundle.message("low.disk.space.title"))
|
||||
.whenExpired { monitorDiskSpace(scope, dir, store, initialDelay = 5.seconds) }
|
||||
.notify(null)
|
||||
return@launch
|
||||
}
|
||||
else {
|
||||
delay(((usableSpace - LOW_DISK_SPACE_THRESHOLD) / MAX_WRITE_SPEED_IN_BPS).coerceIn(5, 3600).seconds)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun storeName(store: FileStore): String =
|
||||
if (store.name().isBlank()) store.toString().trim().trimStart('(').trimEnd(')')
|
||||
else store.toString()
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user