Skip to content

Commit 4fb2e54

Browse files
committed
1 parent 84eacea commit 4fb2e54

File tree

3 files changed

+18
-25
lines changed

3 files changed

+18
-25
lines changed

profiler/src/main/java/com/navercorp/pinpoint/profiler/context/AsyncChildTrace.java

+5-6
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,9 @@ public class AsyncChildTrace implements Trace {
3636

3737
private static final int ASYNC_BEGIN_STACK_ID = 1001;
3838

39-
private static final Logger logger = LogManager.getLogger(AsyncChildTrace.class);
40-
private static final boolean isDebug = logger.isDebugEnabled();
39+
protected final Logger logger = LogManager.getLogger(getClass());
40+
protected final boolean isDebug = logger.isDebugEnabled();
41+
4142
private final CallStack<SpanEvent> callStack;
4243

4344
private final Storage storage;
@@ -103,7 +104,7 @@ private SpanEvent traceBlockBegin0(final int stackId) {
103104

104105
private void stackDump(String caused) {
105106
PinpointException exception = new PinpointException(caused);
106-
logger.warn("[DefaultTrace] Corrupted call stack found TraceRoot:{}, CallStack:{}", getTraceRoot(), callStack, exception);
107+
logger.warn("[{}] Corrupted call stack found TraceRoot:{}, CallStack:{}", getClass().getSimpleName(), getTraceRoot(), callStack, exception);
107108
}
108109

109110
@Override
@@ -165,9 +166,7 @@ public void close() {
165166

166167
public void close0() {
167168
if (closed) {
168-
if (logger.isWarnEnabled()) {
169-
logger.warn("Already closed {}", this);
170-
}
169+
logger.warn("Already closed {}", this);
171170
return;
172171
}
173172
closed = true;

profiler/src/main/java/com/navercorp/pinpoint/profiler/context/DefaultTrace.java

+11-12
Original file line numberDiff line numberDiff line change
@@ -39,8 +39,8 @@
3939
*/
4040
public class DefaultTrace implements Trace {
4141

42-
static final Logger logger = LogManager.getLogger(DefaultTrace.class);
43-
static final boolean isDebug = logger.isDebugEnabled();
42+
protected final Logger logger = LogManager.getLogger(getClass());
43+
protected final boolean isDebug = logger.isDebugEnabled();
4444

4545
private final CallStack<SpanEvent> callStack;
4646

@@ -109,8 +109,7 @@ private SpanEvent traceBlockBegin0(final int stackId) {
109109
if (logger.isWarnEnabled()) {
110110
stackDump("already closed trace");
111111
}
112-
final SpanEvent dummy = dummySpanEvent();
113-
return dummy;
112+
return dummySpanEvent();
114113
}
115114
// Set properties for the case when stackFrame is not used as part of Span.
116115
final SpanEvent spanEvent = newSpanEvent(stackId);
@@ -120,9 +119,7 @@ private SpanEvent traceBlockBegin0(final int stackId) {
120119

121120
private void stackDump(String caused) {
122121
PinpointException exception = new PinpointException(caused);
123-
if (logger.isWarnEnabled()) {
124-
logger.warn("[{}] Corrupted call stack found TraceRoot:{}, CallStack:{}", getClass().getSimpleName(), getTraceRoot(), callStack, exception);
125-
}
122+
logger.warn("[{}] Corrupted call stack found TraceRoot:{}, CallStack:{}", getClass().getSimpleName(), getTraceRoot(), callStack, exception);
126123
}
127124

128125
@Override
@@ -160,6 +157,7 @@ public void traceBlockEnd(int stackId) {
160157
stackDump("not matched stack id. expected=" + stackId + ", current=" + spanEvent.getStackId());
161158
}
162159
}
160+
163161
if (spanEvent.isTimeRecording()) {
164162
spanEvent.markAfterTime();
165163
}
@@ -193,7 +191,7 @@ public void close() {
193191
if (span.isTimeRecording()) {
194192
span.markAfterTime(afterTime);
195193
}
196-
logSpan(span);
194+
logSpan();
197195
}
198196

199197
this.storage.close();
@@ -226,6 +224,7 @@ public long getStartTime() {
226224
return getTraceRoot().getTraceStartTime();
227225
}
228226

227+
229228
@Override
230229
public boolean canSampled() {
231230
return true;
@@ -240,8 +239,8 @@ private void logSpan(SpanEvent spanEvent) {
240239
this.storage.store(spanEvent);
241240
}
242241

243-
private void logSpan(Span span) {
244-
this.storage.store(span);
242+
private void logSpan() {
243+
this.storage.store(this.span);
245244
}
246245

247246
@Override
@@ -320,7 +319,7 @@ public TraceScope addScope(String name) {
320319
@Override
321320
public String toString() {
322321
return "DefaultTrace{" +
323-
", traceRoot=" + getTraceRoot() +
324-
'}';
322+
"traceRoot=" + getTraceRoot() +
323+
'}';
325324
}
326325
}

profiler/src/main/java/com/navercorp/pinpoint/profiler/context/DisableTrace.java

+2-7
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,8 @@
3535
* @author jaehong.kim
3636
*/
3737
public class DisableTrace implements Trace {
38-
static final Logger logger = LogManager.getLogger(DisableTrace.class);
39-
static final boolean isDebug = logger.isDebugEnabled();
38+
protected final Logger logger = LogManager.getLogger(getClass());
39+
protected final boolean isDebug = logger.isDebugEnabled();
4040

4141
public static final String UNSUPPORTED_OPERATION = "disable trace";
4242
public static final long DISABLE_TRACE_OBJECT_ID = -1;
@@ -157,15 +157,10 @@ protected void flush() {
157157
this.closed = true;
158158
}
159159

160-
private boolean getStatus() {
161-
return getShared().getErrorCode() == 0;
162-
}
163-
164160
private Shared getShared() {
165161
return traceRoot.getShared();
166162
}
167163

168-
169164
@Override
170165
public int getCallStackFrameId() {
171166
return DEFAULT_STACKID;

0 commit comments

Comments
 (0)