diff --git a/.travis.yml b/.travis.yml index bd48465a7..88795829f 100644 --- a/.travis.yml +++ b/.travis.yml @@ -4,6 +4,8 @@ language: java install: - jdk_switcher use oraclejdk8 - - ./mvnw clean install --quiet jacoco:report coveralls:report - - ./mvnw clean javadoc:javadoc -Dmaven.test.skip=true --quiet + - ./mvnw clean install --quiet + - ./mvnw javadoc:javadoc -Dmaven.test.skip=true --quiet +after_success: +- ./mvnw clean test jacoco:report coveralls:report --quiet diff --git a/apm-checkstyle/pom.xml b/apm-checkstyle/pom.xml index bf6ef229c..90154638c 100644 --- a/apm-checkstyle/pom.xml +++ b/apm-checkstyle/pom.xml @@ -27,41 +27,7 @@ org.apache.skywalking apm-checkstyle - 6.0.0-beta + 6.1.0 Module to hold Checkstyle for SkyWalking. - - 0.7.9 - 4.1.0 - - - - - - - org.jacoco - jacoco-maven-plugin - ${jacoco-maven-plugin.version} - - - prepare-agent - - prepare-agent - - - - - - org.eluder.coveralls - coveralls-maven-plugin - ${coveralls-maven-plugin.version} - - xFwR2GqmxcMxV7tGEpW2NfwIrbCD4cQCS - - ${project.build.sourceDirectory} - - - - - diff --git a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/listener/endpoint/MultiScopesSpanListener.java b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/listener/endpoint/MultiScopesSpanListener.java index 0330e775a..55f095989 100644 --- a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/listener/endpoint/MultiScopesSpanListener.java +++ b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/listener/endpoint/MultiScopesSpanListener.java @@ -20,7 +20,7 @@ package org.apache.skywalking.oap.server.receiver.trace.provider.parser.listener import java.util.*; import org.apache.skywalking.apm.network.common.KeyStringValuePair; -import org.apache.skywalking.apm.network.language.agent.SpanLayer; +import org.apache.skywalking.apm.network.language.agent.*; import org.apache.skywalking.oap.server.core.*; import org.apache.skywalking.oap.server.core.cache.*; import org.apache.skywalking.oap.server.core.source.*; @@ -43,7 +43,7 @@ import static java.util.Objects.nonNull; * * @author peng-yongsheng, wusheng */ -public class MultiScopesSpanListener implements EntrySpanListener, ExitSpanListener { +public class MultiScopesSpanListener implements EntrySpanListener, ExitSpanListener, GlobalTraceIdsListener { private static final Logger logger = LoggerFactory.getLogger(MultiScopesSpanListener.class); @@ -58,6 +58,7 @@ public class MultiScopesSpanListener implements EntrySpanListener, ExitSpanListe private final TraceServiceModuleConfig config; private SpanDecorator entrySpanDecorator; private long minuteTimeBucket; + private String traceId; private MultiScopesSpanListener(ModuleManager moduleManager, TraceServiceModuleConfig config) { this.sourceReceiver = moduleManager.find(CoreModule.NAME).provider().getService(SourceReceiver.class); @@ -68,10 +69,11 @@ public class MultiScopesSpanListener implements EntrySpanListener, ExitSpanListe this.serviceInventoryCache = moduleManager.find(CoreModule.NAME).provider().getService(ServiceInventoryCache.class); this.endpointInventoryCache = moduleManager.find(CoreModule.NAME).provider().getService(EndpointInventoryCache.class); this.config = config; + this.traceId = null; } @Override public boolean containsPoint(Point point) { - return Point.Entry.equals(point) || Point.Exit.equals(point); + return Point.Entry.equals(point) || Point.Exit.equals(point) || Point.TraceIds.equals(point); } @Override @@ -156,7 +158,7 @@ public class MultiScopesSpanListener implements EntrySpanListener, ExitSpanListe statement.setDatabaseServiceId(sourceBuilder.getDestServiceId()); statement.setLatency(sourceBuilder.getLatency()); statement.setTimeBucket(TimeBucketUtils.INSTANCE.getSecondTimeBucket(segmentCoreInfo.getStartTime())); - statement.setTraceId(segmentCoreInfo.getSegmentId()); + statement.setTraceId(traceId); for (KeyStringValuePair tag : spanDecorator.getAllTags()) { if (SpanTags.DB_STATEMENT.equals(tag.getKey())) { statement.setStatement(tag.getValue()); @@ -242,6 +244,20 @@ public class MultiScopesSpanListener implements EntrySpanListener, ExitSpanListe slowDatabaseAccesses.forEach(sourceReceiver::receive); } + @Override public void parseGlobalTraceId(UniqueId uniqueId, SegmentCoreInfo segmentCoreInfo) { + if (traceId == null) { + StringBuilder traceIdBuilder = new StringBuilder(); + for (int i = 0; i < uniqueId.getIdPartsList().size(); i++) { + if (i == 0) { + traceIdBuilder.append(uniqueId.getIdPartsList().get(i)); + } else { + traceIdBuilder.append(".").append(uniqueId.getIdPartsList().get(i)); + } + } + traceId = traceIdBuilder.toString(); + } + } + public static class Factory implements SpanListenerFactory { @Override diff --git a/pom.xml b/pom.xml index 8f87c44ed..f9ff4fb93 100644 --- a/pom.xml +++ b/pom.xml @@ -133,8 +133,8 @@ 3.0.1 2.5 4.3.0 - 0.8.1 3.0.0 + 0.8.3 @@ -384,21 +384,16 @@ coveralls-maven-plugin ${coveralls-maven-plugin.version} + xFwR2GqmxcMxV7tGEpW2NfwIrbCD4cQCS ${project.build.sourceDirectory} - org.jacoco jacoco-maven-plugin ${jacoco-maven-plugin.version} - - - *MethodAccess - - prepare-agent