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

asyncio_micro: Implement start_server().

pull/11/head
Paul Sokolovsky 2014-05-03 23:15:38 +03:00
rodzic b86919a6ff
commit acd25d05fc
1 zmienionych plików z 20 dodań i 0 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

20
asyncio_micro/asyncio_micro.py
Wyświetl plik

@ -235,3 +235,23 @@ def open_connection(host, port):
s = yield IOWrite(s) s = yield IOWrite(s)
log.debug("open_connection: After iowait: %s", s) log.debug("open_connection: After iowait: %s", s)
return StreamReader(s), StreamWriter(s) return StreamReader(s), StreamWriter(s)
def start_server(client_coro, host, port):
log.debug("start_server(%s, %s)", host, port)
s = _socket.socket()
s.setblocking(False)
ai = _socket.getaddrinfo(host, port)
addr = ai[0][4]
s.setsockopt(_socket.SOL_SOCKET, _socket.SO_REUSEADDR, 1)
s.bind(addr)
s.listen(10)
while True:
log.debug("start_server: Before accept")
yield IORead(s)
log.debug("start_server: After iowait")
s2, client_addr = s.accept()
s2.setblocking(False)
log.debug("start_server: After accept: %s", s2)
yield client_coro(StreamReader(s2), StreamWriter(s2))