Home
last modified time | relevance | path

Searched defs:pollset (Results 1 – 25 of 80) sorted by relevance

1234

/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dpollset.cc33 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in grpc_pollset_init()
37 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in grpc_pollset_shutdown()
41 void grpc_pollset_destroy(grpc_pollset* pollset) { in grpc_pollset_destroy()
45 grpc_error_handle grpc_pollset_work(grpc_pollset* pollset, in grpc_pollset_work()
51 grpc_error_handle grpc_pollset_kick(grpc_pollset* pollset, in grpc_pollset_kick()
Dpollset_windows.cc90 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
97 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
107 static void pollset_destroy(grpc_pollset* pollset) {} in pollset_destroy()
109 static grpc_error_handle pollset_work(grpc_pollset* pollset, in pollset_work()
Dpollset_custom.cc50 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
61 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
66 static grpc_error_handle pollset_work(grpc_pollset* pollset, in pollset_work()
Dev_apple.cc222 static grpc_error_handle pollset_work(grpc_pollset* pollset, in pollset_work()
275 static grpc_error_handle pollset_kick(grpc_pollset* pollset, in pollset_kick()
302 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
310 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
326 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
346 grpc_pollset* pollset) {} in pollset_set_add_pollset()
348 grpc_pollset* pollset) {} in pollset_set_del_pollset()
Dev_posix.cc303 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
308 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
313 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
318 static grpc_error_handle pollset_work(grpc_pollset* pollset, in pollset_work()
330 static grpc_error_handle pollset_kick(grpc_pollset* pollset, in pollset_kick()
336 void grpc_pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd) { in grpc_pollset_add_fd()
363 grpc_pollset* pollset) { in pollset_set_add_pollset()
370 grpc_pollset* pollset) { in pollset_set_del_pollset()
Dpollset_set_windows.cc35 grpc_pollset* pollset) {} in pollset_set_add_pollset()
38 grpc_pollset* pollset) {} in pollset_set_del_pollset()
Dpollset_set.cc38 grpc_pollset* pollset) { in grpc_pollset_set_add_pollset()
43 grpc_pollset* pollset) { in grpc_pollset_set_del_pollset()
Dev_epollex_linux.cc277 grpc_pollset* pollset; member
538 static bool fd_has_pollset(grpc_fd* fd, grpc_pollset* pollset) {
549 static void fd_add_pollset(grpc_fd* fd, grpc_pollset* pollset) {
663 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) {
728 static grpc_error_handle pollset_kick(grpc_pollset* pollset,
780 static grpc_error_handle pollset_kick_all(grpc_pollset* pollset) {
795 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) {
858 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) {
866 static grpc_error_handle pollable_process_events(grpc_pollset* pollset,
930 static void pollset_destroy(grpc_pollset* pollset) {
[all …]
Dev_epoll1_linux.cc477 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert()
494 static worker_remove_result worker_remove(grpc_pollset* pollset, in worker_remove()
550 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
564 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
592 static grpc_error_handle pollset_kick_all(grpc_pollset* pollset) { in pollset_kick_all()
626 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) { in pollset_maybe_finish_shutdown()
636 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
749 static bool begin_worker(grpc_pollset* pollset, grpc_pollset_worker* worker, in begin_worker()
938 static void end_worker(grpc_pollset* pollset, grpc_pollset_worker* worker, in end_worker()
1068 static grpc_error_handle pollset_kick(grpc_pollset* pollset, in pollset_kick()
Dev_poll_posix.cc60 grpc_pollset* pollset; member
601 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset,
851 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) {
866 static void pollset_destroy(grpc_pollset* pollset) {
879 static void pollset_add_fd(grpc_pollset* pollset, grpc_fd* fd) {
899 static void finish_shutdown(grpc_pollset* pollset) {
918 static grpc_error_handle pollset_work(grpc_pollset* pollset,
1147 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) {
1185 grpc_pollset* pollset = pollset_set->pollsets[i]; local
1205 grpc_pollset* pollset) {
[all …]
/external/grpc-grpc/src/core/lib/iomgr/
Dpollset.cc33 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in grpc_pollset_init()
37 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in grpc_pollset_shutdown()
41 void grpc_pollset_destroy(grpc_pollset* pollset) { in grpc_pollset_destroy()
45 grpc_error* grpc_pollset_work(grpc_pollset* pollset, in grpc_pollset_work()
51 grpc_error* grpc_pollset_kick(grpc_pollset* pollset, in grpc_pollset_kick()
Dpollset_custom.cc50 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
56 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
61 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
66 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work()
90 static grpc_error* pollset_kick(grpc_pollset* pollset, in pollset_kick()
Dpollset_windows.cc90 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
97 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
107 static void pollset_destroy(grpc_pollset* pollset) {} in pollset_destroy()
109 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work()
Dev_posix.cc298 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
303 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
308 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
313 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work()
324 static grpc_error* pollset_kick(grpc_pollset* pollset, in pollset_kick()
330 void grpc_pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd) { in grpc_pollset_add_fd()
357 grpc_pollset* pollset) { in pollset_set_add_pollset()
364 grpc_pollset* pollset) { in pollset_set_del_pollset()
Dpollset_set_windows.cc35 grpc_pollset* pollset) {} in pollset_set_add_pollset()
38 grpc_pollset* pollset) {} in pollset_set_del_pollset()
Dev_epoll1_linux.cc458 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert()
475 static worker_remove_result worker_remove(grpc_pollset* pollset, in worker_remove()
531 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
545 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
573 static grpc_error* pollset_kick_all(grpc_pollset* pollset) { in pollset_kick_all()
607 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) { in pollset_maybe_finish_shutdown()
616 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
646 static grpc_error* process_epoll_events(grpc_pollset* pollset) { in process_epoll_events()
729 static bool begin_worker(grpc_pollset* pollset, grpc_pollset_worker* worker, in begin_worker()
916 static void end_worker(grpc_pollset* pollset, grpc_pollset_worker* worker, in end_worker()
[all …]
Dpollset_set.cc38 grpc_pollset* pollset) { in grpc_pollset_set_add_pollset()
43 grpc_pollset* pollset) { in grpc_pollset_set_del_pollset()
Dpollset_set_custom.cc32 grpc_pollset* pollset) {} in pollset_set_add_pollset()
35 grpc_pollset* pollset) {} in pollset_set_del_pollset()
Dev_epollex_linux.cc252 grpc_pollset* pollset; member
716 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) {
779 static grpc_error* pollset_kick(grpc_pollset* pollset,
830 static grpc_error* pollset_kick_all(grpc_pollset* pollset) {
845 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) {
906 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) {
914 static grpc_error* pollable_process_events(grpc_pollset* pollset,
978 static void pollset_destroy(grpc_pollset* pollset) {
1058 static bool begin_worker(grpc_pollset* pollset, grpc_pollset_worker* worker,
1113 static void end_worker(grpc_pollset* pollset, grpc_pollset_worker* worker,
[all …]
Dev_poll_posix.cc58 grpc_pollset* pollset; member
639 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset,
886 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) {
901 static void pollset_destroy(grpc_pollset* pollset) {
914 static void pollset_add_fd(grpc_pollset* pollset, grpc_fd* fd) {
934 static void finish_shutdown(grpc_pollset* pollset) {
951 static grpc_error* pollset_work(grpc_pollset* pollset,
1180 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) {
1218 grpc_pollset* pollset = pollset_set->pollsets[i]; local
1238 grpc_pollset* pollset) {
[all …]
/external/grpc-grpc/test/core/util/
Dmock_endpoint.cc66 static void me_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) {} in me_add_to_pollset()
69 grpc_pollset_set* pollset) {} in me_add_to_pollset_set()
72 grpc_pollset_set* pollset) {} in me_delete_from_pollset_set()
Dport_server_client.cc44 grpc_pollset* pollset = in destroy_pops_and_shutdown() local
75 grpc_pollset* pollset = in grpc_free_port_using_server() local
207 grpc_pollset* pollset = in grpc_pick_port_using_server() local
Dpassthru_endpoint.cc102 static void me_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) {} in me_add_to_pollset()
105 grpc_pollset_set* pollset) {} in me_add_to_pollset_set()
108 grpc_pollset_set* pollset) {} in me_delete_from_pollset_set()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dbackup_poller.cc46 grpc_pollset* pollset; // guarded by pollset_mu member
169 grpc_pollset* pollset = g_poller->pollset; in grpc_client_channel_start_backup_polling() local
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dbackup_poller.cc44 grpc_pollset* pollset; // guarded by pollset_mu member
161 grpc_pollset* pollset = g_poller->pollset; in grpc_client_channel_start_backup_polling() local

1234