home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-09 04:46:06 +10:00
Code Issues Packages Projects Releases Wiki Activity

[#noissue] cleanup testcase log level

Browse Source
This commit is contained in:
emeroad
2017-02-21 14:53:26 +09:00
committed by Woonduk Kang
parent 5bc1d97b1c
commit 7ea9e270e6
27 changed files with 106 additions and 109 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bootstrap-core/src/test/java/com/navercorp/pinpoint/bootstrap/interceptor/WeakAtomicReferenceArrayTest.java
+8 -8
View File
@@ -158,12 +158,12 @@ public class WeakAtomicReferenceArrayTest {
private boolean checkInteger(int findIndex, Integer findResult) {
if (findResult == null) {
logger.info("null find:{} result:{}", findIndex, nextId.get());
logger.debug("null find:{} result:{}", findIndex, nextId.get());
return false;
}
final boolean result = findResult == findIndex;
if (!result) {
logger.info("not equals findResult:{}, findIndex:{}", findResult, findIndex);
logger.debug("not equals findResult:{}, findIndex:{}", findResult, findIndex);
}
return result;
}
@@ -256,7 +256,7 @@ public class WeakAtomicReferenceArrayTest {
final Runnable writeJob = new Runnable() {
@Override
public void run() {
logger.info("WriteJob-start");
logger.debug("WriteJob-start");
int i =0;
while (start.get()) {
@@ -269,7 +269,7 @@ public class WeakAtomicReferenceArrayTest {
}
i++;
}
logger.info("WriteJob-end");
logger.debug("WriteJob-end");
}
};
@@ -277,7 +277,7 @@ public class WeakAtomicReferenceArrayTest {
final Runnable readJob = new Runnable() {
@Override
public void run() {
logger.info("ReaderJob-start");
logger.debug("ReaderJob-start");
while (start.get()) {
AtomicReferenceTest atomicReferenceTest = getTestMock();
@@ -299,7 +299,7 @@ public class WeakAtomicReferenceArrayTest {
// e.printStackTrace();
// }
}
logger.info("ReaderJob-end");
logger.debug("ReaderJob-end");
}
};
@@ -310,10 +310,10 @@ public class WeakAtomicReferenceArrayTest {
writer.execute(writeJob);
}
logger.info("start");
logger.debug("start");
for (int i = 0; i < 100; i++) {
Thread.sleep(1000);
logger.info("failCounter:{}", failCounter.get());
logger.debug("failCounter:{}", failCounter.get());
}
start.set(false);
Thread.sleep(1000);
bootstrap/src/test/java/com/navercorp/pinpoint/bootstrap/AgentClassLoaderTest.java
+1 -1
View File
@@ -56,7 +56,7 @@ public class AgentClassLoaderTest {
CodeSource codeSource = protectionDomain.getCodeSource();
URL location = codeSource.getLocation();
logger.info("lib location:" + location);
logger.debug("lib location:{}", location);
String path = location.getPath();
// file:/D:/nhn_source/pinpoint_project/pinpoint-tomcat-profiler/target/classes/
int dirPath = path.lastIndexOf("target/classes/");
collector/src/test/java/com/navercorp/pinpoint/collector/receiver/udp/NettyUdpReceiverTest.java
+2 -2
View File
@@ -110,10 +110,10 @@ public class NettyUdpReceiverTest {
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
String name = Thread.currentThread().getName();
logger.debug("sleep-------------------{}", name);
logger.debug("sleep:{}", name);
Thread.sleep(10000);
// if (!name.equals("New I/O worker #1")) {
logger.info("messageReceived thread-{} message:", Thread.currentThread().getName());
logger.debug("messageReceived thread-{} message:", Thread.currentThread().getName());
// }
}
});
commons/src/test/java/com/navercorp/pinpoint/common/buffer/AutomaticBufferTest.java
+4 -4
View File
@@ -300,10 +300,10 @@ public class AutomaticBufferTest {
buffer.putShort((short)28704);
Buffer read = new FixedBuffer(buffer.getBuffer());
logger.info("{}", (char)read.readByte());
logger.info("{}", (char)read.readByte());
logger.info("{}", (char)read.readByte());
logger.info("{}", (char)read.readByte());
logger.debug("{}", (char)read.readByte());
logger.debug("{}", (char)read.readByte());
logger.debug("{}", (char)read.readByte());
logger.debug("{}", (char)read.readByte());
}
commons/src/test/java/com/navercorp/pinpoint/common/buffer/FixedBufferTest.java
+8 -8
View File
@@ -380,7 +380,7 @@ public class FixedBufferTest {
if (offset != -1) {
Assert.assertEquals(buffer.getOffset(), offset);
} else {
logger.info("{} offsetSize:{}", v, buffer.getOffset());
logger.debug("{} offsetSize:{}", v, buffer.getOffset());
}
buffer.setOffset(0);
int readV = buffer.readVInt();
@@ -423,12 +423,12 @@ public class FixedBufferTest {
try {
int i = buffer.readVInt();
} catch (IllegalArgumentException e) {
logger.info(e.getMessage(), e);
logger.debug(e.getMessage(), e);
String binaryString = BytesUtils.toString(bytes);
logger.info(binaryString);
logger.debug(binaryString);
for (byte aByte : bytes) {
String code = String.valueOf((int) aByte);
logger.info(code);
logger.debug(code);
}
return;
}
@@ -446,12 +446,12 @@ public class FixedBufferTest {
try {
long i = buffer.readVLong();
} catch (IllegalArgumentException e) {
logger.info(e.getMessage(), e);
logger.debug(e.getMessage(), e);
String binaryString = BytesUtils.toString(bytes);
logger.info(binaryString);
logger.debug(binaryString);
for (byte aByte : bytes) {
String code = String.valueOf((int) aByte);
logger.info(code);
logger.debug(code);
}
return;
}
@@ -490,7 +490,7 @@ public class FixedBufferTest {
if (offset != -1) {
Assert.assertEquals(buffer.getOffset(), offset);
} else {
logger.info("{} offsetSize:{}", v, buffer.getOffset());
logger.debug("{} offsetSize:{}", v, buffer.getOffset());
}
buffer.setOffset(0);
int readV = buffer.readSVInt();
commons/src/test/java/com/navercorp/pinpoint/common/util/AnnotationTranscoderTest.java
+1 -1
View File
@@ -156,7 +156,7 @@ public class AnnotationTranscoderTest {
protocol.writeI32(value);
byte[] buffer = baos.toByteArray();
logger.info(Arrays.toString(buffer));
logger.debug(Arrays.toString(buffer));
}
@Test
commons/src/test/java/com/navercorp/pinpoint/common/util/ArrayUtilsTest.java
+1 -1
View File
@@ -73,7 +73,7 @@ public class ArrayUtilsTest {
byte[] bytes = new byte[]{1};
String small = ArrayUtils.abbreviate(bytes, 1);
logger.info(small);
logger.debug(small);
Assert.assertEquals("[1]", small);
}
commons/src/test/java/com/navercorp/pinpoint/common/util/ClassLoaderUtilsTest.java
+1 -1
View File
@@ -90,6 +90,6 @@ public class ClassLoaderUtilsTest {
@Test
public void append() throws Exception {
String log = ClassLoaderUtils.dumpStandardClassLoader();
logger.info("StandardClassLoader dump:{}", log);
logger.debug("StandardClassLoader dump:{}", log);
}
}
commons/src/test/java/com/navercorp/pinpoint/common/util/OutputParameterParserTest.java
+1 -1
View File
@@ -49,7 +49,7 @@ public class OutputParameterParserTest {
private void assertOutputParameter(String outputParam, String... params) {
List<String> result = parser.parseOutputParameter(outputParam);
logger.info("parseResult:{}", result);
logger.debug("parseResult:{}", result);
try {
Assert.assertArrayEquals(result.toArray(new String[result.size()]), params);
} catch (AssertionError e) {
commons/src/test/java/com/navercorp/pinpoint/common/util/StringTraceHeaderParserTest.java
+2 -2
View File
@@ -38,7 +38,7 @@ public class StringTraceHeaderParserTest {
@Test
public void getIdSize() {
String test = "3ccb94f3-a8fe-4464-bfbd-d35490afab3d";
logger.info("idSize={}", test.length());
logger.debug("idSize={}", test.length());
}
@@ -60,6 +60,6 @@ public class StringTraceHeaderParserTest {
Assert.assertEquals("pSpanId", String.valueOf(pSpanId), header.getParentSpanId());
Assert.assertEquals("sampling", String.valueOf(sampling), header.getSampling());
Assert.assertEquals("flag", String.valueOf(flag), header.getFlag());
logger.info("{}, parse:" + header);
logger.debug("{}, parse:" + header);
}
}
commons/src/test/java/com/navercorp/pinpoint/common/util/TimeSlotTest.java
+6 -6
View File
@@ -39,8 +39,8 @@ public class TimeSlotTest {
long currentTime = System.currentTimeMillis();
long timeSlot = this.timeSlot.getTimeSlot(currentTime);
logger.info("{} currentTime ", currentTime);
logger.info("{} timeSlot", timeSlot);
logger.debug("{} currentTime ", currentTime);
logger.debug("{} timeSlot", timeSlot);
Assert.assertTrue(currentTime >= timeSlot);
}
@@ -49,8 +49,8 @@ public class TimeSlotTest {
int slotTest = 60 * 1000;
long timeSlot = this.timeSlot.getTimeSlot(slotTest);
logger.info("{} slotTest ", slotTest);
logger.info("{} timeSlot", timeSlot);
logger.debug("{} slotTest ", slotTest);
logger.debug("{} timeSlot", timeSlot);
Assert.assertEquals(slotTest, timeSlot);
}
@@ -60,8 +60,8 @@ public class TimeSlotTest {
int slotTest = sourceTest + 1;
long timeSlot = this.timeSlot.getTimeSlot(slotTest);
logger.info("{} slotTest ", slotTest);
logger.info("{} timeSlot", timeSlot);
logger.debug("{} slotTest ", slotTest);
logger.debug("{} timeSlot", timeSlot);
Assert.assertEquals(sourceTest, timeSlot);
}
}
profiler-test/src/test/java/com/navercorp/pinpoint/test/javasssit/JavassistClassTest.java
+12 -12
View File
@@ -67,12 +67,12 @@ public class JavassistClassTest {
@Test
public void testClassHierarchy() throws InstrumentException {
JavassistEngine pool = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
JavassistEngine engine = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
String testObjectName = "com.navercorp.pinpoint.test.javasssit.mock.TestObject";
byte[] testObjectByteCode = readByteCode(testObjectName);
InstrumentClass testObject = pool.getClass(null, null, testObjectName, testObjectByteCode);
InstrumentClass testObject = engine.getClass(null, null, testObjectName, testObjectByteCode);
Assert.assertEquals(testObject.getName(), testObjectName);
@@ -84,7 +84,7 @@ public class JavassistClassTest {
final String classHierarchyTestMockName = "com.navercorp.pinpoint.test.javasssit.mock.ClassHierarchyTestMock";
byte[] classHierarchyTestMockByteCode = readByteCode(classHierarchyTestMockName);
InstrumentClass classHierarchyObject = pool.getClass(null, null, classHierarchyTestMockName, classHierarchyTestMockByteCode);
InstrumentClass classHierarchyObject = engine.getClass(null, null, classHierarchyTestMockName, classHierarchyTestMockByteCode);
String hierarchySuperClass = classHierarchyObject.getSuperClass();
Assert.assertEquals("java.util.HashMap", hierarchySuperClass);
@@ -97,11 +97,11 @@ public class JavassistClassTest {
@Test
public void testDeclaredMethod() throws InstrumentException {
JavassistEngine pool = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
JavassistEngine engine = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
String testObjectName = "com.navercorp.pinpoint.test.javasssit.mock.TestObject";
byte[] testObjectByteCode = readByteCode(testObjectName);
InstrumentClass testObject = pool.getClass(null, null, testObjectName, testObjectByteCode);
InstrumentClass testObject = engine.getClass(null, null, testObjectName, testObjectByteCode);
Assert.assertEquals(testObject.getName(), testObjectName);
@@ -113,11 +113,11 @@ public class JavassistClassTest {
@Test
public void testDeclaredMethods() throws InstrumentException {
JavassistEngine pool = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
JavassistEngine engine = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
String testObjectName = "com.navercorp.pinpoint.test.javasssit.mock.TestObject";
byte[] testObjectByteCode = readByteCode(testObjectName);
InstrumentClass testObject = pool.getClass(null, null, testObjectName, testObjectByteCode);
InstrumentClass testObject = engine.getClass(null, null, testObjectName, testObjectByteCode);
Assert.assertEquals(testObject.getName(), testObjectName);
int findMethodCount = 0;
@@ -271,18 +271,18 @@ public class JavassistClassTest {
@Test
public void nullDescriptor() {
String nullDescriptor = Descriptor.ofParameters(null);
logger.info("Descript null:{}", nullDescriptor);
logger.debug("Descriptor null:{}", nullDescriptor);
}
@Test
public void getNestedClasses() throws Exception {
JavassistEngine pool = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
JavassistEngine engine = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
String testObjectName = "com.navercorp.pinpoint.test.javasssit.mock.TestObjectNestedClass";
byte[] testObjectByteCode = readByteCode(testObjectName);
InstrumentClass testObject = pool.getClass(null, null, testObjectName, testObjectByteCode);
InstrumentClass testObject = engine.getClass(null, null, testObjectName, testObjectByteCode);
Assert.assertEquals(testObject.getName(), testObjectName);
// find class name condition.
@@ -303,11 +303,11 @@ public class JavassistClassTest {
@Test
public void hasEnclodingMethod() throws Exception {
JavassistEngine pool = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
JavassistEngine engine = new JavassistEngine(new GlobalInterceptorRegistryBinder(), null);
String testObjectName = "com.navercorp.pinpoint.test.javasssit.mock.TestObjectNestedClass";
byte[] testObjectByteCode = readByteCode(testObjectName);
InstrumentClass testObject = pool.getClass(null, null, testObjectName, testObjectByteCode);
InstrumentClass testObject = engine.getClass(null, null, testObjectName, testObjectByteCode);
Assert.assertEquals(testObject.getName(), testObjectName);
assertEquals(1, testObject.getNestedClasses(ClassFilters.enclosingMethod("enclosingMethod", "java.lang.String", "int")).size());
profiler/src/test/java/com/navercorp/pinpoint/profiler/AgentInfoSenderTest.java
+3 -3
View File
@@ -496,12 +496,12 @@ public class AgentInfoSenderTest {
@Override
public void handleSend(SendPacket sendPacket, PinpointSocket pinpointSocket) {
logger.info("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
}
@Override
public void handleRequest(RequestPacket requestPacket, PinpointSocket pinpointSocket) {
logger.info("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
int requestCount = this.requestCount.incrementAndGet();
if (requestCount < successCondition) {
@@ -530,7 +530,7 @@ public class AgentInfoSenderTest {
@Override
public void handlePing(PingPacket pingPacket, PinpointServer pinpointServer) {
logger.info("ping received {} {} ", pingPacket, pinpointServer);
logger.debug("ping received {} {} ", pingPacket, pinpointServer);
}
}
profiler/src/test/java/com/navercorp/pinpoint/profiler/context/TraceTest.java
+1 -1
View File
@@ -69,7 +69,7 @@ public class TraceTest {
trace.close();
logger.info(String.valueOf(dataSender.event));
logger.debug(String.valueOf(dataSender.event));
}
private TraceContext getDefaultTraceContext() {
profiler/src/test/java/com/navercorp/pinpoint/profiler/sender/TcpDataSenderReconnectTest.java
+6 -6
View File
@@ -60,13 +60,13 @@ public class TcpDataSenderReconnectTest {
@Override
public void handleSend(SendPacket sendPacket, PinpointSocket pinpointSocket) {
logger.info("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
send++;
}
@Override
public void handleRequest(RequestPacket requestPacket, PinpointSocket pinpointSocket) {
logger.info("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
}
@Override
@@ -76,7 +76,7 @@ public class TcpDataSenderReconnectTest {
@Override
public void handlePing(PingPacket pingPacket, PinpointServer pinpointServer) {
logger.info("ping received {} {} ", pingPacket, pinpointServer);
logger.debug("ping received {} {} ", pingPacket, pinpointServer);
}
});
serverAcceptor.bind(HOST, PORT);
@@ -97,15 +97,15 @@ public class TcpDataSenderReconnectTest {
oldAcceptor.close();
waitClientDisconnected(client);
logger.info("Server start------------------");
logger.debug("Server start------------------");
PinpointServerAcceptor serverAcceptor = serverAcceptorStart();
waitClientConnected(serverAcceptor);
logger.info("sendMessage------------------");
logger.debug("sendMessage------------------");
sender.send(new TApiMetaData("test", System.currentTimeMillis(), 1, "TestApi"));
Thread.sleep(500);
logger.info("sender stop------------------");
logger.debug("sender stop------------------");
sender.stop();
serverAcceptor.close();
profiler/src/test/java/com/navercorp/pinpoint/profiler/sender/TcpDataSenderTest.java
+3 -3
View File
@@ -58,7 +58,7 @@ public class TcpDataSenderTest {
@Override
public void handleSend(SendPacket sendPacket, PinpointSocket pinpointSocket) {
logger.info("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
if (sendLatch != null) {
sendLatch.countDown();
}
@@ -66,7 +66,7 @@ public class TcpDataSenderTest {
@Override
public void handleRequest(RequestPacket requestPacket, PinpointSocket pinpointSocket) {
logger.info("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
}
@Override
@@ -76,7 +76,7 @@ public class TcpDataSenderTest {
@Override
public void handlePing(PingPacket pingPacket, PinpointServer pinpointServer) {
logger.info("ping received {} {} ", pingPacket, pinpointServer);
logger.debug("ping received {} {} ", pingPacket, pinpointServer);
}
});
serverAcceptor.bind(HOST, PORT);
profiler/src/test/java/com/navercorp/pinpoint/profiler/sender/UdpSocketTest.java
+1 -1
View File
@@ -135,7 +135,7 @@ public class UdpSocketTest {
DatagramPacket datagramPacket = newDatagramPacket(70000);
try {
receiver.receive(datagramPacket);
logger.info("data size:{}", datagramPacket.getLength());
logger.debug("data size:{}", datagramPacket.getLength());
} catch (IOException e) {
logger.warn("receive error:{}", e.getMessage(), e);
}
profiler/src/test/java/com/navercorp/pinpoint/profiler/util/JavaAssistUtilsTest.java
+20 -20
View File
@@ -51,10 +51,10 @@ public class JavaAssistUtilsTest {
CtMethod substring = ctClass.getDeclaredMethod("substring", new CtClass[]{CtClass.intType});
String ctDescription = JavaAssistUtils.getParameterDescription(substring.getParameterTypes());
logger.info(ctDescription);
logger.debug(ctDescription);
String clsDescription = JavaAssistUtils.getParameterDescription(new Class[]{int.class});
logger.info(clsDescription);
logger.debug(clsDescription);
Assert.assertEquals(ctDescription, clsDescription);
}
@@ -234,23 +234,23 @@ public class JavaAssistUtilsTest {
CtMethod setParams = ctClass.getDeclaredMethod("getLineNumber_testAPI", new CtClass[]{params});
int lineNumber = JavaAssistUtils.getLineNumber(setParams);
logger.info("line:{}", lineNumber);
logger.debug("line:{}", lineNumber);
logger.info(setParams.getName());
logger.info(setParams.getLongName());
logger.debug(setParams.getName());
logger.debug(setParams.getLongName());
String[] paramName = JavaAssistUtils.getParameterVariableName(setParams);
logger.info(Arrays.toString(paramName));
logger.debug(Arrays.toString(paramName));
Assert.assertEquals(paramName.length, 1);
Assert.assertEquals(paramName[0], "params");
String[] parameterType = JavaAssistUtils.parseParameterSignature(setParams.getSignature());
String[] parameterType2 = JavaAssistUtils.getParameterType(setParams.getParameterTypes());
logger.info(Arrays.toString(parameterType));
logger.debug(Arrays.toString(parameterType));
Assert.assertArrayEquals(parameterType, parameterType2);
String s = ApiUtils.mergeParameterVariableNameDescription(parameterType, paramName);
logger.info(s);
logger.debug(s);
}
public void testVariableNameError1_testAPI(boolean autoCommitFlag) {
@@ -262,23 +262,23 @@ public class JavaAssistUtilsTest {
CtClass ctClass = pool.get(TEST_CLASS_NAME);
CtMethod setParams = ctClass.getDeclaredMethod("testVariableNameError1_testAPI", new CtClass[]{CtClass.booleanType});
int lineNumber = JavaAssistUtils.getLineNumber(setParams);
logger.info("line:{}", lineNumber);
logger.debug("line:{}", lineNumber);
logger.info(setParams.getName());
logger.info(setParams.getLongName());
logger.debug(setParams.getName());
logger.debug(setParams.getLongName());
String[] paramName = JavaAssistUtils.getParameterVariableName(setParams);
logger.info(Arrays.toString(paramName));
logger.debug(Arrays.toString(paramName));
Assert.assertEquals(paramName.length, 1);
Assert.assertEquals(paramName[0], "autoCommitFlag");
String[] parameterType = JavaAssistUtils.parseParameterSignature(setParams.getSignature());
String[] parameterType2 = JavaAssistUtils.getParameterType(setParams.getParameterTypes());
logger.info(Arrays.toString(parameterType));
logger.debug(Arrays.toString(parameterType));
Assert.assertArrayEquals(parameterType, parameterType2);
String s = ApiUtils.mergeParameterVariableNameDescription(parameterType, paramName);
logger.info(s);
logger.debug(s);
}
public void testVariableNameError2_testAPI(String sql) {
@@ -292,28 +292,28 @@ public class JavaAssistUtilsTest {
CtMethod setParams = ctClass.getDeclaredMethod("testVariableNameError2_testAPI", new CtClass[]{params});
int lineNumber = JavaAssistUtils.getLineNumber(setParams);
logger.info(setParams.getName());
logger.info(setParams.getLongName());
logger.debug(setParams.getName());
logger.debug(setParams.getLongName());
String[] paramName = JavaAssistUtils.getParameterVariableName(setParams);
logger.info(Arrays.toString(paramName));
logger.debug(Arrays.toString(paramName));
Assert.assertEquals(paramName.length, 1);
Assert.assertEquals(paramName[0], "sql");
String[] parameterType = JavaAssistUtils.parseParameterSignature(setParams.getSignature());
String[] parameterType2 = JavaAssistUtils.getParameterType(setParams.getParameterTypes());
logger.info(Arrays.toString(parameterType));
logger.debug(Arrays.toString(parameterType));
Assert.assertArrayEquals(parameterType, parameterType2);
String s = ApiUtils.mergeParameterVariableNameDescription(parameterType, paramName);
logger.info(s);
logger.debug(s);
}
@Test
public void testGetParameterDescription2() throws Exception {
String clsDescription = JavaAssistUtils.getParameterDescription(new Class[]{String.class, Integer.class});
logger.info(clsDescription);
logger.debug(clsDescription);
Assert.assertEquals("(java.lang.String, java.lang.Integer)", clsDescription);
}
rpc/src/test/java/com/navercorp/pinpoint/rpc/DiscardServerHandler.java
+3 -3
View File
@@ -38,7 +38,7 @@ public class DiscardServerHandler extends SimpleChannelUpstreamHandler {
@Override
public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e) throws Exception {
if (e instanceof ChannelStateEvent) {
logger.info("event:{}", e);
logger.debug("event:{}", e);
}
}
@@ -47,8 +47,8 @@ public class DiscardServerHandler extends SimpleChannelUpstreamHandler {
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
transferredBytes += ((ChannelBuffer) e.getMessage()).readableBytes();
logger.info("messageReceived. meg:{} channel:{}", e.getMessage(), e.getChannel());
logger.info("transferredBytes. transferredBytes:{}", transferredBytes);
logger.debug("messageReceived. meg:{} channel:{}", e.getMessage(), e.getChannel());
logger.debug("transferredBytes. transferredBytes:{}", transferredBytes);
}
rpc/src/test/java/com/navercorp/pinpoint/rpc/RecordedStreamChannelMessageListener.java
+2 -2
View File
@@ -47,14 +47,14 @@ public class RecordedStreamChannelMessageListener implements ClientStreamChannel
@Override
public void handleStreamData(ClientStreamChannelContext streamChannelContext, StreamResponsePacket packet) {
logger.info("handleStreamData {}, {}", streamChannelContext, packet);
logger.debug("handleStreamData {}, {}", streamChannelContext, packet);
receivedMessageList.add(packet.getPayload());
latch.countDown();
}
@Override
public void handleStreamClose(ClientStreamChannelContext streamChannelContext, StreamClosePacket packet) {
logger.info("handleClose {}, {}", streamChannelContext, packet);
logger.debug("handleClose {}, {}", streamChannelContext, packet);
receivedMessageList.add(packet.getPayload());
latch.countDown();
}
rpc/src/test/java/com/navercorp/pinpoint/rpc/client/PinpointClientFactoryTest.java
+2 -2
View File
@@ -152,9 +152,9 @@ public class PinpointClientFactoryTest {
try {
PinpointClient client = clientFactory.connect("127.0.0.1", bindPort);
logger.info("send1");
logger.debug("send1");
client.send(new byte[20]);
logger.info("send2");
logger.debug("send2");
client.sendSync(new byte[20]);
PinpointRPCTestUtils.close(client);
rpc/src/test/java/com/navercorp/pinpoint/rpc/client/ReconnectTest.java
+8 -8
View File
@@ -86,14 +86,14 @@ public class ReconnectTest {
});
PinpointRPCTestUtils.close(serverAcceptor);
logger.info("server.close()---------------------------");
logger.debug("server.close");
assertClientDisconnected(client);
newServerAcceptor = PinpointRPCTestUtils.createPinpointServerFactory(bindPort, SimpleServerMessageListener.DUPLEX_ECHO_INSTANCE);
logger.info("bind server---------------------------");
logger.debug("bind server");
assertClientConnected(client);
logger.info("request server---------------------------");
logger.debug("request server");
byte[] randomByte = TestByteUtils.createRandomByte(10);
byte[] response = PinpointRPCTestUtils.request(client, randomByte);
@@ -117,20 +117,20 @@ public class ReconnectTest {
int threadCount = tbean.getThreadCount();
for (int i = 0; i < count; i++) {
logger.info((i + 1) + "th's start.");
logger.debug((i + 1) + "th's start.");
PinpointServerAcceptor serverAcceptor = PinpointRPCTestUtils.createPinpointServerFactory(bindPort, SimpleServerMessageListener.DUPLEX_ECHO_INSTANCE);
PinpointClient client = clientFactory.connect("localhost", bindPort);
PinpointRPCTestUtils.close(serverAcceptor);
logger.info("server.close()---------------------------");
logger.debug("server.close");
assertClientDisconnected(client);
serverAcceptor = PinpointRPCTestUtils.createPinpointServerFactory(bindPort, SimpleServerMessageListener.DUPLEX_ECHO_INSTANCE);
logger.info("bind server---------------------------");
logger.debug("bind server");
assertClientConnected(client);
logger.info("request server---------------------------");
logger.debug("request server");
byte[] randomByte = TestByteUtils.createRandomByte(10);
byte[] response = PinpointRPCTestUtils.request(client, randomByte);
@@ -158,7 +158,7 @@ public class ReconnectTest {
serverAcceptor = PinpointRPCTestUtils.createPinpointServerFactory(bindPort, SimpleServerMessageListener.DUPLEX_ECHO_INSTANCE);
assertClientConnected(client);
logger.info("request server---------------------------");
logger.debug("request server");
byte[] randomByte = TestByteUtils.createRandomByte(10);
byte[] response = PinpointRPCTestUtils.request(client, randomByte);
rpc/src/test/java/com/navercorp/pinpoint/rpc/server/ControlPacketServerTest.java
+2 -2
View File
@@ -239,12 +239,12 @@ public class ControlPacketServerTest {
@Override
public void handleSend(SendPacket sendPacket, PinpointSocket pinpointSocket) {
logger.info("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
}
@Override
public void handleRequest(RequestPacket requestPacket, PinpointSocket pinpointSocket) {
logger.info("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
pinpointSocket.response(requestPacket, requestPacket.getPayload());
}
rpc/src/test/java/com/navercorp/pinpoint/rpc/util/PinpointRPCTestUtils.java
+3 -3
View File
@@ -164,13 +164,13 @@ public final class PinpointRPCTestUtils {
@Override
public void handleSend(SendPacket sendPacket, PinpointSocket pinpointSocket) {
logger.info("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleSend packet:{}, remote:{}", sendPacket, pinpointSocket.getRemoteAddress());
sendPacketRepository.add(sendPacket);
}
@Override
public void handleRequest(RequestPacket requestPacket, PinpointSocket pinpointSocket) {
logger.info("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
logger.debug("handleRequest packet:{}, remote:{}", requestPacket, pinpointSocket.getRemoteAddress());
requestPacketRepository.add(requestPacket);
pinpointSocket.response(requestPacket, requestPacket.getPayload());
@@ -178,7 +178,7 @@ public final class PinpointRPCTestUtils {
@Override
public HandshakeResponseCode handleHandshake(Map properties) {
logger.info("handle Handshake {}", properties);
logger.debug("handle Handshake {}", properties);
return HandshakeResponseType.Success.DUPLEX_COMMUNICATION;
}
thrift/src/test/java/com/navercorp/pinpoint/thrift/io/HeaderUtilsTest.java
+1 -4
View File
@@ -22,9 +22,6 @@ import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.navercorp.pinpoint.thrift.io.Header;
import com.navercorp.pinpoint.thrift.io.HeaderUtils;
/**
* @author emeroad
*/
@@ -42,7 +39,7 @@ public class HeaderUtilsTest {
Assert.assertTrue(HeaderUtils.validateSignature(error.getSignature()) != HeaderUtils.OK);
logger.info(header.toString());
logger.debug(header.toString());
}
}
web/src/test/java/com/navercorp/pinpoint/web/cluster/ClusterTest.java
+3 -3
View File
@@ -79,7 +79,7 @@ public class ClusterTest {
ts = createZookeeperServer(zookeeperPort);
CLUSTER_NODE_PATH = "/pinpoint-cluster/web/" + acceptorAddress;
LOGGER.info("CLUSTER_NODE_PATH:{}", CLUSTER_NODE_PATH);
LOGGER.debug("CLUSTER_NODE_PATH:{}", CLUSTER_NODE_PATH);
WebConfig config = mock(WebConfig.class);
@@ -247,7 +247,7 @@ public class ClusterTest {
}
private void getNodeAndCompareContents(ZooKeeper zookeeper) throws KeeperException, InterruptedException {
LOGGER.info("getNodeAndCompareContents() {}", CLUSTER_NODE_PATH);
LOGGER.debug("getNodeAndCompareContents() {}", CLUSTER_NODE_PATH);
byte[] contents = zookeeper.getData(CLUSTER_NODE_PATH, null, null);
@@ -264,7 +264,7 @@ public class ClusterTest {
private boolean getNodeAndCompareContents0(ZooKeeper zookeeper) {
try {
LOGGER.info("getNodeAndCompareContents() {}", CLUSTER_NODE_PATH);
LOGGER.debug("getNodeAndCompareContents() {}", CLUSTER_NODE_PATH);
byte[] contents = zookeeper.getData(CLUSTER_NODE_PATH, null, null);
if (contents == null) {
web/src/test/java/com/navercorp/pinpoint/web/cluster/zookeeper/ZookeeperClusterTest.java
+1 -1
View File
@@ -267,7 +267,7 @@ public class ZookeeperClusterTest {
}
String result = zookeeper.create(subPath, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
logger.info("Create path {} success.", result);
logger.debug("Create path {} success.", result);
} while (pos < path.length());
}