U ÷Õ/eÿ ã@s´UddlmZddlZddlZddlmZmZddlm Z ddl m Z Gdd„de ƒZ ej dkrrejjZded <nd d d d œd d „ZGdd„deƒZiZded<d ddœdd„ZdS)é)Ú annotationsN)ÚABCÚabstractmethod)ÚIterable)ÚProtocolc@seZdZdddœdd„ZdS)Ú _EntryPointsÚstrú'Iterable[importlib.metadata.EntryPoint])ÚkwargsÚreturncKsdS©N©)Úselfr r r ú=/tmp/pip-unpacked-wheel-g426oqom/distributed/comm/registry.pyÚ__call__ sz_EntryPoints.__call__N)Ú__name__Ú __module__Ú __qualname__rr r r rr sr)éé Ú _entry_pointsrr )ÚgroupÚnamer ccs,tj ¡ |g¡D]}|j|kr|VqdSr )Ú importlibÚmetadataÚ entry_pointsÚgetr)rrÚepr r rrs c@sTeZdZdZedd„ƒZedd„ƒZedd„ƒZedd „ƒZd d „Z ed d „ƒZ dS)ÚBackendzO A communication backend, selected by a given URI scheme (e.g. 'tcp'). cCsdS)zL Get a connector object usable for connecting to addresses. Nr )rr r rÚ get_connector$szBackend.get_connectorcKsdS)zJ Get a listener object for the scheme-less address *loc*. Nr )rÚlocZ handle_commZ deserializeZconnection_argsr r rÚ get_listener*szBackend.get_listenercCsdS)zš Get a host name (normally an IP address) identifying the host the address is located on. *loc* is a scheme-less address. Nr ©rr r r rÚget_address_host2szBackend.get_address_hostcCsdS)z  Resolve the address into a canonical form. *loc* is a scheme-less address. Simple implementations may return *loc* unchanged. Nr r"r r rÚresolve_address:szBackend.resolve_addresscCst‚dS)zŽ Get the (host, port) tuple of the scheme-less address *loc*. This should only be implemented by IP-based transports. N)ÚNotImplementedErrorr"r r rÚget_address_host_portCszBackend.get_address_host_portcCsdS)zN Get the local listening address suitable for reaching *loc*. Nr r"r r rÚget_local_address_forJszBackend.get_local_address_forN) rrrÚ__doc__rrr!r#r$r&r'r r r rrs    rzdict[str, Backend]Úbackends)Úschemer cCs^t |¡}|dk r|St|ddD]}| ¡ƒ}|t|<|Std|›dttƒ›dƒ‚dS)zÍ Get the Backend instance for the given *scheme*. It looks for matching scheme in dask's internal cache, and falls-back to package metadata for the group name ``distributed.comm.backends`` Nzdistributed.comm.backends)rrzunknown address scheme z (known schemes: ú))r)rrÚloadÚ ValueErrorÚsorted)r*ÚbackendZbackend_class_epr r rÚ get_backendUs ÿ  ÿr0)Ú __future__rÚimportlib.metadatarÚsysÚabcrrÚcollections.abcrÚtypingrrÚ version_inforrrÚ__annotations__rr)r0r r r rÚs    5