Skip to content

Commit 3b64321

Browse files
jmswenfacebook-github-bot
authored andcommitted
Support compression in ThriftTransport
Reviewed By: disylh Differential Revision: D28259547 fbshipit-source-id: 175639d0ff595a67003e20cf4481e8fab92b4582
1 parent 0fb0dae commit 3b64321

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

mcrouter/lib/network/ThriftTransport.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,14 @@ apache::thrift::RocketClientChannel::Ptr ThriftTransportBase::createChannel() {
158158
apache::thrift::RocketClientChannel::newChannel(std::move(socket));
159159
channel->setProtocolId(apache::thrift::protocol::T_COMPACT_PROTOCOL);
160160
channel->setCloseCallback(this);
161+
if (connectionOptions_.thriftCompression) {
162+
apache::thrift::CodecConfig codec;
163+
codec.zstdConfig_ref() = apache::thrift::ZstdCompressionCodecConfig();
164+
apache::thrift::CompressionConfig compressionConfig;
165+
compressionConfig.codecConfig_ref() = std::move(codec);
166+
channel->setDefaultCompressionConfig(std::move(compressionConfig));
167+
}
168+
161169
return channel;
162170
#else
163171
return nullptr;

0 commit comments

Comments
 (0)