| /external/grpc-grpc/src/core/lib/iomgr/ |
| polling_entity.h | 24 #include "src/core/lib/iomgr/pollset.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
39 grpc_pollset* pollset; member in union:grpc_polling_entity::__anon23138
48 grpc_pollset* pollset);
50 /** If \a pollent contains a pollset, 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
|
| pollset_windows.h | 31 /* There isn't really any such thing as a pollset under Windows, due to the
32 nature of the IO completion ports. A Windows "pollset" is merely a mutex
53 struct grpc_pollset* pollset; member in struct:grpc_pollset_worker
|
| ev_epollex_linux.cc | 97 /// a pollset
155 return "pollset";
171 /// Shared empty pollable - used by pollset to poll on until the first fd is
234 * Pollset Declarations
252 grpc_pollset* pollset; member in struct:grpc_pollset_worker
270 * Pollset-set Declarations
307 * epoll_wait deal with the race between pollset removal and incoming poll
696 * Pollset Definitions
715 /* pollset->mu must be held while calling this function */
716 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) {
[all...] |
| ev_poll_posix.cc | 58 grpc_pollset* pollset; member in struct:grpc_fd_watcher
137 Registers that the given pollset is interested in this fd - so that if read
138 or writability interest changes, the pollset can be kicked to pick up that
146 MUST NOT be called with a pollset lock taken */
147 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset,
151 MUST NOT be called with a pollset lock taken
176 * pollset declarations
211 /* Add an fd to a pollset */
212 static void pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd);
235 /* Return 1 if the pollset has active threads in pollset_work (pollset mus
1218 grpc_pollset* pollset = pollset_set->pollsets[i]; local
[all...] |
| /external/grpc-grpc/test/core/util/ |
| test_tcp_server.h | 30 grpc_pollset* pollset; member in struct:test_tcp_server
|
| port_server_client.cc | 44 grpc_pollset* pollset = local
46 grpc_pollset_destroy(pollset);
47 gpr_free(pollset);
75 grpc_pollset* pollset = local
77 grpc_pollset_init(pollset, &pr.mu);
78 pr.pops = grpc_polling_entity_create_from_pollset(pollset);
207 grpc_pollset* pollset = local
209 grpc_pollset_init(pollset, &pr.mu);
210 pr.pops = grpc_polling_entity_create_from_pollset(pollset);
|
| /external/grpc-grpc/test/core/security/ |
| oauth2_utils.cc | 76 grpc_pollset* pollset = local
78 grpc_pollset_init(pollset, &request.mu);
79 request.pops = grpc_polling_entity_create_from_pollset(pollset);
|
| print_google_default_creds_token.cc | 72 grpc_pollset* pollset = nullptr; local
91 pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
92 grpc_pollset_init(pollset, &sync.mu);
93 sync.pops = grpc_polling_entity_create_from_pollset(pollset);
|
| verify_jwt.cc | 33 grpc_pollset* pollset; member in struct:__anon23379
71 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(sync->pollset, nullptr));
96 sync.pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
97 grpc_pollset_init(sync.pollset, &sync.mu);
100 grpc_jwt_verifier_verify(verifier, sync.pollset, jwt, aud,
108 grpc_pollset_work(sync.pollset, &worker, GRPC_MILLIS_INF_FUTURE)))
116 gpr_free(sync.pollset);
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| backup_poller.cc | 31 #include "src/core/lib/iomgr/pollset.h"
44 grpc_pollset* pollset; // guarded by pollset_mu member in struct:__anon22956::backup_poller
78 grpc_pollset_destroy(p->pollset);
79 gpr_free(p->pollset);
97 p->pollset, GRPC_CLOSURE_INIT(&p->shutdown_closure, done_poller, p,
122 grpc_pollset_work(p->pollset, nullptr, grpc_core::ExecCtx::Get()->Now());
133 g_poller->pollset =
136 grpc_pollset_init(g_poller->pollset, &g_poller->pollset_mu);
138 // one for timer cancellation, one for pollset shutdown
157 /* Get a reference to g_poller->pollset before releasing g_poller_mu to mak
161 grpc_pollset* pollset = g_poller->pollset; local
[all...] |
| /external/grpc-grpc/src/core/lib/security/context/ |
| security_context.h | 24 #include "src/core/lib/iomgr/pollset.h"
48 grpc_pollset* pollset; member in struct:grpc_auth_context
|
| /external/grpc-grpc/test/core/http/ |
| httpcli_test.cc | 198 grpc_pollset* pollset = local
200 grpc_pollset_init(pollset, &g_mu);
201 g_pops = grpc_polling_entity_create_from_pollset(pollset);
|
| httpscli_test.cc | 207 grpc_pollset* pollset = local
209 grpc_pollset_init(pollset, &g_mu);
210 g_pops = grpc_polling_entity_create_from_pollset(pollset);
|
| /external/grpc-grpc/src/core/lib/transport/ |
| transport.cc | 179 grpc_pollset* pollset; local
181 if ((pollset = grpc_polling_entity_pollset(pollent)) != nullptr) {
182 transport->vtable->set_pollset(transport, stream, pollset);
187 // No-op for empty pollset. Empty pollset is possible when using
|
| /external/grpc-grpc/test/core/iomgr/ |
| ev_epollsig_linux_test.cc | 39 grpc_pollset* pollset; member in struct:test_pollset
93 pollsets[i].pollset =
95 grpc_pollset_init(pollsets[i].pollset, &pollsets[i].mu);
108 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, pollsets[i].pollset,
110 grpc_pollset_shutdown(pollsets[i].pollset, &destroyed);
113 gpr_free(pollsets[i].pollset);
119 * case 1) Polling islands of both fd and pollset are NULL
120 * case 2) Polling island of fd is NULL but that of pollset is not-NULL
121 * case 3) Polling island of fd is not-NULL but that of pollset is NULL
122 * case 4) Polling islands of both fd and pollset are not-NULL and
221 grpc_pollset* pollset; member in struct:threading_shared
[all...] |
| pollset_set_test.cc | 216 /* Construct the pollset_set/pollset/fd tree (see diagram above) */
241 * doing grpc_pollset_work on any pollset
243 * For every pollset, do the following:
246 * - Call grpc_pollset_work() on the pollset
308 test_pollset pollset; local
315 init_test_pollsets(&pollset, num_ps);
323 grpc_pollset_add_fd(pollset.ps, tfds[1].fd);
324 grpc_pollset_add_fd(pollset.ps, tfds[2].fd);
326 grpc_pollset_set_add_pollset(pollset_sets[1].pss, pollset.ps);
330 * grpc_pollset_work on the pollset 'PS' *
[all...] |
| resolve_address_posix_test.cc | 46 grpc_pollset* pollset; member in struct:args_struct
54 args->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
55 grpc_pollset_init(args->pollset, &args->mu);
57 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
67 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
72 grpc_pollset_shutdown(args->pollset, &do_nothing_cb);
75 grpc_pollset_destroy(args->pollset);
76 gpr_free(args->pollset);
98 GRPC_LOG_IF_ERROR("pollset_work", grpc_pollset_work(args->pollset, &worker,
|
| resolve_address_test.cc | 44 grpc_pollset* pollset; member in struct:args_struct
52 args->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
53 grpc_pollset_init(args->pollset, &args->mu);
55 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
63 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
69 grpc_pollset_shutdown(args->pollset, &do_nothing_cb);
73 grpc_pollset_destroy(args->pollset);
74 gpr_free(args->pollset);
95 GRPC_LOG_IF_ERROR("pollset_work", grpc_pollset_work(args->pollset, &worker,
110 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, nullptr))
[all...] |
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| dns_resolver_cooldown_test.cc | 54 grpc_pollset* pollset; member in struct:iomgr_args
120 args->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
121 grpc_pollset_init(args->pollset, &args->mu);
123 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
129 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
135 grpc_pollset_shutdown(args->pollset, &do_nothing_cb);
139 grpc_pollset_destroy(args->pollset);
140 gpr_free(args->pollset);
161 GRPC_LOG_IF_ERROR("pollset_work", grpc_pollset_work(args->pollset, &worker,
190 grpc_pollset_kick(g_iomgr_args.pollset, nullptr))
[all...] |
| /external/grpc-grpc/test/core/surface/ |
| concurrent_connectivity_test.cc | 90 grpc_pollset* pollset; member in struct:server_thread_args
117 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, nullptr));
139 grpc_tcp_server_start(s, &args->pollset, 1, on_connect, args);
149 grpc_pollset_work(args->pollset, &worker, deadline))) {
163 static void done_pollset_shutdown(void* pollset, grpc_error* error) {
164 grpc_pollset_destroy(static_cast<grpc_pollset*>(pollset));
165 gpr_free(pollset);
221 args.pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
222 grpc_pollset_init(args.pollset, &args.mu);
242 args.pollset, GRPC_CLOSURE_CREATE(done_pollset_shutdown, args.pollset
[all...] |
| /external/grpc-grpc/test/core/transport/chttp2/ |
| settings_timeout_test.cc | 32 #include "src/core/lib/iomgr/pollset.h"
206 grpc_pollset* pollset = static_cast<grpc_pollset*>(arg); local
207 grpc_pollset_destroy(pollset);
208 gpr_free(pollset);
|
| /external/grpc-grpc/test/cpp/naming/ |
| cancel_ares_query_test.cc | 41 #include "src/core/lib/iomgr/pollset.h"
112 grpc_pollset* pollset; member in struct:__anon23439::ArgsStruct
119 args->pollset = (grpc_pollset*)gpr_zalloc(grpc_pollset_size());
120 grpc_pollset_init(args->pollset, &args->mu);
122 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
131 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
136 grpc_pollset_shutdown(args->pollset, &DoNothing_cb);
140 grpc_pollset_destroy(args->pollset);
141 gpr_free(args->pollset);
156 grpc_pollset_work(args->pollset, &worker
208 grpc_pollset* pollset = (grpc_pollset*)gpr_zalloc(grpc_pollset_size()); local
[all...] |
| resolver_component_test.cc | 159 grpc_pollset* pollset; member in struct:__anon23440::ArgsStruct
170 args->pollset = (grpc_pollset*)gpr_zalloc(grpc_pollset_size());
171 grpc_pollset_init(args->pollset, &args->mu);
173 grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
183 grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
188 grpc_pollset_shutdown(args->pollset, &DoNothing_cb);
192 grpc_pollset_destroy(args->pollset);
193 gpr_free(args->pollset);
218 grpc_pollset_work(args->pollset, &worker,
418 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, nullptr))
[all...] |
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| http_proxy_fixture.cc | 43 #include "src/core/lib/iomgr/pollset.h"
60 pollset(nullptr),
70 grpc_pollset* pollset; member in struct:grpc_end2end_http_proxy
479 grpc_pollset_set_add_pollset(conn->pollset_set, proxy->pollset);
522 grpc_pollset_work(proxy->pollset, &worker,
554 proxy->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
555 grpc_pollset_init(proxy->pollset, &proxy->mu);
556 grpc_tcp_server_start(proxy->server, &proxy->pollset, 1, on_accept, proxy);
565 grpc_pollset* pollset = static_cast<grpc_pollset*>(arg); local
566 grpc_pollset_destroy(pollset);
[all...] |
