Lines Matching refs:self
63 def __init__(self, selector):
64 self._selector = selector
66 def __len__(self):
67 return len(self._selector._fd_to_key)
69 def __getitem__(self, fileobj):
71 fd = self._selector._fileobj_lookup(fileobj)
72 return self._selector._fd_to_key[fd]
76 def __iter__(self):
77 return iter(self._selector._fd_to_key)
96 def register(self, fileobj, events, data=None):
119 def unregister(self, fileobj):
137 def modify(self, fileobj, events, data=None):
151 self.unregister(fileobj)
152 return self.register(fileobj, events, data)
155 def select(self, timeout=None):
173 def close(self):
180 def get_key(self, fileobj):
186 mapping = self.get_map()
195 def get_map(self):
199 def __enter__(self):
200 return self
202 def __exit__(self, *args):
203 self.close()
209 def __init__(self):
211 self._fd_to_key = {}
213 self._map = _SelectorMapping(self)
215 def _fileobj_lookup(self, fileobj):
228 for key in self._fd_to_key.values():
234 def register(self, fileobj, events, data=None):
238 key = SelectorKey(fileobj, self._fileobj_lookup(fileobj), events, data)
240 if key.fd in self._fd_to_key:
244 self._fd_to_key[key.fd] = key
247 def unregister(self, fileobj):
249 key = self._fd_to_key.pop(self._fileobj_lookup(fileobj))
254 def modify(self, fileobj, events, data=None):
256 key = self._fd_to_key[self._fileobj_lookup(fileobj)]
260 self.unregister(fileobj)
261 key = self.register(fileobj, events, data)
265 self._fd_to_key[key.fd] = key
268 def close(self):
269 self._fd_to_key.clear()
270 self._map = None
272 def get_map(self):
273 return self._map
275 def _key_from_fd(self, fd):
285 return self._fd_to_key[fd]
293 def __init__(self):
295 self._readers = set()
296 self._writers = set()
298 def register(self, fileobj, events, data=None):
301 self._readers.add(key.fd)
303 self._writers.add(key.fd)
306 def unregister(self, fileobj):
308 self._readers.discard(key.fd)
309 self._writers.discard(key.fd)
313 def _select(self, r, w, _, timeout=None):
319 def select(self, timeout=None):
323 r, w, _ = self._select(self._readers, self._writers, [], timeout)
335 key = self._key_from_fd(fd)
347 def __init__(self):
349 self._selector = self._selector_cls()
351 def register(self, fileobj, events, data=None):
355 poller_events |= self._EVENT_READ
357 poller_events |= self._EVENT_WRITE
359 self._selector.register(key.fd, poller_events)
365 def unregister(self, fileobj):
368 self._selector.unregister(key.fd)
375 def modify(self, fileobj, events, data=None):
377 key = self._fd_to_key[self._fileobj_lookup(fileobj)]
385 selector_events |= self._EVENT_READ
387 selector_events |= self._EVENT_WRITE
389 self._selector.modify(key.fd, selector_events)
399 self._fd_to_key[key.fd] = key
402 def select(self, timeout=None):
415 fd_event_list = self._selector.poll(timeout)
420 if event & ~self._EVENT_READ:
422 if event & ~self._EVENT_WRITE:
425 key = self._key_from_fd(fd)
448 def fileno(self):
449 return self._selector.fileno()
451 def select(self, timeout=None):
464 max_ev = max(len(self._fd_to_key), 1)
468 fd_event_list = self._selector.poll(timeout, max_ev)
478 key = self._key_from_fd(fd)
483 def close(self):
484 self._selector.close()
496 def fileno(self):
497 return self._selector.fileno()
499 def close(self):
500 self._selector.close()
509 def __init__(self):
511 self._selector = select.kqueue()
513 def fileno(self):
514 return self._selector.fileno()
516 def register(self, fileobj, events, data=None):
522 self._selector.control([kev], 0, 0)
526 self._selector.control([kev], 0, 0)
532 def unregister(self, fileobj):
538 self._selector.control([kev], 0, 0)
547 self._selector.control([kev], 0, 0)
553 def select(self, timeout=None):
558 max_ev = max(len(self._fd_to_key), 1)
561 kev_list = self._selector.control(None, max_ev, timeout)
573 key = self._key_from_fd(fd)
578 def close(self):
579 self._selector.close()