def _del_timeout(self, fd):
if fd._timeout_id:
self._lock.acquire()
i = bisect_left(self._timeouts, (fd._timeout_id, fd))
while i < len(self._timeouts):
if self._timeouts[i] == (fd._timeout_id, fd):
del self._timeouts[i]
fd._timeout_id = None
break
if fd._timeout_id != self._timeouts[i][0]:
logger.warning('fd %s with %s is not found',
fd._fileno, fd._timeout_id)
break
i += 1
if self._polling:
self.interrupt()
self._lock.release()
评论列表
文章目录