Home
last modified time | relevance | path

Searched refs:root_worker (Results 1 – 11 of 11) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dev_epoll1_linux.cc205 grpc_pollset_worker* root_worker; member
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()
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()
536 pollset->root_worker = nullptr; in pollset_init()
576 if (pollset->root_worker != nullptr) { in pollset_kick_all()
577 grpc_pollset_worker* worker = pollset->root_worker; in pollset_kick_all()
[all …]
Dpollset_windows.cc92 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()
136 next_worker = pop_front_worker(&pollset->root_worker, in pollset_work()
156 push_front_worker(&pollset->root_worker, GRPC_POLLSET_WORKER_LINK_POLLSET, in pollset_work()
190 p->root_worker.links[GRPC_POLLSET_WORKER_LINK_POLLSET].next; in pollset_kick()
191 specific_worker != &p->root_worker; in pollset_kick()
211 pop_front_worker(&p->root_worker, GRPC_POLLSET_WORKER_LINK_POLLSET); in pollset_kick()
Dev_epollex_linux.cc118 grpc_pollset_worker* root_worker; member
265 grpc_pollset_worker* root_worker; member
590 (*p)->root_worker = nullptr;
722 pollset->root_worker, pollset->containing_pollset_set_count);
724 if (pollset->shutdown_closure != nullptr && pollset->root_worker == nullptr &&
756 if (specific_worker == p->root_worker) {
788 (void*)gpr_tls_get(&g_current_thread_worker), pollset->root_worker);
792 if (pollset->root_worker == nullptr) {
816 pollset->root_worker->links[PWLINK_POLLSET].next);
834 grpc_pollset_worker* w = pollset->root_worker;
[all …]
Dev_epollsig_linux.cc227 grpc_pollset_worker root_worker; member
1006 return p->root_worker.next != &p->root_worker;
1016 grpc_pollset_worker* w = p->root_worker.next;
1025 worker->next = &p->root_worker;
1031 worker->prev = &p->root_worker;
1048 for (worker = p->root_worker.next; worker != &p->root_worker;
1095 pollset->root_worker.next = pollset->root_worker.prev = &pollset->root_worker;
Dpollset_windows.h61 grpc_pollset_worker root_worker; member
Dev_poll_posix.cc197 grpc_pollset_worker root_worker; member
756 return p->root_worker.next != &p->root_worker;
769 grpc_pollset_worker* w = p->root_worker.next;
778 worker->next = &p->root_worker;
784 worker->prev = &p->root_worker;
809 for (specific_worker = p->root_worker.next;
810 specific_worker != &p->root_worker;
889 pollset->root_worker.next = pollset->root_worker.prev = &pollset->root_worker;
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dev_epoll1_linux.cc215 grpc_pollset_worker* root_worker; member
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()
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()
555 pollset->root_worker = nullptr; in pollset_init()
595 if (pollset->root_worker != nullptr) { in pollset_kick_all()
596 grpc_pollset_worker* worker = pollset->root_worker; in pollset_kick_all()
[all …]
Dpollset_windows.cc92 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()
136 next_worker = pop_front_worker(&pollset->root_worker, in pollset_work()
157 push_front_worker(&pollset->root_worker, GRPC_POLLSET_WORKER_LINK_POLLSET, in pollset_work()
193 p->root_worker.links[GRPC_POLLSET_WORKER_LINK_POLLSET].next; in pollset_kick()
194 specific_worker != &p->root_worker; in pollset_kick()
216 pop_front_worker(&p->root_worker, GRPC_POLLSET_WORKER_LINK_POLLSET); in pollset_kick()
Dev_epollex_linux.cc108 grpc_pollset_worker* root_worker; member
291 grpc_pollset_worker* root_worker; member
606 (*p)->root_worker = nullptr;
669 pollset->root_worker, pollset->containing_pollset_set_count);
671 if (pollset->shutdown_closure != nullptr && pollset->root_worker == nullptr &&
705 if (specific_worker == p->root_worker) {
737 gpr_tls_get(&g_current_thread_worker), pollset->root_worker);
742 if (pollset->root_worker == nullptr) {
766 pollset->root_worker->links[PWLINK_POLLSET].next);
784 grpc_pollset_worker* w = pollset->root_worker;
[all …]
Dev_poll_posix.cc199 grpc_pollset_worker root_worker; member
717 return p->root_worker.next != &p->root_worker;
730 grpc_pollset_worker* w = p->root_worker.next;
739 worker->next = &p->root_worker;
745 worker->prev = &p->root_worker;
770 for (specific_worker = p->root_worker.next;
771 specific_worker != &p->root_worker;
852 pollset->root_worker.next = pollset->root_worker.prev = &pollset->root_worker;
Dpollset_windows.h61 grpc_pollset_worker root_worker; member