Home
last modified time | relevance | path

Searched refs:on_done (Results 1 – 25 of 53) sorted by relevance

123

/external/rust/crates/grpcio-sys/grpc/src/core/lib/http/
Dhttpcli.cc56 grpc_closure* on_done; member
73 void (*on_done)(void* arg, in plaintext_handshake()
75 on_done(arg, endpoint); in plaintext_handshake()
94 grpc_core::ExecCtx::Run(DEBUG_LOCATION, req->on_done, error); in finish()
233 grpc_millis deadline, grpc_closure* on_done, in internal_request_begin() argument
242 req->on_done = on_done; in internal_request_begin()
272 grpc_closure* on_done, grpc_httpcli_response* response) { in grpc_httpcli_get() argument
273 if (g_get_override && g_get_override(request, deadline, on_done, response)) { in grpc_httpcli_get()
279 on_done, response, name.c_str(), in grpc_httpcli_get()
288 grpc_millis deadline, grpc_closure* on_done, in grpc_httpcli_post() argument
[all …]
Dhttpcli.h48 void (*on_done)(void* arg, grpc_endpoint* endpoint));
86 grpc_closure* on_done, grpc_httpcli_response* response);
107 grpc_millis deadline, grpc_closure* on_done,
Dhttpcli_security_connector.cc182 void (*on_done)(void* arg, grpc_endpoint* endpoint)) { in ssl_handshake()
190 on_done(arg, nullptr); in ssl_handshake()
194 c->func = on_done; in ssl_handshake()
/external/grpc-grpc/src/core/lib/http/
Dhttpcli.cc51 grpc_closure* on_done; member
69 void (*on_done)(void* arg, in plaintext_handshake()
71 on_done(arg, endpoint); in plaintext_handshake()
90 GRPC_CLOSURE_SCHED(req->on_done, error); in finish()
230 grpc_millis deadline, grpc_closure* on_done, in internal_request_begin() argument
238 req->on_done = on_done; in internal_request_begin()
268 grpc_closure* on_done, grpc_httpcli_response* response) { in grpc_httpcli_get() argument
270 if (g_get_override && g_get_override(request, deadline, on_done, response)) { in grpc_httpcli_get()
275 on_done, response, name, in grpc_httpcli_get()
285 grpc_millis deadline, grpc_closure* on_done, in grpc_httpcli_post() argument
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dresolve_address_custom.cc40 grpc_closure* on_done = nullptr; member
83 if (r->on_done) { in grpc_custom_resolve_callback()
84 grpc_core::ExecCtx::Run(DEBUG_LOCATION, r->on_done, error); in grpc_custom_resolve_callback()
142 grpc_closure* on_done, in resolve_address_impl() argument
149 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, err); in resolve_address_impl()
153 r->on_done = on_done; in resolve_address_impl()
Dtcp_client_windows.cc45 grpc_closure* on_done; member
84 grpc_closure* on_done = ac->on_done; in on_connect() local
120 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, error); in on_connect()
125 static void tcp_connect(grpc_closure* on_done, grpc_endpoint** endpoint, in tcp_connect() argument
199 ac->on_done = on_done; in tcp_connect()
227 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, final_error); in tcp_connect()
Dresolve_address_windows.cc54 grpc_closure* on_done; member
132 grpc_core::ExecCtx::Run(DEBUG_LOCATION, r->on_done, error); in do_request_thread()
140 grpc_closure* on_done, in windows_resolve_address() argument
146 r->on_done = on_done; in windows_resolve_address()
Dresolve_address_posix.cc141 grpc_closure* on_done; member
151 DEBUG_LOCATION, r->on_done, in do_request_thread()
160 grpc_closure* on_done, in posix_resolve_address() argument
166 r->on_done = on_done; in posix_resolve_address()
Dresolve_address.cc32 grpc_closure* on_done, in grpc_resolve_address() argument
35 addr, default_port, interested_parties, on_done, addresses); in grpc_resolve_address()
Dresolve_address.h55 grpc_closure* on_done,
69 grpc_closure* on_done,
/external/grpc-grpc/src/core/lib/iomgr/
Dresolve_address_custom.cc38 grpc_closure* on_done; member
80 if (r->on_done) { in grpc_custom_resolve_callback()
81 GRPC_CLOSURE_SCHED(r->on_done, error); in grpc_custom_resolve_callback()
157 grpc_closure* on_done, in resolve_address_impl() argument
166 GRPC_CLOSURE_SCHED(on_done, err); in resolve_address_impl()
172 r->on_done = on_done; in resolve_address_impl()
Dtcp_client_windows.cc44 grpc_closure* on_done; member
84 grpc_closure* on_done = ac->on_done; in on_connect() local
120 GRPC_CLOSURE_SCHED(on_done, error); in on_connect()
125 static void tcp_connect(grpc_closure* on_done, grpc_endpoint** endpoint, in tcp_connect() argument
199 ac->on_done = on_done; in tcp_connect()
226 GRPC_CLOSURE_SCHED(on_done, final_error); in tcp_connect()
Dresolve_address_windows.cc50 grpc_closure* on_done; member
143 GRPC_CLOSURE_SCHED(r->on_done, error); in do_request_thread()
151 grpc_closure* on_done, in windows_resolve_address() argument
159 r->on_done = on_done; in windows_resolve_address()
Dresolve_address_posix.cc152 grpc_closure* on_done; member
162 GRPC_CLOSURE_SCHED(r->on_done, grpc_blocking_resolve_address( in do_request_thread()
171 grpc_closure* on_done, in posix_resolve_address() argument
179 r->on_done = on_done; in posix_resolve_address()
Dresolve_address.cc32 grpc_closure* on_done, in grpc_resolve_address() argument
35 addr, default_port, interested_parties, on_done, addresses); in grpc_resolve_address()
Dresolve_address.h57 grpc_closure* on_done,
71 grpc_closure* on_done,
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_wrapper_fallback.cc31 grpc_pollset_set* interested_parties, grpc_closure* on_done, in grpc_dns_lookup_ares_locked_impl() argument
39 grpc_pollset_set* interested_parties, grpc_closure* on_done,
52 grpc_closure* on_done, in grpc_resolve_address_ares_impl() argument
57 grpc_pollset_set* interested_parties, grpc_closure* on_done,
Dgrpc_ares_wrapper.cc59 grpc_closure* on_done; member
151 GRPC_CLOSURE_SCHED(r->on_done, r->error); in grpc_ares_complete_request_locked()
362 grpc_pollset_set* interested_parties, grpc_closure* on_done, in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked() argument
395 r->on_done = on_done; in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked()
476 GRPC_CLOSURE_SCHED(on_done, error); in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked()
536 grpc_pollset_set* interested_parties, grpc_closure* on_done, in grpc_dns_lookup_ares_locked_impl() argument
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()
552 dns_server, name, default_port, interested_parties, on_done, addrs, in grpc_dns_lookup_ares_locked_impl()
558 grpc_pollset_set* interested_parties, grpc_closure* on_done,
[all …]
Dgrpc_ares_wrapper.h48 grpc_closure* on_done,
60 grpc_pollset_set* interested_parties, grpc_closure* on_done,
/external/grpc-grpc/test/core/client_channel/resolvers/
Ddns_resolver_connectivity_test.cc40 grpc_closure* on_done, in my_resolve_address() argument
57 GRPC_CLOSURE_SCHED(on_done, error); in my_resolve_address()
65 grpc_pollset_set* interested_parties, grpc_closure* on_done, in my_dns_lookup_ares_locked() argument
81 GRPC_CLOSURE_SCHED(on_done, error); in my_dns_lookup_ares_locked()
100 static void on_done(void* ev, grpc_error* error) { in on_done() function
161 GRPC_CLOSURE_CREATE(on_done, &ev1, grpc_schedule_on_exec_ctx), in main()
171 GRPC_CLOSURE_CREATE(on_done, &ev2, grpc_schedule_on_exec_ctx), in main()
Ddns_resolver_cooldown_test.cc42 grpc_pollset_set* interested_parties, grpc_closure* on_done,
63 grpc_closure* on_done, in test_resolve_address_impl() argument
66 name, default_port, g_iomgr_args.pollset_set, on_done, addrs); in test_resolve_address_impl()
92 grpc_pollset_set* interested_parties, grpc_closure* on_done, in test_dns_lookup_ares_locked() argument
96 dns_server, name, default_port, g_iomgr_args.pollset_set, on_done, addrs, in test_dns_lookup_ares_locked()
/external/grpc-grpc/test/core/security/
Djwt_verifier_test.cc322 size_t body_size, grpc_millis deadline, grpc_closure* on_done, in httpcli_post_should_not_be_called() argument
330 grpc_closure* on_done, grpc_httpcli_response* response) { in httpcli_get_google_keys_for_email() argument
338 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_google_keys_for_email()
376 grpc_closure* on_done, grpc_httpcli_response* response) { in httpcli_get_custom_keys_for_email() argument
381 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_custom_keys_for_email()
408 grpc_millis deadline, grpc_closure* on_done, in httpcli_get_jwk_set() argument
414 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_jwk_set()
420 grpc_closure* on_done, in httpcli_get_openid_config() argument
428 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in httpcli_get_openid_config()
463 grpc_millis deadline, grpc_closure* on_done, in httpcli_get_bad_json() argument
[all …]
/external/grpc-grpc/test/core/end2end/
Dgoaway_server_test.cc49 grpc_pollset_set* interested_parties, grpc_closure* on_done,
61 grpc_closure* on_done, in my_resolve_address() argument
65 on_done, addrs); in my_resolve_address()
88 GRPC_CLOSURE_SCHED(on_done, error); in my_resolve_address()
103 grpc_pollset_set* interested_parties, grpc_closure* on_done, in my_dns_lookup_ares_locked() argument
108 dns_server, addr, default_port, interested_parties, on_done, lb_addrs, in my_dns_lookup_ares_locked()
129 GRPC_CLOSURE_SCHED(on_done, error); in my_dns_lookup_ares_locked()
/external/rust/crates/grpcio-sys/grpc/test/core/security/
Djwt_verifier_test.cc348 grpc_closure* on_done, grpc_httpcli_response* response) { in httpcli_get_google_keys_for_email() argument
356 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_google_keys_for_email()
395 grpc_closure* on_done, grpc_httpcli_response* response) { in httpcli_get_custom_keys_for_email() argument
400 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_custom_keys_for_email()
428 grpc_millis /*deadline*/, grpc_closure* on_done, in httpcli_get_jwk_set() argument
434 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_jwk_set()
440 grpc_closure* on_done, in httpcli_get_openid_config() argument
448 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_openid_config()
484 grpc_millis /*deadline*/, grpc_closure* on_done, in httpcli_get_bad_json() argument
488 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_bad_json()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_wrapper.h55 grpc_closure* on_done,
68 grpc_pollset_set* interested_parties, grpc_closure* on_done,

123