Home
last modified time | relevance | path

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

12

/third_party/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()
/third_party/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,
Dev_posix.h53 void (*fd_orphan)(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
135 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
Dev_posix.cc264 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd, in grpc_fd_orphan() argument
267 on_done, release_fd, reason); in grpc_fd_orphan()
270 g_event_engine->fd_orphan(fd, on_done, release_fd, reason); in grpc_fd_orphan()
Dudp_server.h101 void grpc_udp_server_destroy(grpc_udp_server* server, grpc_closure* on_done);
Dresource_quota.h152 grpc_closure on_done; member
Dudp_server.cc307 void grpc_udp_server_destroy(grpc_udp_server* s, grpc_closure* on_done) { in grpc_udp_server_destroy() argument
313 s->shutdown_complete = on_done; in grpc_udp_server_destroy()
Dresource_quota.cc608 grpc_core::Closure::Run(DEBUG_LOCATION, &slice_allocator->on_done, in ru_allocated_slices()
993 GRPC_CLOSURE_INIT(&slice_allocator->on_done, cb, p, in grpc_resource_user_slice_allocator_init()
/third_party/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
41 grpc_pollset_set* interested_parties, grpc_closure* on_done,
60 grpc_closure* on_done, in grpc_resolve_address_ares_impl() argument
65 grpc_pollset_set* interested_parties, grpc_closure* on_done,
Dgrpc_ares_wrapper.h55 grpc_closure* on_done,
68 grpc_pollset_set* interested_parties, grpc_closure* on_done,
Dgrpc_ares_wrapper.cc67 grpc_closure* on_done; member
621 grpc_core::ExecCtx::Run(DEBUG_LOCATION, r->on_done, r->error); in grpc_ares_complete_request_locked()
919 grpc_core::ExecCtx::Run(DEBUG_LOCATION, r->on_done, error); in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked()
1057 grpc_pollset_set* interested_parties, grpc_closure* on_done, in grpc_dns_lookup_ares_locked_impl() argument
1065 r->on_done = on_done; in grpc_dns_lookup_ares_locked_impl()
1102 grpc_pollset_set* interested_parties, grpc_closure* on_done,
1210 grpc_closure* on_done, in grpc_resolve_address_ares_impl() argument
1216 r->on_resolve_address_done = on_done; in grpc_resolve_address_ares_impl()
1227 grpc_pollset_set* interested_parties, grpc_closure* on_done,
/third_party/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()
394 grpc_closure* on_done, grpc_httpcli_response* response) { in httpcli_get_custom_keys_for_email() argument
399 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_custom_keys_for_email()
426 grpc_millis /*deadline*/, grpc_closure* on_done, in httpcli_get_jwk_set() argument
432 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_jwk_set()
438 grpc_closure* on_done, in httpcli_get_openid_config() argument
446 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_openid_config()
481 grpc_millis /*deadline*/, grpc_closure* on_done, in httpcli_get_bad_json() argument
485 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in httpcli_get_bad_json()
Dcredentials_test.cc586 grpc_closure* on_done, grpc_httpcli_response* response) { in compute_engine_httpcli_get_success_override() argument
589 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in compute_engine_httpcli_get_success_override()
595 grpc_closure* on_done, grpc_httpcli_response* response) { in compute_engine_httpcli_get_failure_override() argument
598 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in compute_engine_httpcli_get_failure_override()
698 grpc_millis /*deadline*/, grpc_closure* on_done, in refresh_token_httpcli_post_success() argument
702 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in refresh_token_httpcli_post_success()
710 grpc_closure* on_done, in token_httpcli_post_failure() argument
713 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in token_httpcli_post_failure()
932 grpc_closure* on_done, in sts_token_httpcli_post_success() argument
936 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in sts_token_httpcli_post_success()
[all …]
/third_party/grpc/test/core/end2end/
Dgoaway_server_test.cc54 grpc_pollset_set* interested_parties, grpc_closure* on_done,
70 grpc_closure* on_done, in my_resolve_address() argument
74 on_done, addrs); in my_resolve_address()
97 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, error); in my_resolve_address()
112 grpc_pollset_set* interested_parties, grpc_closure* on_done, in my_dns_lookup_ares_locked() argument
119 dns_server, addr, default_port, interested_parties, on_done, addresses, in my_dns_lookup_ares_locked()
138 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, error); in my_dns_lookup_ares_locked()
/third_party/grpc/test/core/client_channel/resolvers/
Ddns_resolver_connectivity_test.cc40 grpc_closure* on_done, in my_resolve_address() argument
57 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, error); in my_resolve_address()
65 grpc_pollset_set* /*interested_parties*/, grpc_closure* on_done, in my_dns_lookup_ares_locked() argument
85 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, error); in my_dns_lookup_ares_locked()
Ddns_resolver_cooldown_test.cc44 grpc_pollset_set* interested_parties, grpc_closure* on_done,
67 grpc_closure* on_done, in test_resolve_address_impl() argument
70 name, default_port, g_iomgr_args.pollset_set, on_done, addrs); in test_resolve_address_impl()
96 grpc_pollset_set* /*interested_parties*/, grpc_closure* on_done, in test_dns_lookup_ares_locked() argument
102 dns_server, name, default_port, g_iomgr_args.pollset_set, on_done, in test_dns_lookup_ares_locked()
/third_party/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()
531 std::function<void(grpc::Status, ResponseType*)> on_done) in ClientRpcContextStreamingFromClientImpl() argument
538 callback_(on_done), in ClientRpcContextStreamingFromClientImpl()
663 std::function<void(grpc::Status, ResponseType*)> on_done) in ClientRpcContextStreamingFromServerImpl() argument
670 callback_(on_done), in ClientRpcContextStreamingFromServerImpl()
778 std::function<void(grpc::Status, ByteBuffer*)> on_done) in ClientRpcContextGenericStreamingImpl() argument
785 callback_(std::move(on_done)), in ClientRpcContextGenericStreamingImpl()
/third_party/grpc/doc/core/
Dgrpc-polling-engines.md54 - Signature: `grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd, char* reason)`
55 - Release the `grpc_fd` structure and call `on_done` closure when the operation is complete

12