mirror of
https://github.com/wahyd4/pinpoint.git
synced 2026-08-17 16:56:15 +10:00
[#17] recovery fail test
This commit is contained in:
@@ -9,7 +9,6 @@ import java.util.List;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.test.context.ContextConfiguration;
|
||||
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
||||
|
||||
@@ -30,8 +29,7 @@ public class ProcessorTest {
|
||||
|
||||
private static final String SERVICE_NAME = "local_tomcat";
|
||||
|
||||
@Autowired
|
||||
AlarmProcessor processor;
|
||||
AlarmProcessor processor = new AlarmProcessor();
|
||||
|
||||
private static MapResponseDao mockMapResponseDAO;
|
||||
|
||||
|
||||
@@ -14,7 +14,6 @@ import org.springframework.batch.core.StepExecution;
|
||||
import org.springframework.batch.item.ExecutionContext;
|
||||
|
||||
import com.nhn.pinpoint.common.ServiceType;
|
||||
import com.nhn.pinpoint.web.alarm.DataCollectorFactory.DataCollectorCategory;
|
||||
import com.nhn.pinpoint.web.alarm.collector.DataCollector;
|
||||
import com.nhn.pinpoint.web.alarm.collector.ResponseTimeDataCollector;
|
||||
import com.nhn.pinpoint.web.alarm.vo.Rule;
|
||||
|
||||
@@ -9,8 +9,8 @@ import org.junit.BeforeClass;
|
||||
import org.junit.Test;
|
||||
|
||||
import com.nhn.pinpoint.common.ServiceType;
|
||||
import com.nhn.pinpoint.common.bo.AgentStatCpuLoadBo;
|
||||
import com.nhn.pinpoint.common.bo.AgentStatMemoryGcBo;
|
||||
import com.nhn.pinpoint.common.bo.AgentStatMemoryGcBo.Builder;
|
||||
import com.nhn.pinpoint.web.alarm.CheckerCategory;
|
||||
import com.nhn.pinpoint.web.alarm.DataCollectorFactory;
|
||||
import com.nhn.pinpoint.web.alarm.DataCollectorFactory.DataCollectorCategory;
|
||||
@@ -41,13 +41,16 @@ public class GcCountCheckerTest {
|
||||
public List<AgentStat> scanAgentStatList(String agentId, Range range) {
|
||||
List<AgentStat> AgentStatList = new LinkedList<AgentStat>();
|
||||
|
||||
for (int i = 1; i < 37; i++) {
|
||||
Builder builder = new Builder("AGETNT_NAME", 0L, 1L);
|
||||
builder.jvmGcOldCount(i);
|
||||
AgentStatMemoryGcBo memoryBo = builder.build();
|
||||
for (int i = 36; i > 0; i--) {
|
||||
AgentStatMemoryGcBo.Builder memoryBuilder = new AgentStatMemoryGcBo.Builder("AGETNT_NAME", 0L, 1L);
|
||||
memoryBuilder.jvmGcOldCount(i);
|
||||
AgentStatMemoryGcBo memoryBo = memoryBuilder.build();
|
||||
AgentStatCpuLoadBo.Builder cpuBuilder = new AgentStatCpuLoadBo.Builder("AGETNT_NAME", 0L, 1L);
|
||||
AgentStatCpuLoadBo cpuLoadBo = cpuBuilder.build();
|
||||
|
||||
AgentStat stat = new AgentStat();
|
||||
stat.setMemoryGc(memoryBo);
|
||||
stat.setCpuLoad(cpuLoadBo);
|
||||
|
||||
AgentStatList.add(stat);
|
||||
}
|
||||
|
||||
+8
-4
@@ -13,6 +13,7 @@ import org.springframework.test.context.ContextConfiguration;
|
||||
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
||||
|
||||
import com.nhn.pinpoint.common.ServiceType;
|
||||
import com.nhn.pinpoint.common.bo.AgentStatCpuLoadBo;
|
||||
import com.nhn.pinpoint.common.bo.AgentStatMemoryGcBo;
|
||||
import com.nhn.pinpoint.common.bo.AgentStatMemoryGcBo.Builder;
|
||||
import com.nhn.pinpoint.web.alarm.CheckerCategory;
|
||||
@@ -47,13 +48,16 @@ public class HeapUsageRateCheckerTest {
|
||||
List<AgentStat> AgentStatList = new LinkedList<AgentStat>();
|
||||
|
||||
for (int i = 0; i < 36; i++) {
|
||||
Builder builder = new Builder("AGETNT_NAME", 0L, 1L);
|
||||
builder.jvmMemoryHeapUsed(70L);
|
||||
builder.jvmMemoryHeapMax(100L);
|
||||
AgentStatMemoryGcBo memoryBo = builder.build();
|
||||
AgentStatMemoryGcBo.Builder memoryBuilder = new AgentStatMemoryGcBo.Builder("AGETNT_NAME", 0L, 1L);
|
||||
memoryBuilder.jvmMemoryHeapUsed(70L);
|
||||
memoryBuilder.jvmMemoryHeapMax(100L);
|
||||
AgentStatMemoryGcBo memoryBo = memoryBuilder.build();
|
||||
AgentStatCpuLoadBo.Builder cpuBuilder = new AgentStatCpuLoadBo.Builder("AGETNT_NAME", 0L, 1L);
|
||||
AgentStatCpuLoadBo cpuLoadBo = cpuBuilder.build();
|
||||
|
||||
AgentStat stat = new AgentStat();
|
||||
stat.setMemoryGc(memoryBo);
|
||||
stat.setCpuLoad(cpuLoadBo);
|
||||
|
||||
AgentStatList.add(stat);
|
||||
}
|
||||
|
||||
+1
-1
@@ -42,7 +42,7 @@ public class JvmCpuUsageRateCheckerTest {
|
||||
|
||||
for (int i = 0; i < 36; i++) {
|
||||
AgentStatCpuLoadBo.Builder cpuLoadBoBuilder = new AgentStatCpuLoadBo.Builder("AGETNT_NAME", 0L, 1L);
|
||||
cpuLoadBoBuilder.jvmCpuLoad(60);
|
||||
cpuLoadBoBuilder.jvmCpuLoad(0.6);
|
||||
AgentStatCpuLoadBo cpuLoadBo = cpuLoadBoBuilder.build();
|
||||
|
||||
AgentStatMemoryGcBo.Builder memoryGcBobuilder = new AgentStatMemoryGcBo.Builder("AGETNT_NAME", 0L, 1L);
|
||||
|
||||
-7
@@ -86,11 +86,4 @@ public class ResponseCountCheckerTest {
|
||||
filter.check();
|
||||
assertFalse(filter.isDetected());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void test() {
|
||||
double val = -1;
|
||||
int i = (int) val;
|
||||
System.out.println(val);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user