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

[WEB-194] TimeSlot testcase가 수정되지 않은 곳이 있어 수정함.

Browse Source
This commit is contained in:
Woonduk Kang
2014-07-30 14:16:18 +09:00
parent 3b7721fb56
commit ec66ae319d
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/com/nhn/pinpoint/collector/dao/hbase/HbaseHostApplicationMapDaoTest.java
+3 -1
View File
@@ -4,6 +4,7 @@ import com.nhn.pinpoint.common.ServiceType;
import com.nhn.pinpoint.common.buffer.Buffer;
import com.nhn.pinpoint.common.buffer.FixedBuffer;
import com.nhn.pinpoint.common.hbase.HBaseTables;
import com.nhn.pinpoint.common.util.DefaultTimeSlot;
import com.nhn.pinpoint.common.util.TimeSlot;
import com.nhn.pinpoint.common.util.TimeUtils;
import junit.framework.Assert;
@@ -18,11 +19,12 @@ public class HbaseHostApplicationMapDaoTest {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
private final TimeSlot timeSlot = new DefaultTimeSlot();
@Test
public void testCreateRowKey() throws Exception {
HbaseHostApplicationMapDao dao = new HbaseHostApplicationMapDao();
long statisticsRowSlot = TimeSlot.getStatisticsRowSlot(System.currentTimeMillis());
long statisticsRowSlot = timeSlot.getTimeSlot(System.currentTimeMillis());
byte[] parentApps = dao.createRowKey("parentApp", ServiceType.TOMCAT.getCode(), statisticsRowSlot, null);
logger.debug("rowKey size:{}", parentApps.length);
src/test/java/com/nhn/pinpoint/collector/receiver/udp/UDPReceiverTest.java
+2 -2
View File
@@ -59,10 +59,10 @@ public class UDPReceiverTest {
public void socketBufferSize() throws SocketException {
DatagramSocket datagramSocket = new DatagramSocket();
int receiveBufferSize = datagramSocket.getReceiveBufferSize();
System.out.println(receiveBufferSize);
logger.debug("{}", receiveBufferSize);
datagramSocket.setReceiveBufferSize(64*1024*10);
System.out.println(datagramSocket.getReceiveBufferSize());
logger.debug("{}", datagramSocket.getReceiveBufferSize());
datagramSocket.close();
}