Build Span Attributes which may be missing from OTEL-provided Span

bradAtTraceable · bradAtTraceable · commit bcc9c1d8f4de · 2022-09-20T06:44:26.000-07:00
diff --git a/filter-api/src/main/java/org/hypertrace/agent/filter/MultiFilter.java b/filter-api/src/main/java/org/hypertrace/agent/filter/MultiFilter.java
@@ -51,6 +51,25 @@ public boolean evaluateRequestHeaders(Span span, Map<String, String> headers) {
     return shouldBlock;
   }
 
+  @Override
+  public boolean evaluateRequestHeaders(
+      Span span, Map<String, String> headers, Map<String, String> possiblyMissingSpanAttrs) {
+    boolean shouldBlock = false;
+    for (Filter filter : filters) {
+      try {
+        if (filter.evaluateRequestHeaders(span, headers, possiblyMissingSpanAttrs)) {
+          shouldBlock = true;
+        }
+      } catch (Throwable t) {
+        logger.warn(
+            "Throwable thrown while evaluating Request headers for filter {}",
+            filter.getClass().getName(),
+            t);
+      }
+    }
+    return shouldBlock;
+  }
+
   @Override
   public boolean evaluateRequestBody(Span span, String body, Map<String, String> headers) {
     boolean shouldBlock = false;
@@ -68,4 +87,26 @@ public boolean evaluateRequestBody(Span span, String body, Map<String, String> h
     }
     return shouldBlock;
   }
+
+  @Override
+  public boolean evaluateRequestBody(
+      Span span,
+      String body,
+      Map<String, String> headers,
+      Map<String, String> possiblyMissingAttrs) {
+    boolean shouldBlock = false;
+    for (Filter filter : filters) {
+      try {
+        if (filter.evaluateRequestBody(span, body, headers, possiblyMissingAttrs)) {
+          shouldBlock = true;
+        }
+      } catch (Throwable t) {
+        logger.warn(
+            "Throwable thrown while evaluating Request body for filter {}",
+            filter.getClass().getName(),
+            t);
+      }
+    }
+    return shouldBlock;
+  }
 }
diff --git a/filter-api/src/main/java/org/hypertrace/agent/filter/api/Filter.java b/filter-api/src/main/java/org/hypertrace/agent/filter/api/Filter.java
@@ -34,6 +34,19 @@ public interface Filter {
    */
   boolean evaluateRequestHeaders(Span span, Map<String, String> headers);
 
+  /**
+   * Evaluate the execution (includes extra attributes which might be missing from the span).
+   *
+   * @param span
+   * @param headers
+   * @param possiblyMissingSpanAttrs
+   * @return
+   */
+  default boolean evaluateRequestHeaders(
+      Span span, Map<String, String> headers, Map<String, String> possiblyMissingSpanAttrs) {
+    return evaluateRequestHeaders(span, headers);
+  }
+
   /**
    * Evaluate the execution.
    *
@@ -43,4 +56,12 @@ public interface Filter {
    * @return filter result
    */
   boolean evaluateRequestBody(Span span, String body, Map<String, String> headers);
+
+  default boolean evaluateRequestBody(
+      Span span,
+      String body,
+      Map<String, String> headers,
+      Map<String, String> possiblyMissingSpanAttrs) {
+    return evaluateRequestBody(span, body, headers);
+  }
 }
diff --git a/instrumentation/apache-httpasyncclient-4.1/build.gradle.kts b/instrumentation/apache-httpasyncclient-4.1/build.gradle.kts
@@ -35,5 +35,6 @@ dependencies {
     testImplementation("io.opentelemetry.instrumentation:opentelemetry-instrumentation-api-semconv:${versions["opentelemetry_semconv"]}")
     library("org.apache.httpcomponents:httpasyncclient:4.1")
      testImplementation(testFixtures(project(":testing-common")))
+    implementation(project(":instrumentation:utils"))
 }
 
diff --git a/instrumentation/build.gradle.kts b/instrumentation/build.gradle.kts
@@ -19,6 +19,7 @@ dependencies{
     implementation(project(":instrumentation:undertow:undertow-1.4"))
     implementation(project(":instrumentation:undertow:undertow-servlet-1.4"))
     implementation(project(":instrumentation:vertx:vertx-web-3.0"))
+    implementation(project(":instrumentation:utils"))
     implementation(project(":otel-extensions"))
 }
 
diff --git a/instrumentation/netty/netty-4.0/build.gradle.kts b/instrumentation/netty/netty-4.0/build.gradle.kts
@@ -88,5 +88,6 @@ dependencies {
 
      testImplementation(testFixtures(project(":testing-common")))
     testImplementation("org.asynchttpclient:async-http-client:2.0.9")
+    implementation(project(":instrumentation:utils"))
 }
 
diff --git a/instrumentation/netty/netty-4.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/netty/v4_0/server/HttpServerBlockingRequestHandler.java b/instrumentation/netty/netty-4.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/netty/v4_0/server/HttpServerBlockingRequestHandler.java
@@ -28,6 +28,7 @@
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.context.Context;
 import io.opentelemetry.javaagent.instrumentation.hypertrace.netty.v4_0.AttributeKeys;
+import io.opentelemetry.javaagent.instrumentation.hypertrace.utils.SpanUtils;
 import java.util.Map;
 import org.hypertrace.agent.filter.FilterRegistry;
 
@@ -50,7 +51,11 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
     if (msg instanceof HttpRequest) {
       Attribute<Map<String, String>> headersAttr = channel.attr(AttributeKeys.REQUEST_HEADERS);
       Map<String, String> headers = headersAttr.getAndRemove();
-      if (headers != null && FilterRegistry.getFilter().evaluateRequestHeaders(span, headers)) {
+      Map<String, String> possiblyMissingAttrs =
+          SpanUtils.getPossiblyMissingSpanAttributesFromURI(((HttpRequest) msg).getUri());
+      if (headers != null
+          && FilterRegistry.getFilter()
+              .evaluateRequestHeaders(span, headers, possiblyMissingAttrs)) {
         forbidden(ctx, (HttpRequest) msg);
         return;
       }
diff --git a/instrumentation/netty/netty-4.1/build.gradle.kts b/instrumentation/netty/netty-4.1/build.gradle.kts
@@ -53,5 +53,6 @@ dependencies {
      testImplementation(testFixtures(project(":testing-common")))
     testImplementation("io.netty:netty-handler:4.1.0.Final")
     testImplementation("org.asynchttpclient:async-http-client:2.1.0")
+    implementation(project(":instrumentation:utils"))
 }
 
diff --git a/instrumentation/netty/netty-4.1/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerBlockingRequestHandler.java b/instrumentation/netty/netty-4.1/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerBlockingRequestHandler.java
@@ -28,6 +28,7 @@
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.context.Context;
 import io.opentelemetry.javaagent.instrumentation.hypertrace.netty.v4_1.AttributeKeys;
+import io.opentelemetry.javaagent.instrumentation.hypertrace.utils.SpanUtils;
 import java.util.Map;
 import org.hypertrace.agent.filter.FilterRegistry;
 
@@ -50,7 +51,12 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
     if (msg instanceof HttpRequest) {
       Attribute<Map<String, String>> headersAttr = channel.attr(AttributeKeys.REQUEST_HEADERS);
       Map<String, String> headers = headersAttr.getAndRemove();
-      if (headers != null && FilterRegistry.getFilter().evaluateRequestHeaders(span, headers)) {
+      Map<String, String> possiblyMissingAttrs =
+          SpanUtils.getPossiblyMissingSpanAttributesFromURI(((HttpRequest) msg).uri());
+
+      if (headers != null
+          && FilterRegistry.getFilter()
+              .evaluateRequestHeaders(span, headers, possiblyMissingAttrs)) {
         forbidden(ctx, (HttpRequest) msg);
         return;
       }
diff --git a/instrumentation/servlet/servlet-3.0/build.gradle.kts b/instrumentation/servlet/servlet-3.0/build.gradle.kts
@@ -46,4 +46,5 @@ dependencies {
     testImplementation("org.eclipse.jetty:jetty-server:8.1.22.v20160922")
     testImplementation("org.eclipse.jetty:jetty-servlet:8.1.22.v20160922")
     testImplementation("io.opentelemetry.instrumentation:opentelemetry-instrumentation-api-semconv:${versions["opentelemetry_semconv"]}")
+    implementation(project(":instrumentation:utils"))
 }
diff --git a/instrumentation/servlet/servlet-3.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/Servlet30AndFilterInstrumentation.java b/instrumentation/servlet/servlet-3.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/Servlet30AndFilterInstrumentation.java
@@ -115,7 +115,11 @@ public static boolean start(
         headers.put(attributeKey.getKey(), headerValue);
       }
 
-      if (FilterRegistry.getFilter().evaluateRequestHeaders(currentSpan, headers)) {
+      Map<String, String> possiblyMissingAttrs =
+          Utils.getPossiblyMissingSpanAttributes(httpRequest);
+
+      if (FilterRegistry.getFilter()
+          .evaluateRequestHeaders(currentSpan, headers, possiblyMissingAttrs)) {
         httpResponse.setStatus(403);
         // skip execution of the user code
         return true;
diff --git a/instrumentation/servlet/servlet-3.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/Utils.java b/instrumentation/servlet/servlet-3.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/Utils.java
@@ -18,6 +18,7 @@
 
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.instrumentation.api.field.VirtualField;
+import io.opentelemetry.javaagent.instrumentation.hypertrace.utils.SpanUtils;
 import java.io.BufferedReader;
 import java.io.PrintWriter;
 import java.io.UnsupportedEncodingException;
@@ -121,4 +122,14 @@ public static void resetRequestBodyBuffers(
       }
     }
   }
+
+  /**
+   * Creates a Map of those attributes that may be missing from the Span.
+   *
+   * @param request
+   * @return
+   */
+  public static Map<String, String> getPossiblyMissingSpanAttributes(HttpServletRequest request) {
+    return SpanUtils.getPossiblyMissingSpanAttributes(request);
+  }
 }
diff --git a/instrumentation/servlet/servlet-3.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/request/Utils.java b/instrumentation/servlet/servlet-3.0/src/main/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/request/Utils.java
@@ -43,11 +43,16 @@ public static ByteBufferSpanPair createRequestByteBufferSpanPair(
     if (contentLength < 0) {
       contentLength = ContentLengthUtils.DEFAULT;
     }
+    Map<String, String> possiblyMissingAttrs =
+        io.opentelemetry.javaagent.instrumentation.hypertrace.servlet.v3_0.nowrapping.Utils
+            .getPossiblyMissingSpanAttributes(httpServletRequest);
+
     return new ByteBufferSpanPair(
         span,
         BoundedBuffersFactory.createStream(contentLength, charset),
         filter::evaluateRequestBody,
-        headers);
+        headers,
+        possiblyMissingAttrs);
   }
 
   public static CharBufferSpanPair createRequestCharBufferSpanPair(
@@ -56,11 +61,15 @@ public static CharBufferSpanPair createRequestCharBufferSpanPair(
     if (contentLength < 0) {
       contentLength = ContentLengthUtils.DEFAULT;
     }
+    Map<String, String> possiblyMissingAttrs =
+        io.opentelemetry.javaagent.instrumentation.hypertrace.servlet.v3_0.nowrapping.Utils
+            .getPossiblyMissingSpanAttributes(httpServletRequest);
     return new CharBufferSpanPair(
         span,
         BoundedBuffersFactory.createWriter(contentLength),
         filter::evaluateRequestBody,
-        headers);
+        headers,
+        possiblyMissingAttrs);
   }
 
   /**
diff --git a/instrumentation/servlet/servlet-3.0/src/test/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/request/ServletInputStreamInstrumentationTest.java b/instrumentation/servlet/servlet-3.0/src/test/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/v3_0/nowrapping/request/ServletInputStreamInstrumentationTest.java
@@ -25,7 +25,7 @@
 import javax.servlet.ServletInputStream;
 import org.ServletStreamContextAccess;
 import org.TestServletInputStream;
-import org.hypertrace.agent.core.TriFunction;
+import org.hypertrace.agent.core.QuadFunction;
 import org.hypertrace.agent.core.instrumentation.buffer.BoundedBuffersFactory;
 import org.hypertrace.agent.core.instrumentation.buffer.BoundedByteArrayOutputStream;
 import org.hypertrace.agent.core.instrumentation.buffer.ByteBufferSpanPair;
@@ -48,7 +48,8 @@ public void read() throws IOException {
     BoundedByteArrayOutputStream buffer =
         BoundedBuffersFactory.createStream(StandardCharsets.UTF_8);
     ByteBufferSpanPair bufferSpanPair =
-        new ByteBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new ByteBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
     ServletStreamContextAccess.addToInputStreamContext(servletInputStream, bufferSpanPair);
 
     while (servletInputStream.read() != -1) {}
@@ -66,7 +67,8 @@ public void read_callDepth_is_cleared() throws IOException {
     BoundedByteArrayOutputStream buffer =
         BoundedBuffersFactory.createStream(StandardCharsets.UTF_8);
     ByteBufferSpanPair bufferSpanPair =
-        new ByteBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new ByteBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
     ServletStreamContextAccess.addToInputStreamContext(servletInputStream, bufferSpanPair);
 
     while (servletInputStream.read() != -1) {}
@@ -84,13 +86,14 @@ public void read_call_depth_read_calls_read() throws IOException {
     BoundedByteArrayOutputStream buffer =
         BoundedBuffersFactory.createStream(StandardCharsets.UTF_8);
     ByteBufferSpanPair bufferSpanPair =
-        new ByteBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new ByteBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
     ServletStreamContextAccess.addToInputStreamContext(servletInputStream, bufferSpanPair);
 
     servletInputStream.read(new byte[BODY.length()]);
     Assertions.assertEquals(BODY.substring(2), buffer.toStringWithSuppliedCharset());
   }
 
-  private static final TriFunction<Span, String, Map<String, String>, Boolean> NOOP_FILTER =
-      (span, body, headers) -> false;
+  private static final QuadFunction<Span, String, Map<String, String>, Map<String, String>, Boolean>
+      NOOP_FILTER = (span, body, headers, missingAttrs) -> false;
 }
diff --git a/instrumentation/servlet/servlet-rw/src/test/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/rw/reader/BufferedReaderInstrumentationTest.java b/instrumentation/servlet/servlet-rw/src/test/java/io/opentelemetry/javaagent/instrumentation/hypertrace/servlet/rw/reader/BufferedReaderInstrumentationTest.java
@@ -24,7 +24,7 @@
 import java.util.Map;
 import org.BufferedReaderPrintWriterContextAccess;
 import org.TestBufferedReader;
-import org.hypertrace.agent.core.TriFunction;
+import org.hypertrace.agent.core.QuadFunction;
 import org.hypertrace.agent.core.instrumentation.buffer.*;
 import org.hypertrace.agent.testing.AbstractInstrumenterTest;
 import org.junit.jupiter.api.Assertions;
@@ -34,8 +34,8 @@ public class BufferedReaderInstrumentationTest extends AbstractInstrumenterTest
 
   private static final String TEST_SPAN_NAME = "foo";
   private static final String BODY = "boobar";
-  private static final TriFunction<Span, String, Map<String, String>, Boolean> NOOP_FILTER =
-      (span, s, stringStringMap) -> false;
+  private static final QuadFunction<Span, String, Map<String, String>, Map<String, String>, Boolean>
+      NOOP_FILTER = (span, s, stringStringMap, missingAttrMap) -> false;
 
   @Test
   public void read() throws IOException {
@@ -45,7 +45,8 @@ public void read() throws IOException {
 
     BoundedCharArrayWriter buffer = BoundedBuffersFactory.createWriter();
     CharBufferSpanPair bufferSpanPair =
-        new CharBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new CharBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
 
     BufferedReaderPrintWriterContextAccess.addToBufferedReaderContext(
         bufferedReader, bufferSpanPair);
@@ -63,7 +64,8 @@ public void read_callDepth_isCleared() throws IOException {
 
     BoundedCharArrayWriter buffer = BoundedBuffersFactory.createWriter();
     CharBufferSpanPair bufferSpanPair =
-        new CharBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new CharBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
 
     BufferedReaderPrintWriterContextAccess.addToBufferedReaderContext(
         bufferedReader, bufferSpanPair);
@@ -80,7 +82,8 @@ public void read_char_arr() throws IOException {
 
     BoundedCharArrayWriter buffer = BoundedBuffersFactory.createWriter();
     CharBufferSpanPair bufferSpanPair =
-        new CharBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new CharBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
 
     BufferedReaderPrintWriterContextAccess.addToBufferedReaderContext(
         bufferedReader, bufferSpanPair);
@@ -98,7 +101,8 @@ public void read_callDepth_char_arr() throws IOException {
 
     BoundedCharArrayWriter buffer = BoundedBuffersFactory.createWriter();
     CharBufferSpanPair bufferSpanPair =
-        new CharBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new CharBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
 
     BufferedReaderPrintWriterContextAccess.addToBufferedReaderContext(
         bufferedReader, bufferSpanPair);
@@ -115,7 +119,8 @@ public void read_char_arr_offset() throws IOException {
 
     BoundedCharArrayWriter buffer = BoundedBuffersFactory.createWriter();
     CharBufferSpanPair bufferSpanPair =
-        new CharBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new CharBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
 
     BufferedReaderPrintWriterContextAccess.addToBufferedReaderContext(
         bufferedReader, bufferSpanPair);
@@ -134,7 +139,8 @@ public void readLine() throws IOException {
 
     BoundedCharArrayWriter buffer = BoundedBuffersFactory.createWriter();
     CharBufferSpanPair bufferSpanPair =
-        new CharBufferSpanPair(span, buffer, NOOP_FILTER, Collections.emptyMap());
+        new CharBufferSpanPair(
+            span, buffer, NOOP_FILTER, Collections.emptyMap(), Collections.emptyMap());
 
     BufferedReaderPrintWriterContextAccess.addToBufferedReaderContext(
         bufferedReader, bufferSpanPair);
diff --git a/javaagent-core/src/main/java/org/hypertrace/agent/core/instrumentation/buffer/ByteBufferSpanPair.java b/javaagent-core/src/main/java/org/hypertrace/agent/core/instrumentation/buffer/ByteBufferSpanPair.java
diff --git a/javaagent-core/src/main/java/org/hypertrace/agent/core/instrumentation/buffer/CharBufferSpanPair.java b/javaagent-core/src/main/java/org/hypertrace/agent/core/instrumentation/buffer/CharBufferSpanPair.java
diff --git a/settings.gradle.kts b/settings.gradle.kts

Original file line number	Diff line number	Diff line change
`@@ -35,5 +35,6 @@ dependencies {`
`35`	`35`	`testImplementation("io.opentelemetry.instrumentation:opentelemetry-instrumentation-api-semconv:${versions["opentelemetry_semconv"]}")`
`36`	`36`	`library("org.apache.httpcomponents:httpasyncclient:4.1")`
`37`	`37`	`testImplementation(testFixtures(project(":testing-common")))`
	`38`	`+ implementation(project(":instrumentation:utils"))`
`38`	`39`	`}`
`39`	`40`
Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,7 @@ dependencies{`
`19`	`19`	`implementation(project(":instrumentation:undertow:undertow-1.4"))`
`20`	`20`	`implementation(project(":instrumentation:undertow:undertow-servlet-1.4"))`
`21`	`21`	`implementation(project(":instrumentation:vertx:vertx-web-3.0"))`
	`22`	`+ implementation(project(":instrumentation:utils"))`
`22`	`23`	`implementation(project(":otel-extensions"))`
`23`	`24`	`}`
`24`	`25`
Original file line number	Diff line number	Diff line change
`@@ -88,5 +88,6 @@ dependencies {`
`88`	`88`
`89`	`89`	`testImplementation(testFixtures(project(":testing-common")))`
`90`	`90`	`testImplementation("org.asynchttpclient:async-http-client:2.0.9")`
	`91`	`+ implementation(project(":instrumentation:utils"))`
`91`	`92`	`}`
`92`	`93`
Original file line number	Diff line number	Diff line change
`@@ -53,5 +53,6 @@ dependencies {`
`53`	`53`	`testImplementation(testFixtures(project(":testing-common")))`
`54`	`54`	`testImplementation("io.netty:netty-handler:4.1.0.Final")`
`55`	`55`	`testImplementation("org.asynchttpclient:async-http-client:2.1.0")`
	`56`	`+ implementation(project(":instrumentation:utils"))`
`56`	`57`	`}`
`57`	`58`
Original file line number	Diff line number	Diff line change
`@@ -46,4 +46,5 @@ dependencies {`
`46`	`46`	`testImplementation("org.eclipse.jetty:jetty-server:8.1.22.v20160922")`
`47`	`47`	`testImplementation("org.eclipse.jetty:jetty-servlet:8.1.22.v20160922")`
`48`	`48`	`testImplementation("io.opentelemetry.instrumentation:opentelemetry-instrumentation-api-semconv:${versions["opentelemetry_semconv"]}")`
	`49`	`+ implementation(project(":instrumentation:utils"))`
`49`	`50`	`}`
Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@`
`18`	`18`
`19`	`19`	`import io.opentelemetry.api.trace.Span;`
`20`	`20`	`import io.opentelemetry.instrumentation.api.field.VirtualField;`
	`21`	`+import io.opentelemetry.javaagent.instrumentation.hypertrace.utils.SpanUtils;`
`21`	`22`	`import java.io.BufferedReader;`
`22`	`23`	`import java.io.PrintWriter;`
`23`	`24`	`import java.io.UnsupportedEncodingException;`
`@@ -121,4 +122,14 @@ public static void resetRequestBodyBuffers(`
`121`	`122`	`}`
`122`	`123`	`}`
`123`	`124`	`}`
	`125`	`+`
	`126`	`+ /**`
	`127`	`+ * Creates a Map of those attributes that may be missing from the Span.`
	`128`	`+ *`
	`129`	`+ * @param request`
	`130`	`+ * @return`
	`131`	`+ */`
	`132`	`+ public static Map<String, String> getPossiblyMissingSpanAttributes(HttpServletRequest request) {`
	`133`	`+ return SpanUtils.getPossiblyMissingSpanAttributes(request);`
	`134`	`+ }`
`124`	`135`	`}`