diff options
| author |  Muxi Yan <muxi@users.noreply.github.com> | 2017-04-12 20:24:42 -0700 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-04-12 20:24:42 -0700 |
| commit | 29723ee1ba8a52bc8b373d9bbe3dcfae266b95f1 (patch) | |
| tree | 0cc52f375d6972ad02370e30fa388a20bf87be93 /src/core/ext/transport/cronet | |
| parent | 1838a8f22f24b25304d5289b719c34c124082cb2 (diff) | |
Revert "Revert "Implement lazy deframe""
Diffstat (limited to 'src/core/ext/transport/cronet')
| -rw-r--r-- | src/core/ext/transport/cronet/transport/cronet_transport.c | 17 |
1 files changed, 14 insertions, 3 deletions
diff --git a/src/core/ext/transport/cronet/transport/cronet_transport.c b/src/core/ext/transport/cronet/transport/cronet_transport.c index 88335ecd0b..7896c70f9e 100644 --- a/src/core/ext/transport/cronet/transport/cronet_transport.c +++ b/src/core/ext/transport/cronet/transport/cronet_transport.c @@ -973,9 +973,20 @@ static enum e_op_result execute_stream_op(grpc_exec_ctx *exec_ctx, grpc_slice_buffer write_slice_buffer; grpc_slice slice; grpc_slice_buffer_init(&write_slice_buffer); - grpc_byte_stream_next( - NULL, stream_op->payload->send_message.send_message, &slice, - stream_op->payload->send_message.send_message->length, NULL); + if (1 != grpc_byte_stream_next( + exec_ctx, stream_op->payload->send_message.send_message, + stream_op->payload->send_message.send_message->length, + NULL)) { + /* Should never reach here */ + GPR_ASSERT(false); + } + if (GRPC_ERROR_NONE != + grpc_byte_stream_pull(exec_ctx, + stream_op->payload->send_message.send_message, + &slice)) { + /* Should never reach here */ + GPR_ASSERT(false); + } grpc_slice_buffer_add(&write_slice_buffer, slice); if (write_slice_buffer.count != 1) { /* Empty request not handled yet */ |