σ ίόΪ\c@`sMddlmZmZmZddlmZddlZddlZddlm Z ddl m Z ddl m Z mZddlmZmZmZejeƒZd dZyed d d dƒZWn ek rκed d ƒZnXe eejƒd„Ze jdddd„ƒZe jedd„ƒZd„Z d„Z!dS(i(tprint_functiontdivisiontabsolute_import(tThreadPoolExecutorN(tgeni(tprotocol(tfinalizetPY3(tget_iptget_ipv6tnbytesi it max_workersitthread_name_prefixs Dask-OffloadcO`stj|||ŽS(N(t_offload_executortsubmit(tfntargstkwargs((s5lib/python2.7/site-packages/distributed/comm/utils.pytoffloadstmessagec#`sJ‡‡‡‡fd†}tr.t|ƒV}n |ƒ}tj|ƒ‚dS(sI Serialize a message into a list of Distributed protocol frames. c `scy)ttjˆdˆdˆdˆƒƒSWn3tk r^}tjdˆƒtj|ƒ‚nXdS(Nt serializerston_errortcontextsUnserializable Message: %s(tlistRtdumpst Exceptiontloggertinfot exception(te(RtmsgRR(s5lib/python2.7/site-packages/distributed/comm/utils.pyt _to_frames)s  N(RRRtReturn(RRRRRtres((RRRRs5lib/python2.7/site-packages/distributed/comm/utils.pyt to_frames#s   c#`sktttˆƒƒ‰‡‡‡‡fd†}ˆrOˆtkrOt|ƒV}n |ƒ}tj|ƒ‚dS(s< Unserialize a list of Distributed protocol frames. c`sfytjˆdˆdˆƒSWnBtk raˆdkrBd}nˆ}tjdˆ|ƒ‚nXdS(Nt deserializet deserializersiθs[too large to display]s$truncated data stream (%d bytes): %s(RtloadstEOFErrorRterror(tdatastr(R#R$tframestsize(s5lib/python2.7/site-packages/distributed/comm/utils.pyt _from_framesDs   N(tsumtmapR tFRAME_OFFLOAD_THRESHOLDRRR (R)R#R$R+R!((R#R$R)R*s5lib/python2.7/site-packages/distributed/comm/utils.pyt from_frames=s  c`s’t|jjƒƒ‰ˆs1td|fƒ‚n‡fd†}|tjƒ}|dkrm|tjƒ}n|dkrˆtdƒ‚n|jƒS(s? Get the bound address of a started Tornado TCPServer. sTCP Server %r not started yet?c`s(x!ˆD]}|j|kr|SqWdS(N(tfamilytNone(tfamtsock(tsockets(s5lib/python2.7/site-packages/distributed/comm/utils.pyt_look_for_familybs s'No Internet socket found on TCPServer??N( Rt_socketstvaluest RuntimeErrortsockettAF_INETR1tAF_INET6t getsockname(t tcp_serverR5R3((R4s5lib/python2.7/site-packages/distributed/comm/utils.pytget_tcp_server_addressZs  cC`s.|dkrtƒS|dkr&tƒS|SdS(sm Ensure the given host string (or IP) denotes a concrete host, not a wildcard listening address. s0.0.0.0ts::N(s0.0.0.0R?(RR (thost((s5lib/python2.7/site-packages/distributed/comm/utils.pytensure_concrete_hostss   i("t __future__RRRtconcurrent.futuresRtloggingR9ttornadoRR?Rt compatibilityRRtutilsRR R t getLoggert__name__RR.R t TypeErrortshutdownRt coroutineR1R"tTrueR/R>RA(((s5lib/python2.7/site-packages/distributed/comm/utils.pyts,