From 218916db7cb43aadb6878a26828203580daac74e Mon Sep 17 00:00:00 2001 From: pedohorse <13556996+pedohorse@users.noreply.github.com> Date: Tue, 29 Oct 2024 17:22:23 +0100 Subject: [PATCH] test with 0 reping interval --- .../test_connection_pool_integration.py | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/tests/tests_net_messages/test_connection_pool_integration.py b/tests/tests_net_messages/test_connection_pool_integration.py index 4247e0ae..5926f676 100644 --- a/tests/tests_net_messages/test_connection_pool_integration.py +++ b/tests/tests_net_messages/test_connection_pool_integration.py @@ -120,15 +120,22 @@ def _create_protocol(): while srv is None: await asyncio.sleep(0.1) + stream_stash = [] + timeout = 2 + pooled_factory = TcpMessageStreamPooledFactory( + timeout, + _fake_conn_opener_factory(stream_stash, _initialize_connection), + timeout=5, + minimal_reping_interval=0, + ) + try: - stream_stash = [] - timeout = 2 - pooled_factory = TcpMessageStreamPooledFactory(timeout, _fake_conn_opener_factory(stream_stash, _initialize_connection), timeout=5) addr = DirectAddress(f'{get_localhost()}:29361'), DirectAddress(f'{get_localhost()}:29360') print('attempting connection') for _ in range(3): + print('sending message') stream0 = await pooled_factory.open_sending_stream(*addr) stream0.close() await stream0.wait_closed() @@ -141,6 +148,7 @@ def _create_protocol(): await prt.last_writer.wait_closed() for _ in range(3): + print('sending message') stream0 = await pooled_factory.open_sending_stream(*addr) await stream0.send_data_message(b'foo', addr[0], session=uuid.uuid4()) stream0.close()