mirrors/dragonflydb-dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00
Code Activity

fix: Fix live-lock in connection test (#3135)

Browse source 
fix: Fix livelocking connection test
This commit is contained in:
Shahar Mike 2024-06-05 21:30:02 +03:00 committed by GitHub
parent 9f09104c61
commit 229eeeb014
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 12 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
tests/dragonfly/connection_test.py
View file

@ -761,7 +761,6 @@ async def test_multiple_blocking_commands_client_pause(async_client: aioredis.Re
await all
@pytest.mark.skip("The test deadlock")
async def test_tls_when_read_write_is_interleaved(
with_ca_tls_server_args, with_ca_tls_client_args, df_local_factory
):
@ -789,18 +788,23 @@ async def test_tls_when_read_write_is_interleaved(
ssl_version=ssl.PROTOCOL_TLSv1_2,
)
ssl_sock.connect(("127.0.0.1", server.port))
ssl_sock.settimeout(0.1)
tmp = "f" * 1000
message = f"SET foo {tmp}\r\n".encode()
ssl_sock.send(message)
for i in range(0, 100000):
res = random.randint(1, 4)
message = b""
for j in range(0, res):
message = message + b"GET foo\r\n"
ssl_sock.send(message)
ssl_sock.do_handshake()
try:
for i in range(0, 100_000):
res = random.randint(1, 4)
message = b""
for j in range(0, res):
message = message + b"GET foo\r\n"
ssl_sock.send(message)
ssl_sock.do_handshake()
except:
# We might have filled the socket buffer, causing further sending will fail
pass
# This deadlocks
client = aioredis.Redis(port=server.port, **with_ca_tls_client_args)