Home
last modified time | relevance | path

Searched refs:pollset (Results 1 – 25 of 75) sorted by relevance

123

/third_party/grpc/src/core/lib/iomgr/
Dev_epoll1_linux.cc477 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 …]
Dev_poll_posix.cc60 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 …]
Dev_epollex_linux.cc277 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 …]
Dpollset_windows.cc90 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 …]
Dpollset.cc33 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()
Dpollset.h44 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,
Dev_posix.cc303 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 …]
Dev_apple.cc222 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work() argument
226 pollset, worker, deadline); in pollset_work()
228 reinterpret_cast<GrpcApplePollset*>(pollset); in pollset_work()
275 static grpc_error* pollset_kick(grpc_pollset* pollset, in pollset_kick() argument
278 reinterpret_cast<GrpcApplePollset*>(pollset); in pollset_kick()
280 GRPC_POLLING_TRACE("pollset kick: %p, worker:%p", pollset, specific_worker); in pollset_kick()
302 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init() argument
303 GRPC_POLLING_TRACE("pollset init: %p", pollset); in pollset_init()
304 GrpcApplePollset* apple_pollset = new (pollset) GrpcApplePollset(); in pollset_init()
310 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown() argument
[all …]
Dpolling_entity.cc35 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()
Dpollset_custom.cc50 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()
Dev_posix.h64 void (*pollset_init)(grpc_pollset* pollset, gpr_mu** mu);
65 void (*pollset_shutdown)(grpc_pollset* pollset, grpc_closure* closure);
66 void (*pollset_destroy)(grpc_pollset* pollset);
67 grpc_error* (*pollset_work)(grpc_pollset* pollset,
70 grpc_error* (*pollset_kick)(grpc_pollset* pollset,
72 void (*pollset_add_fd)(grpc_pollset* pollset, struct grpc_fd* fd);
77 grpc_pollset* pollset);
79 grpc_pollset* pollset);
184 void grpc_pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd);
Dpollset_set.cc38 grpc_pollset* pollset) { in grpc_pollset_set_add_pollset() argument
39 grpc_pollset_set_impl->add_pollset(pollset_set, pollset); in grpc_pollset_set_add_pollset()
43 grpc_pollset* pollset) { 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.h36 void (*add_pollset)(grpc_pollset_set* pollset_set, grpc_pollset* pollset);
37 void (*del_pollset)(grpc_pollset_set* pollset_set, grpc_pollset* pollset);
47 grpc_pollset* pollset);
49 grpc_pollset* pollset);
Dendpoint.h44 void (*add_to_pollset)(grpc_endpoint* ep, grpc_pollset* pollset);
45 void (*add_to_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
46 void (*delete_from_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
94 void grpc_endpoint_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset);
/third_party/NuttX/fs/vfs/
Dfs_select.c99 struct pollfd *pollset = NULL; in do_select() local
140 pollset = pfd; in do_select()
141 (void)memset_s(pollset, npfds * sizeof(struct pollfd), 0, npfds * sizeof(struct pollfd)); in do_select()
145 pollset = (struct pollfd *)zalloc(npfds * sizeof(struct pollfd)); in do_select()
146 if (pollset == NULL) in do_select()
199 pollset[ndx].fd = fd; in do_select()
200 pollset[ndx].events |= (POLLIN | POLLRDNORM); in do_select()
210 pollset[ndx].fd = fd; in do_select()
211 pollset[ndx].events |= (POLLOUT | POLLWRNORM); in do_select()
219 pollset[ndx].fd = fd; in do_select()
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/
Dbackup_poller.cc46 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()
/third_party/grpc/test/core/util/
Dtest_tcp_server.cc48 grpc_pollset* pollset = in test_tcp_server_init() local
50 grpc_pollset_init(pollset, &server->mu); in test_tcp_server_init()
51 server->pollset.push_back(pollset); in test_tcp_server_init()
75 grpc_tcp_server_start(server->tcp_server, &server->pollset, in test_tcp_server_start()
87 grpc_pollset_work(server->pollset[0], &worker, deadline)); in test_tcp_server_poll()
110 grpc_pollset_shutdown(server->pollset[0], in test_tcp_server_destroy()
111 GRPC_CLOSURE_CREATE(finish_pollset, server->pollset[0], in test_tcp_server_destroy()
114 gpr_free(server->pollset[0]); in test_tcp_server_destroy()
Dport_server_client.cc44 grpc_pollset* pollset = in destroy_pops_and_shutdown() local
46 grpc_pollset_destroy(pollset); in destroy_pops_and_shutdown()
47 gpr_free(pollset); in destroy_pops_and_shutdown()
76 grpc_pollset* pollset = in grpc_free_port_using_server() local
78 grpc_pollset_init(pollset, &pr.mu); in grpc_free_port_using_server()
79 pr.pops = grpc_polling_entity_create_from_pollset(pollset); in grpc_free_port_using_server()
208 grpc_pollset* pollset = in grpc_pick_port_using_server() local
210 grpc_pollset_init(pollset, &pr.mu); in grpc_pick_port_using_server()
211 pr.pops = grpc_polling_entity_create_from_pollset(pollset); in grpc_pick_port_using_server()
/third_party/grpc/test/cpp/naming/
Dcancel_ares_query_test.cc87 grpc_pollset* pollset; member
94 args->pollset = (grpc_pollset*)gpr_zalloc(grpc_pollset_size()); in ArgsInit()
95 grpc_pollset_init(args->pollset, &args->mu); 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()
111 grpc_pollset_shutdown(args->pollset, &DoNothing_cb); in ArgsFinish()
115 grpc_pollset_destroy(args->pollset); in ArgsFinish()
116 gpr_free(args->pollset); in ArgsFinish()
130 grpc_pollset_work(args->pollset, &worker, in PollPollsetUntilRequestDone()
145 grpc_pollset_kick(args_->pollset, nullptr)); in ~AssertFailureResultHandler()
[all …]
/third_party/grpc/test/core/surface/
Dconcurrent_connectivity_test.cc103 std::vector<grpc_pollset*> pollset; member
129 grpc_pollset_kick(args->pollset[0], nullptr)); in on_connect()
150 grpc_tcp_server_start(s, &args->pollset, on_connect, args); in bad_server_thread()
160 grpc_pollset_work(args->pollset[0], &worker, deadline))) { in bad_server_thread()
172 static void done_pollset_shutdown(void* pollset, grpc_error* /*error*/) { in done_pollset_shutdown() argument
173 grpc_pollset_destroy(static_cast<grpc_pollset*>(pollset)); in done_pollset_shutdown()
174 gpr_free(pollset); in done_pollset_shutdown()
229 auto* pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in run_concurrent_connectivity_test() local
230 grpc_pollset_init(pollset, &args.mu); in run_concurrent_connectivity_test()
231 args.pollset.push_back(pollset); in run_concurrent_connectivity_test()
[all …]
/third_party/grpc/test/core/security/
Dverify_jwt.cc33 grpc_pollset* pollset; member
67 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(sync->pollset, nullptr)); in on_jwt_verification_done()
92 sync.pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in main()
93 grpc_pollset_init(sync.pollset, &sync.mu); in main()
96 grpc_jwt_verifier_verify(verifier, sync.pollset, jwt, aud, in main()
104 grpc_pollset_work(sync.pollset, &worker, GRPC_MILLIS_INF_FUTURE))) in main()
112 gpr_free(sync.pollset); in main()
/third_party/grpc/test/core/iomgr/
Dresolve_address_posix_test.cc55 grpc_pollset* pollset; member
63 args->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in args_init()
64 grpc_pollset_init(args->pollset, &args->mu); 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()
81 grpc_pollset_shutdown(args->pollset, &do_nothing_cb); in args_finish()
84 grpc_pollset_destroy(args->pollset); in args_finish()
85 gpr_free(args->pollset); in args_finish()
107 GRPC_LOG_IF_ERROR("pollset_work", grpc_pollset_work(args->pollset, &worker, in actually_poll()
128 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, nullptr)); in must_succeed()
[all …]
Dresolve_address_test.cc46 grpc_pollset* pollset; member
54 args->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in args_init()
55 grpc_pollset_init(args->pollset, &args->mu); 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()
71 grpc_pollset_shutdown(args->pollset, &do_nothing_cb); in args_finish()
75 grpc_pollset_destroy(args->pollset); in args_finish()
76 gpr_free(args->pollset); in args_finish()
99 GRPC_LOG_IF_ERROR("pollset_work", grpc_pollset_work(args->pollset, &worker, in poll_pollset_until_request_done()
114 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, nullptr)); in must_succeed()
[all …]
/third_party/grpc/test/core/client_channel/resolvers/
Ddns_resolver_cooldown_test.cc58 grpc_pollset* pollset; member
131 args->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in iomgr_args_init()
132 grpc_pollset_init(args->pollset, &args->mu); 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()
146 grpc_pollset_shutdown(args->pollset, &do_nothing_cb); in iomgr_args_finish()
150 grpc_pollset_destroy(args->pollset); in iomgr_args_finish()
151 gpr_free(args->pollset); in iomgr_args_finish()
172 GRPC_LOG_IF_ERROR("pollset_work", grpc_pollset_work(args->pollset, &worker, in poll_pollset_until_request_done()
234 grpc_pollset_kick(g_iomgr_args.pollset, nullptr)); in on_fourth_resolution()
[all …]
/third_party/grpc/doc/core/
Dgrpc-polling-engines.md63 - Add fd to pollset
68 …> **NOTE**: `grpc_pollset_work()` requires the pollset mutex to be locked before calling it. Short…
69 - Poll the fds in the pollset for events AND return when ANY of the following is true:
71 …- Some fds in the pollset were found to be readable/writable/error and those associated closures w…
77 - If `worker == nullptr`, kick ANY worker active on that pollset
87 - What does adding a pollset to a pollset_set mean ?
88 …n the pollset will also poll all the fds in the pollset_set i.e semantically, it is similar to add…
89 - This guarantee is no longer true once the pollset is removed from the pollset_set
115 …tation). `grpc_pollset_workers` that call `grpc_pollset_work` on a given pollset are all queued in…
117 …pollset is put in a neighborhood based on the CPU core of the root worker thread. When picking the…
[all …]

123