mirror
/
micropython-lib
kopia lustrzana https://github.com/micropython/micropython-lib
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

uasyncio: Be sure to create socket with params returned by getaddrinfo().

pull/255/merge
Paul Sokolovsky 2018-01-23 23:22:37 +02:00
rodzic 63b3d75af2
commit 147085d0f7
1 zmienionych plików z 8 dodań i 8 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

16
uasyncio/uasyncio/__init__.py
Wyświetl plik

@ -203,12 +203,12 @@ class StreamWriter:
def open_connection(host, port, ssl=False): def open_connection(host, port, ssl=False):
if DEBUG and __debug__: if DEBUG and __debug__:
log.debug("open_connection(%s, %s)", host, port) log.debug("open_connection(%s, %s)", host, port)
s = _socket.socket() ai = _socket.getaddrinfo(host, port, 0, _socket.SOCK_STREAM)
ai = ai[0]
s = _socket.socket(ai[0], ai[1], ai[2])
s.setblocking(False) s.setblocking(False)
ai = _socket.getaddrinfo(host, port)
addr = ai[0][4]
try: try:
s.connect(addr) s.connect(ai[-1])
except OSError as e: except OSError as e:
if e.args[0] != uerrno.EINPROGRESS: if e.args[0] != uerrno.EINPROGRESS:
raise raise
@ -232,13 +232,13 @@ def open_connection(host, port, ssl=False):
def start_server(client_coro, host, port, backlog=10): def start_server(client_coro, host, port, backlog=10):
if DEBUG and __debug__: if DEBUG and __debug__:
log.debug("start_server(%s, %s)", host, port) log.debug("start_server(%s, %s)", host, port)
s = _socket.socket() ai = _socket.getaddrinfo(host, port, 0, _socket.SOCK_STREAM)
ai = ai[0]
s = _socket.socket(ai[0], ai[1], ai[2])
s.setblocking(False) s.setblocking(False)
ai = _socket.getaddrinfo(host, port)
addr = ai[0][4]
s.setsockopt(_socket.SOL_SOCKET, _socket.SO_REUSEADDR, 1) s.setsockopt(_socket.SOL_SOCKET, _socket.SO_REUSEADDR, 1)
s.bind(addr) s.bind(ai[-1])
s.listen(backlog) s.listen(backlog)
while True: while True:
if DEBUG and __debug__: if DEBUG and __debug__: