є ▀№┌\c@`sюddlmZmZmZddlZddlZddlmZmZdZ dДddd d dgDГZ y-ejejdГd e e Нe e d s tstrtbintarraytmaptextttrawsutf-8tencodingcC`s°|s |Sttt|ГГ|kr)|Sg}x┬|D]║}t|Г|krуt|ttfГrrt|Г}ny |j}Wntk rШd}nXxTt dt|Г|||ГD]"}|j |||||!Гq║Wq6|j |Гq6W|S(s Split a list of frames into a list of frames of maximum size This helps us to avoid passing around very large bytestrings. Examples -------- >>> frame_split_size([b'12345', b'678'], n=3) # doctest: +SKIP [b'123', b'45', b'678'] ii(tmaxR Rt isinstancetbytest bytearrayt memoryviewtitemsizetAttributeErrortrangetappend(tframestntouttframeRti((s9lib/python2.7/site-packages/distributed/protocol/utils.pytframe_split_sizes" '#cC`sQt|dГ}|s|St|Гttt|ГГksAtВtdДt||ГDГГrd|S|dddЕ}|dddЕ}g}x║|rL|jГ}g}x||r)|jГ}t|Г|krЄ|j|Г|t|Г8}qоt |Г}|j|| Г|j||Гd}qоW|jdj tt|ГГГqУW|S(s╪ Merge frames into original lengths Examples -------- >>> merge_frames({'lengths': [3, 3]}, [b'123456']) [b'123', b'456'] >>> merge_frames({'lengths': [6]}, [b'123', b'456']) [b'123456'] tlengthscs`s'|]\}}t|Г|kVqdS(N(tlen(Rtftl((s9lib/python2.7/site-packages/distributed/protocol/utils.pys IsNi iR(tlisttsumR RtAssertionErrortalltziptpopRRtjoinR(theaderRRRR!tLRtmv((s9lib/python2.7/site-packages/distributed/protocol/utils.pytmerge_frames8s. ' #cC`spg|D]}t|Г^q}tjdt|ГГgg|D]}tjdt|ГГ^q>}dj|ГS(NtQR(RtstructtpackRR((RR RR((s9lib/python2.7/site-packages/distributed/protocol/utils.pytpack_frames_preludeas,cC`s>t|Гg}t|tГs-t|Г}ndj||ГS(sв Pack frames into a byte-like object This prepends length information to the front of the bytes-like object See Also -------- unpack_frames R(R0RR"R((Rtprelude((s9lib/python2.7/site-packages/distributed/protocol/utils.pytpack_framesis cC`sЬtjd|d Г\}g}d|d}xht|ГD]Z}tjd||dd|dd!Г\}||||!}|j|Г||7}q:W|S(s─ Unpack bytes into a sequence of frames This assumes that length information is at the front of the bytestring, as performed by pack_frames See Also -------- pack_frames R-iii(R.tunpackRR(tbtn_framesRtstartRtlengthR((s9lib/python2.7/site-packages/distributed/protocol/utils.pyt unpack_frameszs , i(t __future__RRRR.tmsgpacktutilsRRtBIG_BYTES_SHARD_SIZEtmsgpack_optstloadstdumpstFalset TypeErrorRR,R0R2R8(((s9lib/python2.7/site-packages/distributed/protocol/utils.pyts ! )