Lines Matching full:events
16 # generic events, that must be mapped to implementation-specific ones
46 SelectorKey = namedtuple('SelectorKey', ['fileobj', 'fd', 'events', 'data'])
48 SelectorKey.__doc__ = """SelectorKey(fileobj, fd, events, data)
55 SelectorKey.events.__doc__ = 'Events that must be waited for on this file object.'
88 I/O events.
100 def register(self, fileobj, events, data=None): argument
105 events -- events to monitor (bitwise mask of EVENT_READ|EVENT_WRITE)
112 ValueError if events is invalid
141 def modify(self, fileobj, events, data=None): argument
142 """Change a registered file object monitored events or attached data.
146 events -- events to monitor (bitwise mask of EVENT_READ|EVENT_WRITE)
156 return self.register(fileobj, events, data)
172 list of (key, events) for ready file objects
173 `events` is a bitwise mask of EVENT_READ|EVENT_WRITE
238 def register(self, fileobj, events, data=None): argument
239 if (not events) or (events & ~(EVENT_READ | EVENT_WRITE)):
240 raise ValueError("Invalid events: {!r}".format(events))
242 key = SelectorKey(fileobj, self._fileobj_lookup(fileobj), events, data)
258 def modify(self, fileobj, events, data=None): argument
263 if events != key.events:
265 key = self.register(fileobj, events, data)
289 def register(self, fileobj, events, data=None): argument
290 key = super().register(fileobj, events, data)
291 if events & EVENT_READ:
293 if events & EVENT_WRITE:
324 events = ((fd in r and EVENT_READ)
326 ready.append((key, events & key.events))
340 def register(self, fileobj, events, data=None): argument
341 key = super().register(fileobj, events, data)
342 poller_events = ((events & EVENT_READ and self._EVENT_READ)
343 | (events & EVENT_WRITE and self._EVENT_WRITE) )
361 def modify(self, fileobj, events, data=None): argument
368 if events != key.events:
369 selector_events = ((events & EVENT_READ and self._EVENT_READ)
370 | (events & EVENT_WRITE and self._EVENT_WRITE))
381 key = key._replace(events=events, data=data)
406 events = ((event & ~self._EVENT_READ and EVENT_WRITE)
408 ready.append((key, events & key.events))
460 events = ((event & _NOT_EPOLLIN and EVENT_WRITE)
462 ready.append((key, events & key.events))
499 def register(self, fileobj, events, data=None): argument
500 key = super().register(fileobj, events, data)
502 if events & EVENT_READ:
507 if events & EVENT_WRITE:
519 if key.events & EVENT_READ:
529 if key.events & EVENT_WRITE:
558 events = ((flag == select.KQ_FILTER_READ and EVENT_READ)
560 ready.append((key, events & key.events))