logging and dependency fixes

Author: jell-o-fishi

requirements.txt

@@ -9,8 +9,8 @@ asyncstdlib==3.13.0
 asyncclick==8.1.8; python_version > "3.8"
 asyncclick==8.1.7.2; python_version == "3.8"
 
-coverage==7.5.4
-coveralls==4.0.1
+coverage==6.5.0
+coveralls==3.3.1
 decoy==2.1.1
 flake8==7.1.2
 

rsocket/transports/aioquic_transport.py

@@ -102,6 +102,8 @@ async def send_frame(self, frame: Frame):
 
     async def incoming_data_listener(self):
         try:
+            logger().debug('Quic - Listener started')
+
             await self._quic_protocol.wait_connected()
 
             while True:
@@ -118,8 +120,11 @@ async def incoming_data_listener(self):
             logger().debug('Asyncio task canceled: incoming_data_listener')
         except Exception:
             self._incoming_frame_queue.put_nowait(RSocketTransportError())
+        finally:
+            logger().debug('Quic - Listener stopped')
 
     async def close(self):
+        logger().debug('Quic - Closing transport')
         await cancel_if_task_exists(self._listener)
         self._quic_protocol.close()
 

tests/rsocket/test_concurrency.py

@@ -1,4 +1,5 @@
 import asyncio
+import logging
 from typing import Tuple, Optional
 
 import pytest
@@ -76,6 +77,8 @@ async def run():
             request_2 = asyncio.create_task(measure_time(client.request_response(Payload(b'10'))))
             return await request_1, await request_2
 
+        logging.debug("Starting concurrent requests")
+
         measure_result = await measure_time(run())
 
         results = measure_result.result

tests/tools/fixtures_aioquic.py

@@ -1,3 +1,4 @@
+import logging
 from asyncio import Event
 from contextlib import asynccontextmanager
 from typing import Optional
@@ -34,12 +35,16 @@ def store_server(new_server):
         server = new_server
         wait_for_server.set()
 
+    logging.debug('test quic - starting server')
+
     quic_server = await rsocket_serve(host='localhost',
                                       port=unused_tcp_port,
                                       configuration=server_configuration,
                                       on_server_create=store_server,
                                       **(server_arguments or {}))
 
+    logging.debug('test quic - server started')
+
     try:
         # from datetime import timedelta
         # test_overrides = {'keep_alive_period': timedelta(minutes=20)}
@@ -49,7 +54,12 @@ def store_server(new_server):
                                    configuration=quic_client_configuration(certificate)) as transport:
             async with RSocketClient(single_transport_provider(transport),
                                      **client_arguments) as client:
+                logging.debug('test quic - waiting for server to be ready')
+
                 await wait_for_server.wait()
+
+                logging.debug('test quic - server and client ready, starting test')
+
                 yield server, client
     finally:
         if server is not None: