| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_epoll1_linux.cc | 458 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert() argument
459 if (pollset->root_worker == nullptr) { in worker_insert()
460 pollset->root_worker = worker; in worker_insert()
464 worker->next = pollset->root_worker; in worker_insert()
475 static worker_remove_result worker_remove(grpc_pollset* pollset, in worker_remove() argument
477 if (worker == pollset->root_worker) { in worker_remove()
479 pollset->root_worker = nullptr; in worker_remove()
482 pollset->root_worker = worker->next; in worker_remove()
531 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
532 gpr_mu_init(&pollset->mu); in pollset_init()
[all …]
|
| D | ev_epollex_linux.cc | 252 grpc_pollset* pollset; member
716 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) { argument
721 pollset, pollset->active_pollable, pollset->shutdown_closure,
722 pollset->root_worker, pollset->containing_pollset_set_count);
724 if (pollset->shutdown_closure != nullptr && pollset->root_worker == nullptr &&
725 pollset->containing_pollset_set_count == 0) {
727 GRPC_CLOSURE_SCHED(pollset->shutdown_closure, GRPC_ERROR_NONE);
728 pollset->shutdown_closure = nullptr;
729 pollset->already_shutdown = true;
779 static grpc_error* pollset_kick(grpc_pollset* pollset, argument
[all …]
|
| D | pollset_windows.cc | 90 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
92 pollset->root_worker.links[GRPC_POLLSET_WORKER_LINK_POLLSET].next = in pollset_init()
93 pollset->root_worker.links[GRPC_POLLSET_WORKER_LINK_POLLSET].prev = in pollset_init()
94 &pollset->root_worker; in pollset_init()
97 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown() argument
98 pollset->shutting_down = 1; in pollset_shutdown()
99 grpc_pollset_kick(pollset, GRPC_POLLSET_KICK_BROADCAST); in pollset_shutdown()
100 if (!pollset->is_iocp_worker) { in pollset_shutdown()
103 pollset->on_shutdown = closure; in pollset_shutdown()
107 static void pollset_destroy(grpc_pollset* pollset) {} in pollset_destroy() argument
[all …]
|
| D | ev_poll_posix.cc | 58 grpc_pollset* pollset; member
147 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset,
212 static void pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd);
237 static bool pollset_has_workers(grpc_pollset* pollset);
438 gpr_mu_lock(&watcher->pollset->mu);
440 grpc_error* err = pollset_kick_ext(watcher->pollset, watcher->worker,
442 gpr_mu_unlock(&watcher->pollset->mu);
639 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset, argument
654 watcher->pollset = nullptr;
682 watcher->pollset = pollset;
[all …]
|
| D | pollset.cc | 33 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in grpc_pollset_init() argument
34 grpc_pollset_impl->init(pollset, mu); in grpc_pollset_init()
37 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in grpc_pollset_shutdown() argument
38 grpc_pollset_impl->shutdown(pollset, closure); in grpc_pollset_shutdown()
41 void grpc_pollset_destroy(grpc_pollset* pollset) { in grpc_pollset_destroy() argument
42 grpc_pollset_impl->destroy(pollset); in grpc_pollset_destroy()
45 grpc_error* grpc_pollset_work(grpc_pollset* pollset, in grpc_pollset_work() argument
48 return grpc_pollset_impl->work(pollset, worker, deadline); in grpc_pollset_work()
51 grpc_error* grpc_pollset_kick(grpc_pollset* pollset, in grpc_pollset_kick() argument
53 return grpc_pollset_impl->kick(pollset, specific_worker); in grpc_pollset_kick()
|
| D | pollset.h | 44 void (*init)(grpc_pollset* pollset, gpr_mu** mu);
45 void (*shutdown)(grpc_pollset* pollset, grpc_closure* closure);
46 void (*destroy)(grpc_pollset* pollset);
47 grpc_error* (*work)(grpc_pollset* pollset, grpc_pollset_worker** worker,
49 grpc_error* (*kick)(grpc_pollset* pollset,
61 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu);
64 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure);
65 void grpc_pollset_destroy(grpc_pollset* pollset);
89 grpc_error* grpc_pollset_work(grpc_pollset* pollset,
95 grpc_error* grpc_pollset_kick(grpc_pollset* pollset,
|
| D | ev_posix.cc | 298 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
299 GRPC_POLLING_API_TRACE("pollset_init(%p)", pollset); in pollset_init()
300 g_event_engine->pollset_init(pollset, mu); in pollset_init()
303 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown() argument
304 GRPC_POLLING_API_TRACE("pollset_shutdown(%p)", pollset); in pollset_shutdown()
305 g_event_engine->pollset_shutdown(pollset, closure); in pollset_shutdown()
308 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy() argument
309 GRPC_POLLING_API_TRACE("pollset_destroy(%p)", pollset); in pollset_destroy()
310 g_event_engine->pollset_destroy(pollset); in pollset_destroy()
313 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work() argument
[all …]
|
| D | pollset_custom.cc | 50 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
52 gpr_mu_init(&pollset->mu); in pollset_init()
53 *mu = &pollset->mu; in pollset_init()
56 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown() argument
61 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy() argument
63 gpr_mu_destroy(&pollset->mu); in pollset_destroy()
66 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work() argument
70 gpr_mu_unlock(&pollset->mu); in pollset_work()
86 gpr_mu_lock(&pollset->mu); in pollset_work()
90 static grpc_error* pollset_kick(grpc_pollset* pollset, in pollset_kick() argument
|
| D | polling_entity.cc | 35 grpc_pollset* pollset) { in grpc_polling_entity_create_from_pollset() argument
37 pollent.pollent.pollset = pollset; in grpc_polling_entity_create_from_pollset()
44 return pollent->pollent.pollset; in grpc_polling_entity_pollset()
66 if (pollent->pollent.pollset != nullptr) { in grpc_polling_entity_add_to_pollset_set()
67 grpc_pollset_set_add_pollset(pss_dst, pollent->pollent.pollset); in grpc_polling_entity_add_to_pollset_set()
82 if (pollent->pollent.pollset != nullptr) { in grpc_polling_entity_del_from_pollset_set()
83 grpc_pollset_set_del_pollset(pss_dst, pollent->pollent.pollset); in grpc_polling_entity_del_from_pollset_set()
86 GPR_ASSERT(pollent->pollent.pollset != nullptr); in grpc_polling_entity_del_from_pollset_set()
87 grpc_pollset_set_del_pollset(pss_dst, pollent->pollent.pollset); in grpc_polling_entity_del_from_pollset_set()
|
| D | ev_epollsig_linux.cc | 1087 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { argument
1088 gpr_mu_init(&pollset->po.mu);
1089 *mu = &pollset->po.mu;
1090 pollset->po.pi = nullptr;
1092 pollset->po.obj_type = POLL_OBJ_POLLSET;
1095 pollset->root_worker.next = pollset->root_worker.prev = &pollset->root_worker;
1096 pollset->kicked_without_pollers = false;
1098 pollset->shutting_down = false;
1099 pollset->finish_shutdown_called = false;
1100 pollset->shutdown_done = nullptr;
[all …]
|
| D | ev_posix.h | 59 void (*pollset_init)(grpc_pollset* pollset, gpr_mu** mu);
60 void (*pollset_shutdown)(grpc_pollset* pollset, grpc_closure* closure);
61 void (*pollset_destroy)(grpc_pollset* pollset);
62 grpc_error* (*pollset_work)(grpc_pollset* pollset,
65 grpc_error* (*pollset_kick)(grpc_pollset* pollset,
67 void (*pollset_add_fd)(grpc_pollset* pollset, struct grpc_fd* fd);
72 grpc_pollset* pollset);
74 grpc_pollset* pollset);
170 void grpc_pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | ev_epoll1_linux.cc | 477 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert() argument
478 if (pollset->root_worker == nullptr) { in worker_insert()
479 pollset->root_worker = worker; in worker_insert()
483 worker->next = pollset->root_worker; in worker_insert()
494 static worker_remove_result worker_remove(grpc_pollset* pollset, in worker_remove() argument
496 if (worker == pollset->root_worker) { in worker_remove()
498 pollset->root_worker = nullptr; in worker_remove()
501 pollset->root_worker = worker->next; in worker_remove()
550 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
551 gpr_mu_init(&pollset->mu); in pollset_init()
[all …]
|
| D | ev_poll_posix.cc | 60 grpc_pollset* pollset; member
149 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset,
214 static void pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd);
239 static bool pollset_has_workers(grpc_pollset* pollset);
398 gpr_mu_lock(&watcher->pollset->mu);
400 grpc_error* err = pollset_kick_ext(watcher->pollset, watcher->worker,
402 gpr_mu_unlock(&watcher->pollset->mu);
600 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset, argument
615 watcher->pollset = nullptr;
643 watcher->pollset = pollset;
[all …]
|
| D | ev_epollex_linux.cc | 277 grpc_pollset* pollset; member
538 static bool fd_has_pollset(grpc_fd* fd, grpc_pollset* pollset) { argument
539 const int epfd = pollset->active_pollable->epfd;
549 static void fd_add_pollset(grpc_fd* fd, grpc_pollset* pollset) { argument
550 const int epfd = pollset->active_pollable->epfd;
663 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) { argument
668 pollset, pollset->active_pollable, pollset->shutdown_closure,
669 pollset->root_worker, pollset->containing_pollset_set_count);
671 if (pollset->shutdown_closure != nullptr && pollset->root_worker == nullptr &&
672 pollset->containing_pollset_set_count == 0) {
[all …]
|
| D | pollset_windows.cc | 90 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
92 pollset->root_worker.links[GRPC_POLLSET_WORKER_LINK_POLLSET].next = in pollset_init()
93 pollset->root_worker.links[GRPC_POLLSET_WORKER_LINK_POLLSET].prev = in pollset_init()
94 &pollset->root_worker; in pollset_init()
97 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown() argument
98 pollset->shutting_down = 1; in pollset_shutdown()
99 grpc_pollset_kick(pollset, GRPC_POLLSET_KICK_BROADCAST); in pollset_shutdown()
100 if (!pollset->is_iocp_worker) { in pollset_shutdown()
103 pollset->on_shutdown = closure; in pollset_shutdown()
107 static void pollset_destroy(grpc_pollset* pollset) {} in pollset_destroy() argument
[all …]
|
| D | pollset.cc | 33 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in grpc_pollset_init() argument
34 grpc_pollset_impl->init(pollset, mu); in grpc_pollset_init()
37 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in grpc_pollset_shutdown() argument
38 grpc_pollset_impl->shutdown(pollset, closure); in grpc_pollset_shutdown()
41 void grpc_pollset_destroy(grpc_pollset* pollset) { in grpc_pollset_destroy() argument
42 grpc_pollset_impl->destroy(pollset); in grpc_pollset_destroy()
45 grpc_error* grpc_pollset_work(grpc_pollset* pollset, in grpc_pollset_work() argument
48 return grpc_pollset_impl->work(pollset, worker, deadline); in grpc_pollset_work()
51 grpc_error* grpc_pollset_kick(grpc_pollset* pollset, in grpc_pollset_kick() argument
53 return grpc_pollset_impl->kick(pollset, specific_worker); in grpc_pollset_kick()
|
| D | pollset.h | 44 void (*init)(grpc_pollset* pollset, gpr_mu** mu);
45 void (*shutdown)(grpc_pollset* pollset, grpc_closure* closure);
46 void (*destroy)(grpc_pollset* pollset);
47 grpc_error* (*work)(grpc_pollset* pollset, grpc_pollset_worker** worker,
49 grpc_error* (*kick)(grpc_pollset* pollset,
61 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu);
64 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure);
65 void grpc_pollset_destroy(grpc_pollset* pollset);
89 grpc_error* grpc_pollset_work(grpc_pollset* pollset,
95 grpc_error* grpc_pollset_kick(grpc_pollset* pollset,
|
| D | ev_posix.cc | 303 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
304 GRPC_POLLING_API_TRACE("pollset_init(%p)", pollset); in pollset_init()
305 g_event_engine->pollset_init(pollset, mu); in pollset_init()
308 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown() argument
309 GRPC_POLLING_API_TRACE("pollset_shutdown(%p)", pollset); in pollset_shutdown()
310 g_event_engine->pollset_shutdown(pollset, closure); in pollset_shutdown()
313 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy() argument
314 GRPC_POLLING_API_TRACE("pollset_destroy(%p)", pollset); in pollset_destroy()
315 g_event_engine->pollset_destroy(pollset); in pollset_destroy()
318 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work() argument
[all …]
|
| D | ev_apple.cc | 219 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work() argument
223 pollset, worker, deadline); in pollset_work()
225 reinterpret_cast<GrpcApplePollset*>(pollset); in pollset_work()
272 static grpc_error* pollset_kick(grpc_pollset* pollset, in pollset_kick() argument
275 reinterpret_cast<GrpcApplePollset*>(pollset); in pollset_kick()
277 GRPC_POLLING_TRACE("pollset kick: %p, worker:%p", pollset, specific_worker); in pollset_kick()
299 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
300 GRPC_POLLING_TRACE("pollset init: %p", pollset); in pollset_init()
301 GrpcApplePollset* apple_pollset = new (pollset) GrpcApplePollset(); in pollset_init()
307 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown() argument
[all …]
|
| D | polling_entity.cc | 35 grpc_pollset* pollset) { in grpc_polling_entity_create_from_pollset() argument
37 pollent.pollent.pollset = pollset; in grpc_polling_entity_create_from_pollset()
44 return pollent->pollent.pollset; in grpc_polling_entity_pollset()
66 if (pollent->pollent.pollset != nullptr) { in grpc_polling_entity_add_to_pollset_set()
67 grpc_pollset_set_add_pollset(pss_dst, pollent->pollent.pollset); in grpc_polling_entity_add_to_pollset_set()
82 if (pollent->pollent.pollset != nullptr) { in grpc_polling_entity_del_from_pollset_set()
83 grpc_pollset_set_del_pollset(pss_dst, pollent->pollent.pollset); in grpc_polling_entity_del_from_pollset_set()
86 GPR_ASSERT(pollent->pollent.pollset != nullptr); in grpc_polling_entity_del_from_pollset_set()
87 grpc_pollset_set_del_pollset(pss_dst, pollent->pollent.pollset); in grpc_polling_entity_del_from_pollset_set()
|
| D | pollset_custom.cc | 50 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
52 gpr_mu_init(&pollset->mu); in pollset_init()
53 *mu = &pollset->mu; in pollset_init()
61 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy() argument
63 gpr_mu_destroy(&pollset->mu); in pollset_destroy()
66 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work() argument
70 gpr_mu_unlock(&pollset->mu); in pollset_work()
86 gpr_mu_lock(&pollset->mu); in pollset_work()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | ev_epollsig_linux_test.cc | 39 grpc_pollset* pollset; member
93 pollsets[i].pollset = in test_pollset_init()
95 grpc_pollset_init(pollsets[i].pollset, &pollsets[i].mu); in test_pollset_init()
108 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, pollsets[i].pollset, in test_pollset_cleanup()
110 grpc_pollset_shutdown(pollsets[i].pollset, &destroyed); in test_pollset_cleanup()
113 gpr_free(pollsets[i].pollset); in test_pollset_cleanup()
169 grpc_pollset_add_fd(pollsets[0].pollset, tfds[i].fd); in test_add_fd_to_pollset()
174 grpc_pollset_add_fd(pollsets[1].pollset, tfds[i].fd); in test_add_fd_to_pollset()
179 grpc_pollset_add_fd(pollsets[2].pollset, tfds[i].fd); in test_add_fd_to_pollset()
185 grpc_pollset_add_fd(pollsets[3].pollset, tfds[i].fd); in test_add_fd_to_pollset()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 44 grpc_pollset* pollset; // guarded by pollset_mu member
78 grpc_pollset_destroy(p->pollset); in backup_poller_shutdown_unref()
79 gpr_free(p->pollset); in backup_poller_shutdown_unref()
97 p->pollset, GRPC_CLOSURE_INIT(&p->shutdown_closure, done_poller, p, in g_poller_unref()
122 grpc_pollset_work(p->pollset, nullptr, grpc_core::ExecCtx::Get()->Now()); in run_poller()
133 g_poller->pollset = in g_poller_init_locked()
136 grpc_pollset_init(g_poller->pollset, &g_poller->pollset_mu); in g_poller_init_locked()
161 grpc_pollset* pollset = g_poller->pollset; in grpc_client_channel_start_backup_polling() local
164 grpc_pollset_set_add_pollset(interested_parties, pollset); in grpc_client_channel_start_backup_polling()
172 grpc_pollset_set_del_pollset(interested_parties, g_poller->pollset); in grpc_client_channel_stop_backup_polling()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 46 grpc_pollset* pollset; // guarded by pollset_mu member
86 grpc_pollset_destroy(p->pollset); in backup_poller_shutdown_unref()
87 gpr_free(p->pollset); in backup_poller_shutdown_unref()
105 p->pollset, GRPC_CLOSURE_INIT(&p->shutdown_closure, done_poller, p, in g_poller_unref()
131 grpc_pollset_work(p->pollset, nullptr, grpc_core::ExecCtx::Get()->Now()); in run_poller()
142 g_poller->pollset = in g_poller_init_locked()
145 grpc_pollset_init(g_poller->pollset, &g_poller->pollset_mu); in g_poller_init_locked()
169 grpc_pollset* pollset = g_poller->pollset; in grpc_client_channel_start_backup_polling() local
172 grpc_pollset_set_add_pollset(interested_parties, pollset); in grpc_client_channel_start_backup_polling()
180 grpc_pollset_set_del_pollset(interested_parties, g_poller->pollset); in grpc_client_channel_stop_backup_polling()
|
| /external/grpc-grpc/test/cpp/naming/ |
| D | cancel_ares_query_test.cc | 112 grpc_pollset* pollset; member
119 args->pollset = (grpc_pollset*)gpr_zalloc(grpc_pollset_size()); in ArgsInit()
120 grpc_pollset_init(args->pollset, &args->mu); 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()
136 grpc_pollset_shutdown(args->pollset, &DoNothing_cb); in ArgsFinish()
140 grpc_pollset_destroy(args->pollset); in ArgsFinish()
141 gpr_free(args->pollset); in ArgsFinish()
156 grpc_pollset_work(args->pollset, &worker, in PollPollsetUntilRequestDone()
168 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, nullptr)); in CheckResolverResultAssertFailureLocked()
[all …]
|