Searched refs:pending_events (Results 1 – 6 of 6) sorted by relevance
250 if (pending_events.Load(grpc_core::MemoryOrder::ACQUIRE) != 0) { in ~cq_next_data()265 grpc_core::Atomic<intptr_t> pending_events{1}; member281 if (pending_events.Load(grpc_core::MemoryOrder::ACQUIRE) != 0) { in ~cq_pluck_data()293 grpc_core::Atomic<intptr_t> pending_events{1}; member319 if (pending_events.Load(grpc_core::MemoryOrder::ACQUIRE) != 0) { in ~cq_callback_data()329 grpc_core::Atomic<intptr_t> pending_events{1}; member470 if (cqd->pending_events.FetchSub(1, grpc_core::MemoryOrder::ACQ_REL) == 1) { in grpc_completion_queue_thread_local_cache_flush()661 return cqd->pending_events.IncrementIfNonzero();666 return cqd->pending_events.IncrementIfNonzero();671 return cqd->pending_events.IncrementIfNonzero();[all …]
226 gpr_atm pending_events; member238 gpr_atm pending_events; member261 gpr_atm pending_events; member404 if (gpr_atm_full_fetch_add(&cqd->pending_events, -1) == 1) { in grpc_completion_queue_thread_local_cache_flush()505 gpr_atm_no_barrier_store(&cqd->pending_events, 1); in cq_init_next()521 gpr_atm_no_barrier_store(&cqd->pending_events, 1); in cq_init_pluck()539 gpr_atm_no_barrier_store(&cqd->pending_events, 1); in cq_init_callback()648 return atm_inc_if_nonzero(&cqd->pending_events);653 return atm_inc_if_nonzero(&cqd->pending_events);658 return atm_inc_if_nonzero(&cqd->pending_events);[all …]
31 self.pending_events = []138 self.pending_events.append(event)147 self.pending_events.append(event)173 for e in self.pending_events:185 self.pending_events = None
37 self.pending_events = []144 self.pending_events.append(event)153 self.pending_events.append(event)179 for e in self.pending_events:191 self.pending_events = None
193 unsigned int pending_events; member308 set_flag(&o->pending_events, EVENT_FLIP); in do_page_flip()366 set_flag(&o->pending_events, EVENT_VBLANK); in do_wait_for_vblank()410 clear_flag(&o->pending_events, EVENT_FLIP); in page_flip_handler()482 clear_flag(&o->pending_events, EVENT_VBLANK); in vblank_handler()680 do_flip = (o->flags & TEST_FLIP) && !(o->pending_events & EVENT_FLIP); in run_test_step()682 !(o->pending_events & EVENT_VBLANK); in run_test_step()695 !(o->pending_events & EVENT_VBLANK) && o->flip_state.count > 0) { in run_test_step()1031 event_mask = o->pending_events; in wait_for_events()1054 } while (o->pending_events); in wait_for_events()[all …]
74 fn pending_events(&self) -> bool { in pending_events() method661 if !self.display.pending_events() { in dispatch_display_events()