diff options
author | Jim Mussared <jim.mussared@gmail.com> | 2023-06-08 16:01:38 +1000 |
---|---|---|
committer | Damien George <damien@micropython.org> | 2023-06-19 17:33:03 +1000 |
commit | 6027c41c8f5b8f1a9e7b85b2bb93b3e6f2718e54 (patch) | |
tree | 08f41a4d0cd48fa5c0bc49519832ac2faba6923a /tests/multi_net/uasyncio_tcp_client_rst.py | |
parent | 2fbc08c462e247e7f78460783c9a07c76c5b762e (diff) | |
download | micropython-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.py | 56 |
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 |