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

[유치수] [ARCUS-127] add TODO comments.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@483 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Chisu Yu
2012-07-31 08:55:23 +00:00
parent e25dc5c54b
commit 6141602d8d
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/profiler/sender/DataSender.java
+5 -1
View File
@@ -24,7 +24,7 @@ import com.profiler.dto.RequestThriftDTO;
*/
public class DataSender extends Thread {
private final LinkedBlockingQueue<TBase<?, ?>> addedQueue = new LinkedBlockingQueue<TBase<?, ?>>();
private final LinkedBlockingQueue<TBase<?, ?>> addedQueue = new LinkedBlockingQueue<TBase<?, ?>>(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;