Home
last modified time | relevance | path

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

/external/grpc-grpc/src/core/lib/iomgr/
Dpollset_windows.cc186 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
187 if (specific_worker != NULL) { in pollset_kick()
188 if (specific_worker == GRPC_POLLSET_KICK_BROADCAST) { in pollset_kick()
189 for (specific_worker = in pollset_kick()
191 specific_worker != &p->root_worker; in pollset_kick()
192 specific_worker = in pollset_kick()
193 specific_worker->links[GRPC_POLLSET_WORKER_LINK_POLLSET].next) { in pollset_kick()
194 specific_worker->kicked = 1; in pollset_kick()
195 gpr_cv_signal(&specific_worker->cv); in pollset_kick()
202 if (p->is_iocp_worker && g_active_poller == specific_worker) { in pollset_kick()
[all …]
Dev_poll_posix.cc232 grpc_pollset_worker* specific_worker,
798 grpc_pollset_worker* specific_worker, argument
805 if (specific_worker != nullptr) {
806 if (specific_worker == GRPC_POLLSET_KICK_BROADCAST) {
809 for (specific_worker = p->root_worker.next;
810 specific_worker != &p->root_worker;
811 specific_worker = specific_worker->next) {
813 &error, grpc_wakeup_fd_wakeup(&specific_worker->wakeup_fd->fd));
817 (intptr_t)specific_worker) {
820 specific_worker->reevaluate_polling_on_wakeup = true;
[all …]
Dev_epoll1_linux.cc1046 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
1055 specific_worker, (void*)gpr_tls_get(&g_current_thread_pollset), in pollset_kick()
1066 if (specific_worker != nullptr) { in pollset_kick()
1068 kick_state_string(specific_worker->state)); in pollset_kick()
1077 if (specific_worker == nullptr) { in pollset_kick()
1165 if (specific_worker->state == KICKED) { in pollset_kick()
1171 (intptr_t)specific_worker) { in pollset_kick()
1174 gpr_log(GPR_INFO, " .. mark %p kicked", specific_worker); in pollset_kick()
1176 SET_KICK_STATE(specific_worker, KICKED); in pollset_kick()
1178 } else if (specific_worker == in pollset_kick()
[all …]
Dpollset.cc52 grpc_pollset_worker* specific_worker) { in grpc_pollset_kick() argument
53 return grpc_pollset_impl->kick(pollset, specific_worker); in grpc_pollset_kick()
Dpollset.h50 grpc_pollset_worker* specific_worker);
96 grpc_pollset_worker* specific_worker)
Dev_epollex_linux.cc736 static grpc_error* kick_one_worker(grpc_pollset_worker* specific_worker) { argument
738 pollable* p = specific_worker->pollable_obj;
740 GPR_ASSERT(specific_worker != nullptr);
741 if (specific_worker->kicked) {
748 if (gpr_tls_get(&g_current_thread_worker) == (intptr_t)specific_worker) {
753 specific_worker->kicked = true;
756 if (specific_worker == p->root_worker) {
761 specific_worker->kicked = true;
765 if (specific_worker->initialized_cv) {
770 specific_worker->kicked = true;
[all …]
Dev_posix.cc325 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
326 GRPC_POLLING_API_TRACE("pollset_kick(%p, %p)", pollset, specific_worker); in pollset_kick()
327 return g_event_engine->pollset_kick(pollset, specific_worker); in pollset_kick()
Dpollset_custom.cc91 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
Dev_posix.h66 grpc_pollset_worker* specific_worker);
Dev_epollsig_linux.cc1038 grpc_pollset_worker* specific_worker) { argument
1043 grpc_pollset_worker* worker = specific_worker;
/external/grpc-grpc/src/core/lib/surface/
Dcompletion_queue.cc66 grpc_pollset_worker* specific_worker);
140 grpc_pollset* pollset, grpc_pollset_worker* specific_worker) { in non_polling_poller_kick() argument
142 if (specific_worker == nullptr) in non_polling_poller_kick()
143 specific_worker = reinterpret_cast<grpc_pollset_worker*>(p->root); in non_polling_poller_kick()
144 if (specific_worker != nullptr) { in non_polling_poller_kick()
146 reinterpret_cast<non_polling_worker*>(specific_worker); in non_polling_poller_kick()