Lines Matching refs:fut
336 fut = self.create_future()
337 self._sock_sendfile_native_impl(fut, None, sock, fileno,
339 return await fut
341 def _sock_sendfile_native_impl(self, fut, registered_fd, sock, fileno,
350 if fut.cancelled():
357 fut.set_result(total_sent)
364 self._sock_add_cancellation_callback(fut, sock)
365 self.add_writer(fd, self._sock_sendfile_native_impl, fut,
388 fut.set_exception(err)
391 fut.set_exception(exc)
394 fut.set_exception(exc)
399 fut.set_result(total_sent)
404 self._sock_add_cancellation_callback(fut, sock)
405 self.add_writer(fd, self._sock_sendfile_native_impl, fut,
413 def _sock_add_cancellation_callback(self, fut, sock):
414 def cb(fut):
415 if fut.cancelled():
419 fut.add_done_callback(cb)
