SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update PayloadUtils.java (#2145)

Browse Source 
fixing #2102 Netty reports LEAK while using reactor (Rsocket) with Sleuth
This commit is contained in:
kevin
2022-04-14 15:57:29 +08:00
committed by GitHub
parent 5767526db1
commit 0267191c46
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/rsocket/PayloadUtils.java
View File

@@ -38,12 +38,12 @@ final class PayloadUtils {
static Payload cleanTracingMetadata(Payload payload, Set<String> fields) {
Set<String> fieldsWithDefaultZipkin = new HashSet<>(fields);
fieldsWithDefaultZipkin.add(WellKnownMimeType.MESSAGE_RSOCKET_TRACING_ZIPKIN.getString());
final CompositeMetadata entries = new CompositeMetadata(payload.metadata(), true);
final CompositeMetadata entries = new CompositeMetadata(payload.metadata(), false);
final CompositeByteBuf metadata = ByteBufAllocator.DEFAULT.compositeBuffer();
for (Entry entry : entries) {
if (!fieldsWithDefaultZipkin.contains(entry.getMimeType())) {
CompositeMetadataCodec.encodeAndAddMetadataWithCompression(metadata, ByteBufAllocator.DEFAULT,
entry.getMimeType(), entry.getContent());
entry.getMimeType(), entry.getContent().retain());
}
}
return payload(payload, metadata);
@@ -53,10 +53,10 @@ final class PayloadUtils {
final Payload newPayload;
try {
if (payload instanceof ByteBufPayload) {
newPayload = ByteBufPayload.create(payload.data().retain(), metadata.retain());
newPayload = ByteBufPayload.create(payload.data().retain(), metadata);
}
else {
newPayload = DefaultPayload.create(payload.data().retain(), metadata.retain());
newPayload = DefaultPayload.create(payload.data().retain(), metadata);
}
}
finally {