kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Endpoint register to client and server side based on detect point. (#1866)

This commit is contained in:
吴晟 Wu Sheng 2018-11-02 12:07:25 +08:00 committed by 彭勇升 pengys
parent 6b1014c336
commit 75e4c67952
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/ServiceMeshMetricDataDecorator.java
View File

@ -88,8 +88,14 @@ public class ServiceMeshMetricDataDecorator {
if (destServiceId != Const.NONE) {
DetectPoint point = origin.getDetectPoint();
endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(destServiceId, endpoint,
org.apache.skywalking.oap.server.core.source.DetectPoint.fromMeshDetectPoint(point));
if (DetectPoint.client.equals(point)) {
endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(sourceServiceId, endpoint,
org.apache.skywalking.oap.server.core.source.DetectPoint.fromMeshDetectPoint(point));
} else {
endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(destServiceId, endpoint,
org.apache.skywalking.oap.server.core.source.DetectPoint.fromMeshDetectPoint(point));
}
if (endpointId != Const.NONE) {
} else {
isRegistered = false;