B F.\x@sddlmZmZmZddlZddlZddlmZej dZ dddZ d d Z d d Z dd dZdddZdddZddZddZddZdS))print_functiondivisionabsolute_importN)registryzdistributed.comm.default-schemeFcCsTt|tjstd|jj|d\}}}|rD|sDd|}t||sLt}||fS)z Split address into its scheme and scheme-dependent location string. >>> parse_address('tcp://127.0.0.1') ('tcp', '127.0.0.1') If strict is set to true the address must have a scheme. zexpected str, got %rz://zKInvalid url scheme. Must include protocol like tcp://localhost:8000. Got %s) isinstancesixZ string_types TypeError __class____name__ rpartition ValueErrorDEFAULT_SCHEME)addrstrictschemeseplocmsgr:lib/python3.7/site-packages/distributed/comm/addressing.py parse_address s rcCs d||fS)zb Undo parse_address(). >>> unparse_address('tcp', '127.0.0.1') 'tcp://127.0.0.1' z%s://%sr)rrrrrunparse_address#srcCs tt|S)z Canonicalize address, adding a default scheme if necessary. >>> normalize_address('tls://[::1]') 'tls://[::1]' >>> normalize_address('[::1]') 'tcp://[::1]' )rr)rrrrnormalize_address-s rcsttrSfdd}fdd}dr~ddd\}}}|sT||s`|}q|d sp||dd}n*d \}}}|s|}nd |kr||t|fS) zB Parse an endpoint address given in the form "host:port". cstdfdS)Nzinvalid address %r)r r)addressrr_fail@szparse_host_port.._failcsdkrtdfS)Nz!missing port number in address %r)r r)r default_portrr_defaultCsz!parse_host_port.._default[rN]:)rtuple startswith partitionint)rrrrhostrtailportr)rrrparse_host_port9s&    r(cCs2d|kr|dsd|}|r*d||fS|SdS)z! Undo parse_host_port(). r rz[%s]z%s:%sN)r")r%r'rrrunparse_host_port_s  r)cCsLt||d\}}t|}y ||Stk rFtd|fYnXdS)a Get a (host, port) tuple out of the given address. For definition of strict check parse_address ValueError is raised if the address scheme doesn't allow extracting the requested information. >>> get_address_host_port('tcp://1.2.3.4:80') ('1.2.3.4', 80) )rz6don't know how to extract host and port for address %rN)rr get_backendget_address_host_portNotImplementedErrorr )rrrrbackendrrrr+ks   r+cCs t|\}}t|}||S)a  Return a hostname / IP address identifying the machine this address is located on. In contrast to get_address_host_port(), this function should always succeed for well-formed addresses. >>> get_address_host('tcp://1.2.3.4:80') '1.2.3.4' )rrr*get_address_host)rrrr-rrrr.~s  r.cCs&t|\}}t|}t|||S)ah Get a local listening address suitable for reaching *addr*. For instance, trying to reach an external TCP address will return a local TCP address that's routable to that external address. >>> get_local_address_for('tcp://8.8.8.8:1234') 'tcp://192.168.1.68' >>> get_local_address_for('tcp://127.0.0.1:1234') 'tcp://127.0.0.1' )rrr*rget_local_address_for)rrrr-rrrr/s  r/cCs&t|\}}t|}t|||S)a Apply scheme-specific address resolution to *addr*, replacing all symbolic references with concrete location specifiers. In practice, this can mean hostnames are resolved to IP addresses. >>> resolve_address('tcp://localhost:8786') 'tcp://127.0.0.1:8786' )rrr*rresolve_address)rrrr-rrrr0s  r0)F)N)N)F)Z __future__rrrrZdaskrZconfiggetrrrrr(r)r+r.r/r0rrrrs     &