Chiebot-Mirror
/
grpc
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Rename run

Browse Source
pull/3423/head
Craig Tiller 10 years ago
parent 9fa914e554
commit 098047b53a
40 changed files with 138 additions and 138 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 4
      src/core/iomgr/iomgr.c
  2. 2
      src/core/iomgr/resolve_address_posix.c
  3. 2
      src/core/security/credentials.c
  4. 4
      src/core/security/google_default_credentials.c
  5. 2
      src/core/security/server_auth_filter.c
  6. 4
      src/core/security/server_secure_chttp2.c
  7. 10
      src/core/surface/call.c
  8. 2
      src/core/surface/channel.c
  9. 4
      src/core/surface/channel_connectivity.c
  10. 2
      src/core/surface/channel_create.c
  11. 6
      src/core/surface/completion_queue.c
  12. 2
      src/core/surface/lame_client.c
  13. 2
      src/core/surface/secure_channel_create.c
  14. 12
      src/core/surface/server.c
  15. 2
      src/core/surface/server_chttp2.c
  16. 12
      test/core/bad_client/bad_client.c
  17. 2
      test/core/client_config/lb_policies_test.c
  18. 8
      test/core/end2end/fixtures/h2_sockpair+trace.c
  19. 6
      test/core/end2end/fixtures/h2_sockpair.c
  20. 6
      test/core/end2end/fixtures/h2_sockpair_1byte.c
  21. 6
      test/core/httpcli/httpcli_test.c
  22. 14
      test/core/iomgr/alarm_list_test.c
  23. 4
      test/core/iomgr/endpoint_pair_test.c
  24. 8
      test/core/iomgr/endpoint_tests.c
  25. 2
      test/core/iomgr/fd_conservation_posix_test.c
  26. 14
      test/core/iomgr/fd_posix_test.c
  27. 10
      test/core/iomgr/tcp_client_posix_test.c
  28. 18
      test/core/iomgr/tcp_posix_test.c
  29. 12
      test/core/iomgr/tcp_server_posix_test.c
  30. 8
      test/core/iomgr/udp_server_test.c
  31. 6
      test/core/iomgr/workqueue_test.c
  32. 34
      test/core/security/credentials_test.c
  33. 14
      test/core/security/jwt_verifier_test.c
  34. 4
      test/core/security/oauth2_utils.c
  35. 2
      test/core/security/print_google_default_creds_token.c
  36. 8
      test/core/security/secure_endpoint_test.c
  37. 2
      test/core/security/verify_jwt.c
  38. 2
      test/core/surface/completion_queue_test.c
  39. 8
      test/core/util/port_posix.c
  40. 6
      test/core/util/reconnect_server.c

4
src/core/iomgr/iomgr.c
Unescape View File

@ -116,7 +116,7 @@ grpc_iomgr_shutdown (void)
if (grpc_alarm_check (gpr_inf_future (GPR_CLOCK_MONOTONIC), NULL, &closure_list))
{
gpr_mu_unlock (&g_mu);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (&g_mu);
continue;
}
@ -143,7 +143,7 @@ grpc_iomgr_shutdown (void)
gpr_mu_unlock (&g_mu);
grpc_alarm_list_shutdown (&closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* ensure all threads have left g_mu */
gpr_mu_lock (&g_mu);

2
src/core/iomgr/resolve_address_posix.c
Unescape View File

@ -169,7 +169,7 @@ do_request_thread (void *rp)
cb (arg, resolved, &closure_list);
grpc_iomgr_unregister_object (&r->iomgr_object);
gpr_free (r);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void

2
src/core/security/credentials.c
Unescape View File

@ -812,7 +812,7 @@ on_simulated_token_fetch_done (void *user_data)
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
r->cb (r->user_data, c->md_store->entries, c->md_store->num_entries, GRPC_CREDENTIALS_OK, &closure_list);
grpc_credentials_metadata_request_destroy (r);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void

4
src/core/security/google_default_credentials.c
Unescape View File

@ -123,7 +123,7 @@ is_stack_running_on_compute_engine (void)
grpc_httpcli_get (&context, &detector.pollset, &request, gpr_time_add (gpr_now (GPR_CLOCK_REALTIME), max_detection_delay), on_compute_engine_detection_http_response, &detector, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* Block until we get the response. This is not ideal but this should only be
called once for the lifetime of the process by the default credentials. */
@ -138,7 +138,7 @@ is_stack_running_on_compute_engine (void)
grpc_httpcli_context_destroy (&context);
grpc_closure_init (&destroy_closure, destroy_pollset, &detector.pollset);
grpc_pollset_shutdown (&detector.pollset, &destroy_closure, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return detector.success;
}

2
src/core/security/server_auth_filter.c
Unescape View File

@ -147,7 +147,7 @@ on_md_processing_done (void *user_data, const grpc_metadata * consumed_md, size_
grpc_call_next_op (elem, &calld->transport_op, &closure_list);
}
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void

4
src/core/security/server_secure_chttp2.c
Unescape View File

@ -302,7 +302,7 @@ grpc_server_add_secure_http2_port (grpc_server * server, const char *addr, grpc_
/* Register with the server only upon success */
grpc_server_add_listener (server, state, start, destroy, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return port_num;
/* Error path: cleanup and return */
@ -323,6 +323,6 @@ error:
{
gpr_free (state);
}
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return 0;
}

10
src/core/surface/call.c
Unescape View File

@ -404,7 +404,7 @@ grpc_call_create (grpc_channel * channel, grpc_call * parent_call, gpr_uint32 pr
{
set_deadline_alarm (call, send_deadline, &closure_list);
}
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return call;
}
@ -1426,7 +1426,7 @@ grpc_call_destroy (grpc_call * c)
if (cancel)
grpc_call_cancel (c, NULL);
GRPC_CALL_INTERNAL_UNREF (c, "destroy", &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
grpc_call_error
@ -1445,7 +1445,7 @@ grpc_call_cancel_with_status (grpc_call * c, grpc_status_code status, const char
lock (c);
r = cancel_with_status (c, status, description);
unlock (c, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return r;
}
@ -1517,7 +1517,7 @@ grpc_call_get_peer (grpc_call * call)
grpc_call_element *elem = CALL_ELEM_FROM_CALL (call, 0);
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
char *result = elem->filter->get_peer (elem, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return result;
}
@ -1994,7 +1994,7 @@ grpc_call_start_batch (grpc_call * call, const grpc_op * ops, size_t nops, void
error = grpc_call_start_ioreq_and_call_back (call, reqs, out, finish_func, tag, &closure_list);
done:
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return error;
}

2
src/core/surface/channel.c
Unescape View File

@ -326,7 +326,7 @@ grpc_channel_destroy (grpc_channel * channel)
GRPC_CHANNEL_INTERNAL_UNREF (channel, "channel", &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
grpc_channel_stack *

4
src/core/surface/channel_connectivity.c
Unescape View File

@ -53,7 +53,7 @@ grpc_channel_check_connectivity_state (grpc_channel * channel, int try_to_connec
return GRPC_CHANNEL_FATAL_FAILURE;
}
state = grpc_client_channel_check_connectivity_state (client_channel_elem, try_to_connect, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return state;
}
@ -209,5 +209,5 @@ grpc_channel_watch_connectivity_state (grpc_channel * channel, grpc_connectivity
grpc_client_channel_watch_connectivity_state (client_channel_elem, &w->state, &w->on_complete, &closure_list);
}
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}

2
src/core/surface/channel_create.c
Unescape View File

@ -228,7 +228,7 @@ grpc_insecure_channel_create (const char *target, const grpc_channel_args * args
GRPC_RESOLVER_UNREF (resolver, "create", &closure_list);
grpc_subchannel_factory_unref (&f->base, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return channel;
}

6
src/core/surface/completion_queue.c
Unescape View File

@ -237,7 +237,7 @@ grpc_completion_queue_next (grpc_completion_queue * cc, gpr_timespec deadline, v
}
GRPC_SURFACE_TRACE_RETURNED_EVENT (cc, &ret);
GRPC_CQ_INTERNAL_UNREF (cc, "next");
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return ret;
}
@ -341,7 +341,7 @@ grpc_completion_queue_pluck (grpc_completion_queue * cc, void *tag, gpr_timespec
done:
GRPC_SURFACE_TRACE_RETURNED_EVENT (cc, &ret);
GRPC_CQ_INTERNAL_UNREF (cc, "pluck");
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return ret;
}
@ -368,7 +368,7 @@ grpc_completion_queue_shutdown (grpc_completion_queue * cc)
gpr_mu_unlock (GRPC_POLLSET_MU (&cc->pollset));
grpc_pollset_shutdown (&cc->pollset, &cc->pollset_destroy_done, &closure_list);
}
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void

2
src/core/surface/lame_client.c
Unescape View File

@ -171,6 +171,6 @@ grpc_lame_client_channel_create (const char *target, grpc_status_code error_code
chand = (channel_data *) elem->channel_data;
chand->error_code = error_code;
chand->error_message = error_message;
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return channel;
}

2
src/core/surface/secure_channel_create.c
Unescape View File

@ -313,7 +313,7 @@ grpc_secure_channel_create (grpc_credentials * creds, const char *target, const
grpc_channel_args_destroy (new_args_from_connector);
}
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return channel;
}

12
src/core/surface/server.c
Unescape View File

@ -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;
}

2
src/core/surface/server_chttp2.c
Unescape View File

@ -151,6 +151,6 @@ error:
port_num = 0;
done:
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return port_num;
}

12
test/core/bad_client/bad_client.c
Unescape View File

@ -78,7 +78,7 @@ server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx
};
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
grpc_server_setup_transport (a->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (a->server), &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void
@ -119,7 +119,7 @@ grpc_run_bad_client_test (grpc_bad_client_server_side_validator validator, const
transport = grpc_create_chttp2_transport (NULL, sfd.server, mdctx, 0, &closure_list);
server_setup_transport (&a, transport, mdctx);
grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* Bind everything into the same pollset */
grpc_endpoint_add_to_pollset (sfd.client, grpc_cq_pollset (a.cq), &closure_list);
@ -137,7 +137,7 @@ grpc_run_bad_client_test (grpc_bad_client_server_side_validator validator, const
/* Write data */
grpc_endpoint_write (sfd.client, &outgoing, &done_write_closure, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* Await completion */
GPR_ASSERT (gpr_event_wait (&a.done_write, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (5)));
@ -146,7 +146,7 @@ grpc_run_bad_client_test (grpc_bad_client_server_side_validator validator, const
{
grpc_endpoint_shutdown (sfd.client, &closure_list);
grpc_endpoint_destroy (sfd.client, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
sfd.client = NULL;
}
@ -157,7 +157,7 @@ grpc_run_bad_client_test (grpc_bad_client_server_side_validator validator, const
{
grpc_endpoint_shutdown (sfd.client, &closure_list);
grpc_endpoint_destroy (sfd.client, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
grpc_server_shutdown_and_notify (a.server, a.cq, NULL);
GPR_ASSERT (grpc_completion_queue_pluck (a.cq, NULL, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (1), NULL).type == GRPC_OP_COMPLETE);
@ -165,6 +165,6 @@ grpc_run_bad_client_test (grpc_bad_client_server_side_validator validator, const
grpc_completion_queue_destroy (a.cq);
gpr_slice_buffer_destroy (&outgoing);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_shutdown ();
}

2
test/core/client_config/lb_policies_test.c
Unescape View File

@ -423,7 +423,7 @@ assert_channel_connectivity (grpc_channel * ch, size_t num_accepted_conn_states,
client_channel_filter = grpc_channel_stack_last_element (client_stack);
actual_conn_state = grpc_client_channel_check_connectivity_state (client_channel_filter, 0 /* don't try to connect */ , &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
va_start (ap, accepted_conn_state);
for (i = 0; i < num_accepted_conn_states; i++)
{

8
test/core/end2end/fixtures/h2_sockpair+trace.c
Unescape View File

@ -66,7 +66,7 @@ server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx
};
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
grpc_server_setup_transport (f->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (f->server), &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
typedef struct
@ -122,7 +122,7 @@ chttp2_init_client_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
client_setup_transport (&cs, transport, mdctx, &closure_list);
GPR_ASSERT (f->client);
grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -139,7 +139,7 @@ chttp2_init_server_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
transport = grpc_create_chttp2_transport (server_args, sfd->server, mdctx, 0, &closure_list);
server_setup_transport (f, transport, mdctx);
grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -172,7 +172,7 @@ main (int argc, char **argv)
grpc_test_init (argc, argv);
grpc_init ();
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
GPR_ASSERT (0 == grpc_tracer_set_enabled ("also-doesnt-exist", 0));
GPR_ASSERT (1 == grpc_tracer_set_enabled ("http", 1));

6
test/core/end2end/fixtures/h2_sockpair.c
Unescape View File

@ -65,7 +65,7 @@ server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx
};
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
grpc_server_setup_transport (f->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (f->server), &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
typedef struct
@ -121,7 +121,7 @@ chttp2_init_client_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
client_setup_transport (&cs, transport, mdctx, &closure_list);
GPR_ASSERT (f->client);
grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -138,7 +138,7 @@ chttp2_init_server_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
transport = grpc_create_chttp2_transport (server_args, sfd->server, mdctx, 0, &closure_list);
server_setup_transport (f, transport, mdctx);
grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void

6
test/core/end2end/fixtures/h2_sockpair_1byte.c
Unescape View File

@ -65,7 +65,7 @@ server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx
};
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
grpc_server_setup_transport (f->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (f->server), &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
typedef struct
@ -121,7 +121,7 @@ chttp2_init_client_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
client_setup_transport (&cs, transport, mdctx, &closure_list);
GPR_ASSERT (f->client);
grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -138,7 +138,7 @@ chttp2_init_server_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
transport = grpc_create_chttp2_transport (server_args, sfd->server, mdctx, 0, &closure_list);
server_setup_transport (f, transport, mdctx);
grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void

6
test/core/httpcli/httpcli_test.c
Unescape View File

@ -95,7 +95,7 @@ test_get (int use_ssl, int port)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), n_seconds_time (20), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@ -127,7 +127,7 @@ test_post (int use_ssl, int port)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), n_seconds_time (20), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@ -185,7 +185,7 @@ main (int argc, char **argv)
grpc_httpcli_context_destroy (&g_context);
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_shutdown ();
gpr_subprocess_destroy (server);

14
test/core/iomgr/alarm_list_test.c
Unescape View File

@ -74,7 +74,7 @@ add_test (void)
/* collect alarms. Only the first batch should be ready. */
GPR_ASSERT (10 == grpc_alarm_check (gpr_time_add (start, gpr_time_from_millis (500, GPR_TIMESPAN)), NULL, &closure_list));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
for (i = 0; i < 20; i++)
{
GPR_ASSERT (cb_called[i][1] == (i < 10));
@ -82,7 +82,7 @@ add_test (void)
}
GPR_ASSERT (0 == grpc_alarm_check (gpr_time_add (start, gpr_time_from_millis (600, GPR_TIMESPAN)), NULL, &closure_list));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
for (i = 0; i < 30; i++)
{
GPR_ASSERT (cb_called[i][1] == (i < 10));
@ -91,7 +91,7 @@ add_test (void)
/* collect the rest of the alarms */
GPR_ASSERT (10 == grpc_alarm_check (gpr_time_add (start, gpr_time_from_millis (1500, GPR_TIMESPAN)), NULL, &closure_list));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
for (i = 0; i < 30; i++)
{
GPR_ASSERT (cb_called[i][1] == (i < 20));
@ -106,7 +106,7 @@ add_test (void)
}
grpc_alarm_list_shutdown (&closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static gpr_timespec
@ -133,16 +133,16 @@ destruction_test (void)
grpc_alarm_init (&alarms[3], tfm (3), cb, (void *) (gpr_intptr) 3, gpr_time_0 (GPR_CLOCK_REALTIME), &closure_list);
grpc_alarm_init (&alarms[4], tfm (1), cb, (void *) (gpr_intptr) 4, gpr_time_0 (GPR_CLOCK_REALTIME), &closure_list);
GPR_ASSERT (1 == grpc_alarm_check (tfm (2), NULL, &closure_list));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
GPR_ASSERT (1 == cb_called[4][1]);
grpc_alarm_cancel (&alarms[0], &closure_list);
grpc_alarm_cancel (&alarms[3], &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
GPR_ASSERT (1 == cb_called[0][0]);
GPR_ASSERT (1 == cb_called[3][0]);
grpc_alarm_list_shutdown (&closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
GPR_ASSERT (1 == cb_called[1][0]);
GPR_ASSERT (1 == cb_called[2][0]);
}

4
test/core/iomgr/endpoint_pair_test.c
Unescape View File

@ -60,7 +60,7 @@ create_fixture_endpoint_pair (size_t slice_size)
f.server_ep = p.server;
grpc_endpoint_add_to_pollset (f.client_ep, &g_pollset, &closure_list);
grpc_endpoint_add_to_pollset (f.server_ep, &g_pollset, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return f;
}
@ -86,7 +86,7 @@ main (int argc, char **argv)
grpc_endpoint_tests (configs[0], &g_pollset);
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_shutdown ();
return 0;

8
test/core/iomgr/endpoint_tests.c
Unescape View File

@ -232,7 +232,7 @@ read_and_write_test (grpc_endpoint_test_config config, size_t num_bytes, size_t
even when bytes_written is unsigned. */
state.bytes_written -= state.current_write_size;
read_and_write_test_write_handler (&state, 1, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_endpoint_read (state.read_ep, &state.incoming, &state.done_read, &closure_list);
@ -243,7 +243,7 @@ read_and_write_test (grpc_endpoint_test_config config, size_t num_bytes, size_t
gpr_log (GPR_DEBUG, "shutdown write");
grpc_endpoint_shutdown (state.write_ep, &closure_list);
}
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (g_pollset));
while (!state.read_done || !state.write_done)
@ -253,14 +253,14 @@ read_and_write_test (grpc_endpoint_test_config config, size_t num_bytes, size_t
grpc_pollset_work (g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
}
gpr_mu_unlock (GRPC_POLLSET_MU (g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
end_test (config);
gpr_slice_buffer_destroy (&state.outgoing);
gpr_slice_buffer_destroy (&state.incoming);
grpc_endpoint_destroy (state.read_ep, &closure_list);
grpc_endpoint_destroy (state.write_ep, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void

2
test/core/iomgr/fd_conservation_posix_test.c
Unescape View File

@ -61,7 +61,7 @@ main (int argc, char **argv)
p = grpc_iomgr_create_endpoint_pair ("test", 1);
grpc_endpoint_destroy (p.client, &closure_list);
grpc_endpoint_destroy (p.server, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
grpc_iomgr_shutdown ();

14
test/core/iomgr/fd_posix_test.c
Unescape View File

@ -285,7 +285,7 @@ server_wait_and_shutdown (server * sv)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@ -425,7 +425,7 @@ client_wait_and_shutdown (client * cl)
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@ -446,7 +446,7 @@ test_grpc_fd (void)
port = server_start (&sv, &closure_list);
client_init (&cl);
client_start (&cl, port, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
client_wait_and_shutdown (&cl);
server_wait_and_shutdown (&sv);
GPR_ASSERT (sv.read_bytes_total == cl.write_bytes_total);
@ -540,7 +540,7 @@ test_grpc_fd_change (void)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
GPR_ASSERT (a.cb_that_ran == first_read_callback);
@ -563,7 +563,7 @@ test_grpc_fd_change (void)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
/* Except now we verify that second_read_callback ran instead */
@ -571,7 +571,7 @@ test_grpc_fd_change (void)
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_fd_orphan (em_fd, NULL, "d", &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
destroy_change_data (&a);
destroy_change_data (&b);
close (sv[1]);
@ -595,7 +595,7 @@ main (int argc, char **argv)
test_grpc_fd_change ();
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_iomgr_shutdown ();
return 0;
}

10
test/core/iomgr/tcp_client_posix_test.c
Unescape View File

@ -134,7 +134,7 @@ test_succeeds (void)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_SECONDS_TO_DEADLINE (5), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
@ -171,7 +171,7 @@ test_fails (void)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), test_deadline (), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
@ -257,7 +257,7 @@ test_times_out (void)
}
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_MILLIS_TO_DEADLINE (10), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@ -285,7 +285,7 @@ main (int argc, char **argv)
grpc_pollset_set_init (&g_pollset_set);
grpc_pollset_init (&g_pollset);
grpc_pollset_set_add_pollset (&g_pollset_set, &g_pollset, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
test_succeeds ();
gpr_log (GPR_ERROR, "End of first test");
test_fails ();
@ -293,7 +293,7 @@ main (int argc, char **argv)
grpc_pollset_set_destroy (&g_pollset_set);
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_shutdown ();
return 0;
}

18
test/core/iomgr/tcp_posix_test.c
Unescape View File

@ -216,7 +216,7 @@ read_test (size_t num_bytes, size_t slice_size)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
GPR_ASSERT (state.read_bytes == state.target_read_bytes);
@ -224,7 +224,7 @@ read_test (size_t num_bytes, size_t slice_size)
gpr_slice_buffer_destroy (&state.incoming);
grpc_endpoint_destroy (ep, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
/* Write to a socket until it fills up, then read from it using the grpc_tcp
@ -263,7 +263,7 @@ large_read_test (size_t slice_size)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
GPR_ASSERT (state.read_bytes == state.target_read_bytes);
@ -271,7 +271,7 @@ large_read_test (size_t slice_size)
gpr_slice_buffer_destroy (&state.incoming);
grpc_endpoint_destroy (ep, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
struct write_socket_state
@ -338,7 +338,7 @@ drain_socket_blocking (int fd, size_t num_bytes, size_t read_size)
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_MILLIS_TO_DEADLINE (10), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
do
{
bytes_read = read (fd, buf, bytes_left > read_size ? read_size : bytes_left);
@ -405,7 +405,7 @@ write_test (size_t num_bytes, size_t slice_size)
}
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@ -413,7 +413,7 @@ write_test (size_t num_bytes, size_t slice_size)
gpr_slice_buffer_destroy (&outgoing);
grpc_endpoint_destroy (ep, &closure_list);
gpr_free (slices);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void
@ -458,7 +458,7 @@ create_fixture_tcp_socketpair (size_t slice_size)
grpc_endpoint_add_to_pollset (f.client_ep, &g_pollset, &closure_list);
grpc_endpoint_add_to_pollset (f.server_ep, &g_pollset, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return f;
}
@ -485,7 +485,7 @@ main (int argc, char **argv)
grpc_endpoint_tests (configs[0], &g_pollset);
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_shutdown ();
return 0;

12
test/core/iomgr/tcp_server_posix_test.c
Unescape View File

@ -75,7 +75,7 @@ test_no_op_with_start (void)
LOG_TEST ("test_no_op_with_start");
grpc_tcp_server_start (s, NULL, 0, on_connect, NULL, &closure_list);
grpc_tcp_server_destroy (s, NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -91,7 +91,7 @@ test_no_op_with_port (void)
GPR_ASSERT (grpc_tcp_server_add_port (s, (struct sockaddr *) &addr, sizeof (addr)));
grpc_tcp_server_destroy (s, NULL, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -109,7 +109,7 @@ test_no_op_with_port_and_start (void)
grpc_tcp_server_start (s, NULL, 0, on_connect, NULL, &closure_list);
grpc_tcp_server_destroy (s, NULL, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -157,7 +157,7 @@ test_connect (int n)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
gpr_log (GPR_DEBUG, "wait done");
@ -169,7 +169,7 @@ test_connect (int n)
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_tcp_server_destroy (s, NULL, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -196,7 +196,7 @@ main (int argc, char **argv)
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_iomgr_shutdown ();
return 0;
}

8
test/core/iomgr/udp_server_test.c
Unescape View File

@ -80,7 +80,7 @@ test_no_op_with_start (void)
LOG_TEST ("test_no_op_with_start");
grpc_udp_server_start (s, NULL, 0, &closure_list);
grpc_udp_server_destroy (s, NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -112,7 +112,7 @@ test_no_op_with_port_and_start (void)
grpc_udp_server_start (s, NULL, 0, &closure_list);
grpc_udp_server_destroy (s, NULL, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -161,7 +161,7 @@ test_receive (int number_of_clients)
grpc_pollset_worker worker;
grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
}
GPR_ASSERT (g_number_of_reads == number_of_reads_before + 1);
@ -198,7 +198,7 @@ main (int argc, char **argv)
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_iomgr_shutdown ();
return 0;
}

6
test/core/iomgr/workqueue_test.c
Unescape View File

@ -68,11 +68,11 @@ test_add_closure (void)
GPR_ASSERT (!done);
grpc_pollset_work (&g_pollset, &worker, gpr_now (deadline.clock_type), deadline, &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
GPR_ASSERT (done);
GRPC_WORKQUEUE_UNREF (wq, "destroy", &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -94,7 +94,7 @@ main (int argc, char **argv)
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_shutdown ();
return 0;
}

34
test/core/security/credentials_test.c
Unescape View File

@ -309,7 +309,7 @@ test_google_iam_creds (void)
GPR_ASSERT (grpc_credentials_has_request_metadata (creds));
GPR_ASSERT (grpc_credentials_has_request_metadata_only (creds));
grpc_credentials_get_request_metadata (creds, NULL, test_service_url, check_google_iam_metadata, creds, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -332,7 +332,7 @@ test_access_token_creds (void)
GPR_ASSERT (grpc_credentials_has_request_metadata_only (creds));
GPR_ASSERT (strcmp (creds->type, GRPC_CREDENTIALS_TYPE_OAUTH2) == 0);
grpc_credentials_get_request_metadata (creds, NULL, test_service_url, check_access_token_metadata, creds, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -366,7 +366,7 @@ test_ssl_oauth2_composite_creds (void)
GPR_ASSERT (strcmp (creds_array->creds_array[0]->type, GRPC_CREDENTIALS_TYPE_SSL) == 0);
GPR_ASSERT (strcmp (creds_array->creds_array[1]->type, GRPC_CREDENTIALS_TYPE_OAUTH2) == 0);
grpc_credentials_get_request_metadata (composite_creds, NULL, test_service_url, check_ssl_oauth2_composite_metadata, composite_creds, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void
@ -422,7 +422,7 @@ test_ssl_oauth2_google_iam_composite_creds (void)
GPR_ASSERT (strcmp (creds_array->creds_array[1]->type, GRPC_CREDENTIALS_TYPE_OAUTH2) == 0);
GPR_ASSERT (strcmp (creds_array->creds_array[2]->type, GRPC_CREDENTIALS_TYPE_IAM) == 0);
grpc_credentials_get_request_metadata (composite_creds, NULL, test_service_url, check_ssl_oauth2_google_iam_composite_metadata, composite_creds, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -499,12 +499,12 @@ test_compute_engine_creds_success (void)
/* First request: http get should be called. */
grpc_httpcli_set_override (compute_engine_httpcli_get_success_override, httpcli_post_should_not_be_called);
grpc_credentials_get_request_metadata (compute_engine_creds, NULL, test_service_url, on_oauth2_creds_get_metadata_success, (void *) test_user_data, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* Second request: the cached token should be served directly. */
grpc_httpcli_set_override (httpcli_get_should_not_be_called, httpcli_post_should_not_be_called);
grpc_credentials_get_request_metadata (compute_engine_creds, NULL, test_service_url, on_oauth2_creds_get_metadata_success, (void *) test_user_data, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_credentials_unref (compute_engine_creds);
grpc_httpcli_set_override (NULL, NULL);
@ -521,7 +521,7 @@ test_compute_engine_creds_failure (void)
grpc_credentials_get_request_metadata (compute_engine_creds, NULL, test_service_url, on_oauth2_creds_get_metadata_failure, (void *) test_user_data, &closure_list);
grpc_credentials_unref (compute_engine_creds);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -573,16 +573,16 @@ test_refresh_token_creds_success (void)
/* First request: http get should be called. */
grpc_httpcli_set_override (httpcli_get_should_not_be_called, refresh_token_httpcli_post_success);
grpc_credentials_get_request_metadata (refresh_token_creds, NULL, test_service_url, on_oauth2_creds_get_metadata_success, (void *) test_user_data, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* Second request: the cached token should be served directly. */
grpc_httpcli_set_override (httpcli_get_should_not_be_called, httpcli_post_should_not_be_called);
grpc_credentials_get_request_metadata (refresh_token_creds, NULL, test_service_url, on_oauth2_creds_get_metadata_success, (void *) test_user_data, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_credentials_unref (refresh_token_creds);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -597,7 +597,7 @@ test_refresh_token_creds_failure (void)
grpc_credentials_get_request_metadata (refresh_token_creds, NULL, test_service_url, on_oauth2_creds_get_metadata_failure, (void *) test_user_data, &closure_list);
grpc_credentials_unref (refresh_token_creds);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -670,18 +670,18 @@ test_jwt_creds_success (void)
/* First request: jwt_encode_and_sign should be called. */
grpc_jwt_encode_and_sign_set_override (encode_and_sign_jwt_success);
grpc_credentials_get_request_metadata (jwt_creds, NULL, test_service_url, on_jwt_creds_get_metadata_success, (void *) test_user_data, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* Second request: the cached token should be served directly. */
grpc_jwt_encode_and_sign_set_override (encode_and_sign_jwt_should_not_be_called);
grpc_credentials_get_request_metadata (jwt_creds, NULL, test_service_url, on_jwt_creds_get_metadata_success, (void *) test_user_data, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
/* Third request: Different service url so jwt_encode_and_sign should be
called again (no caching). */
grpc_jwt_encode_and_sign_set_override (encode_and_sign_jwt_success);
grpc_credentials_get_request_metadata (jwt_creds, NULL, other_test_service_url, on_jwt_creds_get_metadata_success, (void *) test_user_data, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_free (json_key_string);
grpc_credentials_unref (jwt_creds);
@ -703,7 +703,7 @@ test_jwt_creds_signing_failure (void)
gpr_free (json_key_string);
grpc_credentials_unref (jwt_creds);
grpc_jwt_encode_and_sign_set_override (NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -858,7 +858,7 @@ test_metadata_plugin_success (void)
GPR_ASSERT (state == PLUGIN_GET_METADATA_CALLED_STATE);
grpc_credentials_release (creds);
GPR_ASSERT (state == PLUGIN_DESTROY_CALLED_STATE);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -879,7 +879,7 @@ test_metadata_plugin_failure (void)
GPR_ASSERT (state == PLUGIN_GET_METADATA_CALLED_STATE);
grpc_credentials_release (creds);
GPR_ASSERT (state == PLUGIN_DESTROY_CALLED_STATE);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
int

14
test/core/security/jwt_verifier_test.c
Unescape View File

@ -236,7 +236,7 @@ test_jwt_verifier_google_email_issuer_success (void)
gpr_free (jwt);
grpc_jwt_verifier_destroy (verifier);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static int
@ -269,7 +269,7 @@ test_jwt_verifier_custom_email_issuer_success (void)
gpr_free (jwt);
grpc_jwt_verifier_destroy (verifier);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static int
@ -315,7 +315,7 @@ test_jwt_verifier_url_issuer_success (void)
gpr_free (jwt);
grpc_jwt_verifier_destroy (verifier);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -354,7 +354,7 @@ test_jwt_verifier_url_issuer_bad_config (void)
gpr_free (jwt);
grpc_jwt_verifier_destroy (verifier);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -375,7 +375,7 @@ test_jwt_verifier_bad_json_key (void)
gpr_free (jwt);
grpc_jwt_verifier_destroy (verifier);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static void
@ -423,7 +423,7 @@ test_jwt_verifier_bad_signature (void)
gpr_free (jwt);
grpc_jwt_verifier_destroy (verifier);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
static int
@ -450,7 +450,7 @@ test_jwt_verifier_bad_format (void)
grpc_jwt_verifier_verify (verifier, NULL, "bad jwt", expected_audience, on_verification_bad_format, (void *) expected_user_data, &closure_list);
grpc_jwt_verifier_destroy (verifier);
grpc_httpcli_set_override (NULL, NULL);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
/* find verification key: bad jks, cannot find key in jks */

4
test/core/security/oauth2_utils.c
Unescape View File

@ -94,7 +94,7 @@ grpc_test_fetch_oauth2_token_with_credentials (grpc_credentials * creds)
grpc_credentials_get_request_metadata (creds, &request.pollset, "", on_oauth2_response, &request, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&request.pollset));
while (!request.is_done)
@ -105,7 +105,7 @@ grpc_test_fetch_oauth2_token_with_credentials (grpc_credentials * creds)
gpr_mu_unlock (GRPC_POLLSET_MU (&request.pollset));
grpc_pollset_shutdown (&request.pollset, &do_nothing_closure, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_pollset_destroy (&request.pollset);
return request.token;
}

2
test/core/security/print_google_default_creds_token.c
Unescape View File

@ -105,7 +105,7 @@ main (int argc, char **argv)
grpc_pollset_worker worker;
grpc_pollset_work (&sync.pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&sync.pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&sync.pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&sync.pollset));

8
test/core/security/secure_endpoint_test.c
Unescape View File

@ -110,7 +110,7 @@ secure_endpoint_create_fixture_tcp_socketpair (size_t slice_size, gpr_slice * le
}
f.server_ep = grpc_secure_endpoint_create (fake_write_protector, tcp.server, NULL, 0);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return f;
}
@ -162,7 +162,7 @@ test_leftover (grpc_endpoint_test_config config, size_t slice_size)
gpr_slice_buffer_init (&incoming);
grpc_closure_init (&done_closure, inc_call_ctr, &n);
grpc_endpoint_read (f.client_ep, &incoming, &done_closure, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
GPR_ASSERT (n == 1);
GPR_ASSERT (incoming.count == 1);
GPR_ASSERT (0 == gpr_slice_cmp (s, incoming.slices[0]));
@ -171,7 +171,7 @@ test_leftover (grpc_endpoint_test_config config, size_t slice_size)
grpc_endpoint_shutdown (f.server_ep, &closure_list);
grpc_endpoint_destroy (f.client_ep, &closure_list);
grpc_endpoint_destroy (f.server_ep, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_slice_unref (s);
gpr_slice_buffer_destroy (&incoming);
@ -197,7 +197,7 @@ main (int argc, char **argv)
test_leftover (configs[1], 1);
grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_shutdown ();
return 0;

2
test/core/security/verify_jwt.c
Unescape View File

@ -121,7 +121,7 @@ main (int argc, char **argv)
grpc_pollset_worker worker;
grpc_pollset_work (&sync.pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&sync.pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&sync.pollset));
}
gpr_mu_unlock (GRPC_POLLSET_MU (&sync.pollset));

2
test/core/surface/completion_queue_test.c
Unescape View File

@ -244,7 +244,7 @@ producer_thread (void *arg)
{
grpc_cq_end_op (opt->cc, (void *) (gpr_intptr) 1, 1, free_completion, NULL, gpr_malloc (sizeof (grpc_cq_completion)), &closure_list);
opt->events_triggered++;
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
gpr_log (GPR_INFO, "producer %d phase 2 done", opt->id);

8
test/core/util/port_posix.c
Unescape View File

@ -126,9 +126,9 @@ free_port_using_server (char *server, int port)
gpr_mu_unlock (GRPC_POLLSET_MU (&pr.pollset));
grpc_httpcli_context_destroy (&context);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_pollset_shutdown (&pr.pollset, &shutdown_closure, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_free (path);
}
@ -288,7 +288,7 @@ pick_port_using_server (char *server)
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_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
gpr_mu_lock (GRPC_POLLSET_MU (&pr.pollset));
while (pr.port == -1)
{
@ -299,7 +299,7 @@ pick_port_using_server (char *server)
grpc_httpcli_context_destroy (&context);
grpc_pollset_shutdown (&pr.pollset, &shutdown_closure, &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
return pr.port;
}

6
test/core/util/reconnect_server.c
Unescape View File

@ -143,7 +143,7 @@ reconnect_server_start (reconnect_server * server, int port)
grpc_tcp_server_start (server->tcp_server, server->pollsets, 1, on_connect, server, &closure_list);
gpr_log (GPR_INFO, "reconnect tcp server listening on 0.0.0.0:%d", port);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void
@ -156,7 +156,7 @@ reconnect_server_poll (reconnect_server * server, int seconds)
gpr_mu_lock (GRPC_POLLSET_MU (&server->pollset));
grpc_pollset_work (&server->pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
gpr_mu_unlock (GRPC_POLLSET_MU (&server->pollset));
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
}
void
@ -189,7 +189,7 @@ reconnect_server_destroy (reconnect_server * server)
grpc_tcp_server_destroy (server->tcp_server, &do_nothing_closure[0], &closure_list);
reconnect_server_clear_timestamps (server);
grpc_pollset_shutdown (&server->pollset, &do_nothing_closure[1], &closure_list);
grpc_closure_list_run (&closure_list);
grpc_exec_ctx_finish (&exec_ctx);
grpc_pollset_destroy (&server->pollset);
grpc_shutdown ();
}

Write Preview
Loading…
Cancel
Save