| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | ev_poll_posix.cc | 216 static void pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
1172 grpc_pollset_set* pollset_set = local
1173 static_cast<grpc_pollset_set*>(gpr_zalloc(sizeof(*pollset_set)));
1174 gpr_mu_init(&pollset_set->mu);
1175 return pollset_set;
1178 static void pollset_set_destroy(grpc_pollset_set* pollset_set) { argument
1180 gpr_mu_destroy(&pollset_set->mu);
1181 for (i = 0; i < pollset_set->fd_count; i++) {
1182 GRPC_FD_UNREF(pollset_set->fds[i], "pollset_set");
1184 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 | 357 static void pollset_set_destroy(grpc_pollset_set* pollset_set) { in pollset_set_destroy() argument
358 GRPC_POLLING_API_TRACE("pollset_set_destroy(%p)", pollset_set); in pollset_set_destroy()
359 g_event_engine->pollset_set_destroy(pollset_set); in pollset_set_destroy()
362 static void pollset_set_add_pollset(grpc_pollset_set* pollset_set, in pollset_set_add_pollset() argument
364 GRPC_POLLING_API_TRACE("pollset_set_add_pollset(%p, %p)", pollset_set, in pollset_set_add_pollset()
366 g_event_engine->pollset_set_add_pollset(pollset_set, pollset); in pollset_set_add_pollset()
369 static void pollset_set_del_pollset(grpc_pollset_set* pollset_set, in pollset_set_del_pollset() argument
371 GRPC_POLLING_API_TRACE("pollset_set_del_pollset(%p, %p)", pollset_set, in pollset_set_del_pollset()
373 g_event_engine->pollset_set_del_pollset(pollset_set, pollset); in pollset_set_del_pollset()
393 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 | 75 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);
|
| 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
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| 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 | 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 | 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
|
| /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()
|
| /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/rust/crates/grpcio-sys/grpc/src/core/lib/http/ |
| D | httpcli.cc | 82 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()
|
| /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()
|