Module test_comms

distributed.comm.tests.test_comms

Functions

▷ def check_tls_extra(info)
source link
▷ def get_inproc_comm_pair(**kwargs)
source link
▷ def get_tcp_comm_pair(**kwargs)
source link
▷ def get_tls_comm_pair(**kwargs)
source link
▷ def inproc_check()
source link
▷ def run_coro(func, *args, **kwargs)
source link
▷ def run_coro_in_thread(func, *args, **kwargs)
source link
▷ def tcp_eq(expected_host, expected_port=None)
source link
▷ def test_get_address_host()
source link
▷ def test_get_local_address_for()
source link
▷ def test_parse_host_port()
source link
▷ def test_register_backend_entrypoint()
source link
▷ def test_resolve_address()
source link
▷ def test_unparse_host_port()
source link