add missing refs

1 files changed, 4 insertions, 3 deletions

diff --git a/src/core/ext/filters/http/message_compress/message_compress_filter.c b/src/core/ext/filters/http/message_compress/message_compress_filter.c
index e1267294ec..f414a60eee 100644
--- a/src/core/ext/filters/http/message_compress/message_compress_filter.c
+++ b/src/core/ext/filters/http/message_compress/message_compress_filter.c
@@ -295,9 +295,9 @@ static void compress_start_transport_stream_op_batch(
         if ((cur & CANCELLED_BIT) == 0) {
           grpc_transport_stream_op_batch_finish_with_failure(
               exec_ctx, (grpc_transport_stream_op_batch *)cur,
-              op->payload->cancel_stream.cancel_error);
+              GRPC_ERROR_REF(op->payload->cancel_stream.cancel_error));
         } else {
-          GRPC_ERROR_UNREF((grpc_error*)(cur & ~CANCELLED_BIT));
+          GRPC_ERROR_UNREF((grpc_error *)(cur & ~CANCELLED_BIT));
         }
         break;
     }
@@ -354,7 +354,8 @@ static void compress_start_transport_stream_op_batch(
       default:
         if (cur & CANCELLED_BIT) {
           grpc_transport_stream_op_batch_finish_with_failure(
-              exec_ctx, op, (grpc_error *)(cur & ~CANCELLED_BIT));
+              exec_ctx, op,
+              GRPC_ERROR_REF((grpc_error *)(cur & ~CANCELLED_BIT)));
         } else {
           /* >1 send_message concurrently */
           GPR_UNREACHABLE_CODE(break);