Add helpers for SEND_FINISH

10 years ago · 6afe256b56
parent 12b533de59
commit 6afe256b56
2 changed files with 10 additions and 0 deletions
--- 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);
+}
--- 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)