| /external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | handshaker_registry.cc | 44 grpc_pollset_set* interested_parties,
65 grpc_pollset_set* interested_parties, in AddHandshakers() argument
69 handshaker_factory->AddHandshakers(args, interested_parties, handshake_mgr); in AddHandshakers()
98 grpc_pollset_set* interested_parties, in AddHandshakers() argument
102 factory_list.AddHandshakers(args, interested_parties, handshake_mgr); in AddHandshakers()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | child_policy_handler.cc | 65 parent_->child_policy_->interested_parties(), in UpdateState()
66 parent_->interested_parties()); in UpdateState()
131 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in ShutdownLocked()
132 interested_parties()); in ShutdownLocked()
142 pending_child_policy_->interested_parties(), interested_parties()); in ShutdownLocked()
282 grpc_pollset_set_add_pollset_set(lb_policy->interested_parties(), in CreateChildPolicy()
283 interested_parties()); in CreateChildPolicy()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_wrapper_fallback.cc | 31 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,
51 grpc_pollset_set* interested_parties, in grpc_resolve_address_ares_impl() argument
57 grpc_pollset_set* interested_parties, grpc_closure* on_done,
|
| D | grpc_ares_wrapper.cc | 362 grpc_pollset_set* interested_parties, grpc_closure* on_done, in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked() argument
401 error = grpc_ares_ev_driver_create_locked(&r->ev_driver, interested_parties, 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
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,
614 grpc_pollset_set* interested_parties; member
647 nullptr /* dns_server */, r->name, r->default_port, r->interested_parties, in grpc_resolve_address_invoke_dns_lookup_ares_locked()
654 grpc_pollset_set* interested_parties, in grpc_resolve_address_ares_impl() argument
667 r->interested_parties = interested_parties; in grpc_resolve_address_ares_impl()
676 grpc_pollset_set* interested_parties, grpc_closure* on_done,
|
| D | grpc_ares_wrapper.h | 47 grpc_pollset_set* interested_parties,
60 grpc_pollset_set* interested_parties, grpc_closure* on_done,
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | cds.cc | 279 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in MaybeDestroyChildPolicyLocked()
280 interested_parties()); in MaybeDestroyChildPolicyLocked()
395 grpc_pollset_set_add_pollset_set(child_policy_->interested_parties(), in OnClusterChanged()
396 interested_parties()); in OnClusterChanged()
482 root_certificate_provider_->interested_parties() != nullptr) { in UpdateXdsCertificateProvider()
484 interested_parties(), in UpdateXdsCertificateProvider()
485 root_certificate_provider_->interested_parties()); in UpdateXdsCertificateProvider()
488 new_root_provider->interested_parties() != nullptr) { in UpdateXdsCertificateProvider()
489 grpc_pollset_set_add_pollset_set(interested_parties(), in UpdateXdsCertificateProvider()
490 new_root_provider->interested_parties()); in UpdateXdsCertificateProvider()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_shared_resource.cc | 64 g_alts_resource_dedicated.interested_parties = grpc_pollset_set_create(); in grpc_alts_shared_resource_dedicated_start()
65 grpc_pollset_set_add_pollset(g_alts_resource_dedicated.interested_parties, in grpc_alts_shared_resource_dedicated_start()
74 grpc_pollset_set_del_pollset(g_alts_resource_dedicated.interested_parties, in grpc_alts_shared_resource_dedicated_shutdown()
78 grpc_pollset_set_destroy(g_alts_resource_dedicated.interested_parties); in grpc_alts_shared_resource_dedicated_shutdown()
|
| D | alts_tsi_handshaker.cc | 54 grpc_pollset_set* interested_parties; member
412 handshaker->interested_parties = in alts_tsi_handshaker_continue_handshaker_next()
413 grpc_alts_get_shared_resource_dedicated()->interested_parties; in alts_tsi_handshaker_continue_handshaker_next()
414 GPR_ASSERT(handshaker->interested_parties != nullptr); in alts_tsi_handshaker_continue_handshaker_next()
425 handshaker->interested_parties, handshaker->options, in alts_tsi_handshaker_continue_handshaker_next()
624 grpc_pollset_set* interested_parties, tsi_handshaker** self, in alts_tsi_handshaker_create() argument
634 handshaker->use_dedicated_cq = interested_parties == nullptr; in alts_tsi_handshaker_create()
641 handshaker->interested_parties = interested_parties; in alts_tsi_handshaker_create()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_client_posix.cc | 60 grpc_pollset_set* interested_parties; member
175 grpc_pollset_set_del_fd(ac->interested_parties, fd); in on_writable()
212 grpc_pollset_set_del_fd(ac->interested_parties, fd); in on_writable()
277 grpc_pollset_set* interested_parties, grpc_closure* closure, const int fd, in grpc_tcp_client_create_from_prepared_fd() argument
305 grpc_pollset_set_add_fd(interested_parties, fdobj); in grpc_tcp_client_create_from_prepared_fd()
311 ac->interested_parties = interested_parties; in grpc_tcp_client_create_from_prepared_fd()
332 grpc_pollset_set* interested_parties, in tcp_connect() argument
345 grpc_tcp_client_create_from_prepared_fd(interested_parties, closure, fd, in tcp_connect()
|
| D | tcp_client.cc | 26 grpc_pollset_set* interested_parties, in grpc_tcp_client_connect() argument
30 grpc_tcp_client_impl->connect(on_connect, endpoint, interested_parties, in grpc_tcp_client_connect()
|
| D | tcp_client.h | 32 grpc_pollset_set* interested_parties,
43 grpc_pollset_set* interested_parties,
|
| D | resolve_address.cc | 31 grpc_pollset_set* interested_parties, in grpc_resolve_address() argument
35 addr, default_port, interested_parties, on_done, addresses); in grpc_resolve_address()
|
| D | resolve_address.h | 54 grpc_pollset_set* interested_parties,
68 grpc_pollset_set* interested_parties,
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_client_posix.cc | 59 grpc_pollset_set* interested_parties; member
180 grpc_pollset_set_del_fd(ac->interested_parties, fd); in on_writable()
216 grpc_pollset_set_del_fd(ac->interested_parties, fd); in on_writable()
292 grpc_pollset_set* interested_parties, grpc_closure* closure, grpc_fd* fdobj, in grpc_tcp_client_create_from_prepared_fd() argument
315 grpc_pollset_set_add_fd(interested_parties, fdobj); in grpc_tcp_client_create_from_prepared_fd()
321 ac->interested_parties = interested_parties; in grpc_tcp_client_create_from_prepared_fd()
342 grpc_pollset_set* interested_parties, in tcp_connect() argument
355 grpc_tcp_client_create_from_prepared_fd(interested_parties, closure, fdobj, in tcp_connect()
|
| D | tcp_client.cc | 26 grpc_pollset_set* interested_parties, in grpc_tcp_client_connect() argument
30 grpc_tcp_client_impl->connect(closure, ep, interested_parties, channel_args, in grpc_tcp_client_connect()
|
| D | tcp_client.h | 32 grpc_pollset_set* interested_parties,
43 grpc_pollset_set* interested_parties,
|
| D | resolve_address.cc | 31 grpc_pollset_set* interested_parties, in grpc_resolve_address() argument
35 addr, default_port, interested_parties, on_done, addresses); in grpc_resolve_address()
|
| D | resolve_address.h | 56 grpc_pollset_set* interested_parties,
70 grpc_pollset_set* interested_parties,
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 149 grpc_pollset_set* interested_parties) { in grpc_client_channel_start_backup_polling() argument
164 grpc_pollset_set_add_pollset(interested_parties, pollset); in grpc_client_channel_start_backup_polling()
168 grpc_pollset_set* interested_parties) { in grpc_client_channel_stop_backup_polling() argument
172 grpc_pollset_set_del_pollset(interested_parties, g_poller->pollset); in grpc_client_channel_stop_backup_polling()
|
| D | backup_poller.h | 29 grpc_pollset_set* interested_parties);
33 grpc_pollset_set* interested_parties);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 158 grpc_pollset_set* interested_parties) { in grpc_client_channel_start_backup_polling() argument
172 grpc_pollset_set_add_pollset(interested_parties, pollset); in grpc_client_channel_start_backup_polling()
176 grpc_pollset_set* interested_parties) { in grpc_client_channel_stop_backup_polling() argument
180 grpc_pollset_set_del_pollset(interested_parties, g_poller->pollset); in grpc_client_channel_stop_backup_polling()
|
| D | backup_poller.h | 35 grpc_pollset_set* interested_parties);
39 grpc_pollset_set* interested_parties);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/client/ |
| D | chttp2_connector.cc | 74 grpc_tcp_client_connect(&connected_, ep, args.interested_parties, in Connect()
124 args_.interested_parties, in StartHandshakeLocked()
126 grpc_endpoint_add_to_pollset_set(endpoint_, args_.interested_parties); in StartHandshakeLocked()
203 self->args_.interested_parties); in OnReceiveSettings()
231 self->args_.interested_parties); in OnTimeout()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_wrapper.h | 54 grpc_pollset_set* interested_parties,
68 grpc_pollset_set* interested_parties, grpc_closure* on_done,
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/client/ |
| D | chttp2_connector.cc | 117 c->args.interested_parties); in on_handshake_done()
162 grpc_endpoint_add_to_pollset_set(c->endpoint, c->args.interested_parties); in start_handshake_locked()
164 c->handshake_mgr, c->args.interested_parties, c->endpoint, in start_handshake_locked()
214 grpc_tcp_client_connect(&c->connected, &c->endpoint, args->interested_parties, in chttp2_connector_connect()
|