Searched refs:g_active_poller (Results 1 – 2 of 2) sorted by relevance
38 static grpc_pollset_worker* g_active_poller; variable43 g_active_poller = NULL; in pollset_global_init()124 if (g_active_poller == NULL) { in pollset_work()128 g_active_poller = &worker; in pollset_work()134 g_active_poller = NULL; in pollset_work()202 if (p->is_iocp_worker && g_active_poller == specific_worker) { in pollset_kick()
452 static gpr_atm g_active_poller; variable501 gpr_atm_no_barrier_store(&g_active_poller, 0); in pollset_global_init()786 gpr_atm_no_barrier_cas(&g_active_poller, 0, (gpr_atm)worker)) { in begin_worker()806 GPR_ASSERT(gpr_atm_no_barrier_load(&g_active_poller) != (gpr_atm)worker); in begin_worker()868 if (gpr_atm_no_barrier_cas(&g_active_poller, 0, in check_neighborhood_for_available_poller()927 if (gpr_atm_no_barrier_load(&g_active_poller) == (gpr_atm)worker) { in end_worker()933 gpr_atm_no_barrier_store(&g_active_poller, (gpr_atm)worker->next); in end_worker()943 gpr_atm_no_barrier_store(&g_active_poller, 0); in end_worker()987 GPR_ASSERT(gpr_atm_no_barrier_load(&g_active_poller) != (gpr_atm)worker); in end_worker()1107 &g_active_poller)) { in pollset_kick()[all …]