Home
last modified time | relevance | path

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

/third_party/grpc/src/core/lib/iomgr/
Dpollset_windows.cc187 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
189 if (specific_worker != NULL) { in pollset_kick()
190 if (specific_worker == GRPC_POLLSET_KICK_BROADCAST) { in pollset_kick()
192 for (specific_worker = in pollset_kick()
194 specific_worker != &p->root_worker; in pollset_kick()
195 specific_worker = in pollset_kick()
196 specific_worker->links[GRPC_POLLSET_WORKER_LINK_POLLSET].next) { in pollset_kick()
197 specific_worker->kicked = 1; in pollset_kick()
199 gpr_cv_signal(&specific_worker->cv); in pollset_kick()
207 if (p->is_iocp_worker && g_active_poller == specific_worker) { in pollset_kick()
[all …]
Dev_poll_posix.cc234 grpc_pollset_worker* specific_worker,
759 grpc_pollset_worker* specific_worker, argument
766 if (specific_worker != nullptr) {
767 if (specific_worker == GRPC_POLLSET_KICK_BROADCAST) {
770 for (specific_worker = p->root_worker.next;
771 specific_worker != &p->root_worker;
772 specific_worker = specific_worker->next) {
774 &error, grpc_wakeup_fd_wakeup(&specific_worker->wakeup_fd->fd));
778 reinterpret_cast<intptr_t>(specific_worker)) {
781 specific_worker->reevaluate_polling_on_wakeup = true;
[all …]
Dev_apple.cc276 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
280 GRPC_POLLING_TRACE("pollset kick: %p, worker:%p", pollset, specific_worker); in pollset_kick()
282 if (specific_worker == nullptr) { in pollset_kick()
289 } else if (specific_worker == GRPC_POLLSET_KICK_BROADCAST) { in pollset_kick()
295 reinterpret_cast<GrpcAppleWorker*>(specific_worker); in pollset_kick()
Dev_epoll1_linux.cc1069 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
1076 "PS:%p KICK:%p curps=%p curworker=%p root=%p", pollset, specific_worker, in pollset_kick()
1087 if (specific_worker != nullptr) { in pollset_kick()
1089 kick_state_string(specific_worker->state))); in pollset_kick()
1094 if (specific_worker == nullptr) { in pollset_kick()
1183 if (specific_worker->state == KICKED) { in pollset_kick()
1189 reinterpret_cast<intptr_t>(specific_worker)) { in pollset_kick()
1192 gpr_log(GPR_INFO, " .. mark %p kicked", specific_worker); in pollset_kick()
1194 SET_KICK_STATE(specific_worker, KICKED); in pollset_kick()
1196 } 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.cc684 static grpc_error* kick_one_worker(grpc_pollset_worker* specific_worker) { argument
686 pollable* p = specific_worker->pollable_obj;
688 GPR_ASSERT(specific_worker != nullptr);
689 if (specific_worker->kicked) {
697 reinterpret_cast<intptr_t>(specific_worker)) {
702 specific_worker->kicked = true;
705 if (specific_worker == p->root_worker) {
710 specific_worker->kicked = true;
714 if (specific_worker->initialized_cv) {
719 specific_worker->kicked = true;
[all …]
Dev_posix.cc330 grpc_pollset_worker* specific_worker) { in pollset_kick() argument
331 GRPC_POLLING_API_TRACE("pollset_kick(%p, %p)", pollset, specific_worker); in pollset_kick()
332 return g_event_engine->pollset_kick(pollset, specific_worker); in pollset_kick()
Dev_posix.h71 grpc_pollset_worker* specific_worker);
/third_party/grpc/src/core/lib/surface/
Dcompletion_queue.cc74 grpc_pollset_worker* specific_worker);
149 grpc_pollset_worker* specific_worker) { in non_polling_poller_kick() argument
151 if (specific_worker == nullptr) { in non_polling_poller_kick()
152 specific_worker = reinterpret_cast<grpc_pollset_worker*>(p->root); in non_polling_poller_kick()
154 if (specific_worker != nullptr) { in non_polling_poller_kick()
156 reinterpret_cast<non_polling_worker*>(specific_worker); in non_polling_poller_kick()