From 0c5bc0cfb0519ece2d4d36219b2c5872e84f2097 Mon Sep 17 00:00:00 2001 From: Alexander Koshevoy Date: Wed, 30 May 2018 18:05:38 +0300 Subject: [PATCH] PY-18029 Maximum frame length of "directed" messages increased --- .../python/console/thrift/client/TNettyClientTransport.kt | 2 +- .../python/console/thrift/server/TNettyServerTransport.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/python/python-console/src/com/jetbrains/python/console/thrift/client/TNettyClientTransport.kt b/python/python-console/src/com/jetbrains/python/console/thrift/client/TNettyClientTransport.kt index 62cb12b1130b..7f05ffcce6a9 100644 --- a/python/python-console/src/com/jetbrains/python/console/thrift/client/TNettyClientTransport.kt +++ b/python/python-console/src/com/jetbrains/python/console/thrift/client/TNettyClientTransport.kt @@ -66,7 +66,7 @@ class TNettyClientTransport(private val host: String, override fun initChannel(ch: SocketChannel) { ch.pipeline().addLast(LoggingHandler(LogLevel.DEBUG)) - ch.pipeline().addLast(LengthFieldBasedFrameDecoder(1024, 0, 4, 0, 4)) + ch.pipeline().addLast(LengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4)) ch.pipeline().addLast(LengthFieldPrepender(4)) ch.pipeline().addLast(DirectedMessageCodec()) diff --git a/python/python-console/src/com/jetbrains/python/console/thrift/server/TNettyServerTransport.kt b/python/python-console/src/com/jetbrains/python/console/thrift/server/TNettyServerTransport.kt index 4720d418d828..d3d87a5dc209 100644 --- a/python/python-console/src/com/jetbrains/python/console/thrift/server/TNettyServerTransport.kt +++ b/python/python-console/src/com/jetbrains/python/console/thrift/server/TNettyServerTransport.kt @@ -75,7 +75,7 @@ class TNettyServerTransport(port: Int) : TServerTransport() { ch.pipeline().addLast(LoggingHandler()) // `FixedLengthFrameDecoder` is excessive but convenient - ch.pipeline().addLast(LengthFieldBasedFrameDecoder(1024, 0, 4, 0, 4)) + ch.pipeline().addLast(LengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4)) ch.pipeline().addLast(LengthFieldPrepender(4)) // `DirectedMessageCodec` is above Thrift messages ch.pipeline().addLast(DirectedMessageCodec())