Home
last modified time | relevance | path

Searched refs:GRPC_CLOSURE_CREATE (Results 1 – 25 of 40) sorted by relevance

12

/third_party/grpc/test/core/iomgr/
Dtimer_list_test.cc66 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)i, grpc_schedule_on_exec_ctx)); in add_test()
73 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)i, grpc_schedule_on_exec_ctx)); in add_test()
127 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)0, grpc_schedule_on_exec_ctx)); in destruction_test()
130 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)1, grpc_schedule_on_exec_ctx)); in destruction_test()
133 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)2, grpc_schedule_on_exec_ctx)); in destruction_test()
136 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)3, grpc_schedule_on_exec_ctx)); in destruction_test()
139 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)4, grpc_schedule_on_exec_ctx)); in destruction_test()
183 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)0, grpc_schedule_on_exec_ctx)); in long_running_service_cleanup_test()
186 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)1, grpc_schedule_on_exec_ctx)); in long_running_service_cleanup_test()
189 GRPC_CLOSURE_CREATE(cb, (void*)(intptr_t)2, grpc_schedule_on_exec_ctx)); in long_running_service_cleanup_test()
[all …]
Dresolve_address_test.cc162 GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx), in test_localhost()
175 GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx), in test_default_port()
187 GRPC_CLOSURE_CREATE(must_succeed_with_ipv6_first, &args, in test_localhost_result_has_ipv6_first()
201 GRPC_CLOSURE_CREATE(must_succeed_with_ipv4_first, &args, in test_localhost_result_has_ipv4_first_when_ipv6_isnt_available()
215 GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx), in test_non_numeric_default_port()
228 GRPC_CLOSURE_CREATE(must_fail, &args, grpc_schedule_on_exec_ctx), in test_missing_default_port()
241 GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx), in test_ipv6_with_port()
261 GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx), in test_ipv6_without_port()
281 GRPC_CLOSURE_CREATE(must_fail, &args, grpc_schedule_on_exec_ctx), in test_invalid_ip_addresses()
300 GRPC_CLOSURE_CREATE(must_fail, &args, grpc_schedule_on_exec_ctx), in test_unparseable_hostports()
Dcombiner_test.cc46 lock->Run(GRPC_CLOSURE_CREATE(set_event_to_true, &done, nullptr), in test_execute_one()
81 args->lock->Run(GRPC_CLOSURE_CREATE(check_one, c, nullptr), in execute_many_loop()
89 args->lock->Run(GRPC_CLOSURE_CREATE(set_event_to_true, &args->done, nullptr), in execute_many_loop()
123 GRPC_CLOSURE_CREATE(in_finally, arg, nullptr), GRPC_ERROR_NONE); in add_finally()
132 lock->Run(GRPC_CLOSURE_CREATE(add_finally, lock, nullptr), GRPC_ERROR_NONE); in test_execute_finally()
Dresolve_address_posix_test.cc148 GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx), in test_unix_socket()
169 GRPC_CLOSURE_CREATE(must_fail, &args, grpc_schedule_on_exec_ctx), in test_unix_socket_path_name_too_long()
182 GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx), in resolve_address_must_succeed()
Dendpoint_tests.cc311 GRPC_CLOSURE_CREATE(inc_on_failure, &fail_count, in multiple_shutdown_test()
319 GRPC_CLOSURE_CREATE(inc_on_failure, &fail_count, in multiple_shutdown_test()
325 GRPC_CLOSURE_CREATE(inc_on_failure, &fail_count, in multiple_shutdown_test()
Dresource_quota_test.cc51 return GRPC_CLOSURE_CREATE(set_event_cb, ev, grpc_schedule_on_exec_ctx); in set_event()
75 return GRPC_CLOSURE_CREATE(reclaimer_cb, a, grpc_schedule_on_exec_ctx); in make_reclaimer()
84 return GRPC_CLOSURE_CREATE(unused_reclaimer_cb, then, in make_unused_reclaimer()
Dudp_server_test.cc181 auto closure = GRPC_CLOSURE_CREATE(destroy_pollset, g_pollset, in shutdown_and_destroy_pollset()
/third_party/grpc/test/cpp/common/
Dtimer_test.cc86 GRPC_CLOSURE_CREATE( in TEST_F()
111 GRPC_CLOSURE_CREATE( in TEST_F()
138 GRPC_CLOSURE_CREATE( in TEST_F()
169 GRPC_CLOSURE_CREATE([](void*, grpc_error*) {}, nullptr, in TEST_F()
183 GRPC_CLOSURE_CREATE( in TEST_F()
213 GRPC_CLOSURE_CREATE( in TEST_F()
Dtime_jump_test.cc90 GRPC_CLOSURE_CREATE( in TEST_P()
/third_party/grpc/test/core/util/
Dport_server_client.cc80 shutdown_closure = GRPC_CLOSURE_CREATE(destroy_pops_and_shutdown, &pr.pops, in grpc_free_port_using_server()
92 GRPC_CLOSURE_CREATE(freed_port_from_server, &pr, in grpc_free_port_using_server()
176 GRPC_CLOSURE_CREATE(got_port_from_server, pr, in got_port_from_server()
212 shutdown_closure = GRPC_CLOSURE_CREATE(destroy_pops_and_shutdown, &pr.pops, in grpc_pick_port_using_server()
226 GRPC_CLOSURE_CREATE(got_port_from_server, &pr, in grpc_pick_port_using_server()
Dtest_tcp_server.cc111 GRPC_CLOSURE_CREATE(finish_pollset, server->pollset[0], in test_tcp_server_destroy()
Dtrickle_endpoint.cc193 GRPC_CLOSURE_CREATE(te_finish_write, te, grpc_schedule_on_exec_ctx), in grpc_trickle_endpoint_trickle()
/third_party/grpc/test/core/http/
Dhttpcli_test.cc84 GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx), in test_get()
123 GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx), in test_post()
Dhttpscli_test.cc88 GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx), in test_get()
128 GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx), in test_post()
/third_party/grpc/src/core/lib/iomgr/
Dclosure.h160 #define GRPC_CLOSURE_CREATE(cb, cb_arg, scheduler) \ macro
163 #define GRPC_CLOSURE_CREATE(cb, cb_arg, scheduler) \ macro
Dcombiner.cc318 lock->Run(GRPC_CLOSURE_CREATE(enqueue_finally, closure, nullptr), error); in combiner_finally_exec()
/third_party/grpc/src/core/ext/filters/client_channel/
Dlb_policy.cc112 GRPC_CLOSURE_CREATE( in Pick()
/third_party/grpc/src/cpp/common/
Dalarm.cc87 GRPC_CLOSURE_CREATE( in Set()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_closure.cc101 GRPC_CLOSURE_CREATE(DoNothing, nullptr, grpc_schedule_on_exec_ctx), in BM_ClosureCreateAndRun()
364 GRPC_CLOSURE_CREATE(Step, this, nullptr), in ScheduleFirstAgainstDifferentScheduler()
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc421 GRPC_CLOSURE_CREATE(OnCancelComplete, self, grpc_schedule_on_exec_ctx)); in StartCancel()
434 GRPC_CLOSURE_CREATE(StartCancel, this, grpc_schedule_on_exec_ctx), in Cancel()
/third_party/grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc158 GRPC_CLOSURE_CREATE(&Client::PollsetDestroy, pollset_, in Shutdown()
/third_party/grpc/src/core/lib/security/credentials/jwt/
Djwt_verifier.cc708 GRPC_CLOSURE_CREATE(on_keys_retrieved, ctx, grpc_schedule_on_exec_ctx), in on_openid_config_retrieved()
810 GRPC_CLOSURE_CREATE(on_keys_retrieved, ctx, grpc_schedule_on_exec_ctx); in retrieve_key_and_verify()
822 http_cb = GRPC_CLOSURE_CREATE(on_openid_config_retrieved, ctx, in retrieve_key_and_verify()
/third_party/grpc/test/core/end2end/tests/
Dfilter_causes_close.cc216 GRPC_CLOSURE_CREATE(recv_im_ready, elem, grpc_schedule_on_exec_ctx); in start_transport_stream_op_batch()
/third_party/grpc/test/core/surface/
Dconcurrent_connectivity_test.cc253 GRPC_CLOSURE_CREATE(done_pollset_shutdown, args.pollset[0], in run_concurrent_connectivity_test()
/third_party/grpc/src/core/lib/security/credentials/google_default/
Dgoogle_default_credentials.cc191 GRPC_CLOSURE_CREATE(on_metadata_server_detection_http_response, &detector, in is_metadata_server_reachable()

12