Skip to content
Snippets Groups Projects
Commit 46a36d7c authored by Craig Tiller's avatar Craig Tiller
Browse files

Merge pull request #1778 from yang-g/test

Unref the slices if no write will happen.
parents e396a3f3 dbf8fdc0
No related branches found
No related tags found
No related merge requests found
...@@ -144,6 +144,7 @@ static void handle_op_after_cancellation(grpc_call_element *elem, ...@@ -144,6 +144,7 @@ static void handle_op_after_cancellation(grpc_call_element *elem,
call_data *calld = elem->call_data; call_data *calld = elem->call_data;
channel_data *chand = elem->channel_data; channel_data *chand = elem->channel_data;
if (op->send_ops) { 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); op->on_done_send(op->send_user_data, 0);
} }
if (op->recv_ops) { if (op->recv_ops) {
......
...@@ -55,6 +55,7 @@ static void lame_start_transport_op(grpc_call_element *elem, ...@@ -55,6 +55,7 @@ static void lame_start_transport_op(grpc_call_element *elem,
channel_data *chand = elem->channel_data; channel_data *chand = elem->channel_data;
GRPC_CALL_LOG_OP(GPR_INFO, elem, op); GRPC_CALL_LOG_OP(GPR_INFO, elem, op);
if (op->send_ops) { 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); op->on_done_send(op->send_user_data, 0);
} }
if (op->recv_ops) { if (op->recv_ops) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment