home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-19 17:56:41 +10:00
Code Issues Packages Projects Releases Wiki Activity

[강운덕] [LUCYSUS-1744] 개별 transactionId를 1개의 binary로 묶음. 버전 필드를 추가하여 향후 변경될 경우 별도 처리가 가능하도록 함.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-web/trunk@2554 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Woonduk Kang
2013-10-18 07:09:55 +00:00
parent 1fddf27349
commit 88241cd56f
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/com/nhn/pinpoint/web/service/SpanServiceTest.java
+11 -8
View File
@@ -9,6 +9,7 @@ import java.util.concurrent.atomic.AtomicInteger;
import com.nhn.pinpoint.collector.dao.TracesDao;
import com.nhn.pinpoint.common.util.TransactionIdUtils;
import com.nhn.pinpoint.thrift.dto.TAnnotation;
import com.nhn.pinpoint.thrift.dto.TAnnotationValue;
import com.nhn.pinpoint.thrift.dto.TSpan;
@@ -55,7 +56,8 @@ public class SpanServiceTest {
@Before
public void before() throws TException {
TSpan span = createRootSpan();
logger.debug("id:{}", new TransactionId(span.getTraceAgentId(), span.getTraceAgentStartTime(), span.getTraceTransactionSequence()));
com.nhn.pinpoint.common.util.TransactionId id = TransactionIdUtils.parseTransactionId(span.getTransactionId());
logger.debug("id:{}", new TransactionId(id.getAgentId(), id.getAgentStartTime(), id.getTransactionSequence()));
insert(span);
deleteSpans.add(span);
@@ -104,7 +106,8 @@ public class SpanServiceTest {
}
private void doRead(TSpan span) {
TransactionId traceId = new TransactionId(span.getTraceAgentId(), span.getTraceAgentStartTime(), span.getTraceTransactionSequence());
com.nhn.pinpoint.common.util.TransactionId id = TransactionIdUtils.parseTransactionId(span.getTransactionId());
TransactionId traceId = new TransactionId(id.getAgentId(), id.getAgentStartTime(), id.getTransactionSequence());
List<SpanAlign> sort = spanService.selectSpan(traceId);
for (SpanAlign spanAlign : sort) {
@@ -130,9 +133,9 @@ public class SpanServiceTest {
span.setAgentId("UnitTest");
span.setApplicationName("ApplicationId");
span.setTraceAgentId("traceAgentId");
span.setTraceAgentStartTime(System.currentTimeMillis());
span.setTraceTransactionSequence(0);
byte[] bytes = TransactionIdUtils.formatBytes("traceAgentId", System.currentTimeMillis(), 0);
span.setTransactionId(bytes);
span.setStartTime(time);
span.setElapsed(5);
span.setRpc("RPC");
@@ -159,9 +162,9 @@ public class SpanServiceTest {
sub.setAgentId("UnitTest");
sub.setApplicationName("ApplicationId");
sub.setAgentStartTime(123);
sub.setTraceAgentId(span.getTraceAgentId());
sub.setTraceAgentStartTime(span.getTraceAgentStartTime());
sub.setTraceTransactionSequence(span.getTraceTransactionSequence());
sub.setTransactionId(span.getTransactionId());
sub.setStartTime(time);
sub.setElapsed(5);
sub.setRpc("RPC");