Home
last modified time | relevance | path

Searched refs:pollset_set (Results 1 – 25 of 49) sorted by relevance

12

/third_party/grpc/src/core/lib/iomgr/
Dev_poll_posix.cc216 static void pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
1169 grpc_pollset_set* pollset_set = local
1170 static_cast<grpc_pollset_set*>(gpr_zalloc(sizeof(*pollset_set)));
1171 gpr_mu_init(&pollset_set->mu);
1172 return pollset_set;
1175 static void pollset_set_destroy(grpc_pollset_set* pollset_set) { argument
1177 gpr_mu_destroy(&pollset_set->mu);
1178 for (i = 0; i < pollset_set->fd_count; i++) {
1179 GRPC_FD_UNREF(pollset_set->fds[i], "pollset_set");
1181 for (i = 0; i < pollset_set->pollset_count; i++) {
[all …]
Dpolling_entity.cc27 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()
Dpollset_set.cc33 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()
Dpollset_set.h35 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,
Dev_posix.cc356 static void pollset_set_destroy(grpc_pollset_set* pollset_set) { in pollset_set_destroy() argument
357 GRPC_POLLING_API_TRACE("pollset_set_destroy(%p)", pollset_set); in pollset_set_destroy()
358 g_event_engine->pollset_set_destroy(pollset_set); in pollset_set_destroy()
361 static void pollset_set_add_pollset(grpc_pollset_set* pollset_set, in pollset_set_add_pollset() argument
363 GRPC_POLLING_API_TRACE("pollset_set_add_pollset(%p, %p)", pollset_set, in pollset_set_add_pollset()
365 g_event_engine->pollset_set_add_pollset(pollset_set, pollset); in pollset_set_add_pollset()
368 static void pollset_set_del_pollset(grpc_pollset_set* pollset_set, in pollset_set_del_pollset() argument
370 GRPC_POLLING_API_TRACE("pollset_set_del_pollset(%p, %p)", pollset_set, in pollset_set_del_pollset()
372 g_event_engine->pollset_set_del_pollset(pollset_set, pollset); in pollset_set_del_pollset()
392 void grpc_pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd) { in grpc_pollset_set_add_fd() argument
[all …]
Dev_posix.h75 void (*pollset_set_destroy)(grpc_pollset_set* pollset_set);
76 void (*pollset_set_add_pollset)(grpc_pollset_set* pollset_set,
78 void (*pollset_set_del_pollset)(grpc_pollset_set* pollset_set,
84 void (*pollset_set_add_fd)(grpc_pollset_set* pollset_set, grpc_fd* fd);
85 void (*pollset_set_del_fd)(grpc_pollset_set* pollset_set, grpc_fd* fd);
188 void grpc_pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
189 void grpc_pollset_set_del_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
Dendpoint.cc40 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()
Dpollset_set_windows.cc32 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
Dpolling_entity.h40 grpc_pollset_set* pollset_set; member
46 grpc_pollset_set* pollset_set);
Dendpoint.h96 grpc_pollset_set* pollset_set);
100 grpc_pollset_set* pollset_set);
Dev_apple.cc344 void pollset_set_destroy(grpc_pollset_set* pollset_set) {} in pollset_set_destroy() argument
345 void pollset_set_add_pollset(grpc_pollset_set* pollset_set, in pollset_set_add_pollset() argument
347 void pollset_set_del_pollset(grpc_pollset_set* pollset_set, in pollset_set_del_pollset() argument
/third_party/grpc/test/core/iomgr/
Dresolve_address_test.cc47 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()
65 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in args_finish()
66 grpc_pollset_set_destroy(args->pollset_set); in args_finish()
161 "localhost:1", nullptr, args.pollset_set, in test_localhost()
174 "localhost", "1", args.pollset_set, in test_default_port()
186 grpc_resolve_address("localhost:1", nullptr, args.pollset_set, in test_localhost_result_has_ipv6_first()
200 grpc_resolve_address("localhost:1", nullptr, args.pollset_set, in test_localhost_result_has_ipv4_first_when_ipv6_isnt_available()
214 "localhost", "https", args.pollset_set, in test_non_numeric_default_port()
[all …]
Dresolve_address_posix_test.cc56 grpc_pollset_set* pollset_set; member
65 args->pollset_set = grpc_pollset_set_create(); in args_init()
66 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in args_init()
76 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in args_finish()
77 grpc_pollset_set_destroy(args->pollset_set); in args_finish()
147 "unix:/path/name", nullptr, args.pollset_set, in test_unix_socket()
168 path_name, nullptr, args.pollset_set, in test_unix_socket_path_name_too_long()
181 target, "1" /* port number */, args.pollset_set, in resolve_address_must_succeed()
/third_party/grpc/test/cpp/naming/
Dcancel_ares_query_test.cc88 grpc_pollset_set* pollset_set; member
96 args->pollset_set = grpc_pollset_set_create(); in ArgsInit()
97 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in ArgsInit()
106 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in ArgsFinish()
107 grpc_pollset_set_destroy(args->pollset_set); in ArgsFinish()
168 client_target.c_str(), nullptr, args->pollset_set, args->lock, in TestCancelActiveDNSQuery()
255 grpc_pollset_set_add_pollset_set(fake_other_pollset_set, args.pollset_set); in TEST_F()
Dresolver_component_test.cc206 grpc_pollset_set* pollset_set; member
219 args->pollset_set = grpc_pollset_set_create(); in ArgsInit()
220 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in ArgsInit()
230 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in ArgsFinish()
231 grpc_pollset_set_destroy(args->pollset_set); in ArgsFinish()
645 whole_uri.c_str(), resolver_args, args.pollset_set, args.lock, in RunResolvesRelevantRecordsTest()
/third_party/grpc/test/core/client_channel/resolvers/
Ddns_resolver_cooldown_test.cc59 grpc_pollset_set* pollset_set; member
70 name, default_port, g_iomgr_args.pollset_set, on_done, addrs); in test_resolve_address_impl()
102 dns_server, name, default_port, g_iomgr_args.pollset_set, on_done, in test_dns_lookup_ares_locked()
133 args->pollset_set = grpc_pollset_set_create(); in iomgr_args_init()
134 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset); in iomgr_args_init()
140 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset); in iomgr_args_finish()
141 grpc_pollset_set_destroy(args->pollset_set); in iomgr_args_finish()
/third_party/grpc/src/core/lib/http/
Dhttpcli.cc82 context->pollset_set = grpc_pollset_set_create(); in grpc_httpcli_context_init()
86 grpc_pollset_set_destroy(context->pollset_set); in grpc_httpcli_context_destroy()
93 req->context->pollset_set); in finish()
215 grpc_tcp_client_connect(&req->connected, &req->ep, req->context->pollset_set, in next_address()
261 req->context->pollset_set); in internal_request_begin()
263 request->host, req->handshaker->default_port, req->context->pollset_set, in internal_request_begin()
/third_party/grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc111 grpc_pollset_set* pollset_set = grpc_pollset_set_create(); in Connect() local
112 grpc_pollset_set_add_pollset(pollset_set, pollset_); in Connect()
114 grpc_tcp_client_connect(state.closure(), &endpoint_, pollset_set, in Connect()
121 grpc_pollset_set_destroy(pollset_set); in Connect()
/third_party/grpc/test/core/util/
Dtrickle_endpoint.cc88 grpc_pollset_set* pollset_set) { in te_add_to_pollset_set() argument
90 grpc_endpoint_add_to_pollset_set(te->wrapped, pollset_set); in te_add_to_pollset_set()
94 grpc_pollset_set* pollset_set) { in te_delete_from_pollset_set() argument
96 grpc_endpoint_delete_from_pollset_set(te->wrapped, pollset_set); in te_delete_from_pollset_set()
/third_party/grpc/src/core/ext/filters/client_channel/
Dresolver_registry.cc157 grpc_pollset_set* pollset_set, in CreateResolver() argument
166 resolver_args.pollset_set = pollset_set; in CreateResolver()
/third_party/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_ev_driver.cc66 grpc_pollset_set* pollset_set; member
148 grpc_ares_ev_driver** ev_driver, grpc_pollset_set* pollset_set, in grpc_ares_ev_driver_create_locked() argument
169 (*ev_driver)->pollset_set = pollset_set; in grpc_ares_ev_driver_create_locked()
391 socks[i], ev_driver->pollset_set, ev_driver->work_serializer); in grpc_ares_notify_on_event_locked()
/third_party/grpc/src/core/lib/transport/
Dtransport.cc150 grpc_pollset_set* pollset_set; local
153 } else if ((pollset_set = grpc_polling_entity_pollset_set(pollent)) !=
155 transport->vtable->set_pollset_set(transport, stream, pollset_set);
/third_party/grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc87 grpc_pollset_set* pollset_set; member
134 grpc_pollset_set_destroy(conn->pollset_set); in proxy_connection_unref()
541 conn->pollset_set, nullptr, in on_read_request_done_locked()
566 conn->pollset_set = grpc_pollset_set_create(); in on_accept()
567 grpc_pollset_set_add_pollset(conn->pollset_set, proxy->pollset[0]); in on_accept()
568 grpc_endpoint_add_to_pollset_set(endpoint, conn->pollset_set); in on_accept()
/third_party/grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc393 grpc_pollset_set* pollset_set) { in endpoint_add_to_pollset_set() argument
395 grpc_endpoint_add_to_pollset_set(ep->wrapped_ep, pollset_set); in endpoint_add_to_pollset_set()
399 grpc_pollset_set* pollset_set) { in endpoint_delete_from_pollset_set() argument
401 grpc_endpoint_delete_from_pollset_set(ep->wrapped_ep, pollset_set); in endpoint_delete_from_pollset_set()
/third_party/grpc/src/core/ext/filters/client_channel/resolver/google_c2p/
Dgoogle_c2p_resolver.cc231 pollent_(grpc_polling_entity_create_from_pollset_set(args.pollset_set)) { in GoogleCloud2ProdResolver()
245 args.pollset_set, work_serializer_, std::move(args.result_handler)); in GoogleCloud2ProdResolver()
252 args.pollset_set, work_serializer_, std::move(args.result_handler)); in GoogleCloud2ProdResolver()

12