Home
last modified time | relevance | path

Searched refs:GRPC_CLOSURE_INIT (Results 1 – 25 of 92) sorted by relevance

1234

/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_closure.cc62 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, grpc_schedule_on_exec_ctx)); in BM_ClosureInitAgainstExecCtx()
74 benchmark::DoNotOptimize(GRPC_CLOSURE_INIT( in BM_ClosureInitAgainstCombiner()
86 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureRunOnExecCtx()
116 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, grpc_schedule_on_exec_ctx), in BM_ClosureInitAndRun()
127 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureSchedOnExecCtx()
142 GRPC_CLOSURE_INIT(&c1, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureSched2OnExecCtx()
143 GRPC_CLOSURE_INIT(&c2, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureSched2OnExecCtx()
160 GRPC_CLOSURE_INIT(&c1, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureSched3OnExecCtx()
161 GRPC_CLOSURE_INIT(&c2, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureSched3OnExecCtx()
162 GRPC_CLOSURE_INIT(&c3, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureSched3OnExecCtx()
[all …]
Dbm_pollset.cc56 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_CreateDestroyPollset()
124 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_PollEmptyPollset()
151 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_PollAddFd()
171 GRPC_CLOSURE_INIT(this, C::cbfn, this, scheduler); in MakeClosure()
248 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_SingleThreadPollOneFd()
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc54 GRPC_CLOSURE_INIT(&deadline_state->timer_callback, yield_call_combiner, in send_cancel_op_in_call_combiner()
72 GRPC_CLOSURE_INIT(&deadline_state->timer_callback, in timer_callback()
109 GRPC_CLOSURE_INIT(&deadline_state->timer_callback, timer_callback, in start_timer_if_needed()
145 GRPC_CLOSURE_INIT(&deadline_state->recv_trailing_metadata_ready, in inject_recv_trailing_metadata_ready()
203 GRPC_CLOSURE_INIT(&state->closure, start_timer_after_init, state, in grpc_deadline_state_init()
317 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in server_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc456 GRPC_CLOSURE_INIT(&chand->max_idle_timer_cb, max_idle_timer_cb, chand, in init_channel_elem()
458 GRPC_CLOSURE_INIT(&chand->close_max_age_channel, close_max_age_channel, chand, in init_channel_elem()
460 GRPC_CLOSURE_INIT(&chand->force_close_max_age_channel, in init_channel_elem()
463 GRPC_CLOSURE_INIT(&chand->start_max_idle_timer_after_init, in init_channel_elem()
466 GRPC_CLOSURE_INIT(&chand->start_max_age_timer_after_init, in init_channel_elem()
469 GRPC_CLOSURE_INIT(&chand->start_max_age_grace_timer_after_goaway_op, in init_channel_elem()
472 GRPC_CLOSURE_INIT(&chand->channel_connectivity_changed, in init_channel_elem()
/external/grpc-grpc/test/core/transport/
Dbyte_stream_test.cc59 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
91 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
136 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
171 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
214 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
/external/grpc-grpc/src/core/lib/iomgr/
Dudp_server.cc299 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OrphanFd()
332 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OnFdAboutToOrphan()
337 GRPC_CLOSURE_INIT(&orphan_fd_closure_, shutdown_fd, this, in OnFdAboutToOrphan()
484 GRPC_CLOSURE_INIT(&do_read_closure_, do_read, do_read_arg, in OnRead()
518 GRPC_CLOSURE_INIT(&sp->notify_on_write_closure_, fd_notify_on_write_wrapper, in do_write()
545 GRPC_CLOSURE_INIT(&do_write_closure_, do_write, do_write_arg, in OnCanWrite()
726 GRPC_CLOSURE_INIT(&read_closure_, on_read, this, grpc_schedule_on_exec_ctx); in StartListening()
729 GRPC_CLOSURE_INIT(&write_closure_, on_write, this, grpc_schedule_on_exec_ctx); in StartListening()
Dresource_quota.cc638 GRPC_CLOSURE_INIT(&resource_quota->rq_step_closure, rq_step, resource_quota, in grpc_resource_quota_create()
640 GRPC_CLOSURE_INIT(&resource_quota->rq_reclamation_done_closure, in grpc_resource_quota_create()
701 GRPC_CLOSURE_INIT(&a->closure, rq_resize, a, grpc_schedule_on_exec_ctx); in grpc_resource_quota_resize()
756 GRPC_CLOSURE_INIT(&resource_user->allocate_closure, &ru_allocate, in grpc_resource_user_create()
759 GRPC_CLOSURE_INIT(&resource_user->add_to_free_pool_closure, in grpc_resource_user_create()
762 GRPC_CLOSURE_INIT(&resource_user->post_reclaimer_closure[0], in grpc_resource_user_create()
765 GRPC_CLOSURE_INIT(&resource_user->post_reclaimer_closure[1], in grpc_resource_user_create()
768 GRPC_CLOSURE_INIT(&resource_user->destroy_closure, &ru_destroy, resource_user, in grpc_resource_user_create()
933 GRPC_CLOSURE_INIT(&slice_allocator->on_allocated, ru_allocated_slices, in grpc_resource_user_slice_allocator_init()
935 GRPC_CLOSURE_INIT(&slice_allocator->on_done, cb, p, in grpc_resource_user_slice_allocator_init()
/external/grpc-grpc/test/core/iomgr/
Dfd_posix_test.cc209 GRPC_CLOSURE_INIT(&se->session_read_closure, session_read_cb, se, in listen_cb()
239 GRPC_CLOSURE_INIT(&sv->listen_closure, listen_cb, sv, in server_start()
320 GRPC_CLOSURE_INIT(&cl->write_closure, client_session_write, cl, in client_session_write()
443 GRPC_CLOSURE_INIT(&first_closure, first_read_callback, &a, in test_grpc_fd_change()
445 GRPC_CLOSURE_INIT(&second_closure, second_read_callback, &b, in test_grpc_fd_change()
526 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
Dtcp_client_uv_test.cc110 GRPC_CLOSURE_INIT(&done, must_succeed, NULL, grpc_schedule_on_exec_ctx); in test_succeeds()
152 GRPC_CLOSURE_INIT(&done, must_fail, NULL, grpc_schedule_on_exec_ctx); in test_fails()
198 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
Dtcp_client_posix_test.cc109 GRPC_CLOSURE_INIT(&done, must_succeed, nullptr, grpc_schedule_on_exec_ctx); in test_succeeds()
158 GRPC_CLOSURE_INIT(&done, must_fail, nullptr, grpc_schedule_on_exec_ctx); in test_fails()
208 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
Dtcp_posix_test.cc230 GRPC_CLOSURE_INIT(&state.read_cb, read_cb, &state, grpc_schedule_on_exec_ctx); in read_test()
281 GRPC_CLOSURE_INIT(&state.read_cb, read_cb, &state, grpc_schedule_on_exec_ctx); in large_read_test()
442 GRPC_CLOSURE_INIT(&write_done_closure, write_done, &state, in write_test()
494 GRPC_CLOSURE_INIT(&fd_released_cb, &on_fd_released, &fd_released_done, in release_fd_test()
520 GRPC_CLOSURE_INIT(&state.read_cb, read_cb, &state, grpc_schedule_on_exec_ctx); in release_fd_test()
635 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
/external/grpc-grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc481 GRPC_CLOSURE_INIT(&conn->on_read_request_done, on_read_request_done, conn, in on_accept()
483 GRPC_CLOSURE_INIT(&conn->on_server_connect_done, on_server_connect_done, conn, in on_accept()
485 GRPC_CLOSURE_INIT(&conn->on_write_response_done, on_write_response_done, conn, in on_accept()
487 GRPC_CLOSURE_INIT(&conn->on_client_read_done, on_client_read_done, conn, in on_accept()
489 GRPC_CLOSURE_INIT(&conn->on_client_write_done, on_client_write_done, conn, in on_accept()
491 GRPC_CLOSURE_INIT(&conn->on_server_read_done, on_server_read_done, conn, in on_accept()
493 GRPC_CLOSURE_INIT(&conn->on_server_write_done, on_server_write_done, conn, in on_accept()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc221 GRPC_CLOSURE_INIT(&w->on_complete, watch_complete, w, in grpc_channel_watch_connectivity_state()
223 GRPC_CLOSURE_INIT(&w->on_timeout, timeout_complete, w, in grpc_channel_watch_connectivity_state()
236 GRPC_CLOSURE_INIT(&w->watcher_timer_init, watcher_timer_init, wa, in grpc_channel_watch_connectivity_state()
Dclient_channel.cc209 GRPC_CLOSURE_INIT(&w->on_changed, on_lb_policy_state_changed_locked, w, in watch_lb_policy_locked()
420 GRPC_CLOSURE_INIT(&args->closure, request_reresolution_locked, args, in create_new_lb_policy_locked()
652 GRPC_CLOSURE_INIT(&op->handler_private.closure, start_transport_op_locked, in cc_start_transport_op()
687 GRPC_CLOSURE_INIT(&chand->on_resolver_result_changed, in cc_init_channel_elem()
1251 GRPC_CLOSURE_INIT(&batch->handler_private.closure, in pending_batches_fail()
1304 GRPC_CLOSURE_INIT(&batch->handler_private.closure, in pending_batches_resume()
1425 GRPC_CLOSURE_INIT(&calld->pick_closure, start_pick_locked, elem, in do_retry()
1567 GRPC_CLOSURE_INIT(&batch_data->on_complete, on_complete, batch_data, in batch_data_create()
1856 GRPC_CLOSURE_INIT(&retry_state->recv_initial_metadata_ready, in add_closures_for_deferred_recv_callbacks()
1868 GRPC_CLOSURE_INIT(&retry_state->recv_message_ready, in add_closures_for_deferred_recv_callbacks()
[all …]
Dbackup_poller.cc97 p->pollset, GRPC_CLOSURE_INIT(&p->shutdown_closure, done_poller, p, in g_poller_unref()
140 GRPC_CLOSURE_INIT(&g_poller->run_poller_closure, run_poller, g_poller, in g_poller_init_locked()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/fake/
Dfake_resolver.cc163 GRPC_CLOSURE_INIT(&closure_arg->set_response_closure, SetResponseLocked, in SetResponse()
186 GRPC_CLOSURE_INIT(&closure_arg->set_response_closure, in SetReresolutionResponse()
206 GRPC_CLOSURE_INIT(&closure_arg->set_response_closure, SetFailureLocked, in SetFailure()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc110 GRPC_CLOSURE_INIT(&calld->on_complete_for_send, on_complete_for_send, in start_transport_stream_op_batch()
118 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in start_transport_stream_op_batch()
Dgrpclb.cc529 GRPC_CLOSURE_INIT(&lb_on_initial_request_sent_, OnInitialRequestSentLocked, in BalancerCallState()
531 GRPC_CLOSURE_INIT(&lb_on_balancer_message_received_, in BalancerCallState()
534 GRPC_CLOSURE_INIT(&lb_on_balancer_status_received_, in BalancerCallState()
640 GRPC_CLOSURE_INIT(&client_load_report_closure_, in ScheduleNextClientLoadReportLocked()
707 GRPC_CLOSURE_INIT(&client_load_report_closure_, ClientLoadReportDoneLocked, in SendClientLoadReportLocked()
1038 GRPC_CLOSURE_INIT(&lb_channel_on_connectivity_changed_, in GrpcLb()
1041 GRPC_CLOSURE_INIT(&on_rr_connectivity_changed_, in GrpcLb()
1044 GRPC_CLOSURE_INIT(&on_rr_request_reresolution_, in GrpcLb()
1373 GRPC_CLOSURE_INIT(&lb_on_fallback_, &GrpcLb::OnFallbackTimerLocked, this, in StartPickingLocked()
1432 GRPC_CLOSURE_INIT(&lb_on_call_retry_, &GrpcLb::OnBalancerCallRetryTimerLocked, in StartBalancerCallRetryTimerLocked()
[all …]
/external/grpc-grpc/test/core/security/
Doauth2_utils.cc82 GRPC_CLOSURE_INIT(&do_nothing_closure, do_nothing, nullptr, in grpc_test_fetch_oauth2_token_with_credentials()
85 GRPC_CLOSURE_INIT(&request.closure, on_oauth2_response, &request, in grpc_test_fetch_oauth2_token_with_credentials()
/external/grpc-grpc/test/core/util/
Dtest_tcp_server.cc47 GRPC_CLOSURE_INIT(&server->shutdown_complete, on_server_destroyed, server, in test_tcp_server_init()
101 GRPC_CLOSURE_INIT(&do_nothing_cb, do_nothing, nullptr, in test_tcp_server_destroy()
/external/grpc-grpc/src/cpp/common/
Dalarm.cc60 GRPC_CLOSURE_INIT(&on_alarm_, in Set()
79 GRPC_CLOSURE_INIT(&on_alarm_, in Set()
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc276 GRPC_CLOSURE_INIT(&sc->closure, shutdown_cleanup, sc, in send_shutdown()
340 GRPC_CLOSURE_INIT( in request_matcher_zombify_all_pending_calls()
427 GRPC_CLOSURE_INIT(&chand->finish_destroy_channel_closure, in destroy_channel()
490 GRPC_CLOSURE_INIT( in publish_new_rpc()
553 GRPC_CLOSURE_INIT(&calld->kill_zombie_closure, kill_zombie, elem, in finish_start_new_rpc()
570 GRPC_CLOSURE_INIT(&calld->publish, publish_new_rpc, elem, in finish_start_new_rpc()
783 GRPC_CLOSURE_INIT(&calld->kill_zombie_closure, kill_zombie, elem, in got_initial_metadata()
818 GRPC_CLOSURE_INIT(&calld->got_initial_metadata, got_initial_metadata, elem, in accept_stream()
849 GRPC_CLOSURE_INIT(&calld->server_on_recv_initial_metadata, in init_call_elem()
852 GRPC_CLOSURE_INIT(&calld->recv_trailing_metadata_ready, in init_call_elem()
[all …]
/external/grpc-grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc213 GRPC_CLOSURE_INIT(&calld->async_result_closure, on_credentials_metadata, in send_security_metadata()
226 GRPC_CLOSURE_INIT(&calld->get_request_metadata_cancel_closure, in send_security_metadata()
306 GRPC_CLOSURE_INIT(&calld->async_result_closure, on_host_checked, batch, in auth_start_transport_stream_op_batch()
320 GRPC_CLOSURE_INIT(&calld->check_call_host_cancel_closure, in auth_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc392 GRPC_CLOSURE_INIT(&t->read_action_locked, read_action_locked, t, in init_transport_closures()
394 GRPC_CLOSURE_INIT(&t->benign_reclaimer_locked, benign_reclaimer_locked, t, in init_transport_closures()
396 GRPC_CLOSURE_INIT(&t->destructive_reclaimer_locked, in init_transport_closures()
399 GRPC_CLOSURE_INIT(&t->retry_initiate_ping_locked, retry_initiate_ping_locked, in init_transport_closures()
401 GRPC_CLOSURE_INIT(&t->start_bdp_ping_locked, start_bdp_ping_locked, t, in init_transport_closures()
403 GRPC_CLOSURE_INIT(&t->finish_bdp_ping_locked, finish_bdp_ping_locked, t, in init_transport_closures()
405 GRPC_CLOSURE_INIT(&t->next_bdp_ping_timer_expired_locked, in init_transport_closures()
408 GRPC_CLOSURE_INIT(&t->init_keepalive_ping_locked, init_keepalive_ping_locked, in init_transport_closures()
410 GRPC_CLOSURE_INIT(&t->start_keepalive_ping_locked, in init_transport_closures()
413 GRPC_CLOSURE_INIT(&t->finish_keepalive_ping_locked, in init_transport_closures()
[all …]
/external/grpc-grpc/src/core/lib/transport/
Dtransport.cc128 GRPC_CLOSURE_INIT(&refcount->destroy, cb, cb_arg, grpc_schedule_on_exec_ctx);
258 GRPC_CLOSURE_INIT(&op->outer_on_complete, destroy_made_transport_op, op,
285 GRPC_CLOSURE_INIT(&op->outer_on_complete, destroy_made_transport_stream_op,

1234