Skip to content
Snippets Groups Projects
Commit 518e3fe7 authored by David Garcia Quintas's avatar David Garcia Quintas
Browse files

Fixes for streaming compression.

parent 40d808ff
No related branches found
No related tags found
No related merge requests found
...@@ -174,6 +174,8 @@ static void process_send_ops(grpc_call_element *elem, ...@@ -174,6 +174,8 @@ static void process_send_ops(grpc_call_element *elem,
size_t i; size_t i;
int did_compress = 0; 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) { for (i = 0; i < send_ops->nops; ++i) {
grpc_stream_op *sop = &send_ops->ops[i]; grpc_stream_op *sop = &send_ops->ops[i];
switch (sop->type) { switch (sop->type) {
......
...@@ -92,7 +92,7 @@ grpc_chttp2_parse_error grpc_chttp2_data_parser_parse( ...@@ -92,7 +92,7 @@ grpc_chttp2_parse_error grpc_chttp2_data_parser_parse(
p->frame_type = *cur; p->frame_type = *cur;
switch (p->frame_type) { switch (p->frame_type) {
case 0: case 0:
/* noop */ p->is_frame_compressed = 0; /* GPR_FALSE */
break; break;
case 1: case 1:
p->is_frame_compressed = 1; /* GPR_TRUE */ p->is_frame_compressed = 1; /* GPR_TRUE */
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment