diff options
| -rw-r--r-- | src/core/ext/transport/chttp2/transport/writing.c | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/core/ext/transport/chttp2/transport/writing.c b/src/core/ext/transport/chttp2/transport/writing.c index 0ae10ee883..b6bf0450ee 100644 --- a/src/core/ext/transport/chttp2/transport/writing.c +++ b/src/core/ext/transport/chttp2/transport/writing.c @@ -323,10 +323,12 @@ grpc_chttp2_begin_write_result grpc_chttp2_begin_write( s->flow_controlled_buffer.length == 0 && s->fetching_send_message == NULL); if (is_last_data_frame && s->stream_compression_ctx != NULL) { - GPR_ASSERT(grpc_stream_compress( - s->stream_compression_ctx, &s->flow_controlled_buffer, - s->compressed_data_buffer, NULL, MAX_SIZE_T, - GRPC_STREAM_COMPRESSION_FLUSH_FINISH)); + if (!grpc_stream_compress( + s->stream_compression_ctx, &s->flow_controlled_buffer, + s->compressed_data_buffer, NULL, MAX_SIZE_T, + GRPC_STREAM_COMPRESSION_FLUSH_FINISH)) { + gpr_log(GPR_ERROR, "Stream compression failed."); + } grpc_stream_compression_context_destroy( s->stream_compression_ctx); s->stream_compression_ctx = NULL; |