From 6141602d8d46a3a649bb14aa627a0e9dea220cd6 Mon Sep 17 00:00:00 2001 From: Chisu Yu Date: Tue, 31 Jul 2012 08:55:23 +0000 Subject: [PATCH] =?UTF-8?q?[=EC=9C=A0=EC=B9=98=EC=88=98]=20[ARCUS-127]=20a?= =?UTF-8?q?dd=20TODO=20comments.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@483 84d0f5b1-2673-498c-a247-62c4ff18d310 --- src/main/java/com/profiler/sender/DataSender.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/profiler/sender/DataSender.java b/src/main/java/com/profiler/sender/DataSender.java index 09cb11e25..d6b68dc03 100644 --- a/src/main/java/com/profiler/sender/DataSender.java +++ b/src/main/java/com/profiler/sender/DataSender.java @@ -24,7 +24,7 @@ import com.profiler.dto.RequestThriftDTO; */ public class DataSender extends Thread { - private final LinkedBlockingQueue> addedQueue = new LinkedBlockingQueue>(); + private final LinkedBlockingQueue> addedQueue = new LinkedBlockingQueue>(4096); private final InetSocketAddress requestDataAddr = new InetSocketAddress(TomcatProfilerConfig.SERVER_IP, TomcatProfilerConfig.REQUEST_DATA_LISTEN_PORT); private final InetSocketAddress requestTransactionDataAddr = new InetSocketAddress(TomcatProfilerConfig.SERVER_IP, TomcatProfilerConfig.REQUEST_TRANSACTION_DATA_LISTEN_PORT); @@ -45,9 +45,13 @@ public class DataSender extends Thread { } public boolean addDataToSend(TBase data) { + // TODO: addedQueue가 full일 때 IllegalStateException처리. return addedQueue.add(data); } + // TODO: send timeout추 + // TODO: addedqueue에서 bulk로 drain + // TODO: sender thread가 한 개로 충분한가. public void run() { while (true) { DatagramSocket udpSocket = null;