diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-07-23 17:00:12 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-07-23 17:00:12 -0700 |
| commit | a1b820e981187036835ae0ff43b7b5a17af8e131 (patch) | |
| tree | 397dfce9465a36ec907a35ebcc6c43ea977a98d0 /src/core/channel/compress_filter.c | |
| parent | b5bbf667798f28d960edd6f1145d9479a3b39831 (diff) | |
| parent | 518e3fe700015759cedea57f2e4febf300d57ba7 (diff) | |
Merge pull request #2586 from dgquintas/compress_flag_reset
Fixes for streaming compression.
Diffstat (limited to 'src/core/channel/compress_filter.c')
| -rw-r--r-- | src/core/channel/compress_filter.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/core/channel/compress_filter.c b/src/core/channel/compress_filter.c index 14e8ca7325..4bf24e7db3 100644 --- a/src/core/channel/compress_filter.c +++ b/src/core/channel/compress_filter.c @@ -174,6 +174,8 @@ static void process_send_ops(grpc_call_element *elem, size_t i; int did_compress = 0; + /* In streaming calls, we need to reset the previously accumulated slices */ + gpr_slice_buffer_reset_and_unref(&calld->slices); for (i = 0; i < send_ops->nops; ++i) { grpc_stream_op *sop = &send_ops->ops[i]; switch (sop->type) { |