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

[강운덕] [LUCYSUS-1744] 버그 수정 HeaderTBaseSerializer->SafeHeaderTBaseSerializer로 변경. HeaderTBaseSerializers는 내부 buffer를 그래로 리턴하여 array사이즈가 65536으로 매우 큼.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-server/trunk@2331 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Woonduk Kang
2013-09-16 05:50:26 +00:00
parent d52767551d
commit 5e35fdce8a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/nhn/pinpoint/collector/receiver/tcp/TCPReceiver.java
+2 -1
View File
@@ -21,6 +21,7 @@ import com.nhn.pinpoint.rpc.server.PinpointServerSocket;
import com.nhn.pinpoint.rpc.server.ServerMessageListener;
import com.nhn.pinpoint.rpc.server.ServerStreamChannel;
import com.nhn.pinpoint.rpc.server.SocketChannel;
import com.nhn.pinpoint.thrift.io.SafeHeaderTBaseSerializer;
import org.apache.thrift.TBase;
import org.apache.thrift.TException;
import org.slf4j.Logger;
@@ -156,7 +157,7 @@ public class TCPReceiver {
TBase<?, ?> tBase = deserializer.deserialize(bytes);
TBase result = dispatchHandler.dispatch(tBase, bytes, Header.HEADER_SIZE, bytes.length);
if (result != null) {
HeaderTBaseSerializer serializer = new HeaderTBaseSerializer();
SafeHeaderTBaseSerializer serializer = new SafeHeaderTBaseSerializer();
byte[] resultBytes = serializer.serialize(result);
socketChannel.sendResponseMessage(requestPacket, resultBytes);
}