Searched refs:next_worker (Results 1 – 2 of 2) sorted by relevance
125 grpc_pollset_worker* next_worker; in pollset_work() local136 next_worker = pop_front_worker(&pollset->root_worker, in pollset_work()138 if (next_worker == NULL) { in pollset_work()140 next_worker = pop_front_worker(&g_global_root_worker, in pollset_work()143 if (next_worker != NULL) { in pollset_work()144 next_worker->kicked = 1; in pollset_work()145 gpr_cv_signal(&next_worker->cv); in pollset_work()
1088 grpc_pollset_worker* next_worker = root_worker->next; in pollset_kick() local1096 } else if (next_worker->state == KICKED) { in pollset_kick()1099 gpr_log(GPR_INFO, " .. already kicked %p", next_worker); in pollset_kick()1101 SET_KICK_STATE(next_worker, KICKED); in pollset_kick()1104 next_worker && // only try and wake up a poller if in pollset_kick()1115 } else if (next_worker->state == UNKICKED) { in pollset_kick()1118 gpr_log(GPR_INFO, " .. kicked %p", next_worker); in pollset_kick()1120 GPR_ASSERT(next_worker->initialized_cv); in pollset_kick()1121 SET_KICK_STATE(next_worker, KICKED); in pollset_kick()1122 gpr_cv_signal(&next_worker->cv); in pollset_kick()[all …]