diff options
| author | Jens Geyer <jensg@apache.org> | 2021-11-13 23:01:16 +0100 |
|---|---|---|
| committer | Jens Geyer <jensg@apache.org> | 2021-11-14 00:20:19 +0100 |
| commit | ea39a14a1fbc8a7683e91ab4bdd23f8b207c8d5d (patch) | |
| tree | a2245670978edb6ab96870bdfb5122d255004053 | |
| parent | 591575a8a891717b002abecef57f99830a8c6752 (diff) | |
| download | thrift-ea39a14a1fbc8a7683e91ab4bdd23f8b207c8d5d.tar.gz | |
THRIFT-5480 TThreadPoolAsyncServer using TFramedTransport mistakenly drops client
Client: netstd
Patch: Ioannis Efthymiou & Jens Geyer
This closes #2478
| -rw-r--r-- | lib/netstd/Thrift/Transport/Layered/TFramedTransport.cs | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/netstd/Thrift/Transport/Layered/TFramedTransport.cs b/lib/netstd/Thrift/Transport/Layered/TFramedTransport.cs index be1513fcf..f56098601 100644 --- a/lib/netstd/Thrift/Transport/Layered/TFramedTransport.cs +++ b/lib/netstd/Thrift/Transport/Layered/TFramedTransport.cs @@ -86,6 +86,7 @@ namespace Thrift.Transport private async ValueTask ReadFrameAsync(CancellationToken cancellationToken) { + UpdateKnownMessageSize(-1); await InnerTransport.ReadAllAsync(HeaderBuf, 0, HeaderSize, cancellationToken); int size = BinaryPrimitives.ReadInt32BigEndian(HeaderBuf); |