boxtec
/
yacy_search_server
mirror of https://github.com/yacy/yacy_search_server
4
1
Fork 0
Code Issues Projects Releases Wiki Activity

thread dump with statistics, a little bit of profiling

Browse Source 
git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@5377 6c8d7289-2bf4-0310-a012-ef5d649a1542
pull/1/head
orbiter 16 years ago
parent d39d420b39
commit bd1dc9cd5d
2 changed files with 104 additions and 40 deletions
Show Stats Download Patch File Download Diff File

3
htroot/Threaddump_p.html
Unescape View File

@ -11,7 +11,8 @@
<h2>Threaddump</h2>
<form action="Threaddump_p.html" method="get" >
<fieldset>
<input type="submit" name="createThreaddump" value="create Threaddump" />
<input type="submit" name="singleThreaddump" value="Single Threaddump" />
<input type="submit" name="multipleThreaddump" value="Multiple Dump Statistic" />
</fieldset>
</form>

87
htroot/Threaddump_p.java
Unescape View File

@ -57,13 +57,11 @@ public class Threaddump_p {
sb = (plasmaSwitchboard) env;
final StringBuffer buffer = new StringBuffer(1000);
if (post != null && post.containsKey("createThreaddump")) {
final boolean plain = post.get("plain", "false").equals("true");
final int sleep = post.getInt("sleep", 0); // a sleep before creation of a thread dump can be used for profiling
if (sleep > 0) try {Thread.sleep(sleep);} catch (final InterruptedException e) {}
prop.put("dump", "1");
// Thread dump
final Map<Thread,StackTraceElement[]> stackTraces = Thread.getAllStackTraces();
final Date dt = new Date();
final String versionstring = yacyVersion.combined2prettyVersion(sb.getConfig("version","0.1"));
@ -76,18 +74,32 @@ public class Threaddump_p {
bufferappend(buffer, plain, "");
bufferappend(buffer, plain, "");
if (post != null && post.containsKey("multipleThreaddump")) {
final ArrayList<Map<Thread,StackTraceElement[]>> traces = new ArrayList<Map<Thread,StackTraceElement[]>>();
for (int i = 0; i < 100; i++) {
traces.add(Thread.getAllStackTraces());
}
appendStackTraceStats(sb.getRootPath(), buffer, traces, plain, Thread.State.BLOCKED);
appendStackTraceStats(sb.getRootPath(), buffer, traces, plain, Thread.State.RUNNABLE);
appendStackTraceStats(sb.getRootPath(), buffer, traces, plain, Thread.State.TIMED_WAITING);
appendStackTraceStats(sb.getRootPath(), buffer, traces, plain, Thread.State.WAITING);
appendStackTraceStats(sb.getRootPath(), buffer, traces, plain, Thread.State.NEW);
appendStackTraceStats(sb.getRootPath(), buffer, traces, plain, Thread.State.TERMINATED);
} else {
// generate a single thread dump
final Map<Thread,StackTraceElement[]> stackTraces = Thread.getAllStackTraces();
appendStackTraces(sb.getRootPath(), buffer, stackTraces, plain, Thread.State.BLOCKED);
appendStackTraces(sb.getRootPath(), buffer, stackTraces, plain, Thread.State.RUNNABLE);
appendStackTraces(sb.getRootPath(), buffer, stackTraces, plain, Thread.State.TIMED_WAITING);
appendStackTraces(sb.getRootPath(), buffer, stackTraces, plain, Thread.State.WAITING);
appendStackTraces(sb.getRootPath(), buffer, stackTraces, plain, Thread.State.NEW);
appendStackTraces(sb.getRootPath(), buffer, stackTraces, plain, Thread.State.TERMINATED);
}
bufferappend(buffer, plain, "************* End Thread Dump " + dt + " *******************");
prop.put("plain_content", buffer.toString());
prop.put("plain", (plain) ? 1 : 0);
}
return prop; // return from serverObjects respond()
}
@ -95,7 +107,66 @@ public class Threaddump_p {
private static void appendStackTraces(final File rootPath, final StringBuffer buffer, final Map<Thread,StackTraceElement[]> stackTraces, final boolean plain, final Thread.State stateIn) {
bufferappend(buffer, plain, "THREADS WITH STATES: " + stateIn.toString());
bufferappend(buffer, plain, "");
// collect single dumps
HashMap<String, ArrayList<String>> dumps = dumpCollection(rootPath, stackTraces, plain, stateIn);
// write dumps
for (final Entry<String, ArrayList<String>> entry: dumps.entrySet()) {
ArrayList<String> threads = entry.getValue();
for (int i = 0; i < threads.size(); i++) bufferappend(buffer, plain, threads.get(i));
bufferappend(buffer, plain, entry.getKey());
bufferappend(buffer, plain, "");
}
bufferappend(buffer, plain, "");
}
private static void appendStackTraceStats(final File rootPath, final StringBuffer buffer, final ArrayList<Map<Thread,StackTraceElement[]>> traces, final boolean plain, final Thread.State stateIn) {
bufferappend(buffer, plain, "THREADS WITH STATES: " + stateIn.toString());
bufferappend(buffer, plain, "");
// collect single dumps
HashMap<String, Integer> dumps = dumpStatistic(rootPath, traces, plain, stateIn);
// write dumps
while (dumps.size() > 0) {
Entry<String, Integer> e = removeMax(dumps);
bufferappend(buffer, plain, "Occurrences: " + e.getValue());
bufferappend(buffer, plain, e.getKey());
bufferappend(buffer, plain, "");
}
bufferappend(buffer, plain, "");
}
private static Entry<String, Integer> removeMax(HashMap<String, Integer> result) {
Entry<String, Integer> max = null;
for (final Entry<String, Integer> e: result.entrySet()) {
if (max == null || e.getValue().intValue() > max.getValue().intValue()) {
max = e;
}
}
result.remove(max.getKey());
return max;
}
private static HashMap<String, Integer> dumpStatistic(final File rootPath, final ArrayList<Map<Thread,StackTraceElement[]>> stackTraces, final boolean plain, final Thread.State stateIn) {
Map<Thread,StackTraceElement[]> trace;
HashMap<String, Integer> result = new HashMap<String, Integer>();
HashMap<String, ArrayList<String>> x;
for (int i = 0; i < stackTraces.size(); i++) {
trace = stackTraces.get(i);
x = dumpCollection(rootPath, trace, plain, stateIn);
for (final Entry<String, ArrayList<String>> e: x.entrySet()) {
Integer c = result.get(e.getKey());
if (c == null) result.put(e.getKey(), new Integer(1));
else {
c = new Integer(c.intValue() + 1);
result.put(e.getKey(), c);
}
}
}
return result;
}
private static HashMap<String, ArrayList<String>> dumpCollection(final File rootPath, final Map<Thread,StackTraceElement[]> stackTraces, final boolean plain, final Thread.State stateIn) {
final File classPath = new File(rootPath, "source");
Thread thread;
@ -139,15 +210,7 @@ public class Threaddump_p {
dumps.put(threaddump, threads);
}
}
// write dumps
for (final Entry<String, ArrayList<String>> entry: dumps.entrySet()) {
ArrayList<String> threads = entry.getValue();
for (int i = 0; i < threads.size(); i++) bufferappend(buffer, plain, threads.get(i));
bufferappend(buffer, plain, entry.getKey());
bufferappend(buffer, plain, "");
}
bufferappend(buffer, plain, "");
return dumps;
}
private static File getClassFile(final File sourcePath, final String classname) {

Write Preview
Loading…
Cancel
Save