Lines Matching refs:fut
371 fut = self.create_future()
374 handle = self._add_reader(fd, self._sock_recv, fut, sock, n)
375 fut.add_done_callback(
377 return await fut
379 def _sock_read_done(self, fd, fut, handle=None):
383 def _sock_recv(self, fut, sock, n):
386 if fut.done():
395 fut.set_exception(exc)
397 fut.set_result(data)
412 fut = self.create_future()
415 handle = self._add_reader(fd, self._sock_recv_into, fut, sock, buf)
416 fut.add_done_callback(
418 return await fut
420 def _sock_recv_into(self, fut, sock, buf):
424 if fut.done():
433 fut.set_exception(exc)
435 fut.set_result(nbytes)
452 fut = self.create_future()
455 handle = self._add_reader(fd, self._sock_recvfrom, fut, sock, bufsize)
456 fut.add_done_callback(
458 return await fut
460 def _sock_recvfrom(self, fut, sock, bufsize):
464 if fut.done():
473 fut.set_exception(exc)
475 fut.set_result(result)
493 fut = self.create_future()
496 handle = self._add_reader(fd, self._sock_recvfrom_into, fut, sock, buf,
498 fut.add_done_callback(
500 return await fut
502 def _sock_recvfrom_into(self, fut, sock, buf, bufsize):
506 if fut.done():
515 fut.set_exception(exc)
517 fut.set_result(result)
540 fut = self.create_future()
544 handle = self._add_writer(fd, self._sock_sendall, fut, sock,
546 fut.add_done_callback(
548 return await fut
550 def _sock_sendall(self, fut, sock, view, pos):
551 if fut.done():
562 fut.set_exception(exc)
568 fut.set_result(None)
589 fut = self.create_future()
593 handle = self._add_writer(fd, self._sock_sendto, fut, sock, data,
595 fut.add_done_callback(
597 return await fut
599 def _sock_sendto(self, fut, sock, data, address):
600 if fut.done():
610 fut.set_exception(exc)
612 fut.set_result(n)
631 fut = self.create_future()
632 self._sock_connect(fut, sock, address)
634 return await fut
637 fut = None
639 def _sock_connect(self, fut, sock, address):
650 fd, self._sock_connect_cb, fut, sock, address)
651 fut.add_done_callback(
656 fut.set_exception(exc)
658 fut.set_result(None)
660 fut = None
662 def _sock_write_done(self, fd, fut, handle=None):
666 def _sock_connect_cb(self, fut, sock, address):
667 if fut.done():
681 fut.set_exception(exc)
683 fut.set_result(None)
685 fut = None
698 fut = self.create_future()
699 self._sock_accept(fut, sock)
700 return await fut
702 def _sock_accept(self, fut, sock):
709 handle = self._add_reader(fd, self._sock_accept, fut, sock)
710 fut.add_done_callback(
715 fut.set_exception(exc)
717 fut.set_result((conn, address))