MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

report no more than 20 dumps

Browse Source 
GitOrigin-RevId: add6c718a874d8c327ff1e9ab430219f880b0670
This commit is contained in:
Egor Ushakov
2019-10-03 13:06:01 +00:00
committed by intellij-monorepo-bot
parent ad578a1c85
commit cbeaab0cce
1 changed files with 33 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-impl/src/com/intellij/diagnostic/IdeaFreezeReporter.java
+33 -21
View File
@@ -11,7 +11,6 @@ import com.intellij.openapi.extensions.ExtensionNotApplicableException;
import com.intellij.openapi.util.io.FileUtil;
import com.intellij.openapi.util.registry.Registry;
import com.intellij.openapi.util.text.StringUtil;
import com.intellij.util.ArrayUtil;
import com.intellij.util.containers.ContainerUtil;
import one.util.streamex.StreamEx;
import org.jetbrains.annotations.NotNull;
@@ -21,6 +20,7 @@ import java.io.File;
import java.io.IOException;
import java.lang.management.ThreadInfo;
import java.util.*;
import java.util.function.Function;
final class IdeaFreezeReporter implements IdePerformanceListener {
private static final int FREEZE_THRESHOLD = ApplicationManager.getApplication().isInternal() ? 5 : 25; // seconds
@@ -49,6 +49,7 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
if (files != null) {
List<Attachment> attachments = new ArrayList<>();
String message = null, throwable = null;
List<String> dumps = new ArrayList<>();
for (File file : files) {
String text = FileUtil.loadFile(file);
String name = file.getName();
@@ -59,17 +60,18 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
throwable = text;
}
else if (name.startsWith(REPORT_PREFIX)) {
attachments.add(new Attachment(REPORT_PREFIX + "-" + duration + "s.txt", text));
attachments.add(createReportAttachment(duration, text));
}
else if (name.startsWith(PerformanceWatcher.DUMP_PREFIX)) {
attachments.add(new Attachment(DUMP_PREFIX + "-" + attachments.size() + ".txt", text));
dumps.add(text);
}
}
addDumpsAttachments(dumps, Function.identity(), attachments);
cleanup(dir);
if (message != null && throwable != null && !attachments.isEmpty()) {
attachments.forEach(a -> a.setIncluded(true));
report(LogMessage.createEvent(new Freeze(throwable), message, attachments.toArray(Attachment.EMPTY_ARRAY)));
}
}
@@ -80,6 +82,23 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
});
}
private static Attachment createReportAttachment(int lengthInSeconds, String text) {
Attachment res = new Attachment(REPORT_PREFIX + "-" + lengthInSeconds + "s.txt", text);
res.setIncluded(true);
return res;
}
// get 20 scattered elements
private static <T> void addDumpsAttachments(List<T> from, Function<T, String> textMapper, List<Attachment> container) {
int size = Math.min(from.size(), 20);
int step = from.size() / size;
for (int i = 0; i < size; i++) {
Attachment attachment = new Attachment(DUMP_PREFIX + "-" + i + ".txt", textMapper.apply(from.get(i * step)));
attachment.setIncluded(true);
container.add(attachment);
}
}
private static void cleanup(File dir) {
FileUtil.delete(new File(dir, MESSAGE_FILE_NAME));
FileUtil.delete(new File(dir, THROWABLE_FILE_NAME));
@@ -112,7 +131,7 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
}
File dir = toFile.getParentFile();
IdeaLoggingEvent event = createEvent((int)((myDumpTask.getTotalTime() + PerformanceWatcher.getUnresponsiveInterval()) / 1000),
Attachment.EMPTY_ARRAY, myDumpTask, dir, false);
Collections.emptyList(), myDumpTask, dir, false);
if (event != null) {
try {
FileUtil.writeToFile(new File(dir, MESSAGE_FILE_NAME), event.getMessage());
@@ -142,14 +161,9 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
myCurrentDumps.size() >=
Math.max(3, Math.min(PerformanceWatcher.getMaxDumpDuration(), dumpingDuration / 2) / PerformanceWatcher.getDumpInterval())) &&
!ContainerUtil.isEmpty(myStacktraceCommonPart)) {
int size = Math.min(myCurrentDumps.size(), 20); // report up to 20 dumps
int step = myCurrentDumps.size() / size;
Attachment[] attachments = new Attachment[size];
for (int i = 0; i < size; i++) {
Attachment attachment = new Attachment(DUMP_PREFIX + "-" + i + ".txt", myCurrentDumps.get(i * step).getRawDump());
attachment.setIncluded(true);
attachments[i] = attachment;
}
List<Attachment> attachments = new ArrayList<>();
addDumpsAttachments(myCurrentDumps, ThreadDump::getRawDump, attachments);
report(createEvent(lengthInSeconds, attachments, myDumpTask, reportDir, true));
}
}
@@ -219,7 +233,7 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
@Nullable
private IdeaLoggingEvent createEvent(int lengthInSeconds,
Attachment[] attachments,
List<Attachment> attachments,
@NotNull SamplingTask dumpTask,
@Nullable File reportDir,
boolean finished) {
@@ -248,14 +262,10 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
nonEdtCause = !ThreadDumper.isEDT(commonStackNode.myThreadInfo);
}
String text = root.dump();
String name = REPORT_PREFIX + "-" + lengthInSeconds + "s.txt";
Attachment attachment = new Attachment(name, text);
attachment.setIncluded(true);
attachments = ArrayUtil.append(attachments, attachment);
String reportText = root.dump();
try {
FileUtil.writeToFile(new File(reportDir, REPORT_PREFIX + ".txt"), text);
FileUtil.writeToFile(new File(reportDir, REPORT_PREFIX + ".txt"), reportText);
}
catch (IOException ignored) {
}
@@ -276,7 +286,9 @@ final class IdeaFreezeReporter implements IdePerformanceListener {
if (nonEdtCause) {
message += "\n\nThe stack is from the thread that was blocking EDT";
}
return LogMessage.createEvent(new Freeze(commonStack), message, attachments);
Attachment report = createReportAttachment(lengthInSeconds, reportText);
return LogMessage.createEvent(new Freeze(commonStack), message,
ContainerUtil.append(attachments, report).toArray(Attachment.EMPTY_ARRAY));
}
return null;
}