Home
last modified time | relevance | path

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

12345

/third_party/grpc/test/cpp/microbenchmarks/
Dbm_closure.cc61 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, grpc_schedule_on_exec_ctx)); in BM_ClosureInitAgainstExecCtx()
74 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, nullptr)); in BM_ClosureInitAgainstCombiner()
85 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, grpc_schedule_on_exec_ctx); in BM_ClosureRun()
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.cc55 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_CreateDestroyPollset()
123 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_PollEmptyPollset()
150 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_PollAddFd()
169 explicit C(F f) : f_(f) { GRPC_CLOSURE_INIT(this, C::cbfn, this, nullptr); } in MakeTestClosure()
243 GRPC_CLOSURE_INIT(&shutdown_ps_closure, shutdown_ps, ps, in BM_SingleThreadPollOneFd()
Dbm_timer.cc49 GRPC_CLOSURE_INIT(&timer_closure->closure, in BM_InitCancelTimer()
78 GRPC_CLOSURE_INIT(&timer_closure->closure, in BM_TimerBatch()
/third_party/grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc226 GRPC_CLOSURE_INIT(&conn->on_client_write_done, on_client_write_done, conn, in on_client_write_done_locked()
238 GRPC_CLOSURE_INIT(&conn->on_client_write_done, on_client_write_done_locked, in on_client_write_done()
261 GRPC_CLOSURE_INIT(&conn->on_server_write_done, on_server_write_done, conn, in on_server_write_done_locked()
273 GRPC_CLOSURE_INIT(&conn->on_server_write_done, on_server_write_done_locked, in on_server_write_done()
302 GRPC_CLOSURE_INIT(&conn->on_server_write_done, on_server_write_done, conn, in on_client_read_done_locked()
308 GRPC_CLOSURE_INIT(&conn->on_client_read_done, on_client_read_done, conn, in on_client_read_done_locked()
316 GRPC_CLOSURE_INIT(&conn->on_client_read_done, on_client_read_done_locked, in on_client_read_done()
344 GRPC_CLOSURE_INIT(&conn->on_client_write_done, on_client_write_done, conn, in on_server_read_done_locked()
350 GRPC_CLOSURE_INIT(&conn->on_server_read_done, on_server_read_done, conn, in on_server_read_done_locked()
358 GRPC_CLOSURE_INIT(&conn->on_server_read_done, on_server_read_done_locked, in on_server_read_done()
[all …]
/third_party/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc45 GRPC_CLOSURE_INIT(&closure_, TimerCallback, this, nullptr); in TimerState()
68 GRPC_CLOSURE_INIT(&self->closure_, YieldCallCombiner, self, nullptr)); in SendCancelOpInCallCombiner()
84 GRPC_CLOSURE_INIT(&self->closure_, SendCancelOpInCallCombiner, self, in TimerCallback()
152 GRPC_CLOSURE_INIT(&deadline_state->recv_trailing_metadata_ready, in inject_recv_trailing_metadata_ready()
208 GRPC_CLOSURE_INIT(&state->closure, start_timer_after_init, state, in grpc_deadline_state()
320 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in deadline_server_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc74 GRPC_CLOSURE_INIT(&retry_timer_callback_, OnRetryTimer, this, in HealthCheckClient()
299 GRPC_CLOSURE_INIT(&after_call_stack_destruction_, AfterCallStackDestruction, in StartCall()
317 batch_.on_complete = GRPC_CLOSURE_INIT(&on_complete_, OnComplete, this, in StartCall()
352 GRPC_CLOSURE_INIT(&recv_initial_metadata_ready_, RecvInitialMetadataReady, in StartCall()
359 payload_.recv_message.recv_message_ready = GRPC_CLOSURE_INIT( in StartCall()
375 GRPC_CLOSURE_INIT(&recv_trailing_metadata_ready_, in StartCall()
395 GRPC_CLOSURE_INIT(&batch->handler_private.closure, StartBatchInCallCombiner, in StartBatch()
482 payload_.recv_message.recv_message_ready = GRPC_CLOSURE_INIT( in DoneReadingRecvMessage()
541 GRPC_CLOSURE_INIT(&self->recv_message_ready_, OnByteStreamNext, self, in RecvMessageReady()
/third_party/grpc/test/core/transport/
Dbyte_stream_test.cc61 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
93 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
138 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
173 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
216 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc407 GRPC_CLOSURE_INIT(&t->init_keepalive_ping_locked, init_keepalive_ping, t, in init_keepalive_pings_if_enabled()
636 GRPC_CLOSURE_INIT(&reset_byte_stream, ::reset_byte_stream, this, nullptr);
727 GRPC_CLOSURE_INIT(&s->destroy_stream, destroy_stream_locked, s, nullptr), in destroy_stream()
892 GRPC_CLOSURE_INIT(&t->write_action_begin_locked, in grpc_chttp2_initiate_write()
967 GRPC_CLOSURE_INIT(&t->write_action_end_locked, write_action_end, t, in write_action()
974 t->combiner->Run(GRPC_CLOSURE_INIT(&t->write_action_end_locked, in write_action_end()
1020 GRPC_CLOSURE_INIT(&t->write_action_begin_locked, in write_action_end_locked()
1281 UINT32_MAX, GRPC_CLOSURE_INIT(&s->complete_fetch_locked, in continue_fetching_send_locked()
1297 s->t->combiner->Run(GRPC_CLOSURE_INIT(&s->complete_fetch_locked, in complete_fetch()
1611 t->combiner->Run(GRPC_CLOSURE_INIT(&op->handler_private.closure, in perform_stream_op()
[all …]
/third_party/grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc471 GRPC_CLOSURE_INIT(&chand->max_idle_timer_cb, max_idle_timer_cb, chand, in max_age_init_channel_elem()
473 GRPC_CLOSURE_INIT(&chand->close_max_age_channel, close_max_age_channel, chand, in max_age_init_channel_elem()
475 GRPC_CLOSURE_INIT(&chand->force_close_max_age_channel, in max_age_init_channel_elem()
478 GRPC_CLOSURE_INIT(&chand->start_max_idle_timer_after_init, in max_age_init_channel_elem()
481 GRPC_CLOSURE_INIT(&chand->start_max_age_timer_after_init, in max_age_init_channel_elem()
484 GRPC_CLOSURE_INIT(&chand->start_max_age_grace_timer_after_goaway_op, in max_age_init_channel_elem()
/third_party/grpc/src/core/ext/filters/client_channel/
Dhttp_connect_handshaker.cc140 GRPC_CLOSURE_INIT(&handshaker->request_done_closure_, in OnWriteDoneScheduler()
161 GRPC_CLOSURE_INIT(&handshaker->response_read_closure_, in OnWriteDone()
174 GRPC_CLOSURE_INIT(&handshaker->response_read_closure_, in OnReadDoneScheduler()
237 GRPC_CLOSURE_INIT(&handshaker->response_read_closure_, in OnReadDone()
355 GRPC_CLOSURE_INIT(&request_done_closure_, in DoHandshake()
Dchannel_connectivity.cc237 GRPC_CLOSURE_INIT(&w->on_complete, watch_complete, w, in grpc_channel_watch_connectivity_state()
239 GRPC_CLOSURE_INIT(&w->on_timeout, timeout_complete, w, in grpc_channel_watch_connectivity_state()
252 GRPC_CLOSURE_INIT(&w->watcher_timer_init, watcher_timer_init, wa, in grpc_channel_watch_connectivity_state()
/third_party/grpc/src/core/lib/security/transport/
Dsecurity_handshaker.cc124 GRPC_CLOSURE_INIT(&on_peer_checked_, &SecurityHandshaker::OnPeerCheckedFn, in SecurityHandshaker()
296 GRPC_CLOSURE_INIT( in OnHandshakeNextDoneLocked()
320 GRPC_CLOSURE_INIT( in OnHandshakeNextDoneLocked()
329 GRPC_CLOSURE_INIT( in OnHandshakeNextDoneLocked()
383 GRPC_CLOSURE_INIT(&h->on_handshake_data_received_from_peer_, in OnHandshakeDataReceivedFromPeerFnScheduler()
417 GRPC_CLOSURE_INIT(&h->on_handshake_data_sent_to_peer_, in OnHandshakeDataSentToPeerFnScheduler()
436 GRPC_CLOSURE_INIT( in OnHandshakeDataSentToPeerFn()
/third_party/grpc/src/core/lib/iomgr/
Dudp_server.cc300 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OrphanFd()
333 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OnFdAboutToOrphan()
338 GRPC_CLOSURE_INIT(&orphan_fd_closure_, shutdown_fd, this, in OnFdAboutToOrphan()
485 GRPC_CLOSURE_INIT(&do_read_closure_, do_read, do_read_arg, nullptr); in OnRead()
521 GRPC_CLOSURE_INIT(&sp->notify_on_write_closure_, fd_notify_on_write_wrapper, in do_write()
548 GRPC_CLOSURE_INIT(&do_write_closure_, do_write, do_write_arg, nullptr); in OnCanWrite()
727 GRPC_CLOSURE_INIT(&read_closure_, on_read, this, grpc_schedule_on_exec_ctx); in StartListening()
730 GRPC_CLOSURE_INIT(&write_closure_, on_write, this, grpc_schedule_on_exec_ctx); in StartListening()
Dresource_quota.cc665 GRPC_CLOSURE_INIT(&resource_quota->rq_step_closure, rq_step, resource_quota, in grpc_resource_quota_create()
667 GRPC_CLOSURE_INIT(&resource_quota->rq_reclamation_done_closure, in grpc_resource_quota_create()
727 GRPC_CLOSURE_INIT(&a->closure, rq_resize, a, grpc_schedule_on_exec_ctx); in grpc_resource_quota_resize()
781 GRPC_CLOSURE_INIT(&resource_user->allocate_closure, &ru_allocate, in grpc_resource_user_create()
783 GRPC_CLOSURE_INIT(&resource_user->add_to_free_pool_closure, in grpc_resource_user_create()
785 GRPC_CLOSURE_INIT(&resource_user->post_reclaimer_closure[0], in grpc_resource_user_create()
787 GRPC_CLOSURE_INIT(&resource_user->post_reclaimer_closure[1], in grpc_resource_user_create()
789 GRPC_CLOSURE_INIT(&resource_user->destroy_closure, &ru_destroy, resource_user, in grpc_resource_user_create()
991 GRPC_CLOSURE_INIT(&slice_allocator->on_allocated, ru_allocated_slices, in grpc_resource_user_slice_allocator_init()
993 GRPC_CLOSURE_INIT(&slice_allocator->on_done, cb, p, in grpc_resource_user_slice_allocator_init()
/third_party/grpc/src/cpp/server/
Dserver_callback.cc38 GRPC_CLOSURE_INIT( in ScheduleOnDone()
67 GRPC_CLOSURE_INIT( in CallOnCancel()
/third_party/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_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_client_uv_test.cc110 GRPC_CLOSURE_INIT(&done, must_succeed, NULL, grpc_schedule_on_exec_ctx); in test_succeeds()
153 GRPC_CLOSURE_INIT(&done, must_fail, NULL, grpc_schedule_on_exec_ctx); in test_fails()
201 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
Dendpoint_tests.cc227 GRPC_CLOSURE_INIT(&state.read_scheduler, read_scheduler, &state, in read_and_write_test()
229 GRPC_CLOSURE_INIT(&state.done_read, read_and_write_test_read_handler, &state, in read_and_write_test()
231 GRPC_CLOSURE_INIT(&state.write_scheduler, write_scheduler, &state, in read_and_write_test()
233 GRPC_CLOSURE_INIT(&state.done_write, read_and_write_test_write_handler, in read_and_write_test()
/third_party/grpc/src/core/lib/channel/
Dhandshaker.cc232 GRPC_CLOSURE_INIT(&call_next_handshaker_, in DoHandshake()
235 GRPC_CLOSURE_INIT(&on_handshake_done_, on_handshake_done, &args_, in DoHandshake()
239 GRPC_CLOSURE_INIT(&on_timeout_, &HandshakeManager::OnTimeoutFn, this, in DoHandshake()
/third_party/grpc/test/core/security/
Doauth2_utils.cc83 GRPC_CLOSURE_INIT(&do_nothing_closure, do_nothing, nullptr, in grpc_test_fetch_oauth2_token_with_credentials()
86 GRPC_CLOSURE_INIT(&request.closure, on_oauth2_response, &request, in grpc_test_fetch_oauth2_token_with_credentials()
/third_party/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_ev_driver.cc294 GRPC_CLOSURE_INIT(&driver->on_ares_backup_poll_alarm_locked, in on_ares_backup_poll_alarm_locked()
409 GRPC_CLOSURE_INIT(&fdn->read_closure, on_readable, fdn, in grpc_ares_notify_on_event_locked()
422 GRPC_CLOSURE_INIT(&fdn->write_closure, on_writable, fdn, in grpc_ares_notify_on_event_locked()
468 GRPC_CLOSURE_INIT(&ev_driver->on_timeout_locked, on_timeout, ev_driver, in grpc_ares_ev_driver_start_locked()
476 GRPC_CLOSURE_INIT(&ev_driver->on_ares_backup_poll_alarm_locked, in grpc_ares_ev_driver_start_locked()
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc64 GRPC_CLOSURE_INIT(&on_recv_initial_metadata_ready_, in CallData()
69 GRPC_CLOSURE_INIT(&on_recv_message_next_done_, OnRecvMessageNextDone, this, in CallData()
71 GRPC_CLOSURE_INIT(&on_recv_message_ready_, OnRecvMessageReady, this, in CallData()
74 GRPC_CLOSURE_INIT(&on_recv_trailing_metadata_ready_, in CallData()
/third_party/grpc/test/core/util/
Dtest_tcp_server.cc45 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()
/third_party/grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc44 GRPC_CLOSURE_INIT(&connected_, Connected, this, grpc_schedule_on_exec_ctx); in Chttp2Connector()
176 GRPC_CLOSURE_INIT(&self->on_receive_settings_, OnReceiveSettings, self, in OnHandshakeDone()
182 GRPC_CLOSURE_INIT(&self->on_timeout_, OnTimeout, self, in OnHandshakeDone()

12345