[강운덕] [LUCYSUS-1744] profiler에서 수집 데이터를 일정량 모아서 한번에 flush하는 로직 개발.

git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@1035 84d0f5b1-2673-498c-a247-62c4ff18d310
2026-08-22 03:06:26 +10:00 · 2012-12-18 05:58:37 +00:00
parent ce0678d070
commit 75480a22ac
10 changed files with 450 additions and 185 deletions
@@ -0,0 +1,68 @@
+package com.profiler.context;
+
+import com.profiler.Agent;
+import org.apache.thrift.TBase;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.UUID;
+
+/**
+ *
+ */
+public class SubSpanList implements Thriftable {
+
+    private List<SubSpan> subSpanList = new ArrayList<SubSpan>();
+
+    public SubSpanList(List<SubSpan> subSpanList) {
+        this.subSpanList = subSpanList;
+    }
+
+    @Override
+    public TBase toThrift() {
+        com.profiler.common.dto.thrift.SubSpanList tSubSpanList = new com.profiler.common.dto.thrift.SubSpanList();
+        // TODO 반드시 1개 이상이라는 조건을 충족해야 된다.
+        SubSpan first = subSpanList.get(0);
+        Span parentSpan = first.getParentSpan();
+        tSubSpanList.setAgentId(Agent.getInstance().getAgentId());
+        UUID id = parentSpan.getTraceID().getId();
+        tSubSpanList.setMostTraceId(id.getMostSignificantBits());
+        tSubSpanList.setMostTraceId(id.getLeastSignificantBits());
+        tSubSpanList.setSpanId(parentSpan.getTraceID().getSpanId());
+        tSubSpanList.setStartSequence(first.getSequence());
+
+        List<com.profiler.common.dto.thrift.SubSpan> tSubSpan = createSubSpan(subSpanList);
+
+        tSubSpanList.setSubSpanList(tSubSpan);
+
+        return tSubSpanList;
+    }
+
+    private List<com.profiler.common.dto.thrift.SubSpan> createSubSpan(List<SubSpan> subSpanList) {
+        List<com.profiler.common.dto.thrift.SubSpan> result = new ArrayList<com.profiler.common.dto.thrift.SubSpan>(subSpanList.size());
+        for (SubSpan subSpan : subSpanList) {
+            com.profiler.common.dto.thrift.SubSpan tSubSpan = new com.profiler.common.dto.thrift.SubSpan();
+
+            tSubSpan.setAgentId(Agent.getInstance().getAgentId());
+
+            long parentSpanStartTime = subSpan.getStartTime();
+            tSubSpan.setStartElapsed((int) (subSpan.getStartTime() - parentSpanStartTime));
+            tSubSpan.setEndElapsed((int) (subSpan.getEndTime() - subSpan.getStartTime()));
+
+            tSubSpan.setRpc(subSpan.getRpc());
+            tSubSpan.setServiceName(subSpan.getServiceName());
+            tSubSpan.setServiceType(subSpan.getServiceType().getCode());
+
+            tSubSpan.setEndPoint(subSpan.getEndPoint());
+
+            // 여기서 데이터 인코딩을 하자.
+            List<com.profiler.common.dto.thrift.Annotation> annotationList = new ArrayList<com.profiler.common.dto.thrift.Annotation>(subSpan.getAnnotationSize());
+            for (HippoAnnotation a : subSpan.getAnnotations()) {
+                annotationList.add(a.toThrift());
+            }
+            tSubSpan.setAnnotations(annotationList);
+            result.add(tSubSpan);
+        }
+        return result;
+    }
+}