diff options
| author |  Mark D. Roth <roth@google.com> | 2016-09-20 08:13:16 -0700 |
|---|---|---|
| committer | Mark D. Roth <roth@google.com> | 2016-09-20 08:13:16 -0700 |
| commit | 219db50d39c2b5754e86838a56d7c8b0bc7273df (patch) | |
| tree | 40320fd518450dc167373ac90b7213cd480d67d9 | |
| parent | 9710e2cb719572e63d219a9f0580fbb97b91cc44 (diff) | |
Fix message size filter to use close instead of cancel.
| -rw-r--r-- | src/core/lib/channel/message_size_filter.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/core/lib/channel/message_size_filter.c b/src/core/lib/channel/message_size_filter.c index 6613785dea..a254fe3997 100644 --- a/src/core/lib/channel/message_size_filter.c +++ b/src/core/lib/channel/message_size_filter.c @@ -74,7 +74,7 @@ static void recv_message_ready(grpc_exec_ctx* exec_ctx, void* user_data, (*calld->recv_message)->length, (unsigned long)chand->max_recv_size); gpr_slice message = gpr_slice_from_copied_string(message_string); gpr_free(message_string); - grpc_call_element_send_cancel_with_message( + grpc_call_element_send_close_with_message( exec_ctx, elem, GRPC_STATUS_INVALID_ARGUMENT, &message); } // Invoke the next callback. @@ -95,7 +95,7 @@ static void start_transport_stream_op(grpc_exec_ctx* exec_ctx, op->send_message->length, (unsigned long)chand->max_send_size); gpr_slice message = gpr_slice_from_copied_string(message_string); gpr_free(message_string); - grpc_call_element_send_cancel_with_message( + grpc_call_element_send_close_with_message( exec_ctx, elem, GRPC_STATUS_INVALID_ARGUMENT, &message); } // Inject callback for receiving a message. |