1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
|
package org.eclipse.internal.xtend.util;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
import java.util.Stack;
/**
* This class serves as a ThreadLocal collector for profiling information.
*
* @author arno
*
*/
public class ProfileCollector {
private ProfileCollector () {}
private static final ThreadLocal<ProfileCollector> _instance = new ThreadLocal<ProfileCollector>() {
protected ProfileCollector initialValue() {
return new ProfileCollector();
};
};
private PrintWriter _out;
private final Stack<Triplet<String, Long, Long>> _contextStack = new Stack<Triplet<String, Long, Long>>();
private final Map<String, ProfileEntry> _profile = new HashMap<String, ProfileEntry>();
public static ProfileCollector getInstance () {
return _instance.get();
}
/**
* This method tells the ProfileCollector to perform detailed logging and store it in the Writer passed
* as a parameter.
*/
public void setDetailedLoggingWriter (OutputStream out) {
try {
_out = new PrintWriter (new OutputStreamWriter (out, "utf-8"));
_out.println("<?xml version=\"1.0\" encoding=\"utf-8\"?>");
_out.println("<m2t-profile>");
}
catch (UnsupportedEncodingException exc) {}
}
/**
* This method must be called by the application to indicate that logging is finished. Once this method
* was called, enter() and leave() must not be called.
*/
public void finish () {
if (_out != null) {
_out.println ("</m2t-profile>");
_out.flush();
_out = null;
}
}
public Collection<ProfileEntry> getProfile () {
return _profile.values();
}
public void enter (String context) {
_contextStack.push (new Triplet<String, Long, Long>(context, System.currentTimeMillis(), 0L));
if (_out != null)
_out.println("<call context=\"" + context + "\">");
}
/**
* the leave() method does not need to be passed the context because it keeps a stack of all contexts and
* pops the topmost.
*
*/
public void leave () {
final Triplet<String, Long, Long> entry = _contextStack.pop();
final long duration = System.currentTimeMillis() - entry.getSecond();
final long timeInChildren = entry.getThird();
if (! _contextStack.isEmpty()) {
// add this duration to the "duration in children" field of the parent
final Triplet<String, Long, Long> parent = _contextStack.peek();
parent.setThird(parent.getThird() + duration);
}
if (_profile.containsKey(entry.getFirst())) {
_profile.get(entry.getFirst()).registerCall(duration, duration - timeInChildren);
}
else {
_profile.put (entry.getFirst(), new ProfileEntry (entry.getFirst(), duration, duration - timeInChildren));
}
if (_out != null) {
_out.println ("<duration millis=\"" + duration + "\"/>");
_out.println ("</call>");
}
}
@Override
public String toString() {
final StringBuilder result = new StringBuilder ();
result.append ("context\tnum\ttotal\tnet\tmin\tnet\tmax\tnet\n");
for (ProfileEntry e: _profile.values()) {
result.append (e.getContextName() + "\t" + e.getNumCalls() + "\t" + e.getTotalTimeGross() + "\t" + e.getTotalTimeNet() + "\t" + e.getMinTimeGross() + "\t" + e.getMinTimeNet() + "\t" + e.getMaxTimeGross() + "\t" + e.getMaxTimeNet() + "\n");
}
return result.toString();
}
public static class ProfileEntry {
private final String _contextName;
private int _numCalls = 1;
private long _totalTimeGross;
private long _totalTimeNet;
private long _minTimeGross;
private long _minTimeNet;
private long _maxTimeGross;
private long _maxTimeNet;
public ProfileEntry (String contextName, long grossDuration, long netDuration) {
_contextName = contextName;
_totalTimeGross += grossDuration;
_totalTimeNet += netDuration;
_minTimeGross = grossDuration;
_maxTimeGross = grossDuration;
_minTimeNet = netDuration;
_maxTimeNet = netDuration;
}
public void registerCall (long grossDuration, long netDuration) {
_numCalls++;
_totalTimeGross += grossDuration;
_totalTimeNet += netDuration;
if (grossDuration < _minTimeGross)
_minTimeGross = grossDuration;
if (grossDuration > _maxTimeGross)
_maxTimeGross = grossDuration;
if (netDuration < _minTimeNet)
_minTimeNet = netDuration;
if (netDuration > _maxTimeNet)
_maxTimeNet = netDuration;
}
public String getContextName() {
return _contextName;
}
public long getMaxTimeGross() {
return _maxTimeGross;
}
public long getMaxTimeNet() {
return _maxTimeNet;
}
public long getMinTimeGross() {
return _minTimeGross;
}
public long getMinTimeNet() {
return _minTimeNet;
}
public int getNumCalls() {
return _numCalls;
}
public long getTotalTimeGross() {
return _totalTimeGross;
}
public long getTotalTimeNet() {
return _totalTimeNet;
}
}
}
|
