Lines Matching refs:ioloop
768 def __init__(self, sock=None, ioloop=None): argument
769 self.ioloop = ioloop or IOLoop.instance()
770 self._wanted_io_events = self.ioloop.READ
771 self._current_io_events = self.ioloop.READ
782 events = events if events is not None else self.ioloop.READ
783 self.ioloop.register(self._fileno, self, events)
789 self.ioloop.unregister(self._fileno)
794 if self._fileno not in self.ioloop.socket_map:
802 if events == self.ioloop.READ:
804 elif events == self.ioloop.WRITE:
806 elif events == self.ioloop.READ | self.ioloop.WRITE:
812 self.ioloop.modify(self._fileno, events)
827 callback = self.ioloop.call_later(seconds, target, *args, **kwargs)
834 self.modify_ioloop_events(self.ioloop.WRITE)
931 wanted = self.ioloop.READ
936 wanted = self.ioloop.READ | self.ioloop.WRITE
938 self.ioloop.modify(self._fileno, wanted)
974 AsyncChat.add_channel(self, map=map, events=self.ioloop.WRITE)
983 AsyncChat.add_channel(self, map=map, events=self.ioloop.READ)
1026 if isinstance(self.ioloop, Kqueue):
1027 self.ioloop.modify(self._fileno, self.ioloop.READ)