ProcessCostTimeFilter.java

package com.a.eye.skywalking.analysis.chainbuild.filter.impl;

import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;

public class ProcessCostTimeFilter extends SpanNodeProcessFilter {
	@Override
	public void doFilter(SpanEntry spanEntry, ChainNode node, SubLevelSpanCostCounter costMap) {
		node.setCost(spanEntry.getCost());
		
		this.saveCostAsSubNodeCost(spanEntry, node, costMap);
		this.computeChainNodeCost(costMap, node);

		this.doNext(spanEntry, node, costMap);
	}

	private void saveCostAsSubNodeCost(SpanEntry spanEntry, ChainNode node,
			SubLevelSpanCostCounter costMap) {
		long subNodeCost = spanEntry.getCost();
		if (costMap.exists(spanEntry.getParentLevelId())) {
			subNodeCost += costMap.get(spanEntry.getParentLevelId());
		}

		costMap.put(spanEntry.getParentLevelId(), subNodeCost);
	}

	private void computeChainNodeCost(SubLevelSpanCostCounter costMap, ChainNode node) {
		String levelId = node.getParentLevelId();
		if (levelId != null && levelId.length() > 0) {
			levelId += ".";
		}
		levelId += node.getLevelId() + "";

		if (costMap.exists(levelId)) {
			node.setCost(node.getCost() - costMap.get(levelId));
		}
	}
}