[
https://issues.apache.org/jira/browse/THRIFT-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16599316#comment-16599316
]
ASF GitHub Bot commented on THRIFT-4626:
----------------------------------------
vykulakov commented on issue #1589: THRIFT-4626: Remove checking of remaining
bytes in the Go library.
URL: https://github.com/apache/thrift/pull/1589#issuecomment-417801300
Added the issue: https://issues.apache.org/jira/browse/THRIFT-4626
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> Communication crash when using binary/compact protocol and zlib transport
> -------------------------------------------------------------------------
>
> Key: THRIFT-4626
> URL: https://issues.apache.org/jira/browse/THRIFT-4626
> Project: Thrift
> Issue Type: Bug
> Components: Go - Library
> Affects Versions: 0.11.0
> Environment: Ubuntu 18.04
> Go 1.10.1
> Reporter: Vyacheslav Kulakov
> Priority: Major
>
> Reading a request on the server side or reading a response on the client side
> always fail with the "Invalid data length" error when using the
> binary/compact protocol and the zlib transport, which wraps the framed
> transport.
> In my project, I use the following code on the server side (only for testing):
> {code:go}
> processor := flume.NewThriftSourceProtocolProcessor(protocol)
> serverTransport, _ := thrift.NewTServerSocketTimeout(address, timeout)
> protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
> transportFactory :=
> thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
> transportFactory = thrift.NewTZlibTransportFactoryWithFactory(level,
> transportFactory)
> server := thrift.NewTSimpleServer4(
> processor,
> serverTransport,
> transportFactory,
> protocolFactory,
> )
> {code}
> and following code on the client side:
> {code:go}
> factory := thrift.NewTBinaryProtocolFactoryDefault()
> transport := thrift.TTransport(thrift.NewTFramedTransport(socket))
> transport, err = thrift.NewTZlibTransport(transport, compressionLevel)
> if err != nil {
> return err
> }
> err = transport.Open()
> if err != nil {
> return err
> }
> client := flume.NewThriftSourceProtocolClient(
> thrift.NewTStandardClient(
> factory.GetProtocol(transport),
> factory.GetProtocol(transport),
> ),
> )
> {code}
> When I send data from the client to the server I always get the "EOF" error
> on the client and the "Invalid data length" error on the server. If I use the
> compact protocol the errors stay at their places.
> I investigated Go library code and found a reason of that errors: the
> protocol invoke the RemainingBytes method on the zlib transport and it always
> return zero because all bytes were already read from a frame and were stored
> in a decompressor buffer. But we can't access to this buffer to obtain
> correct number of remaining bytes. So this combination of protocols and
> transports can't work together at all.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
