From 7ce2ac5abdfeac1a6033c89ee0cc8edd434a998e Mon Sep 17 00:00:00 2001 From: peng-yongsheng <8082209@qq.com> Date: Tue, 27 Feb 2018 14:29:58 +0800 Subject: [PATCH] Set call type on line, but when source is USER then return empty string. --- .../collector/ui/service/TopologyBuilder.java | 31 +++++-------------- 1 file changed, 7 insertions(+), 24 deletions(-) diff --git a/apm-collector/apm-collector-ui/collector-ui-jetty-provider/src/main/java/org/apache/skywalking/apm/collector/ui/service/TopologyBuilder.java b/apm-collector/apm-collector-ui/collector-ui-jetty-provider/src/main/java/org/apache/skywalking/apm/collector/ui/service/TopologyBuilder.java index 0161d127b..2ac8e3d72 100644 --- a/apm-collector/apm-collector-ui/collector-ui-jetty-provider/src/main/java/org/apache/skywalking/apm/collector/ui/service/TopologyBuilder.java +++ b/apm-collector/apm-collector-ui/collector-ui-jetty-provider/src/main/java/org/apache/skywalking/apm/collector/ui/service/TopologyBuilder.java @@ -19,11 +19,9 @@ package org.apache.skywalking.apm.collector.ui.service; import java.util.HashMap; -import java.util.HashSet; import java.util.LinkedList; import java.util.List; import java.util.Map; -import java.util.Set; import org.apache.skywalking.apm.collector.cache.CacheModule; import org.apache.skywalking.apm.collector.cache.service.ApplicationCacheService; import org.apache.skywalking.apm.collector.core.module.ModuleManager; @@ -104,7 +102,7 @@ class TopologyBuilder { call.setTarget(actualTargetId); call.setTargetName(applicationCacheService.getApplicationById(actualTargetId).getApplicationCode()); call.setAlert(true); - call.setCallType("aaa"); + call.setCallType(components.get(referenceMetric.getTarget())); call.setCallsPerSec(1); call.setResponseTimePerSec(1); calls.add(call); @@ -136,7 +134,12 @@ class TopologyBuilder { call.setTarget(target.getApplicationId()); call.setTargetName(target.getApplicationCode()); call.setAlert(true); - call.setCallType("aaa"); + + if (source.getApplicationId() == Const.NONE_APPLICATION_ID) { + call.setCallType(Const.EMPTY_STRING); + } else { + call.setCallType(components.get(referenceMetric.getTarget())); + } call.setCallsPerSec(1); call.setResponseTimePerSec(1); calls.add(call); @@ -178,24 +181,4 @@ class TopologyBuilder { }); return components; } - - private List buildCalls(List callerCalls, List calleeCalls) { - List calls = new LinkedList<>(); - - Set distinctCalls = new HashSet<>(); - callerCalls.forEach(callerCall -> { - distinctCalls.add(callerCall.getSource() + Const.ID_SPLIT + callerCall.getTarget()); - calls.add(callerCall); - }); - - calleeCalls.forEach(calleeCall -> { - String call = calleeCall.getSource() + Const.ID_SPLIT + calleeCall.getTarget(); - if (!distinctCalls.contains(call)) { - distinctCalls.add(call); - calls.add(calleeCall); - } - }); - - return calls; - } }