| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_poll_posix.cc | 214 static void pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
1205 grpc_pollset_set* pollset_set = local
1206 static_cast<grpc_pollset_set*>(gpr_zalloc(sizeof(*pollset_set)));
1207 gpr_mu_init(&pollset_set->mu);
1208 return pollset_set;
1211 static void pollset_set_destroy(grpc_pollset_set* pollset_set) { argument
1213 gpr_mu_destroy(&pollset_set->mu);
1214 for (i = 0; i < pollset_set->fd_count; i++) {
1215 GRPC_FD_UNREF(pollset_set->fds[i], "pollset_set");
1217 for (i = 0; i < pollset_set->pollset_count; i++) {
[all …]
|
| D | polling_entity.cc | 27 grpc_pollset_set* pollset_set) { in grpc_polling_entity_create_from_pollset_set() argument
29 pollent.pollent.pollset_set = pollset_set; in grpc_polling_entity_create_from_pollset_set()
52 return pollent->pollent.pollset_set; in grpc_polling_entity_pollset_set()
70 GPR_ASSERT(pollent->pollent.pollset_set != nullptr); in grpc_polling_entity_add_to_pollset_set()
71 grpc_pollset_set_add_pollset_set(pss_dst, pollent->pollent.pollset_set); in grpc_polling_entity_add_to_pollset_set()
90 GPR_ASSERT(pollent->pollent.pollset_set != nullptr); in grpc_polling_entity_del_from_pollset_set()
91 grpc_pollset_set_del_pollset_set(pss_dst, pollent->pollent.pollset_set); in grpc_polling_entity_del_from_pollset_set()
|
| D | pollset_set.cc | 33 void grpc_pollset_set_destroy(grpc_pollset_set* pollset_set) { in grpc_pollset_set_destroy() argument
34 grpc_pollset_set_impl->destroy(pollset_set); in grpc_pollset_set_destroy()
37 void grpc_pollset_set_add_pollset(grpc_pollset_set* pollset_set, in grpc_pollset_set_add_pollset() argument
39 grpc_pollset_set_impl->add_pollset(pollset_set, pollset); in grpc_pollset_set_add_pollset()
42 void grpc_pollset_set_del_pollset(grpc_pollset_set* pollset_set, in grpc_pollset_set_del_pollset() argument
44 grpc_pollset_set_impl->del_pollset(pollset_set, pollset); in grpc_pollset_set_del_pollset()
|
| D | pollset_set.h | 35 void (*destroy)(grpc_pollset_set* pollset_set);
36 void (*add_pollset)(grpc_pollset_set* pollset_set, grpc_pollset* pollset);
37 void (*del_pollset)(grpc_pollset_set* pollset_set, grpc_pollset* pollset);
45 void grpc_pollset_set_destroy(grpc_pollset_set* pollset_set);
46 void grpc_pollset_set_add_pollset(grpc_pollset_set* pollset_set,
48 void grpc_pollset_set_del_pollset(grpc_pollset_set* pollset_set,
|
| D | ev_posix.cc | 351 static void pollset_set_destroy(grpc_pollset_set* pollset_set) { in pollset_set_destroy() argument
352 GRPC_POLLING_API_TRACE("pollset_set_destroy(%p)", pollset_set); in pollset_set_destroy()
353 g_event_engine->pollset_set_destroy(pollset_set); in pollset_set_destroy()
356 static void pollset_set_add_pollset(grpc_pollset_set* pollset_set, in pollset_set_add_pollset() argument
358 GRPC_POLLING_API_TRACE("pollset_set_add_pollset(%p, %p)", pollset_set, in pollset_set_add_pollset()
360 g_event_engine->pollset_set_add_pollset(pollset_set, pollset); in pollset_set_add_pollset()
363 static void pollset_set_del_pollset(grpc_pollset_set* pollset_set, in pollset_set_del_pollset() argument
365 GRPC_POLLING_API_TRACE("pollset_set_del_pollset(%p, %p)", pollset_set, in pollset_set_del_pollset()
367 g_event_engine->pollset_set_del_pollset(pollset_set, pollset); in pollset_set_del_pollset()
387 void grpc_pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd) { in grpc_pollset_set_add_fd() argument
[all …]
|
| D | ev_posix.h | 70 void (*pollset_set_destroy)(grpc_pollset_set* pollset_set);
71 void (*pollset_set_add_pollset)(grpc_pollset_set* pollset_set,
73 void (*pollset_set_del_pollset)(grpc_pollset_set* pollset_set,
79 void (*pollset_set_add_fd)(grpc_pollset_set* pollset_set, grpc_fd* fd);
80 void (*pollset_set_del_fd)(grpc_pollset_set* pollset_set, grpc_fd* fd);
174 void grpc_pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
175 void grpc_pollset_set_del_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
|
| D | endpoint.cc | 40 grpc_pollset_set* pollset_set) { in grpc_endpoint_add_to_pollset_set() argument
41 ep->vtable->add_to_pollset_set(ep, pollset_set); in grpc_endpoint_add_to_pollset_set()
45 grpc_pollset_set* pollset_set) { in grpc_endpoint_delete_from_pollset_set() argument
46 ep->vtable->delete_from_pollset_set(ep, pollset_set); in grpc_endpoint_delete_from_pollset_set()
|
| D | pollset_set_windows.cc | 32 static void pollset_set_destroy(grpc_pollset_set* pollset_set) {} in pollset_set_destroy() argument
34 static void pollset_set_add_pollset(grpc_pollset_set* pollset_set, in pollset_set_add_pollset() argument
37 static void pollset_set_del_pollset(grpc_pollset_set* pollset_set, in pollset_set_del_pollset() argument
|
| D | pollset_set_custom.cc | 29 void pollset_set_destroy(grpc_pollset_set* pollset_set) {} in pollset_set_destroy() argument
31 void pollset_set_add_pollset(grpc_pollset_set* pollset_set, in pollset_set_add_pollset() argument
34 void pollset_set_del_pollset(grpc_pollset_set* pollset_set, in pollset_set_del_pollset() argument
|
| D | polling_entity.h | 40 grpc_pollset_set* pollset_set; member
46 grpc_pollset_set* pollset_set);
|
| D | endpoint.h | 90 grpc_pollset_set* pollset_set);
94 grpc_pollset_set* pollset_set);
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | resolve_address_test.cc | 45 grpc_pollset_set* pollset_set; member
54 args->pollset_set = grpc_pollset_set_create(); in args_init()
55 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in args_init()
63 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in args_finish()
64 grpc_pollset_set_destroy(args->pollset_set); in args_finish()
128 "localhost:1", nullptr, args.pollset_set, in test_localhost()
141 "localhost", "1", args.pollset_set, in test_default_port()
154 "localhost", "https", args.pollset_set, in test_non_numeric_default_port()
167 "localhost", nullptr, args.pollset_set, in test_missing_default_port()
180 "[2001:db8::1]:1", nullptr, args.pollset_set, in test_ipv6_with_port()
[all …]
|
| D | resolve_address_posix_test.cc | 47 grpc_pollset_set* pollset_set; member
56 args->pollset_set = grpc_pollset_set_create(); in args_init()
57 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in args_init()
67 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in args_finish()
68 grpc_pollset_set_destroy(args->pollset_set); in args_finish()
132 "unix:/path/name", nullptr, args.pollset_set, in test_unix_socket()
153 path_name, nullptr, args.pollset_set, in test_unix_socket_path_name_too_long()
|
| D | pollset_set_test.cc | 379 test_pollset_set pollset_set; in pollset_set_test_empty_pollset() local
386 init_test_pollset_sets(&pollset_set, num_pss); in pollset_set_test_empty_pollset()
389 grpc_pollset_set_add_fd(pollset_set.pss, tfds[0].fd); in pollset_set_test_empty_pollset()
393 grpc_pollset_set_add_pollset(pollset_set.pss, pollsets[0].ps); in pollset_set_test_empty_pollset()
394 grpc_pollset_set_add_pollset(pollset_set.pss, pollsets[1].ps); in pollset_set_test_empty_pollset()
412 grpc_pollset_set_del_fd(pollset_set.pss, tfds[0].fd); in pollset_set_test_empty_pollset()
413 grpc_pollset_set_del_pollset(pollset_set.pss, pollsets[0].ps); in pollset_set_test_empty_pollset()
414 grpc_pollset_set_del_pollset(pollset_set.pss, pollsets[1].ps); in pollset_set_test_empty_pollset()
419 cleanup_test_pollset_sets(&pollset_set, num_pss); in pollset_set_test_empty_pollset()
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| D | dns_resolver_cooldown_test.cc | 55 grpc_pollset_set* pollset_set; member
66 name, default_port, g_iomgr_args.pollset_set, on_done, addrs); in test_resolve_address_impl()
96 dns_server, name, default_port, g_iomgr_args.pollset_set, on_done, addrs, in test_dns_lookup_ares_locked()
122 args->pollset_set = grpc_pollset_set_create(); in iomgr_args_init()
123 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in iomgr_args_init()
129 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in iomgr_args_finish()
130 grpc_pollset_set_destroy(args->pollset_set); in iomgr_args_finish()
|
| /external/grpc-grpc/test/cpp/naming/ |
| D | cancel_ares_query_test.cc | 113 grpc_pollset_set* pollset_set; member
121 args->pollset_set = grpc_pollset_set_create(); in ArgsInit()
122 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in ArgsInit()
131 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in ArgsFinish()
132 grpc_pollset_set_destroy(args->pollset_set); in ArgsFinish()
183 client_target, nullptr, args->pollset_set, args->lock); in TestCancelActiveDNSQuery()
248 grpc_pollset_set_add_pollset_set(fake_other_pollset_set, args.pollset_set); in TEST()
|
| D | resolver_component_test.cc | 160 grpc_pollset_set* pollset_set; member
172 args->pollset_set = grpc_pollset_set_create(); in ArgsInit()
173 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in ArgsInit()
183 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in ArgsFinish()
184 grpc_pollset_set_destroy(args->pollset_set); in ArgsFinish()
447 args.pollset_set, args.lock); in RunResolvesRelevantRecordsTest()
|
| /external/grpc-grpc/src/core/lib/http/ |
| D | httpcli.cc | 78 context->pollset_set = grpc_pollset_set_create(); in grpc_httpcli_context_init()
82 grpc_pollset_set_destroy(context->pollset_set); in grpc_httpcli_context_destroy()
89 req->context->pollset_set); in finish()
212 grpc_tcp_client_connect(&req->connected, &req->ep, req->context->pollset_set, in next_address()
257 req->context->pollset_set); in internal_request_begin()
259 request->host, req->handshaker->default_port, req->context->pollset_set, in internal_request_begin()
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 109 grpc_pollset_set* pollset_set = grpc_pollset_set_create(); in Connect() local
110 grpc_pollset_set_add_pollset(pollset_set, pollset_); in Connect()
112 grpc_tcp_client_connect(state.closure(), &endpoint_, pollset_set, in Connect()
119 grpc_pollset_set_destroy(pollset_set); in Connect()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver.cc | 63 grpc_pollset_set* pollset_set; member
120 grpc_pollset_set* pollset_set, in grpc_ares_ev_driver_create_locked() argument
140 (*ev_driver)->pollset_set = pollset_set; in grpc_ares_ev_driver_create_locked()
254 socks[i], ev_driver->pollset_set, ev_driver->combiner); in grpc_ares_notify_on_event_locked()
|
| /external/grpc-grpc/test/core/util/ |
| D | trickle_endpoint.cc | 87 grpc_pollset_set* pollset_set) { in te_add_to_pollset_set() argument
89 grpc_endpoint_add_to_pollset_set(te->wrapped, pollset_set); in te_add_to_pollset_set()
93 grpc_pollset_set* pollset_set) { in te_delete_from_pollset_set() argument
95 grpc_endpoint_delete_from_pollset_set(te->wrapped, pollset_set); in te_delete_from_pollset_set()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | subchannel.cc | 72 grpc_pollset_set* pollset_set; member
108 grpc_pollset_set* pollset_set; member
197 grpc_pollset_set_destroy(c->pollset_set); in subchannel_destroy()
357 c->pollset_set = grpc_pollset_set_create(); in grpc_subchannel_create()
416 args.interested_parties = c->pollset_set; in continue_connect_locked()
440 if (w->pollset_set != nullptr) { in on_external_state_watcher_done()
441 grpc_pollset_set_del_pollset_set(w->subchannel->pollset_set, in on_external_state_watcher_done()
442 w->pollset_set); in on_external_state_watcher_done()
533 w->pollset_set = interested_parties; in grpc_subchannel_notify_on_state_change()
538 grpc_pollset_set_add_pollset_set(c->pollset_set, interested_parties); in grpc_subchannel_notify_on_state_change()
[all …]
|
| D | resolver_registry.cc | 137 grpc_pollset_set* pollset_set, grpc_combiner* combiner) { in CreateResolver() argument
146 resolver_args.pollset_set = pollset_set; in CreateResolver()
|
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| D | http_proxy_fixture.cc | 91 grpc_pollset_set* pollset_set; member
136 grpc_pollset_set_destroy(conn->pollset_set); in proxy_connection_unref()
461 conn->pollset_set, nullptr, in on_read_request_done()
478 conn->pollset_set = grpc_pollset_set_create(); in on_accept()
479 grpc_pollset_set_add_pollset(conn->pollset_set, proxy->pollset); in on_accept()
480 grpc_endpoint_add_to_pollset_set(endpoint, conn->pollset_set); in on_accept()
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.cc | 180 grpc_pollset_set* pollset_set; local
183 } else if ((pollset_set = grpc_polling_entity_pollset_set(pollent)) !=
185 transport->vtable->set_pollset_set(transport, stream, pollset_set);
|