Home
last modified time | relevance | path

Searched refs:GRPC_CLOSURE_SCHED (Results 1 – 25 of 90) sorted by relevance

1234

/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_closure.cc130 GRPC_CLOSURE_SCHED(&c, GRPC_ERROR_NONE); in BM_ClosureSchedOnExecCtx()
146 GRPC_CLOSURE_SCHED(&c1, GRPC_ERROR_NONE); in BM_ClosureSched2OnExecCtx()
147 GRPC_CLOSURE_SCHED(&c2, GRPC_ERROR_NONE); in BM_ClosureSched2OnExecCtx()
165 GRPC_CLOSURE_SCHED(&c1, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
166 GRPC_CLOSURE_SCHED(&c2, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
167 GRPC_CLOSURE_SCHED(&c3, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
250 GRPC_CLOSURE_SCHED(&c, GRPC_ERROR_NONE); in BM_ClosureSchedOnCombiner()
268 GRPC_CLOSURE_SCHED(&c1, GRPC_ERROR_NONE); in BM_ClosureSched2OnCombiner()
269 GRPC_CLOSURE_SCHED(&c2, GRPC_ERROR_NONE); in BM_ClosureSched2OnCombiner()
289 GRPC_CLOSURE_SCHED(&c1, GRPC_ERROR_NONE); in BM_ClosureSched3OnCombiner()
[all …]
Dbm_chttp2_transport.cc70 GRPC_CLOSURE_SCHED(read_cb_, GRPC_ERROR_NONE); in PushInput()
86 GRPC_CLOSURE_SCHED(cb, GRPC_ERROR_NONE); in QueueRead()
100 GRPC_CLOSURE_SCHED(cb, GRPC_ERROR_NONE); in write()
115 GRPC_CLOSURE_SCHED(static_cast<DummyEndpoint*>(ep)->read_cb_, why); in shutdown()
348 GRPC_CLOSURE_SCHED(start.get(), GRPC_ERROR_NONE); in BM_StreamCreateSendInitialMetadataDestroy()
375 GRPC_CLOSURE_SCHED(c.get(), GRPC_ERROR_NONE); in BM_TransportEmptyOp()
589 GRPC_CLOSURE_SCHED(c.get(), GRPC_ERROR_NONE); in BM_TransportStreamRecv()
/external/grpc-grpc/test/core/iomgr/
Dcombiner_test.cc46 GRPC_CLOSURE_SCHED(GRPC_CLOSURE_CREATE(set_event_to_true, &done, in test_execute_one()
82 GRPC_CLOSURE_SCHED(GRPC_CLOSURE_CREATE( in execute_many_loop()
91 GRPC_CLOSURE_SCHED(GRPC_CLOSURE_CREATE(set_event_to_true, &args->done, in execute_many_loop()
125 GRPC_CLOSURE_SCHED(GRPC_CLOSURE_CREATE(in_finally, arg, in add_finally()
137 GRPC_CLOSURE_SCHED( in test_execute_finally()
/external/grpc-grpc/src/core/lib/iomgr/
Dlockfree_event.cc127 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE); in NotifyOn()
140 GRPC_CLOSURE_SCHED(closure, in NotifyOn()
192 GRPC_CLOSURE_SCHED((grpc_closure*)curr, in SetShutdown()
242 GRPC_CLOSURE_SCHED((grpc_closure*)curr, GRPC_ERROR_NONE); in SetReady()
Dcall_combiner.cc88 GRPC_CLOSURE_SCHED(closure, error); in grpc_call_combiner_start()
135 GRPC_CLOSURE_SCHED(closure, closure->error_data.error); in grpc_call_combiner_stop()
159 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_REF(original_error)); in grpc_call_combiner_set_notify_on_cancel()
178 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE); in grpc_call_combiner_set_notify_on_cancel()
206 GRPC_CLOSURE_SCHED(notify_on_cancel, GRPC_ERROR_REF(error)); in grpc_call_combiner_cancel()
Dresource_quota.cc291 GRPC_CLOSURE_SCHED(&resource_quota->rq_step_closure, GRPC_ERROR_NONE); in rq_step_sched()
413 GRPC_CLOSURE_SCHED(c, GRPC_ERROR_NONE); in rq_reclaim()
493 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_CANCELLED); in ru_post_reclaimer()
536 GRPC_CLOSURE_SCHED(resource_user->reclaimers[0], GRPC_ERROR_CANCELLED); in ru_shutdown()
537 GRPC_CLOSURE_SCHED(resource_user->reclaimers[1], GRPC_ERROR_CANCELLED); in ru_shutdown()
559 GRPC_CLOSURE_SCHED(resource_user->reclaimers[0], GRPC_ERROR_CANCELLED); in ru_destroy()
560 GRPC_CLOSURE_SCHED(resource_user->reclaimers[1], GRPC_ERROR_CANCELLED); in ru_destroy()
702 GRPC_CLOSURE_SCHED(&a->closure, GRPC_ERROR_NONE); in grpc_resource_quota_resize()
810 GRPC_CLOSURE_SCHED(&resource_user->destroy_closure, GRPC_ERROR_NONE); in ru_unref_by()
824 GRPC_CLOSURE_SCHED( in grpc_resource_user_shutdown()
[all …]
Dtcp_windows.cc209 GRPC_CLOSURE_SCHED(cb, error); in on_read()
223 GRPC_CLOSURE_SCHED( in win_read()
249 GRPC_CLOSURE_SCHED(&tcp->on_read, GRPC_ERROR_NONE); in win_read()
262 GRPC_CLOSURE_SCHED(&tcp->on_read, in win_read()
294 GRPC_CLOSURE_SCHED(cb, error); in on_write()
312 GRPC_CLOSURE_SCHED( in win_write()
345 GRPC_CLOSURE_SCHED(cb, error); in win_write()
363 GRPC_CLOSURE_SCHED(cb, GRPC_WSA_ERROR(wsa_error, "WSASend")); in win_write()
Dtimer_custom.cc39 GRPC_CLOSURE_SCHED(timer->closure, GRPC_ERROR_NONE); in grpc_custom_timer_callback()
50 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE); in timer_init()
71 GRPC_CLOSURE_SCHED(timer->closure, GRPC_ERROR_CANCELLED); in timer_cancel()
Dtcp_client_posix.cc249 GRPC_CLOSURE_SCHED(closure, error); in on_writable()
306 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE); in grpc_tcp_client_create_from_prepared_fd()
311 GRPC_CLOSURE_SCHED(closure, GRPC_OS_ERROR(errno, "connect")); in grpc_tcp_client_create_from_prepared_fd()
352 GRPC_CLOSURE_SCHED(closure, error); in tcp_connect()
Dtcp_custom.cc144 GRPC_CLOSURE_SCHED(cb, error); in call_read_cb()
220 GRPC_CLOSURE_SCHED(cb, error); in custom_write_callback()
241 GRPC_CLOSURE_SCHED(cb, GRPC_ERROR_CREATE_FROM_STATIC_STRING( in endpoint_write()
252 GRPC_CLOSURE_SCHED(cb, GRPC_ERROR_NONE); in endpoint_write()
Dresolve_address_windows.cc143 GRPC_CLOSURE_SCHED(r->on_done, error); in do_request_thread()
161 GRPC_CLOSURE_SCHED(&r->request_closure, GRPC_ERROR_NONE); in windows_resolve_address()
Dresolve_address_posix.cc157 GRPC_CLOSURE_SCHED(r->on_done, grpc_blocking_resolve_address( in do_request_thread()
176 GRPC_CLOSURE_SCHED(&r->request_closure, GRPC_ERROR_NONE); in posix_resolve_address()
Dsocket_windows.cc125 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE); in socket_notify_on_iocp()
146 GRPC_CLOSURE_SCHED(info->closure, GRPC_ERROR_NONE); in grpc_socket_become_ready()
/external/grpc-grpc/test/core/util/
Dpassthru_endpoint.cc61 GRPC_CLOSURE_SCHED( in me_read()
65 GRPC_CLOSURE_SCHED(cb, GRPC_ERROR_NONE); in me_read()
90 GRPC_CLOSURE_SCHED(m->on_read, GRPC_ERROR_NONE); in me_write()
99 GRPC_CLOSURE_SCHED(cb, error); in me_write()
115 GRPC_CLOSURE_SCHED( in me_shutdown()
122 GRPC_CLOSURE_SCHED( in me_shutdown()
Dmock_endpoint.cc49 GRPC_CLOSURE_SCHED(cb, GRPC_ERROR_NONE); in me_read()
63 GRPC_CLOSURE_SCHED(cb, GRPC_ERROR_NONE); in me_write()
78 GRPC_CLOSURE_SCHED(m->on_read, in me_shutdown()
139 GRPC_CLOSURE_SCHED(m->on_read, GRPC_ERROR_NONE); in grpc_mock_endpoint_put_read()
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc102 GRPC_CLOSURE_SCHED(op->on_connectivity_state_change, GRPC_ERROR_NONE); in lame_start_transport_op()
105 GRPC_CLOSURE_SCHED( in lame_start_transport_op()
110 GRPC_CLOSURE_SCHED( in lame_start_transport_op()
116 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in lame_start_transport_op()
130 GRPC_CLOSURE_SCHED(then_schedule_closure, GRPC_ERROR_NONE); in destroy_call_elem()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc179 GRPC_CLOSURE_SCHED(s->closure_at_destroy, GRPC_ERROR_NONE); in really_destroy_stream()
385 GRPC_CLOSURE_SCHED(op->on_complete, GRPC_ERROR_REF(error)); in complete_if_batch_end_locked()
392 GRPC_CLOSURE_SCHED(&s->op_closure, GRPC_ERROR_REF(error)); in maybe_schedule_op_closure_locked()
467 GRPC_CLOSURE_SCHED(s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
480 GRPC_CLOSURE_SCHED( in fail_helper_locked()
504 GRPC_CLOSURE_SCHED(s->recv_trailing_md_op->payload->recv_trailing_metadata in fail_helper_locked()
561 GRPC_CLOSURE_SCHED( in message_transfer_locked()
651 GRPC_CLOSURE_SCHED( in op_state_machine()
657 GRPC_CLOSURE_SCHED(s->recv_trailing_md_op->on_complete, in op_state_machine()
703 GRPC_CLOSURE_SCHED(s->recv_initial_md_op->payload->recv_initial_metadata in op_state_machine()
[all …]
/external/grpc-grpc/src/core/lib/transport/
Dconnectivity_state.cc69 GRPC_CLOSURE_SCHED(w->notify, error); in grpc_connectivity_state_destroy()
124 GRPC_CLOSURE_SCHED(notify, GRPC_ERROR_CANCELLED); in grpc_connectivity_state_notify_on_state_change()
132 GRPC_CLOSURE_SCHED(notify, GRPC_ERROR_CANCELLED); in grpc_connectivity_state_notify_on_state_change()
143 GRPC_CLOSURE_SCHED(notify, GRPC_ERROR_REF(tracker->current_error)); in grpc_connectivity_state_notify_on_state_change()
192 GRPC_CLOSURE_SCHED(w->notify, GRPC_ERROR_REF(tracker->current_error)); in grpc_connectivity_state_set()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/fake/
Dfake_resolver.cc121 GRPC_CLOSURE_SCHED(next_completion_, GRPC_ERROR_NONE); in MaybeFinishNextLocked()
130 GRPC_CLOSURE_SCHED(next_completion_, GRPC_ERROR_CREATE_FROM_STATIC_STRING( in ShutdownLocked()
162 GRPC_CLOSURE_SCHED( in SetResponse()
185 GRPC_CLOSURE_SCHED( in SetReresolutionResponse()
205 GRPC_CLOSURE_SCHED( in SetFailure()
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1120 GRPC_CLOSURE_SCHED( in execute_stream_op()
1124 GRPC_CLOSURE_SCHED( in execute_stream_op()
1128 GRPC_CLOSURE_SCHED( in execute_stream_op()
1135 GRPC_CLOSURE_SCHED( in execute_stream_op()
1146 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1153 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1161 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1168 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1210 GRPC_CLOSURE_SCHED( in execute_stream_op()
1266 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
[all …]
/external/grpc-grpc/test/core/client_channel/resolvers/
Ddns_resolver_connectivity_test.cc57 GRPC_CLOSURE_SCHED(on_done, error); in my_resolve_address()
81 GRPC_CLOSURE_SCHED(on_done, error); in my_dns_lookup_ares_locked()
138 GRPC_CLOSURE_SCHED(GRPC_CLOSURE_CREATE(call_resolver_next_now_lock_taken, a, in call_resolver_next_after_locking()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc185 GRPC_CLOSURE_SCHED(pick->on_complete, error); in HandOffPendingPicksLocked()
201 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_REF(error)); in ShutdownLocked()
218 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelPickLocked()
239 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelMatchingPicksLocked()
594 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_NONE); in ProcessUnselectedReadyLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_wrapper.cc151 GRPC_CLOSURE_SCHED(r->on_done, r->error); in grpc_ares_complete_request_locked()
476 GRPC_CLOSURE_SCHED(on_done, error); in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked()
541 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in grpc_dns_lookup_ares_locked_impl()
547 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in grpc_dns_lookup_ares_locked_impl()
636 GRPC_CLOSURE_SCHED(r->on_resolve_address_done, GRPC_ERROR_REF(error)); in on_dns_lookup_done_cb()
668 GRPC_CLOSURE_SCHED( in grpc_resolve_address_ares_impl()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc262 GRPC_CLOSURE_SCHED(pick->on_complete, error); in HandOffPendingPicksLocked()
278 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_REF(error)); in ShutdownLocked()
295 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelPickLocked()
317 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelMatchingPicksLocked()
378 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_NONE); in DrainPendingPicksLocked()
/external/grpc-grpc/test/core/security/
Djwt_verifier_test.cc338 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_google_keys_for_email()
381 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_custom_keys_for_email()
414 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_jwk_set()
428 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_openid_config()
467 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_bad_json()

1234