Unref the slices if no write will happen.

10 years ago · dbf8fdc073
parent f381f2596f
commit dbf8fdc073
2 changed files with 2 additions and 0 deletions
--- a/src/core/channel/client_channel.c
+++ b/src/core/channel/client_channel.c
@ -144,6 +144,7 @@ static void handle_op_after_cancellation(grpc_call_element *elem,
  call_data *calld = elem->call_data;
  channel_data *chand = elem->channel_data;
  if (op->send_ops) {
+    grpc_stream_ops_unref_owned_objects(op->send_ops->ops, op->send_ops->nops);
    op->on_done_send(op->send_user_data, 0);
  }
  if (op->recv_ops) {
--- a/src/core/surface/lame_client.c
+++ b/src/core/surface/lame_client.c
@ -55,6 +55,7 @@ static void lame_start_transport_op(grpc_call_element *elem,
  channel_data *chand = elem->channel_data;
  GRPC_CALL_LOG_OP(GPR_INFO, elem, op);
  if (op->send_ops) {
+    grpc_stream_ops_unref_owned_objects(op->send_ops->ops, op->send_ops->nops);
    op->on_done_send(op->send_user_data, 0);
  }
  if (op->recv_ops) {