diff options
author | Craig Tiller <ctiller@google.com> | 2015-09-22 10:55:42 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-09-22 10:55:42 -0700 |
commit | e7db29f8c74da29d88c1f373ae52a27982eb2c87 (patch) | |
tree | 14b82655da1213051cbd3060ad2720ee2fd388f4 /test/core/util | |
parent | f5768a6765cae20477f36b346ce18bfb44fe2e25 (diff) |
Move argument passing to start of list
Diffstat (limited to 'test/core/util')
-rw-r--r-- | test/core/util/port_posix.c | 12 | ||||
-rw-r--r-- | test/core/util/reconnect_server.c | 8 |
2 files changed, 10 insertions, 10 deletions
diff --git a/test/core/util/port_posix.c b/test/core/util/port_posix.c index a598ea818b..bce72f4a0c 100644 --- a/test/core/util/port_posix.c +++ b/test/core/util/port_posix.c @@ -116,18 +116,18 @@ free_port_using_server (char *server, int port) req.path = path; grpc_httpcli_context_init (&context); - grpc_httpcli_get (&context, &pr.pollset, &req, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (10), freed_port_from_server, &pr, &closure_list); + grpc_httpcli_get (&context, &pr.pollset, &req, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (&exec_ctx, 10), freed_port_from_server, &pr); gpr_mu_lock (GRPC_POLLSET_MU (&pr.pollset)); while (!pr.done) { grpc_pollset_worker worker; - grpc_pollset_work (&pr.pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_SECONDS_TO_DEADLINE (1), &closure_list); + grpc_pollset_work (&pr.pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_SECONDS_TO_DEADLINE (&exec_ctx, 1)); } gpr_mu_unlock (GRPC_POLLSET_MU (&pr.pollset)); grpc_httpcli_context_destroy (&context); grpc_exec_ctx_finish (&exec_ctx); - grpc_pollset_shutdown (&pr.pollset, &shutdown_closure, &closure_list); + grpc_pollset_shutdown (&exec_ctx, &pr.pollset, &shutdown_closure); grpc_exec_ctx_finish (&exec_ctx); gpr_free (path); } @@ -287,18 +287,18 @@ pick_port_using_server (char *server) req.path = "/get"; grpc_httpcli_context_init (&context); - grpc_httpcli_get (&context, &pr.pollset, &req, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (10), got_port_from_server, &pr, &closure_list); + grpc_httpcli_get (&context, &pr.pollset, &req, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (&exec_ctx, 10), got_port_from_server, &pr); grpc_exec_ctx_finish (&exec_ctx); gpr_mu_lock (GRPC_POLLSET_MU (&pr.pollset)); while (pr.port == -1) { grpc_pollset_worker worker; - grpc_pollset_work (&pr.pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_SECONDS_TO_DEADLINE (1), &closure_list); + grpc_pollset_work (&pr.pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_SECONDS_TO_DEADLINE (&exec_ctx, 1)); } gpr_mu_unlock (GRPC_POLLSET_MU (&pr.pollset)); grpc_httpcli_context_destroy (&context); - grpc_pollset_shutdown (&pr.pollset, &shutdown_closure, &closure_list); + grpc_pollset_shutdown (&exec_ctx, &pr.pollset, &shutdown_closure); grpc_exec_ctx_finish (&exec_ctx); return pr.port; diff --git a/test/core/util/reconnect_server.c b/test/core/util/reconnect_server.c index 4a1f589b82..761ef233ac 100644 --- a/test/core/util/reconnect_server.c +++ b/test/core/util/reconnect_server.c @@ -140,7 +140,7 @@ reconnect_server_start (reconnect_server * server, int port) port_added = grpc_tcp_server_add_port (server->tcp_server, &addr, sizeof (addr)); GPR_ASSERT (port_added == port); - grpc_tcp_server_start (server->tcp_server, server->pollsets, 1, on_connect, server, &closure_list); + grpc_tcp_server_start (&exec_ctx, server->tcp_server, server->pollsets, 1, on_connect, server); gpr_log (GPR_INFO, "reconnect tcp server listening on 0.0.0.0:%d", port); grpc_exec_ctx_finish (&exec_ctx); @@ -154,7 +154,7 @@ reconnect_server_poll (reconnect_server * server, int seconds) gpr_time_from_seconds (seconds, GPR_TIMESPAN)); grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; gpr_mu_lock (GRPC_POLLSET_MU (&server->pollset)); - grpc_pollset_work (&server->pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list); + grpc_pollset_work (&server->pollset, &worker, gpr_now (&exec_ctx, GPR_CLOCK_MONOTONIC), deadline); gpr_mu_unlock (GRPC_POLLSET_MU (&server->pollset)); grpc_exec_ctx_finish (&exec_ctx); } @@ -186,9 +186,9 @@ reconnect_server_destroy (reconnect_server * server) grpc_closure do_nothing_closure[2]; grpc_closure_init (&do_nothing_closure[0], do_nothing, NULL); grpc_closure_init (&do_nothing_closure[1], do_nothing, NULL); - grpc_tcp_server_destroy (server->tcp_server, &do_nothing_closure[0], &closure_list); + grpc_tcp_server_destroy (&exec_ctx, server->tcp_server, &do_nothing_closure[0]); reconnect_server_clear_timestamps (server); - grpc_pollset_shutdown (&server->pollset, &do_nothing_closure[1], &closure_list); + grpc_pollset_shutdown (&exec_ctx, &server->pollset, &do_nothing_closure[1]); grpc_exec_ctx_finish (&exec_ctx); grpc_pollset_destroy (&server->pollset); grpc_shutdown (); |