Skip to content

Commit 99e400b

Browse files
committed
apply review
1 parent 5feed35 commit 99e400b

File tree

7 files changed

+13
-35
lines changed

7 files changed

+13
-35
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,9 @@ public void onFrameEnd(final HandlerContext handlerContext) {
9999
return;
100100
}
101101
final AgentSpan wsSpan = handlerContext.getWebsocketSpan();
102+
if (wsSpan == null) {
103+
return;
104+
}
102105
try {
103106
final long startTime = handlerContext.getFirstFrameTimestamp();
104107
if (startTime > 0) {

dd-java-agent/agent-bootstrap/src/main/java/datadog/trace/bootstrap/instrumentation/websocket/HandlerContext.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,11 @@
22

33
import datadog.trace.api.time.SystemTimeSource;
44
import datadog.trace.bootstrap.instrumentation.api.AgentSpan;
5+
import org.slf4j.Logger;
6+
import org.slf4j.LoggerFactory;
57

68
public abstract class HandlerContext {
9+
final Logger LOGGER = LoggerFactory.getLogger(HandlerContext.class);
710

811
private final AgentSpan handshakeSpan;
912
private AgentSpan websocketSpan;
@@ -92,7 +95,11 @@ public void recordChunkData(Object data, boolean partialDelivery) {
9295
if (partialDelivery && sz == 0) {
9396
msgChunks--; // if we receive an empty frame with the fin bit don't count it as a chunk
9497
}
95-
} catch (Throwable ignored) {
98+
} catch (Throwable t) {
99+
LOGGER.debug(
100+
"Unable to calculate websocket message size for data type {}",
101+
data.getClass().getName(),
102+
t);
96103
}
97104
}
98105
}

dd-java-agent/instrumentation/jetty-9/src/main/java/datadog/trace/instrumentation/jetty10/JettyServerInstrumentation.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,6 @@ public void typeAdvice(TypeTransformer transformer) {
9999
public void methodAdvice(MethodTransformer transformer) {
100100
transformer.applyAdvice(takesNoArguments().and(named("handle")), packageName + ".HandleAdvice");
101101
transformer.applyAdvice(named("recycle").and(takesNoArguments()), packageName + ".ResetAdvice");
102-
transformer.applyAdvice(named("onCompleted"), packageName + ".OnCompletedAdvice");
103102

104103
if (appSecNotFullyDisabled) {
105104
transformer.applyAdvice(

dd-java-agent/instrumentation/jetty-9/src/main/java_jetty10/datadog/trace/instrumentation/jetty10/OnCompletedAdvice.java

Lines changed: 0 additions & 29 deletions
This file was deleted.

dd-java-agent/instrumentation/spring-webmvc-6.0/src/test/groovy/datadog/trace/instrumentation/springweb6/boot/SpringBootBasedTest.groovy

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ class SpringBootBasedTest extends HttpServerTest<ConfigurableApplicationContext>
6868

6969
@Override
7070
void start() {
71-
app.setDefaultProperties(["server.port" : 0, "server.context-path": "/$servletContext",
71+
app.setDefaultProperties(["server.port": 0, "server.context-path": "/$servletContext",
7272
"spring.mvc.throw-exception-if-no-handler-found": false,
7373
"spring.web.resources.add-mappings" : false])
7474
context = app.run()

dd-java-agent/instrumentation/tomcat-5.5/build.gradle

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,7 @@ dependencies {
139139
project.afterEvaluate {
140140
tasks.withType(Test).configureEach {
141141
if (javaLauncher.get().metadata.languageVersion.asInt() >= 16) {
142+
// to avoid java.lang.IllegalAccessException: class org.apache.tomcat.util.compat.JreCompat cannot access a member of class java.io.FileSystem (in module java.base) with modifiers "static final"
142143
jvmArgs += ['--add-opens', 'java.base/java.io=ALL-UNNAMED']
143144
}
144145
}
Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1 @@
11
apply from: "$rootDir/gradle/java.gradle"
2-
3-
dependencies {
4-
}

0 commit comments

Comments
 (0)