Searched refs:events_ (Results 1 – 8 of 8) sorted by relevance
108 EventVector::iterator event = events_.begin(); in AreKeventValuesValid()109 for (; event != events_.end(); ++event) { in AreKeventValuesValid()115 if (event != events_.end()) { in AreKeventValuesValid()144 for (; local_event != events_.end(); ++local_event) { in HandleAttributesChange()163 for (; local_event != events_.end(); ++local_event) { in HandleDeleteOrMoveChange()200 for (valid = 0; valid < events_.size(); ++valid) { in UpdateWatches()201 if (!IsKeventFileDescriptorOpen(events_[valid])) { in UpdateWatches()211 int count = HANDLE_EINTR(kevent(kqueue_, &events_[0], valid, &updates[0], in UpdateWatches()217 for (; valid < events_.size(); ++valid) { in UpdateWatches()218 EventData* event_data = EventDataForKevent(events_[valid]); in UpdateWatches()[all …]
121 EventVector events_; variable
96 events_[WAKEALL_0] = CreateEvent(NULL, // no security attributes in ConditionVariableEventWin()101 events_[WAKEALL_1] = CreateEvent(NULL, // no security attributes in ConditionVariableEventWin()106 events_[WAKE] = CreateEvent(NULL, // no security attributes in ConditionVariableEventWin()113 CloseHandle(events_[WAKE]); in ~ConditionVariableEventWin()114 CloseHandle(events_[WAKEALL_1]); in ~ConditionVariableEventWin()115 CloseHandle(events_[WAKEALL_0]); in ~ConditionVariableEventWin()140 events[0] = events_[WAKE]; in SleepCS()141 events[1] = events_[eventID]; in SleepCS()161 ResetEvent(events_[eventID]); in SleepCS()175 SetEvent(events_[WAKE]); in Wake()[all …]
41 HANDLE events_[EVENT_COUNT]; variable
101 EventMap::iterator it = events_.find(event_name); in StartEvent()102 bool needs_insert = (it == events_.end()); in StartEvent()108 it = events_.insert( in StartEvent()119 EventMap::iterator it = events_.find(event_name); in StopEvent()120 if (it != events_.end()) { in StopEvent()142 for (EventMap::const_iterator it = events_.begin(); in ReportToLog()143 it != events_.end(); ++it) { in ReportToLog()161 events_.find(event_name); in GetEvent()162 return (it == events_.end()) ? NULL : &it->second; in GetEvent()169 EventMap::iterator it = events_.begin(); in Clear()[all …]
63 events_.erase(stream); in Monitor()68 events_.erase(stream); in Unmonitor()83 events_.erase(socket); in Monitor()90 events_.erase(socket); in Unmonitor()122 EventMap::iterator it = events_.find(obj); in AddEvents()123 if (events_.end() == it) { in AddEvents()124 events_.insert(EventMap::value_type(obj, events)); in AddEvents()130 EventMap::iterator it = events_.find(obj); in DoCheck()131 if ((events_.end() == it) || (0 == (it->second & event))) { in DoCheck()140 EventMap::iterator it = events_.find(obj); in DoEvents()[all …]
134 EventMap events_; variable
44 if (events_.empty()) in HandlePrepare()46 TimeDelta delta = events_[0].time - Time::NowFromSystemTime(); in HandlePrepare()51 if (events_.empty()) in HandleCheck()53 return events_[0].time <= Time::NowFromSystemTime(); in HandleCheck()57 if (events_.empty()) in HandleDispatch()59 Event event = events_[0]; in HandleDispatch()60 events_.erase(events_.begin()); in HandleDispatch()84 events_.clear(); in Reset()103 if (!events_.empty()) in AddEventHelper()104 last_time = (events_.end()-1)->time; in AddEventHelper()[all …]