await asyncio.wait_for(run(), timeout=3 * TIMEOUT)
-def test_tcp_garbage(named_port: int) -> None:
- with create_socket("10.53.0.7", named_port) as sock:
+def test_tcp_garbage(ns7: NamedInstance, named_port: int) -> None:
+ with create_socket(ns7.ip, named_port) as sock:
msg = isctest.query.create(
"a.example.", "A", dnssec=False, use_edns=-1, ad=False
)
raise EOFError from e
-def test_tcp_garbage_response(named_port: int) -> None:
- with create_socket("10.53.0.7", named_port) as sock:
+def test_tcp_garbage_response(ns7: NamedInstance, named_port: int) -> None:
+ with create_socket(ns7.ip, named_port) as sock:
msg = isctest.query.create(
"a.example.", "A", dnssec=False, use_edns=-1, ad=False
)
# Regression test for CVE-2022-0396
-def test_close_wait(named_port: int) -> None:
- with create_socket("10.53.0.7", named_port) as sock:
+def test_close_wait(ns7: NamedInstance, named_port: int) -> None:
+ with create_socket(ns7.ip, named_port) as sock:
msg = isctest.query.create(
"a.example.", "A", dnssec=False, use_edns=-1, ad=False
)
# ns7/named.dropedns and close the socket, making room for the next
# request. If it gets stuck in CLOSE_WAIT state, there is no connection
# available for the query below and it will time out.
- with create_socket("10.53.0.7", named_port) as sock:
+ with create_socket(ns7.ip, named_port) as sock:
msg = isctest.query.create(
"a.example.", "A", dnssec=False, use_edns=-1, ad=False
)
# GL #4273
-def test_tcp_big(named_port: int) -> None:
- with create_socket("10.53.0.7", named_port) as sock:
+def test_tcp_big(ns7: NamedInstance, named_port: int) -> None:
+ with create_socket(ns7.ip, named_port) as sock:
msg = isctest.query.create(
dns.name.root, "URI", dnssec=False, use_edns=-1, ad=False, message_id=0
)