0FieddlmZddlZddlZddlZddlmZddlmZddl m Z ddl m Z m Z mZmZejeZejdZeeer eeZ dd Zdd Zd Zd Zdd ZdS)) annotationsN) parse_bytes)protocol) safe_sizeof)get_ipget_ipv6nbytesoffloadzdistributed.comm.offloadTcKfd}tr9|r7td}|dks |tkrt|d{VS|S)z{ Serialize a message into a list of Distributed protocol frames. Any kwargs are forwarded to protocol.dumps(). c ttjfiS#t$r;}tdt|d}~wwxYw)NzUnserializable Message: %s)listrdumps Exceptionloggerinfo exception)ekwargsmsgs 6lib/python3.11/site-packages/distributed/comm/utils.py _to_frameszto_frames.._to_frames ss s55f5566 6    KK4c : : :   Q     s" A'6A""A') default_sizeN)OFFLOAD_THRESHOLDrr )r allow_offloadrrmsg_sizes` ` r to_framesrs-]- s444 r>>X(999 ,,,,,,,, , :<<cKdfd}|r+r)tr"ttt|r*r(tr!tkrt |d{V}n |}|S)z< Unserialize a list of Distributed protocol frames. Fc tjS#t$r)dkrd}n}td|wxYw)N) deserialize deserializersiz[too large to display]z$truncated data stream (%d bytes): %s)rloadsEOFErrorrerror)datastrr!r"framessizes r _from_framesz!from_frames.._from_frames;st >K}    d{{2  LL?w O O O  s 3A N)rsummapr r )r'r!r"rr)resr(s``` @r from_framesr-5s D        (():(3vv&&''):tFW?W?WL))))))))lnn Jrct|jstd|dfd}|tj}|s|tj}|stdd|DS)zA Get all bound addresses of a started Tornado TCPServer. z TCP Server z not started yet?cVg}D]"}|j|kr||#|SN)familyappend)famsockssocksocketss r_look_for_familyz2get_tcp_server_addresses.._look_for_family[s< # #D{c!! T""" rz'No Internet socket found on TCPServer??c6g|]}|S) getsockname).0r5s r z,get_tcp_server_addresses..js$ 1 1 14D     1 1 1r)r _socketsvalues RuntimeErrorsocketAF_INETAF_INET6) tcp_serverr7r4r6s @rget_tcp_server_addressesrDSs:&--//00G JHHHHIII  V^ , ,E 2  11 FDEEE 1 15 1 1 11rc,t|dS)zE Get the first bound address of a started Tornado TCPServer. r)rD)rCs rget_tcp_server_addressrFms $J / / 22rcZ|dvr|p tS|dkr|p tS|S)zm Ensure the given host string (or IP) denotes a concrete host, not a wildcard listening address. )z0.0.0.0z::)rr)host default_hosts rensure_concrete_hostrKts;  'vxx' )xzz) r)T)TNTr0) __future__rloggingr@dask dask.utilsr distributedrdistributed.sizeofrdistributed.utilsrrr r getLogger__name__rconfiggetr isinstancestrrr-rDrFrKr9rrrYsD"""""" """""" ******????????????  8 $ $KOO$>?? :%%7# $566 ><2224333      r