ó ßüÚ\c@`s·ddlmZmZmZddlZddlZddlmZejj dƒZ e d„Z d„Z d„Zdd „Zdd „Ze d „Zd „Zd „Zd„ZdS(i(tprint_functiontdivisiontabsolute_importNi(tregistrysdistributed.comm.default-schemecC`s‚t|tjƒs+td|jjƒ‚n|jdƒ\}}}|ri| rid|}t|ƒ‚n|sxt}n||fS(sÎ 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. sexpected str, got %rs://sKInvalid url scheme. Must include protocol like tcp://localhost:8000. Got %s( t isinstancetsixt string_typest TypeErrort __class__t__name__t rpartitiont ValueErrortDEFAULT_SCHEME(taddrtstricttschemetseptloctmsg((s:lib/python2.7/site-packages/distributed/comm/addressing.pyt parse_address s   cC`sd||fS(sb Undo parse_address(). >>> unparse_address('tcp', '127.0.0.1') 'tcp://127.0.0.1' s%s://%s((RR((s:lib/python2.7/site-packages/distributed/comm/addressing.pytunparse_address%scC`stt|ƒŒS(s¶ Canonicalize address, adding a default scheme if necessary. >>> normalize_address('tls://[::1]') 'tls://[::1]' >>> normalize_address('[::1]') 'tcp://[::1]' (RR(R ((s:lib/python2.7/site-packages/distributed/comm/addressing.pytnormalize_address/s c`s÷tˆtƒrˆS‡fd†}‡‡fd†}ˆjdƒr§ˆdjdƒ\}}}|so|ƒn|s|ƒ}qç|jdƒsš|ƒn|d}n@ˆjdƒ\}}}|sÑ|ƒ}nd|krç|ƒn|t|ƒfS(sB Parse an endpoint address given in the form "host:port". c`stdˆfƒ‚dS(Nsinvalid address %r(R ((taddress(s:lib/python2.7/site-packages/distributed/comm/addressing.pyt_failBsc`s&ˆdkr"tdˆfƒ‚nˆS(Ns!missing port number in address %r(tNoneR ((Rt default_port(s:lib/python2.7/site-packages/distributed/comm/addressing.pyt_defaultEs t[it]t:(Rttuplet startswitht partitiontint(RRRRthostRttailtport((RRs:lib/python2.7/site-packages/distributed/comm/addressing.pytparse_host_port;s&       cC`sEd|kr)|jdƒ r)d|}n|r=d||fS|SdS(s! Undo parse_host_port(). RRs[%s]s%s:%sN(R(R"R$((s:lib/python2.7/site-packages/distributed/comm/addressing.pytunparse_host_portas  cC`sct|d|ƒ\}}tj|ƒ}y|j|ƒSWn$tk r^td|fƒ‚nXdS(s 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) Rs6don't know how to extract host and port for address %rN(RRt get_backendtget_address_host_porttNotImplementedErrorR (R RRRtbackend((s:lib/python2.7/site-packages/distributed/comm/addressing.pyR(ms  cC`s.t|ƒ\}}tj|ƒ}|j|ƒS(s  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'tget_address_host(R RRR*((s:lib/python2.7/site-packages/distributed/comm/addressing.pyR+s cC`s7t|ƒ\}}tj|ƒ}t||j|ƒƒS(sh 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'Rtget_local_address_for(R RRR*((s:lib/python2.7/site-packages/distributed/comm/addressing.pyR,‘s cC`s7t|ƒ\}}tj|ƒ}t||j|ƒƒS(s 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'Rtresolve_address(R RRR*((s:lib/python2.7/site-packages/distributed/comm/addressing.pyR-¢s (t __future__RRRRtdasktRtconfigtgetR tFalseRRRRR%R&R(R+R,R-(((s:lib/python2.7/site-packages/distributed/comm/addressing.pyts    &