diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-09-22 10:53:14 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-09-22 10:53:14 -0700 |
| commit | 098047b53abfb3142b0dc9eca83564cd565902b7 (patch) | |
| tree | 463bb5d60f365f4c7a5e3a6e77ff77bc09ae80c2 /src/core/surface/server.c | |
| parent | 9fa914e554826f3d11663263498df829e0b1b94e (diff) | |
Rename run
Diffstat (limited to 'src/core/surface/server.c')
| -rw-r--r-- | src/core/surface/server.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/core/surface/server.c b/src/core/surface/server.c index 0b05720fa7..940050e9d9 100644 --- a/src/core/surface/server.c +++ b/src/core/surface/server.c @@ -994,7 +994,7 @@ grpc_server_start (grpc_server * server) l->start (server, l->arg, server->pollsets, server->cq_count, &closure_list); } - grpc_closure_list_run (&closure_list); + grpc_exec_ctx_finish (&exec_ctx); } void @@ -1161,7 +1161,7 @@ grpc_server_shutdown_and_notify (grpc_server * server, grpc_completion_queue * c channel_broadcaster_shutdown (&broadcaster, 1, 0, &closure_list); done: - grpc_closure_list_run (&closure_list); + grpc_exec_ctx_finish (&exec_ctx); } void @@ -1175,7 +1175,7 @@ grpc_server_cancel_all_calls (grpc_server * server) gpr_mu_unlock (&server->mu_global); channel_broadcaster_shutdown (&broadcaster, 0, 1, &closure_list); - grpc_closure_list_run (&closure_list); + grpc_exec_ctx_finish (&exec_ctx); } void @@ -1198,7 +1198,7 @@ grpc_server_destroy (grpc_server * server) gpr_mu_unlock (&server->mu_global); server_unref (server, &closure_list); - grpc_closure_list_run (&closure_list); + grpc_exec_ctx_finish (&exec_ctx); } void @@ -1299,7 +1299,7 @@ grpc_server_request_call (grpc_server * server, grpc_call ** call, grpc_call_det rc->data.batch.initial_metadata = initial_metadata; error = queue_call_request (server, rc, &closure_list); done: - grpc_closure_list_run (&closure_list); + grpc_exec_ctx_finish (&exec_ctx); return error; } @@ -1329,7 +1329,7 @@ grpc_server_request_registered_call (grpc_server * server, void *rm, grpc_call * rc->data.registered.optional_payload = optional_payload; error = queue_call_request (server, rc, &closure_list); done: - grpc_closure_list_run (&closure_list); + grpc_exec_ctx_finish (&exec_ctx); return error; } |