summaryrefslogtreecommitdiffstatshomepage
path: root/tests/multi_net/uasyncio_tcp_client_rst.py
diff options
context:
space:
mode:
authorJim Mussared <jim.mussared@gmail.com>2023-06-08 16:01:38 +1000
committerDamien George <damien@micropython.org>2023-06-19 17:33:03 +1000
commit6027c41c8f5b8f1a9e7b85b2bb93b3e6f2718e54 (patch)
tree08f41a4d0cd48fa5c0bc49519832ac2faba6923a /tests/multi_net/uasyncio_tcp_client_rst.py
parent2fbc08c462e247e7f78460783c9a07c76c5b762e (diff)
downloadmicropython-6027c41c8f5b8f1a9e7b85b2bb93b3e6f2718e54.tar.gz
micropython-6027c41c8f5b8f1a9e7b85b2bb93b3e6f2718e54.zip
tests: Rename uasyncio to asyncio.
This work was funded through GitHub Sponsors. Signed-off-by: Jim Mussared <jim.mussared@gmail.com>
Diffstat (limited to 'tests/multi_net/uasyncio_tcp_client_rst.py')
-rw-r--r--tests/multi_net/uasyncio_tcp_client_rst.py56
1 files changed, 0 insertions, 56 deletions
diff --git a/tests/multi_net/uasyncio_tcp_client_rst.py b/tests/multi_net/uasyncio_tcp_client_rst.py
deleted file mode 100644
index d81f22748e..0000000000
--- a/tests/multi_net/uasyncio_tcp_client_rst.py
+++ /dev/null
@@ -1,56 +0,0 @@
-# Test TCP server with client issuing TCP RST part way through read
-
-try:
- import uasyncio as asyncio
-except ImportError:
- try:
- import asyncio
- except ImportError:
- print("SKIP")
- raise SystemExit
-
-import struct, time, socket
-
-PORT = 8000
-
-
-async def handle_connection(reader, writer):
- data = await reader.read(10) # should succeed
- print(data)
- await asyncio.sleep(0.2) # wait for client to drop connection
- try:
- data = await reader.read(100)
- print(data)
- writer.close()
- await writer.wait_closed()
- except OSError as er:
- print("OSError", er.errno)
- ev.set()
-
-
-async def main():
- global ev
- ev = asyncio.Event()
- server = await asyncio.start_server(handle_connection, "0.0.0.0", PORT)
- multitest.next()
- async with server:
- await asyncio.wait_for(ev.wait(), 10)
-
-
-def instance0():
- multitest.globals(IP=multitest.get_network_ip())
- asyncio.run(main())
-
-
-def instance1():
- if not hasattr(socket, "SO_LINGER"):
- multitest.skip()
- multitest.next()
- s = socket.socket()
- s.connect(socket.getaddrinfo(IP, PORT)[0][-1])
- lgr_onoff = 1
- lgr_linger = 0
- s.setsockopt(socket.SOL_SOCKET, socket.SO_LINGER, struct.pack("ii", lgr_onoff, lgr_linger))
- s.send(b"GET / HTTP/1.0\r\n\r\n")
- time.sleep(0.1)
- s.close() # This issues a TCP RST since we've set the linger option