kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Check sampling mechanism.

This commit is contained in:
wusheng 2017-03-22 16:51:56 +08:00
parent 680c2c2337
commit fa81a0f6ba
3 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/sampling/SamplingService.java
View File

@ -40,6 +40,7 @@ public class SamplingService implements BootService {
if (on) {
if (rollingSeed % Config.Agent.SAMPLING_CYCLE != 0) {
segment.setSampled(false);
this.rollingSeed = 1;
}
rollingSeed++;
}

1
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/context/TracerContextTestCase.java
View File

@ -5,6 +5,7 @@ import com.a.eye.skywalking.trace.TraceId.DistributedTraceId;
import com.a.eye.skywalking.trace.TraceId.PropagatedTraceId;
import com.a.eye.skywalking.trace.TraceSegment;
import com.a.eye.skywalking.trace.tag.Tags;
import java.awt.SystemTray;
import java.util.LinkedList;
import java.util.List;
import org.junit.After;

4
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/sampling/SamplingServiceTest.java
View File

@ -26,6 +26,10 @@ public class SamplingServiceTest {
segment = new TraceSegment();
service.trySampling(segment);
Assert.assertTrue(segment.isSampled());
segment = new TraceSegment();
service.trySampling(segment);
Assert.assertFalse(segment.isSampled());
}
@AfterClass