Loading oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/ServiceMeshMetricDataDecorator.java +10 −8 Original line number Diff line number Diff line Loading @@ -85,22 +85,24 @@ public class ServiceMeshMetricDataDecorator { } } String endpoint = origin.getEndpoint(); if (destServiceId != Const.NONE) { DetectPoint point = origin.getDetectPoint(); DetectPoint point = origin.getDetectPoint(); if (DetectPoint.client.equals(point)) { if (sourceServiceId != Const.NONE) { endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(sourceServiceId, endpoint, org.apache.skywalking.oap.server.core.source.DetectPoint.fromMeshDetectPoint(point)); } } else { if (destServiceId != Const.NONE) { endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(destServiceId, endpoint, org.apache.skywalking.oap.server.core.source.DetectPoint.fromMeshDetectPoint(point)); } } if (endpointId != Const.NONE) { } else { isRegistered = false; } } return isRegistered; } Loading Loading
oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/ServiceMeshMetricDataDecorator.java +10 −8 Original line number Diff line number Diff line Loading @@ -85,22 +85,24 @@ public class ServiceMeshMetricDataDecorator { } } String endpoint = origin.getEndpoint(); if (destServiceId != Const.NONE) { DetectPoint point = origin.getDetectPoint(); DetectPoint point = origin.getDetectPoint(); if (DetectPoint.client.equals(point)) { if (sourceServiceId != Const.NONE) { endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(sourceServiceId, endpoint, org.apache.skywalking.oap.server.core.source.DetectPoint.fromMeshDetectPoint(point)); } } else { if (destServiceId != Const.NONE) { endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(destServiceId, endpoint, org.apache.skywalking.oap.server.core.source.DetectPoint.fromMeshDetectPoint(point)); } } if (endpointId != Const.NONE) { } else { isRegistered = false; } } return isRegistered; } Loading