Skip to content

Commit d3d0c0e

Browse files
Fixed review notes.
1 parent 708b941 commit d3d0c0e

5 files changed

Lines changed: 13 additions & 7 deletions

File tree

dd-trace-api/src/main/java/datadog/trace/api/ConfigDefaults.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,8 @@ public final class ConfigDefaults {
9090

9191
// TODO: forced to use 1.0 for testing only, rollback to "0.4" before merging to master;
9292
static final String DEFAULT_TRACE_AGENT_PROTOCOL_VERSION = ProtocolVersion.V1_0.asConfigValue();
93+
// TODO: static final String DEFAULT_TRACE_AGENT_PROTOCOL_VERSION =
94+
// ProtocolVersion.V0_4.asConfigValue();
9395

9496
static final boolean DEFAULT_CLIENT_IP_ENABLED = false;
9597

dd-trace-api/src/main/java/datadog/trace/api/ProtocolVersion.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ public static ProtocolVersion fromConfigValue(String value) {
6363

6464
public static ProtocolVersion fromTraceEndpoint(String endpoint) {
6565
if (endpoint == null) {
66-
return null;
66+
return V0_4;
6767
}
6868

6969
String normalized = endpoint.toLowerCase(Locale.ROOT);

dd-trace-core/src/main/java/datadog/trace/common/writer/ddagent/DDAgentMapperDiscovery.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ public void discover() {
4747

4848
default:
4949
traceMapper = new TraceMapperV0_4();
50+
break;
5051
}
5152
}
5253

dd-trace-core/src/main/java/datadog/trace/common/writer/ddagent/TraceMapperV1.java

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ public final class TraceMapperV1 implements TraceMapper {
5050
static final int VALUE_TYPE_ARRAY = 6;
5151

5252
// Span kind OTEL values
53+
static final int SPAN_KIND_UNSPECIFIED = 0;
5354
static final int SPAN_KIND_INTERNAL = 1;
5455
static final int SPAN_KIND_SERVER = 2;
5556
static final int SPAN_KIND_CLIENT = 3;
@@ -82,6 +83,11 @@ public TraceMapperV1() {
8283

8384
@Override
8485
public void map(List<? extends CoreSpan<?>> trace, Writable writable) {
86+
if (trace.isEmpty()) {
87+
// Do nothing if no spans in the trace
88+
return;
89+
}
90+
8591
CoreSpan<?> firstSpan = trace.get(0);
8692
firstSpan.processTagsAndBaggage(spanMetadata, false, false);
8793
Metadata firstSpanMeta = spanMetadata.metadata;
@@ -104,9 +110,6 @@ public void map(List<? extends CoreSpan<?>> trace, Writable writable) {
104110
}
105111

106112
private Map<String, Object> buildChunkAttributes(List<? extends CoreSpan<?>> trace) {
107-
if (trace.isEmpty()) {
108-
return emptyMap();
109-
}
110113
CoreSpan<?> localRoot = trace.get(0).getLocalRootSpan();
111114
CharSequence service = localRoot == null ? null : localRoot.getServiceName();
112115
if (service == null) {
@@ -238,7 +241,7 @@ private boolean isEncodableSpanEvent(Object event) {
238241
return false;
239242
}
240243
Map<?, ?> eventMap = (Map<?, ?>) event;
241-
return asLong(eventMap.get("time_unix_nano")) != null && eventMap.get("name") != null;
244+
return eventMap.get("name") != null && asLong(eventMap.get("time_unix_nano")) != null;
242245
}
243246

244247
private void encodeEventAttributes(Writable writable, int fieldId, Map<?, ?> attrs) {
@@ -545,7 +548,7 @@ private void writeStreamingString(Writable writable, CharSequence value) {
545548
/** Converts a span kind string to its OTEL uint32 value. */
546549
static int getSpanKindValue(CharSequence spanKind) {
547550
if (spanKind == null) {
548-
return SPAN_KIND_INTERNAL;
551+
return SPAN_KIND_UNSPECIFIED;
549552
}
550553

551554
switch (spanKind.toString()) {

dd-trace-core/src/test/groovy/datadog/trace/common/writer/ddagent/TraceMapperV1PayloadTest.groovy

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ class TraceMapperV1PayloadTest extends DDSpecification {
7878

7979
def "test span kind value conversion"() {
8080
expect:
81-
TraceMapperV1.getSpanKindValue(null) == TraceMapperV1.SPAN_KIND_INTERNAL
81+
TraceMapperV1.getSpanKindValue(null) == TraceMapperV1.SPAN_KIND_UNSPECIFIED
8282
TraceMapperV1.getSpanKindValue(Tags.SPAN_KIND_INTERNAL) == TraceMapperV1.SPAN_KIND_INTERNAL
8383
TraceMapperV1.getSpanKindValue(Tags.SPAN_KIND_SERVER) == TraceMapperV1.SPAN_KIND_SERVER
8484
TraceMapperV1.getSpanKindValue(Tags.SPAN_KIND_CLIENT) == TraceMapperV1.SPAN_KIND_CLIENT

0 commit comments

Comments
 (0)