diff options
author | Nicolas "Pixel" Noble <pixel@nobis-crew.org> | 2016-04-14 06:17:58 +0200 |
---|---|---|
committer | Nicolas "Pixel" Noble <pixel@nobis-crew.org> | 2016-04-14 06:17:58 +0200 |
commit | 90f03b5d9cf41d3465e2a002476f3d477615ff91 (patch) | |
tree | 8943b8d559cc57bb6f4ecdbc293a8c0e8029f901 | |
parent | 04f812b4e6f50f4ca36a87594332e4e02a5d3cf9 (diff) |
Code formatting.
-rw-r--r-- | test/core/surface/concurrent_connectivity_test.c | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/test/core/surface/concurrent_connectivity_test.c b/test/core/surface/concurrent_connectivity_test.c index 1753623fcd..2d060444f7 100644 --- a/test/core/surface/concurrent_connectivity_test.c +++ b/test/core/surface/concurrent_connectivity_test.c @@ -60,7 +60,7 @@ static int detag(void *p) { return (int)(uintptr_t)p; } void create_loop_destroy(void *addr) { for (int i = 0; i < NUM_OUTER_LOOPS; ++i) { grpc_completion_queue *cq = grpc_completion_queue_create(NULL); - grpc_channel *chan = grpc_insecure_channel_create((char*)addr, NULL, NULL); + grpc_channel *chan = grpc_insecure_channel_create((char *)addr, NULL, NULL); for (int j = 0; j < NUM_INNER_LOOPS; ++j) { gpr_timespec later_time = GRPC_TIMEOUT_MILLIS_TO_DEADLINE(DELAY_MILLIS); @@ -87,7 +87,7 @@ struct server_thread_args { }; void server_thread(void *vargs) { - struct server_thread_args *args = (struct server_thread_args*)vargs; + struct server_thread_args *args = (struct server_thread_args *)vargs; grpc_event ev; gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); ev = grpc_completion_queue_next(args->cq, deadline, NULL); @@ -97,7 +97,7 @@ void server_thread(void *vargs) { static void on_connect(grpc_exec_ctx *exec_ctx, void *vargs, grpc_endpoint *tcp, grpc_tcp_server_acceptor *acceptor) { - struct server_thread_args *args = (struct server_thread_args*)vargs; + struct server_thread_args *args = (struct server_thread_args *)vargs; (void)acceptor; grpc_endpoint_shutdown(exec_ctx, tcp); grpc_endpoint_destroy(exec_ctx, tcp); @@ -105,7 +105,7 @@ static void on_connect(grpc_exec_ctx *exec_ctx, void *vargs, grpc_endpoint *tcp, } void bad_server_thread(void *vargs) { - struct server_thread_args *args = (struct server_thread_args*)vargs; + struct server_thread_args *args = (struct server_thread_args *)vargs; grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; struct sockaddr_storage addr; @@ -124,7 +124,8 @@ void bad_server_thread(void *vargs) { gpr_mu_lock(args->mu); while (gpr_atm_acq_load(&args->stop) == 0) { gpr_timespec now = gpr_now(GPR_CLOCK_MONOTONIC); - gpr_timespec deadline = gpr_time_add(now, gpr_time_from_millis(100, GPR_TIMESPAN)); + gpr_timespec deadline = + gpr_time_add(now, gpr_time_from_millis(100, GPR_TIMESPAN)); grpc_pollset_worker *worker = NULL; grpc_pollset_work(&exec_ctx, args->pollset, &worker, now, deadline); @@ -155,7 +156,6 @@ int main(int argc, char **argv) { gpr_thd_options options = gpr_thd_options_default(); gpr_thd_options_set_joinable(&options); - /* First round, no server */ gpr_log(GPR_DEBUG, "Wave 1"); for (size_t i = 0; i < NUM_THREADS; ++i) { @@ -166,7 +166,6 @@ int main(int argc, char **argv) { } gpr_free(localhost); - /* Second round, actual grpc server */ gpr_log(GPR_DEBUG, "Wave 2"); int port = grpc_pick_unused_port_or_die(); @@ -191,7 +190,6 @@ int main(int argc, char **argv) { grpc_completion_queue_destroy(args.cq); gpr_free(args.addr); - /* Third round, bogus tcp server */ gpr_log(GPR_DEBUG, "Wave 3"); args.pollset = gpr_malloc(grpc_pollset_size()); |