Home
last modified time | relevance | path

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

12

/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 …]
Dhttpcli_security_connector.cc172 void (*on_done)(void* arg, grpc_endpoint* endpoint)) { in ssl_handshake()
180 on_done(arg, nullptr); in ssl_handshake()
184 c->func = on_done; in ssl_handshake()
Dhttpcli.h48 void (*on_done)(void* arg, grpc_endpoint* endpoint));
/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.cc147 grpc_closure* on_done; member
157 GRPC_CLOSURE_SCHED(r->on_done, grpc_blocking_resolve_address( in do_request_thread()
166 grpc_closure* on_done, in posix_resolve_address() argument
174 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,
Dev_posix.h48 void (*fd_orphan)(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
121 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
Dev_posix.cc259 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd, in grpc_fd_orphan() argument
262 on_done, release_fd, reason); in grpc_fd_orphan()
265 g_event_engine->fd_orphan(fd, on_done, release_fd, reason); in grpc_fd_orphan()
Dudp_server.h105 void grpc_udp_server_destroy(grpc_udp_server* server, grpc_closure* on_done);
Dresource_quota.h135 grpc_closure on_done; member
Dudp_server.cc306 void grpc_udp_server_destroy(grpc_udp_server* s, grpc_closure* on_done) { in grpc_udp_server_destroy() argument
312 s->shutdown_complete = on_done; in grpc_udp_server_destroy()
/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/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/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 …]
Dcredentials_test.cc548 grpc_closure* on_done, grpc_httpcli_response* response) { in compute_engine_httpcli_get_success_override() argument
551 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in compute_engine_httpcli_get_success_override()
557 grpc_closure* on_done, grpc_httpcli_response* response) { in compute_engine_httpcli_get_failure_override() argument
560 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in compute_engine_httpcli_get_failure_override()
566 size_t body_size, grpc_millis deadline, grpc_closure* on_done, in httpcli_post_should_not_be_called() argument
574 grpc_closure* on_done, in httpcli_get_should_not_be_called() argument
651 grpc_millis deadline, grpc_closure* on_done, in refresh_token_httpcli_post_success() argument
655 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in refresh_token_httpcli_post_success()
661 grpc_millis deadline, grpc_closure* on_done, in refresh_token_httpcli_post_failure() argument
665 GRPC_CLOSURE_SCHED(on_done, GRPC_ERROR_NONE); in refresh_token_httpcli_post_failure()
/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/grpc-grpc/test/cpp/qps/
Dclient_async.cc74 std::function<void(grpc::Status, ResponseType*, HistogramEntry*)> on_done) in ClientRpcContextUnaryImpl() argument
81 callback_(on_done), in ClientRpcContextUnaryImpl()
345 std::function<void(grpc::Status, ResponseType*)> on_done) in ClientRpcContextStreamingPingPongImpl() argument
352 callback_(on_done), in ClientRpcContextStreamingPingPongImpl()
530 std::function<void(grpc::Status, ResponseType*)> on_done) in ClientRpcContextStreamingFromClientImpl() argument
537 callback_(on_done), in ClientRpcContextStreamingFromClientImpl()
661 std::function<void(grpc::Status, ResponseType*)> on_done) in ClientRpcContextStreamingFromServerImpl() argument
668 callback_(on_done), in ClientRpcContextStreamingFromServerImpl()
775 std::function<void(grpc::Status, ByteBuffer*)> on_done) in ClientRpcContextGenericStreamingImpl() argument
782 callback_(std::move(on_done)), in ClientRpcContextGenericStreamingImpl()
/external/grpc-grpc/test/core/end2end/fuzzers/
Dapi_fuzzer.cc326 grpc_closure* on_done; member
349 GRPC_CLOSURE_SCHED(r->on_done, GRPC_ERROR_NONE); in finish_resolve()
351 GRPC_CLOSURE_SCHED(r->on_done, in finish_resolve()
362 grpc_closure* on_done, in my_resolve_address() argument
366 r->on_done = on_done; in my_resolve_address()
379 grpc_pollset_set* interested_parties, grpc_closure* on_done, in my_dns_lookup_ares_locked() argument
384 r->on_done = on_done; in my_dns_lookup_ares_locked()
/external/grpc-grpc/src/core/lib/surface/
Dserver.h42 grpc_closure* on_done));

12