Lines Matching refs:fut
370 fut = self.create_future()
371 self._sock_sendfile_native_impl(fut, None, sock, fileno,
373 return await fut
375 def _sock_sendfile_native_impl(self, fut, registered_fd, sock, fileno,
384 if fut.cancelled():
391 fut.set_result(total_sent)
398 self._sock_add_cancellation_callback(fut, sock)
399 self.add_writer(fd, self._sock_sendfile_native_impl, fut,
422 fut.set_exception(err)
425 fut.set_exception(exc)
430 fut.set_exception(exc)
435 fut.set_result(total_sent)
440 self._sock_add_cancellation_callback(fut, sock)
441 self.add_writer(fd, self._sock_sendfile_native_impl, fut,
449 def _sock_add_cancellation_callback(self, fut, sock):
450 def cb(fut):
451 if fut.cancelled():
455 fut.add_done_callback(cb)