From 86a9365c5318b0062492e865f668adfd23177113 Mon Sep 17 00:00:00 2001 From: Nik Everett Date: Wed, 13 Apr 2016 22:00:04 -0400 Subject: [PATCH] Small format changes in script and monitor packages Just three files - just adding {}s to if and for statements or making them single line. --- .../monitor/jvm/DeadlockAnalyzer.java | 23 ++++++++---- .../java/org/elasticsearch/script/Script.java | 37 ++++++++----------- .../org/elasticsearch/script/Template.java | 12 ++---- 3 files changed, 35 insertions(+), 37 deletions(-) diff --git a/core/src/main/java/org/elasticsearch/monitor/jvm/DeadlockAnalyzer.java b/core/src/main/java/org/elasticsearch/monitor/jvm/DeadlockAnalyzer.java index 69562739071..02f665a3464 100644 --- a/core/src/main/java/org/elasticsearch/monitor/jvm/DeadlockAnalyzer.java +++ b/core/src/main/java/org/elasticsearch/monitor/jvm/DeadlockAnalyzer.java @@ -79,29 +79,34 @@ public class DeadlockAnalyzer { Set> cycles = new HashSet<>(); for (Map.Entry entry : threadInfoMap.entrySet()) { LinkedHashSet cycle = new LinkedHashSet<>(); - for (ThreadInfo t = entry.getValue(); !cycle.contains(t); t = threadInfoMap.get(Long.valueOf(t.getLockOwnerId()))) + for (ThreadInfo t = entry.getValue(); !cycle.contains(t); t = threadInfoMap.get(Long.valueOf(t.getLockOwnerId()))) { cycle.add(t); + } - if (!cycles.contains(cycle)) + if (!cycles.contains(cycle)) { cycles.add(cycle); + } } return cycles; } - private Set> calculateCycleDeadlockChains(Map threadInfoMap, Set> cycles) { + private Set> calculateCycleDeadlockChains(Map threadInfoMap, + Set> cycles) { ThreadInfo allThreads[] = threadBean.getThreadInfo(threadBean.getAllThreadIds()); Set> deadlockChain = new HashSet<>(); Set knownDeadlockedThreads = threadInfoMap.keySet(); for (ThreadInfo threadInfo : allThreads) { Thread.State state = threadInfo.getThreadState(); if (state == Thread.State.BLOCKED && !knownDeadlockedThreads.contains(threadInfo.getThreadId())) { - for (LinkedHashSet cycle : cycles) { + for (LinkedHashSet cycle : cycles) { if (cycle.contains(threadInfoMap.get(Long.valueOf(threadInfo.getLockOwnerId())))) { LinkedHashSet chain = new LinkedHashSet<>(); - for (ThreadInfo node = threadInfo; !chain.contains(node); node = threadInfoMap.get(Long.valueOf(node.getLockOwnerId()))) + ThreadInfo node = threadInfo; + while (!chain.contains(node)) { chain.add(node); - + node = threadInfoMap.get(Long.valueOf(node.getLockOwnerId())); + } deadlockChain.add(chain); } } @@ -135,10 +140,12 @@ public class DeadlockAnalyzer { for (int x = 0; x < members.length; x++) { ThreadInfo ti = members[x]; sb.append(ti.getThreadName()); - if (x < members.length) + if (x < members.length) { sb.append(" > "); - if (x == members.length - 1) + } + if (x == members.length - 1) { sb.append(ti.getLockOwnerName()); + } builder.add(ti.getThreadId()); } this.description = sb.toString(); diff --git a/core/src/main/java/org/elasticsearch/script/Script.java b/core/src/main/java/org/elasticsearch/script/Script.java index 65a117d014f..8d39f27b863 100644 --- a/core/src/main/java/org/elasticsearch/script/Script.java +++ b/core/src/main/java/org/elasticsearch/script/Script.java @@ -46,7 +46,6 @@ public class Script implements ToXContent, Streamable { * using {@link StreamInput#readOptionalStreamable(Supplier)} */ public static final Supplier