aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorGravatar Mark D. Roth <roth@google.com>2016-09-07 13:35:31 -0700
committerGravatar Mark D. Roth <roth@google.com>2016-09-07 13:35:31 -0700
commitf7dd851c2a00d34e51d34555deac5c9bbee528c5 (patch)
treec50862a14bc2b596732f55fae6ac7e891682689f
parent697a1f602325518cdd4e48a4ef44e49a09f0579a (diff)
Remove unused code for chaining on_complete closures in call.c.
-rw-r--r--src/core/lib/surface/call.c7
1 files changed, 2 insertions, 5 deletions
diff --git a/src/core/lib/surface/call.c b/src/core/lib/surface/call.c
index 7ab97f3140..15c002015c 100644
--- a/src/core/lib/surface/call.c
+++ b/src/core/lib/surface/call.c
@@ -751,7 +751,6 @@ typedef struct termination_closure {
grpc_closure closure;
grpc_call *call;
grpc_error *error;
- grpc_closure *op_closure;
enum { TC_CANCEL, TC_CLOSE } type;
} termination_closure;
@@ -767,13 +766,12 @@ static void done_termination(grpc_exec_ctx *exec_ctx, void *tcp,
break;
}
GRPC_ERROR_UNREF(tc->error);
- grpc_exec_ctx_sched(exec_ctx, tc->op_closure, GRPC_ERROR_NONE, NULL);
gpr_free(tc);
}
static void send_cancel(grpc_exec_ctx *exec_ctx, void *tcp, grpc_error *error) {
- grpc_transport_stream_op op;
termination_closure *tc = tcp;
+ grpc_transport_stream_op op;
memset(&op, 0, sizeof(op));
op.cancel_error = tc->error;
/* reuse closure to catch completion */
@@ -783,13 +781,12 @@ static void send_cancel(grpc_exec_ctx *exec_ctx, void *tcp, grpc_error *error) {
}
static void send_close(grpc_exec_ctx *exec_ctx, void *tcp, grpc_error *error) {
- grpc_transport_stream_op op;
termination_closure *tc = tcp;
+ grpc_transport_stream_op op;
memset(&op, 0, sizeof(op));
op.close_error = tc->error;
/* reuse closure to catch completion */
grpc_closure_init(&tc->closure, done_termination, tc);
- tc->op_closure = op.on_complete;
op.on_complete = &tc->closure;
execute_op(exec_ctx, tc->call, &op);
}