| /external/grpc-grpc/src/core/lib/iomgr/ |
| polling_entity.h | 25 #include "src/core/lib/iomgr/pollset_set.h"
33 /* A grpc_polling_entity is a pollset-or-pollset_set container. It allows
34 * functions that accept a pollset XOR a pollset_set to do so through an
40 grpc_pollset_set* pollset_set; member in union:grpc_polling_entity::__anon23138
46 grpc_pollset_set* pollset_set);
53 /** If \a pollent contains a pollset_set, return it. Otherwise, return NULL */
58 /** Add the pollset or pollset_set in \a pollent to the destination pollset_set
63 /** Delete the pollset or pollset_set in \a pollent from the destination
64 * pollset_set \a * pss_dst *
[all...] |
| ev_epollex_linux.cc | 113 grpc_pollset_set* pollset_set; member in struct:pollable
588 (*p)->pollset_set = nullptr;
[all...] |
| ev_poll_posix.cc | 214 static void pollset_set_add_fd(grpc_pollset_set* pollset_set, grpc_fd* fd);
240 * pollset_set definitions
1205 grpc_pollset_set* pollset_set = local
[all...] |
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| resolver_factory.h | 31 #include "src/core/lib/iomgr/pollset_set.h"
41 grpc_pollset_set* pollset_set = nullptr; member in struct:grpc_core::ResolverArgs
|
| subchannel.cc | 72 grpc_pollset_set* pollset_set; member in struct:external_state_watcher
106 /** pollset_set tracking who's interested in a connection
108 grpc_pollset_set* pollset_set; member in struct:grpc_subchannel
197 grpc_pollset_set_destroy(c->pollset_set);
357 c->pollset_set = grpc_pollset_set_create();
416 args.interested_parties = c->pollset_set;
440 if (w->pollset_set != nullptr) {
441 grpc_pollset_set_del_pollset_set(w->subchannel->pollset_set,
442 w->pollset_set);
533 w->pollset_set = interested_parties
[all...] |
| /external/grpc-grpc/src/core/lib/http/ |
| httpcli.h | 32 #include "src/core/lib/iomgr/pollset_set.h"
41 grpc_pollset_set* pollset_set; member in struct:grpc_httpcli_context
|
| /external/grpc-grpc/src/core/lib/transport/ |
| 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);
|
| /external/grpc-grpc/test/core/iomgr/ |
| pollset_set_test.cc | 168 /* Test some typical scenarios in pollset_set */
216 /* Construct the pollset_set/pollset/fd tree (see diagram above) */
286 /* Same FD added multiple times to the pollset_set tree */
358 /* Pollset_set with an empty pollset */
379 test_pollset_set pollset_set; local
386 init_test_pollset_sets(&pollset_set, num_pss);
389 grpc_pollset_set_add_fd(pollset_set.pss, tfds[0].fd);
393 grpc_pollset_set_add_pollset(pollset_set.pss, pollsets[0].ps);
394 grpc_pollset_set_add_pollset(pollset_set.pss, pollsets[1].ps);
412 grpc_pollset_set_del_fd(pollset_set.pss, tfds[0].fd)
[all...] |
| resolve_address_posix_test.cc | 47 grpc_pollset_set* pollset_set; member in struct:args_struct
56 args->pollset_set = grpc_pollset_set_create();
57 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
67 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
68 grpc_pollset_set_destroy(args->pollset_set);
132 "unix:/path/name", nullptr, args.pollset_set,
153 path_name, nullptr, args.pollset_set,
|
| resolve_address_test.cc | 45 grpc_pollset_set* pollset_set; member in struct:args_struct
54 args->pollset_set = grpc_pollset_set_create();
55 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
63 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
64 grpc_pollset_set_destroy(args->pollset_set);
128 "localhost:1", nullptr, args.pollset_set,
141 "localhost", "1", args.pollset_set,
154 "localhost", "https", args.pollset_set,
167 "localhost", nullptr, args.pollset_set,
180 "[2001:db8::1]:1", nullptr, args.pollset_set,
[all...] |
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| grpc_ares_ev_driver.cc | 63 grpc_pollset_set* pollset_set; member in struct:grpc_ares_ev_driver
120 grpc_pollset_set* pollset_set,
140 (*ev_driver)->pollset_set = pollset_set;
254 socks[i], ev_driver->pollset_set, ev_driver->combiner);
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| dns_resolver_cooldown_test.cc | 55 grpc_pollset_set* pollset_set; member in struct:iomgr_args
66 name, default_port, g_iomgr_args.pollset_set, on_done, addrs);
96 dns_server, name, default_port, g_iomgr_args.pollset_set, on_done, addrs,
122 args->pollset_set = grpc_pollset_set_create();
123 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
129 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
130 grpc_pollset_set_destroy(args->pollset_set);
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| settings_timeout_test.cc | 33 #include "src/core/lib/iomgr/pollset_set.h"
109 grpc_pollset_set* pollset_set = grpc_pollset_set_create(); local
110 grpc_pollset_set_add_pollset(pollset_set, pollset_);
112 grpc_tcp_client_connect(state.closure(), &endpoint_, pollset_set,
119 grpc_pollset_set_destroy(pollset_set);
|
| /external/grpc-grpc/test/cpp/naming/ |
| cancel_ares_query_test.cc | 42 #include "src/core/lib/iomgr/pollset_set.h"
113 grpc_pollset_set* pollset_set; member in struct:__anon23439::ArgsStruct
121 args->pollset_set = grpc_pollset_set_create();
122 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
131 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
132 grpc_pollset_set_destroy(args->pollset_set);
183 client_target, nullptr, args->pollset_set, args->lock);
248 grpc_pollset_set_add_pollset_set(fake_other_pollset_set, args.pollset_set);
|
| resolver_component_test.cc | 160 grpc_pollset_set* pollset_set; member in struct:__anon23440::ArgsStruct
172 args->pollset_set = grpc_pollset_set_create();
173 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
183 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
184 grpc_pollset_set_destroy(args->pollset_set);
447 args.pollset_set, args.lock);
|
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| http_proxy_fixture.cc | 44 #include "src/core/lib/iomgr/pollset_set.h"
91 grpc_pollset_set* pollset_set; member in struct:proxy_connection
136 grpc_pollset_set_destroy(conn->pollset_set);
461 conn->pollset_set, nullptr,
478 conn->pollset_set = grpc_pollset_set_create();
479 grpc_pollset_set_add_pollset(conn->pollset_set, proxy->pollset);
480 grpc_endpoint_add_to_pollset_set(endpoint, conn->pollset_set);
|
