(self, sock, stop_key)
| 327 | """Tracker that tracks the resources.""" |
| 328 | |
| 329 | def __init__(self, sock, stop_key): |
| 330 | self._scheduler_map = {} |
| 331 | self._sock = sock |
| 332 | self._sock.setblocking(0) |
| 333 | self._ioloop = ioloop.IOLoop.current() |
| 334 | self._stop_key = stop_key |
| 335 | self._connections = set() |
| 336 | |
| 337 | def _event_handler(_, events): |
| 338 | self._on_event(events) |
| 339 | |
| 340 | self._ioloop.add_handler(self._sock.fileno(), _event_handler, self._ioloop.READ) |
| 341 | |
| 342 | def _on_event(self, _): |
| 343 | while True: |