From 5e35fdce8a3d71f0ef73809a3dbb68cd804512c2 Mon Sep 17 00:00:00 2001 From: Woonduk Kang Date: Mon, 16 Sep 2013 05:50:26 +0000 Subject: [PATCH] =?UTF-8?q?[=EA=B0=95=EC=9A=B4=EB=8D=95]=20[LUCYSUS-1744]?= =?UTF-8?q?=20=EB=B2=84=EA=B7=B8=20=EC=88=98=EC=A0=95=20HeaderTBaseSeriali?= =?UTF-8?q?zer->SafeHeaderTBaseSerializer=EB=A1=9C=20=EB=B3=80=EA=B2=BD.?= =?UTF-8?q?=20HeaderTBaseSerializers=EB=8A=94=20=EB=82=B4=EB=B6=80=20buffe?= =?UTF-8?q?r=EB=A5=BC=20=EA=B7=B8=EB=9E=98=EB=A1=9C=20=EB=A6=AC=ED=84=B4?= =?UTF-8?q?=ED=95=98=EC=97=AC=20array=EC=82=AC=EC=9D=B4=EC=A6=88=EA=B0=80?= =?UTF-8?q?=2065536=EC=9C=BC=EB=A1=9C=20=EB=A7=A4=EC=9A=B0=20=ED=81=BC.?= 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-server/trunk@2331 84d0f5b1-2673-498c-a247-62c4ff18d310 --- .../com/nhn/pinpoint/collector/receiver/tcp/TCPReceiver.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/nhn/pinpoint/collector/receiver/tcp/TCPReceiver.java b/src/main/java/com/nhn/pinpoint/collector/receiver/tcp/TCPReceiver.java index ebcd24b84..40c7ec59a 100644 --- a/src/main/java/com/nhn/pinpoint/collector/receiver/tcp/TCPReceiver.java +++ b/src/main/java/com/nhn/pinpoint/collector/receiver/tcp/TCPReceiver.java @@ -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); }