aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/util
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:55:42 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:55:42 -0700
commite7db29f8c74da29d88c1f373ae52a27982eb2c87 (patch)
tree14b82655da1213051cbd3060ad2720ee2fd388f4 /test/core/util
parentf5768a6765cae20477f36b346ce18bfb44fe2e25 (diff)
Move argument passing to start of list
Diffstat (limited to 'test/core/util')
-rw-r--r--test/core/util/port_posix.c12
-rw-r--r--test/core/util/reconnect_server.c8
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 ();