From 6afe256b5663ec67308e5ed5cac03ccae5dcd340 Mon Sep 17 00:00:00 2001 From: Craig Tiller Date: Mon, 19 Jan 2015 18:04:23 -0800 Subject: [PATCH] Add helpers for SEND_FINISH --- src/core/channel/channel_stack.c | 9 +++++++++ src/core/channel/channel_stack.h | 1 + 2 files changed, 10 insertions(+) diff --git a/src/core/channel/channel_stack.c b/src/core/channel/channel_stack.c index c70b565d2b9..2721ed8cfc3 100644 --- a/src/core/channel/channel_stack.c +++ b/src/core/channel/channel_stack.c @@ -232,3 +232,12 @@ void grpc_call_element_send_cancel(grpc_call_element *cur_elem) { cancel_op.user_data = NULL; grpc_call_next_op(cur_elem, &cancel_op); } + +void grpc_call_element_send_finish(grpc_call_element *cur_elem) { + grpc_call_op cancel_op; + cancel_op.type = GRPC_SEND_FINISH; + cancel_op.dir = GRPC_CALL_DOWN; + cancel_op.done_cb = do_nothing; + cancel_op.user_data = NULL; + grpc_call_next_op(cur_elem, &cancel_op); +} diff --git a/src/core/channel/channel_stack.h b/src/core/channel/channel_stack.h index 8d3ed0aeede..0bc31ffeaf4 100644 --- a/src/core/channel/channel_stack.h +++ b/src/core/channel/channel_stack.h @@ -295,6 +295,7 @@ void grpc_call_element_send_metadata(grpc_call_element *cur_elem, void grpc_call_element_recv_metadata(grpc_call_element *cur_elem, grpc_mdelem *elem); void grpc_call_element_send_cancel(grpc_call_element *cur_elem); +void grpc_call_element_send_finish(grpc_call_element *cur_elem); #ifdef GRPC_CHANNEL_STACK_TRACE #define GRPC_CALL_LOG_OP(sev, elem, op) grpc_call_log_op(sev, elem, op)