Skip to content

Commit 2d87cde

Browse files
dougqhclaude
andcommitted
Keep peer.port off the id path
peer.port is declared per direction in the registry (#12713), so it has no direction-free id: BaseDecorator, shared by client and server decorators, sets it by name, and the set-by-id tests use an unshared int tag. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
1 parent a2829d1 commit 2d87cde

6 files changed

Lines changed: 18 additions & 15 deletions

File tree

‎dd-java-agent/agent-bootstrap/src/main/java/datadog/trace/bootstrap/instrumentation/decorator/BaseDecorator.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -206,12 +206,12 @@ public final void onPeerConnection(
206206
}
207207

208208
public void setPeerPort(AgentSpan span, String port) {
209-
span.setTag(KnownTags.PEER_PORT_ID, port);
209+
span.setTag(Tags.PEER_PORT, port);
210210
}
211211

212212
public void setPeerPort(AgentSpan span, int port) {
213213
if (port > UNSET_PORT) {
214-
span.setTag(KnownTags.PEER_PORT_ID, port);
214+
span.setTag(Tags.PEER_PORT, port);
215215
}
216216
}
217217

‎dd-trace-core/src/test/java/datadog/trace/core/DDSpanSetTagByIdTest.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,11 +31,11 @@ void tearDown() {
3131

3232
@Test
3333
void storesTheTagUnderItsName() {
34-
span.setTag(KnownTags.PEER_PORT_ID, 5432);
34+
span.setTag(KnownTags.HTTP_RESEND_COUNT_ID, 2);
3535
span.setTag(KnownTags.PEER_HOSTNAME_ID, "db.internal");
3636
span.setTag(KnownTags.DD_PROFILING_ENABLED_ID, true);
3737

38-
assertEquals(5432, span.getTag(KnownTags.PEER_PORT_NAME));
38+
assertEquals(2, span.getTag(KnownTags.HTTP_RESEND_COUNT_NAME));
3939
assertEquals("db.internal", span.getTag(KnownTags.PEER_HOSTNAME_NAME));
4040
assertEquals(true, span.getTag(KnownTags.DD_PROFILING_ENABLED_NAME));
4141
}

‎internal-api/src/jmh/java/datadog/trace/api/TagMapInsertBenchmark.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ public class TagMapInsertBenchmark {
4949
KnownTags.HTTP_CLIENT_IP_NAME,
5050
KnownTags.PEER_HOSTNAME_NAME,
5151
KnownTags.PEER_IPV4_NAME,
52-
KnownTags.PEER_PORT_NAME,
52+
KnownTags.PEER_IPV6_NAME,
5353
KnownTags.DD_INTEGRATION_NAME,
5454
};
5555

@@ -64,7 +64,7 @@ public class TagMapInsertBenchmark {
6464
KnownTags.HTTP_CLIENT_IP_ID,
6565
KnownTags.PEER_HOSTNAME_ID,
6666
KnownTags.PEER_IPV4_ID,
67-
KnownTags.PEER_PORT_ID,
67+
KnownTags.PEER_IPV6_ID,
6868
KnownTags.DD_INTEGRATION_ID,
6969
};
7070

‎internal-api/src/test/java/datadog/trace/api/TagMapEntryCreateByIdTest.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@ void matchesCreateByNameForEveryValueType() {
2020
TagMap.Entry.create(KnownTags.DD_PROFILING_ENABLED_NAME, true),
2121
TagMap.Entry.create(KnownTags.DD_PROFILING_ENABLED_ID, true));
2222
assertEquivalent(
23-
TagMap.Entry.create(KnownTags.PEER_PORT_NAME, 5432),
24-
TagMap.Entry.create(KnownTags.PEER_PORT_ID, 5432));
23+
TagMap.Entry.create(KnownTags.HTTP_STATUS_CODE_NAME, 5432),
24+
TagMap.Entry.create(KnownTags.HTTP_STATUS_CODE_ID, 5432));
2525
assertEquivalent(
2626
TagMap.Entry.create(KnownTags.HTTP_RESEND_COUNT_NAME, 2L),
2727
TagMap.Entry.create(KnownTags.HTTP_RESEND_COUNT_ID, 2L));

‎internal-api/src/test/java/datadog/trace/api/TagMapSetByIdTest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ void anOpenTelemetryRenameIsStoredUnderTheDatadogName() {
3333
@Test
3434
void matchesTheNameKeyedSettersForEveryValueType() {
3535
TagMap byId = TagMap.create();
36-
byId.set(KnownTags.PEER_PORT_ID, 5432);
36+
byId.set(KnownTags.HTTP_STATUS_CODE_ID, 5432);
3737
byId.set(KnownTags.HTTP_RESEND_COUNT_ID, 2L);
3838
byId.set(KnownTags.PEER_HOSTNAME_ID, (CharSequence) "db.internal");
3939
byId.set(KnownTags.DB_INSTANCE_ID, (Object) "orders");
@@ -42,7 +42,7 @@ void matchesTheNameKeyedSettersForEveryValueType() {
4242
byId.set(KnownTags.DB_POOL_NAME_ID, 2.5d);
4343

4444
TagMap byName = TagMap.create();
45-
byName.set(KnownTags.PEER_PORT_NAME, 5432);
45+
byName.set(KnownTags.HTTP_STATUS_CODE_NAME, 5432);
4646
byName.set(KnownTags.HTTP_RESEND_COUNT_NAME, 2L);
4747
byName.set(KnownTags.PEER_HOSTNAME_NAME, (CharSequence) "db.internal");
4848
byName.set(KnownTags.DB_INSTANCE_NAME, (Object) "orders");
@@ -51,7 +51,7 @@ void matchesTheNameKeyedSettersForEveryValueType() {
5151
byName.set(KnownTags.DB_POOL_NAME, 2.5d);
5252

5353
assertEquals(new HashMap<>(byName), new HashMap<>(byId));
54-
assertEquals(5432, byId.getEntry(KnownTags.PEER_PORT_NAME).intValue());
54+
assertEquals(5432, byId.getEntry(KnownTags.HTTP_STATUS_CODE_NAME).intValue());
5555
}
5656

5757
@Test

‎internal-api/src/test/java/datadog/trace/api/TagMapTagHashTest.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,9 @@ void everyKnownTagSurvivesBucketCollisionsAndCopies() throws IllegalAccessExcept
7272
assertEquals(tagIds.size(), copy.size());
7373
for (long tagId : tagIds) {
7474
String name = KnownTagCodec.nameOf(tagId);
75+
if (KnownTagCodec.keyOf(name) != tagId) {
76+
continue; // a name declared per direction does not resolve to either direction's id
77+
}
7578
assertEquals("value", map.getObject(name), name);
7679
assertEquals("value", copy.getObject(name), name);
7780
}
@@ -90,12 +93,12 @@ private static List<Long> knownTagIds() throws IllegalAccessException {
9093
@Test
9194
void lookupsFindEntriesSetEitherWay() {
9295
TagMap map = TagMap.create();
93-
map.set(KnownTags.PEER_PORT_ID, 5432);
96+
map.set(KnownTags.HTTP_STATUS_CODE_ID, 5432);
9497
map.set("my.custom.tag", "value");
9598

96-
assertEquals(5432, map.getEntry(KnownTags.PEER_PORT_NAME).intValue());
99+
assertEquals(5432, map.getEntry(KnownTags.HTTP_STATUS_CODE_NAME).intValue());
97100
assertEquals("value", map.getString("my.custom.tag"));
98-
assertEquals(5432, map.getAndRemove(KnownTags.PEER_PORT_NAME).intValue());
99-
assertEquals(null, map.getEntry(KnownTags.PEER_PORT_NAME));
101+
assertEquals(5432, map.getAndRemove(KnownTags.HTTP_STATUS_CODE_NAME).intValue());
102+
assertEquals(null, map.getEntry(KnownTags.HTTP_STATUS_CODE_NAME));
100103
}
101104
}

0 commit comments

Comments
 (0)