Skip to content

Commit a393715

Browse files
author
Dave Syer
committed
Fix broken test (duh)
1 parent 8d48406 commit a393715

File tree

2 files changed

+21
-28
lines changed

2 files changed

+21
-28
lines changed

spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/log/Slf4jSpanLogger.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,7 @@
2323
import org.springframework.cloud.sleuth.Span;
2424

2525
/**
26-
* Span listener that logs to the console when a span got
27-
* started / stopped / continued.
26+
* Span listener that logs to the console when a span got started / stopped / continued.
2827
*
2928
* @author Spencer Gibb
3029
* @since 1.0.0
@@ -36,8 +35,7 @@ public class Slf4jSpanLogger implements SpanLogger {
3635

3736
public Slf4jSpanLogger(String nameSkipPattern) {
3837
this.nameSkipPattern = Pattern.compile(nameSkipPattern);
39-
this.log = org.slf4j.LoggerFactory
40-
.getLogger(Slf4jSpanLogger.class);
38+
this.log = org.slf4j.LoggerFactory.getLogger(Slf4jSpanLogger.class);
4139
}
4240

4341
Slf4jSpanLogger(String nameSkipPattern, Logger log) {
@@ -66,7 +64,9 @@ public void logContinuedSpan(Span span) {
6664

6765
@Override
6866
public void logStoppedSpan(Span parent, Span span) {
69-
log("Stopped span: {}", span);
67+
if (span != null) {
68+
log("Stopped span: {}", span);
69+
}
7070
if (span != null && parent != null) {
7171
log("With parent: {}", parent);
7272
MDC.put(Span.SPAN_ID_NAME, Span.idToHex(parent.getSpanId()));

spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/trace/DefaultTracer.java

Lines changed: 16 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,8 @@ public class DefaultTracer implements Tracer {
4747

4848
private final SpanReporter spanReporter;
4949

50-
public DefaultTracer(Sampler defaultSampler, Random random, SpanNamer spanNamer,
51-
SpanLogger spanLogger, SpanReporter spanReporter) {
50+
public DefaultTracer(Sampler defaultSampler, Random random, SpanNamer spanNamer, SpanLogger spanLogger,
51+
SpanReporter spanReporter) {
5252
this.defaultSampler = defaultSampler;
5353
this.random = random;
5454
this.spanNamer = spanNamer;
@@ -77,9 +77,8 @@ public Span createSpan(String name, Sampler sampler) {
7777
}
7878
else {
7979
long id = createId();
80-
span = Span.builder().name(name).traceId(id)
81-
.spanId(id).build();
82-
if (sampler==null) {
80+
span = Span.builder().name(name).traceId(id).spanId(id).build();
81+
if (sampler == null) {
8382
sampler = this.defaultSampler;
8483
}
8584
span = sampledSpan(name, id, span, sampler);
@@ -95,8 +94,7 @@ public Span detach(Span span) {
9594
}
9695
Span cur = SpanContextHolder.getCurrentSpan();
9796
if (!span.equals(cur)) {
98-
ExceptionUtils.warn("Tried to detach trace span but "
99-
+ "it is not the current span: " + span
97+
ExceptionUtils.warn("Tried to detach trace span but " + "it is not the current span: " + span
10098
+ ". You may have forgotten to close or detach " + cur);
10199
}
102100
else {
@@ -113,9 +111,8 @@ public Span close(Span span) {
113111
Span cur = SpanContextHolder.getCurrentSpan();
114112
final Span savedSpan = span.getSavedSpan();
115113
if (!span.equals(cur)) {
116-
ExceptionUtils.warn(
117-
"Tried to close span but it is not the current span: " + span
118-
+ ". You may have forgotten to close or detach " + cur);
114+
ExceptionUtils.warn("Tried to close span but it is not the current span: " + span
115+
+ ". You may have forgotten to close or detach " + cur);
119116
}
120117
else {
121118
span.stop();
@@ -130,10 +127,9 @@ public Span close(Span span) {
130127
}
131128
}
132129
SpanContextHolder.close(new SpanContextHolder.SpanFunction() {
133-
@Override public void apply(Span span) {
134-
if (span!=null) {
135-
DefaultTracer.this.spanLogger.logStoppedSpan(savedSpan, span);
136-
}
130+
@Override
131+
public void apply(Span span) {
132+
DefaultTracer.this.spanLogger.logStoppedSpan(savedSpan, span);
137133
}
138134
});
139135
}
@@ -143,8 +139,7 @@ public Span close(Span span) {
143139
protected Span createChild(Span parent, String name) {
144140
long id = createId();
145141
if (parent == null) {
146-
Span span = Span.builder().name(name)
147-
.traceId(id).spanId(id).build();
142+
Span span = Span.builder().name(name).traceId(id).spanId(id).build();
148143
span = sampledSpan(name, id, span, this.defaultSampler);
149144
this.spanLogger.logStartedSpan(null, span);
150145
return span;
@@ -153,10 +148,8 @@ protected Span createChild(Span parent, String name) {
153148
if (!isTracing()) {
154149
SpanContextHolder.push(parent, true);
155150
}
156-
Span span = Span.builder().name(name)
157-
.traceId(parent.getTraceId()).parent(parent.getSpanId()).spanId(id)
158-
.processId(parent.getProcessId()).savedSpan(parent)
159-
.exportable(parent.isExportable()).build();
151+
Span span = Span.builder().name(name).traceId(parent.getTraceId()).parent(parent.getSpanId()).spanId(id)
152+
.processId(parent.getProcessId()).savedSpan(parent).exportable(parent.isExportable()).build();
160153
this.spanLogger.logStartedSpan(parent, span);
161154
return span;
162155
}
@@ -165,8 +158,7 @@ protected Span createChild(Span parent, String name) {
165158
private Span sampledSpan(String name, long id, Span span, Sampler sampler) {
166159
if (!sampler.isSampled(span)) {
167160
// Non-exportable so we keep the trace but not other data
168-
return Span.builder().begin(span.getBegin()).name(name).traceId(id)
169-
.spanId(id).exportable(false).build();
161+
return Span.builder().begin(span.getBegin()).name(name).traceId(id).spanId(id).exportable(false).build();
170162
}
171163
return span;
172164
}
@@ -179,7 +171,8 @@ private long createId() {
179171
public Span continueSpan(Span span) {
180172
if (span != null) {
181173
this.spanLogger.logContinuedSpan(span);
182-
} else {
174+
}
175+
else {
183176
return null;
184177
}
185178
Span newSpan = createContinuedSpan(span, SpanContextHolder.getCurrentSpan());

0 commit comments

Comments
 (0)