From ad0042f6f5a529f646d0286e7cef4d7ca8d81ef9 Mon Sep 17 00:00:00 2001 From: kezhenxu94 Date: Thu, 19 Aug 2021 06:12:05 +0800 Subject: [PATCH] Add missing property set for new field `httpResponseStatusCode` (#7486) Follow up https://github.com/apache/skywalking/pull/7271 --- .../aop/server/receiver/mesh/TelemetryDataDispatcher.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java index 9af5fac86..77e1bd7e3 100644 --- a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java +++ b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java @@ -131,6 +131,7 @@ public class TelemetryDataDispatcher { all.setLatency(metrics.getLatency()); all.setStatus(metrics.getStatus()); all.setResponseCode(metrics.getResponseCode()); + all.setHttpResponseStatusCode(metrics.getResponseCode()); all.setType(protocol2Type(metrics.getProtocol())); SOURCE_RECEIVER.receive(all); @@ -146,6 +147,7 @@ public class TelemetryDataDispatcher { service.setLatency(metrics.getLatency()); service.setStatus(metrics.getStatus()); service.setResponseCode(metrics.getResponseCode()); + service.setHttpResponseStatusCode(metrics.getResponseCode()); service.setType(protocol2Type(metrics.getProtocol())); service.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode()); service.getTcpInfo().setReceivedBytes(metrics.getTcp().getReceivedBytes()); @@ -168,6 +170,7 @@ public class TelemetryDataDispatcher { serviceRelation.setStatus(metrics.getStatus()); serviceRelation.setType(protocol2Type(metrics.getProtocol())); serviceRelation.setResponseCode(metrics.getResponseCode()); + serviceRelation.setHttpResponseStatusCode(metrics.getResponseCode()); serviceRelation.setDetectPoint(detectPointMapping(metrics.getDetectPoint())); serviceRelation.setComponentId(protocol2Component(metrics.getProtocol())); serviceRelation.setTlsMode(metrics.getTlsMode()); @@ -188,6 +191,7 @@ public class TelemetryDataDispatcher { serviceInstance.setLatency(metrics.getLatency()); serviceInstance.setStatus(metrics.getStatus()); serviceInstance.setResponseCode(metrics.getResponseCode()); + serviceInstance.setHttpResponseStatusCode(metrics.getResponseCode()); serviceInstance.setType(protocol2Type(metrics.getProtocol())); serviceInstance.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode()); serviceInstance.getTcpInfo().setReceivedBytes(metrics.getTcp().getReceivedBytes()); @@ -210,6 +214,7 @@ public class TelemetryDataDispatcher { serviceRelation.setStatus(metrics.getStatus()); serviceRelation.setType(protocol2Type(metrics.getProtocol())); serviceRelation.setResponseCode(metrics.getResponseCode()); + serviceRelation.setHttpResponseStatusCode(metrics.getResponseCode()); serviceRelation.setDetectPoint(detectPointMapping(metrics.getDetectPoint())); serviceRelation.setComponentId(protocol2Component(metrics.getProtocol())); serviceRelation.setTlsMode(metrics.getTlsMode()); @@ -230,6 +235,7 @@ public class TelemetryDataDispatcher { endpoint.setLatency(metrics.getLatency()); endpoint.setStatus(metrics.getStatus()); endpoint.setResponseCode(metrics.getResponseCode()); + endpoint.setHttpResponseStatusCode(metrics.getResponseCode()); endpoint.setType(protocol2Type(metrics.getProtocol())); endpoint.getSideCar().setInternalErrorCode(metrics.getInternalErrorCode());