Ë
|
ñúh~ ã ó d Z ddlZddlZddlmZ eed« rddlmZ ddlm Z dZ
|
G d d « Z n dd
|
l m Z d Z
|
d Zd dl mZmZmZmZmZ d dlmZmZ dZd ZdZdZdZd ZdZ dZ dZ dZ dZ e!e"fdZ#d Z$d Z%dZ&i dd e&e fddde fd dd e fd dd e fd dd!e fd"dd#e fd$d%d&d'd(d e&fd)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d d8e fdd9e fdd:e fd;d<e fd=d>e fd e&e fdde fdd e fddefdd efdde fdd e fd? ¥Z' G d@ dA« Z( G dB dC« Z)y)Dz.Fallback pure Python implementation of msgpacké N)ÚdatetimeÚpypy_version_info)Ú newlist_hint)Ú BytesBuilderTc ó e Zd ZddZd Zd Zy)ÚBytesIOc ó |r5t t |« « | _ | j j |« y t « | _ y ©N)r ÚlenÚbuilderÚappend©ÚselfÚss úOH:\Change_password\venv_build\Lib\site-packages\pip/_vendor/msgpack/fallback.pyÚ__init__zBytesIO.__init__ s0 ÙÜ +¬C°«FÓ 3 Ø ×#Ñ# AÕ&ä +~ ó c ó² t |t « r|j « }nt |t « r t |« }| j
|
j |« y r
|
)Ú
|
isinstanceÚ
|
memoryviewÚtobytesÚ bytearrayÚbytesr r r s r Úwritez BytesIO.write s< Ü!ZÔ(ØIIKÜAyÔ)Ü!HØ LL× Ñ Õ "r c ó6 | j j « S r
|
)r Úbuild©r s r ÚgetvaluezBytesIO.getvalue s Ø<<×%Ñ%Ó'Ð 'r N)r )Ú__name__Ú
|
__module__Ú __qualname__r r r © r r r r s ó .ò #ó (r r )r Fc ó g S r
|
r" )Úsizes r r r $ s Ø r é )Ú
|
BufferFullÚ ExtraDataÚ FormatErrorÚ OutOfDataÚ
|
StackError)ÚExtTypeÚ Timestampé é é é iÿ c ó> ||« |u r
|
|| « |v S || « |u S r
|
r" )ÚobjÚtÚtypeÚtuples r Ú_check_type_strictr6 : s* Ù Aw%ÑÙCyA~Ð áCyA~Ð r c óP t | « }|j dk7 r t d« |S )Nr% z$cannot unpack from multi-byte object)r ÚitemsizeÚ
|
ValueError)r2 Úviews r Ú_get_data_from_bufferr; A s( Ü c?DØ }}ÒÜÐ?Ó@Ð@Ø Kr c ó t ddt | « i|¤}|j | « |j « }|j « rt ||j « « |S # t $ r t d« t $ r t w xY w)aw
|
Unpack an object from `packed`.
|
|
Raises ``ExtraData`` when *packed* contains extra bytes.
|
Raises ``ValueError`` when *packed* is incomplete.
|
Raises ``FormatError`` when *packed* is not valid msgpack.
|
Raises ``StackError`` when *packed* contains too nested.
|
Other exceptions can be raised during unpacking.
|
|
See :class:`Unpacker` for options.
|
Úmax_buffer_sizez Unpack failed: incomplete inputr
|
) ÚUnpackerr ÚfeedÚ_unpackr) r9 ÚRecursionErrorr* Ú_got_extradatar' Ú_get_extradata)ÚpackedÚkwargsÚunpackerÚrets r ÚunpackbrH H s ô ÑD¬c°&«kÐD¸VÑDHØ MM&ÔðØ× Ñ Ó ð
|
× Ñ Ô ÜX× 4Ñ 4Ó 6Ó7Ð7Ø Jøô ò <ÜÐ:Ó;Ð;Ü ò ÜÐðús ©A% Á%#BÚ éÄ éÅ ú>HéÆ ú>IéÇ ÚBbéÈ z>HbéÉ z>IbéÊ )r/ z>féË )é z>déÌ éÍ )r- rL éÎ )r/ rN éÏ )rU z>QéÐ )r% ÚbéÑ )r- z>héÒ )r/ z>iéÓ )rU z>qéÔ Úb1sÚb2sÚb4srU Úb8sé Úb16s) éÕ éÖ é× éØ éÙ éÚ éÛ éÜ éÝ éÞ éß c óª e Zd ZdZ dddddddddddeddddddd Zd
|
Zd Zd Zd Z d Z
|
ddZ ddZ d Z efdZd Zd ZeZd Zd Zd Zd Zd Zy) r> a Streaming unpacker.
|
|
Arguments:
|
|
:param file_like:
|
File-like object having `.read(n)` method.
|
If specified, unpacker reads serialized data from it and `.feed()` is not usable.
|
|
:param int read_size:
|
Used as `file_like.read(read_size)`. (default: `min(16*1024, max_buffer_size)`)
|
|
:param bool use_list:
|
If true, unpack msgpack array to Python list.
|
Otherwise, unpack to Python tuple. (default: True)
|
|
:param bool raw:
|
If true, unpack msgpack raw to Python bytes.
|
Otherwise, unpack to Python str by decoding with UTF-8 encoding (default).
|
|
:param int timestamp:
|
Control how timestamp type is unpacked:
|
|
0 - Timestamp
|
1 - float (Seconds from the EPOCH)
|
2 - int (Nanoseconds from the EPOCH)
|
3 - datetime.datetime (UTC).
|
|
:param bool strict_map_key:
|
If true (default), only str or bytes are accepted for map (dict) keys.
|
|
:param object_hook:
|
When specified, it should be callable.
|
Unpacker calls it with a dict argument after unpacking msgpack map.
|
(See also simplejson)
|
|
:param object_pairs_hook:
|
When specified, it should be callable.
|
Unpacker calls it with a list of key-value pairs after unpacking msgpack map.
|
(See also simplejson)
|
|
:param str unicode_errors:
|
The error handler for decoding unicode. (default: 'strict')
|
This option should be used only when you have msgpack data which
|
contains invalid UTF-8 string.
|
|
:param int max_buffer_size:
|
Limits size of data waiting unpacked. 0 means 2**32-1.
|
The default value is 100*1024*1024 (100MiB).
|
Raises `BufferFull` exception when it is insufficient.
|
You should set this parameter when unpacking data from untrusted source.
|
|
:param int max_str_len:
|
Deprecated, use *max_buffer_size* instead.
|
Limits max length of str. (default: max_buffer_size)
|
|
:param int max_bin_len:
|
Deprecated, use *max_buffer_size* instead.
|
Limits max length of bin. (default: max_buffer_size)
|
|
:param int max_array_len:
|
Limits max length of array.
|
(default: max_buffer_size)
|
|
:param int max_map_len:
|
Limits max length of map.
|
(default: max_buffer_size//2)
|
|
:param int max_ext_len:
|
Deprecated, use *max_buffer_size* instead.
|
Limits max size of ext type. (default: max_buffer_size)
|
|
Example of streaming deserialize from file-like object::
|
|
unpacker = Unpacker(file_like)
|
for o in unpacker:
|
process(o)
|
|
Example of streaming deserialize from socket::
|
|
unpacker = Unpacker()
|
while True:
|
buf = sock.recv(1024**2)
|
if not buf:
|
break
|
unpacker.feed(buf)
|
for o in unpacker:
|
process(o)
|
|
Raises ``ExtraData`` when *packed* contains extra bytes.
|
Raises ``OutOfData`` when *packed* is incomplete.
|
Raises ``FormatError`` when *packed* is not valid msgpack.
|
Raises ``StackError`` when *packed* contains too nested.
|
Other exceptions can be raised during unpacking.
|
Nr TFi @éÿÿÿÿ)Ú read_sizeÚuse_listÚrawÚ timestampÚstrict_map_keyÚ object_hookÚobject_pairs_hookÚ list_hookÚunicode_errorsr= Úext_hookÚ max_str_lenÚ max_bin_lenÚ max_array_lenÚ max_map_lenÚ max_ext_lenc ó |
|
d}
|
|d| _ n.t |j « s t d« || _ d| _ t « | _ d| _ d| _ | sd} | dk( r| } |dk( r| }|dk( r| }|dk( r| dz }|dk( r| }| | _ || j kD r t d « |xs t | j d
|
« | _ t |« | _ t |« | _ |
|
| _ || _ d|cxk rd k st d « t d « || _ | | _ || _ || _ | | _ | | _ || _ || _ || _ || _ d| _ | t | « s t d « |t |« s t d« |t |« s t d« | | t d« t | « s t d« y )NÚstrictTz!`file_like.read` must be callableFr iÿÿÿrr r- z.read_size must be smaller than max_buffer_sizei @ r. ztimestamp must be 0..3z`list_hook` is not callablez `object_hook` is not callablez#`object_pairs_hook` is not callablez8object_pairs_hook and object_hook are mutually exclusivez`ext_hook` is not callable) Ú_feedingÚcallableÚreadÚ TypeErrorÚ file_liker Ú_bufferÚ_buff_iÚ_buf_checkpointÚ_max_buffer_sizer9 ÚminÚ
|
_read_sizeÚboolÚ_rawÚ_strict_map_keyÚ_unicode_errorsÚ _use_listÚ
|
_timestampÚ
|
_list_hookÚ _object_hookÚ_object_pairs_hookÚ _ext_hookÚ _max_str_lenÚ _max_bin_lenÚ_max_array_lenÚ _max_map_lenÚ _max_ext_lenÚ_stream_offset)r r rs rt ru rv rw rx ry rz r{ r= r| r} r~ r r r s r r zUnpacker.__init__â s
|
ð* Ð !Ø %Nà Ð Ø DMäINNÔ+Ü Ð CÓDÐDØ &DNØ !DMô !{ à ð !Ô á Ø 'OØ "Ò Ø)KØ "Ò Ø)KØ BÒ Ø +MØ "Ò Ø)¨QÑ.KØ "Ò Ø)Kà /Ô Ø t×,Ñ,Ò ,Ü Ð MÓNÐ NØ#ÒL¤s¨4×+@Ñ+@À)Ó'LÜI Ü # NÓ 3Ô Ø -Ô Ø!ØYÔ# !Ò#Ü Ð 5Ó6Ð 6ð $Ü Ð 5Ó6Ð 6Ø#Ø#Ø 'ÔØ"3Ô Ø!Ø 'ÔØ 'ÔØ +ÔØ 'ÔØ 'ÔØ Ôà Ð ¬°)Ô)<ÜÐ 9Ó:Ð :Ø Ð "¬8°KÔ+@ÜÐ ;Ó<Ð <Ø Ð (´Ð:KÔ1LÜÐ AÓBÐ BØ Ð "Ð'8Ð'DÜÐ VÓWÐ WÜÔ!ÜÐ 8Ó9Ð 9ð "r c óª | j sJ t |« }t | j « | j z
|
t |« z | j
|
kD rt | j dkD r?| j d | j
= | xj | j z c_ d| _ | j j |« |j « y ©Nr )
|
r r; r r r r r& r ÚextendÚrelease)r Ú
|
next_bytesr: s r r? z Unpacker.feed> s¨ Ø}}Ð }Ü$ ZÓ0Ü t||Ó t||Ñ +¬c°$«iÑ 7¸$×:OÑ:OÒ OÜ Ð ð × Ñ !Ò #Ø Ð 3t× 3Ñ 3Ð 3Ð4Ø LLD× 0Ñ 0Ñ 0LØ#$DÔ ð ×ÑDÔ!Ø r c ó~ | xj | j | j z
|
z c_ | j | _ y)z)Gets rid of the used parts of the buffer.N)r r r r s r Ú_consumezUnpacker._consumeN s. à ×Òt||¨d×.BÑ.BÑ BÑBÕØ #||Õ r c óF | j t | j « k S r
|
)r r r r s r rB zUnpacker._got_extradataS s Ø||c $§,¡,Ó /Ñ/Ð/r c ó4 | j | j d S r
|
)r r r s r rC zUnpacker._get_extradataV s Ø||DLLNÐ+Ð+r c óL | j |d¬« }| j « |S )NF©Úraise_outofdata)Ú_readr¥ ©r ÚnrG s r Ú
|
read_byteszUnpacker.read_bytesY s" Øjj¨EjÓ2Ø Ø
|
r c ó | j ||¬« | j }| j |||z }|t |« z | _ |S )Nr© )Ú_reserver r r )r r rª ÚirG s r r« zUnpacker._read^ sC à a¨ Ô9Ø LLØll1q 1uÐ%Ø3s8| Ø
|
r c óê t | j « | j z
|
|z
|
}|dk\ ry | j r| j | _ t
|
| j dkD r?| j d | j
= | xj | j z c_ d| _ | }|t | j « z | j kD rt |dkD rot | j |« }| j j |« }|sn;t |t « sJ | xj |z c_ |t |« z }|dkD rot | j « || j z k r|r d| _ t
|
y y r )r r r r r r) r r& Úmaxr r r r r )r r rª Ú remain_bytesÚ to_read_bytesÚ read_datas r r° zUnpacker._reservef sN Ü4<<Ó(¨4¯<©<Ñ7¸!Ñ; ð 1Ò Ø à ==Ø ×/Ñ/DLÜOð × Ñ !Ò #Ø Ð 3t× 3Ñ 3Ð 3Ð4Ø LLD× 0Ñ 0Ñ 0LØ#$DÔ ð %} Ø #dllÓ+Ñ +¨d×.CÑ.CÒ CÜ Ð ØQÒ Ü §¡° Ó >MØ ×+Ñ+¨MÓ:IÙ ØÜ i¬Ô/Ð /Ð/Ø LLIÑ %LØ C NÑ *Lð QÓ ô t||Ó q 4§<¡<Ñ /Ò /±OØ DLÜOð 5DÐ /r c ó< t }d}d }| j d« | j | j }| xj dz c_ |dz dk( r|}nÃ|dz dk( r
|
d|dz z
|
}n±|dz dk( rH|dz }t }|| j
|
kD rt | d | j
|
d
|
« | j |« }na|d z d k( r6|d z }t }|| j kD r>t | d| j d
|
« |d z dk( r6|d z }t }|| j kD r t | d| j d
|
« |dk( rd }nÜ|dk( rd}nÓ|dk( rd}nÊd|cxk rdk rÉn nÆt | \ }}}| j |« t |« dkD r/t j || j | j « d }n| j | j }| xj |z c_ || j kD rt | d| j d
|
« | j |« }nöd|cxk rdk r¡n nt | \ }}}| j |« t j || j | j « \ }}| xj |z c_ || j" kD rt | d| j" d
|
« | j |« }nJd|cxk rd k rn nt | \ }}| j |« t |« dkD r/t j || j | j « d }n| j | j }| xj |z c_ n²d |cxk rd k rn nt | \ }}}| j" |k rt | d| j" d
|
« | j |dz « t j || j | j « \ }}| xj |dz z c_ nd |cxk rd k rÈn nÅt | \ }}}| j |« t |« dkD r.t j || j | j « \ }n| j | j }| xj |z c_ || j
|
kD rt | d | j
|
d
|
« | j |« }n>d!|cxk rd"k rn nt | \ }}}| j |« t j || j | j « \ }| xj |z c_ || j kD rÁt | d| j d
|
« d#|cxk rd$k rn nt | \ }}}| j |« t j || j | j « \ }| xj |z c_ || j kD r)t | d| j d
|
« t% d%|z « |||fS )&Nr r% é éà rr éÿ é é z exceeds max_str_len(ú)éð é é z exceeds max_array_len(z exceeds max_map_len(éÀ é Féà TrJ rM z exceeds max_bin_len(rO rR z exceeds max_ext_len(rS r^ r_ ri rj rl rm rn ro rp zUnknown header: 0x%x)ÚTYPE_IMMEDIATEr° r r ÚTYPE_RAWr r9 r« Ú
|
TYPE_ARRAYr ÚTYPE_MAPr Ú_MSGPACK_HEADERSr ÚstructÚ unpack_fromr r r( )r Útypr r2 r[ r$ ÚfmtÚLs r Ú _read_headerzUnpacker._read_header s
Ü Ø ØØ aÔØ LL Ñ &Ø Ñ Ø z>QÒ ØCØ ^zÒ )ØD/CØ ^zÒ )ØJAÜCØ4×$Ñ$Ò$Ü A 3Ð&;¸D×<MÑ<MÐ;NÈaÐ!PÓQÐQØ**Q-CØ ^zÒ )ØJAÜ CØ4×&Ñ&Ó&Ü A 3Ð&=¸d×>QÑ>QÐ=RÐRSÐ!TÓUÐUØ ^zÒ )ØJAÜCØ4×$Ñ$Ó$Ü A 3Ð&;¸D×<MÑ<MÐ;NÈaÐ!PÓQÐQØ $YØCØ $YØCØ $YØCØ QÔ $Õ Ü -¨aÑ 0ND#sØ MM$Ô Ü3x!|Ü×&Ñ& s¨D¯L©L¸$¿,¹,ÓGÈÑJàLL § ¡ Ñ.Ø LLDÑ LØ4×$Ñ$Ò$Ü A 3Ð&;¸D×<MÑ<MÐ;NÈaÐ!PÓQÐQØ**Q-CØ QÔ $Õ Ü -¨aÑ 0ND#sØ MM$Ô Ü×%Ñ% c¨4¯<©<¸¿ ¹ ÓFDAqØ LLDÑ LØ4×$Ñ$Ò$Ü A 3Ð&;¸D×<MÑ<MÐ;NÈaÐ!PÓQÐQØ**Q-CØ QÔ $Õ Ü(¨Ñ+ID#Ø MM$Ô Ü3x!|Ü ×(Ñ(¨¨d¯l©l¸D¿L¹LÓIÈ!ÑLàll 4§<¡<Ñ0Ø LLDÑ LØ QÔ $Õ Ü -¨aÑ 0ND#sØ× Ñ 4Ò'Ü D 6Ð)>¸t×?PÑ?PÐ>QÐQRÐ!SÓTÐTØ MM$ (Ô #Ü×'Ñ'¨¨T¯\©\¸4¿<¹<ÓHFAsØ LLD 1HÑ $LØ QÔ $Õ Ü -¨aÑ 0ND#sØ MM$Ô Ü3x!|Ü ×)Ñ)¨#¨t¯|©|¸T¿\¹\ÓJàLL § ¡ Ñ.Ø LLDÑ LØ4×$Ñ$Ò$Ü A 3Ð&;¸D×<MÑ<MÐ;NÈaÐ!PÓQÐQØ**Q-CØ QÔ $Õ Ü -¨aÑ 0ND#sØ MM$Ô Ü×%Ñ% c¨4¯<©<¸¿ ¹ ÓFDQØ LLDÑ LØ4×&Ñ&Ò&Ü A 3Ð&=¸d×>QÑ>QÐ=RÐRSÐ!TÓUÐUØ QÔ $Õ Ü -¨aÑ 0ND#sØ MM$Ô Ü×%Ñ% c¨4¯<©<¸¿ ¹ ÓFDQØ LLDÑ LØ4×$Ñ$Ò$Ü A 3Ð&;¸D×<MÑ<MÐ;NÈaÐ!PÓQÐQä Ð 4°qÑ 8Ó9Ð 9ØAs{Ðr c ó® j « \ }}}|t k( r|t k7 r t d« |S |t k( r|t
|
k7 r t d« |S |t k( r¤|t k( r&t |« D ] } j t « y t |« }t |« D ]& }|j j t « « ( j j |« } j r|S t |« S |t
|
k( r;|t k( r;t |« D ], } j t « j t « . y j % j fdt |« D « « }|S i }t |« D ] } j t « } j r7t# |« t$ t& fvr t dt% t# |« « z « t) |t$ « rt+ j, |« } j t « ||< j. j/ |« }|S |t k( ry |t0 k( r7 j2 r t' |« }|S |j5 d j6 « }|S |t8 k( r t' |« S |t: k( r|dk( r}t= j> t' |« « } j@ dk( r| jC « S j@ dk( r| jE « S j@ d k( r| jG « S | S jI |t' |« « S |tJ k( sJ |S )
|
NzExpected arrayz Expected mapc 3 ór K | ]. }j t « j t « f 0 y wr
|
)r@ Ú EX_CONSTRUCT)Ú.0Ú_r s r ú <genexpr>z#Unpacker._unpack.<locals>.<genexpr> s- øè ø ò .ØQRT\\¤,Ó/°· ± ¼lÓ1KÔLñ.ùs 47z %s is not allowed for map keyÚutf_8rr r% r- r. )&rÎ ÚEX_READ_ARRAY_HEADERrÆ r9 ÚEX_READ_MAP_HEADERrÇ ÚEX_SKIPÚranger@ r r rÑ r r r5 r r r4 Ústrr r ÚsysÚinternr rÅ r Údecoder ÚTYPE_BINÚTYPE_EXTr, Ú
|
from_bytesr Úto_unixÚ to_unix_nanoÚ to_datetimer rÄ )
|
r ÚexecuterË r r2 r± rG rÓ ÚkeyÚtss
|
` r r@ zUnpacker._unpackè sö ø Ø×'Ñ'Ó) Qà Ô*Ò *ØjÒ Ü Ð!1Ó2Ð2ØHØ Ô(Ò (ØhÜ Ó0Ð0ØHà *Ò Ø'Ò!Ü qò *AàLL¤Õ)ð*ð Ü q/CÜ1Xò 7Ø
|
|
4<<¬ Ó5Õ6ð 7àÐ*Øoo cÓ*à ..3Ð 8¬e°C«jÐ 8Ø (?Ø'Ò!Ü qò *AàLL¤Ô)ØLL¤Õ)ð*ð Ø×&Ñ&Ð2Ø×-Ñ-ó .ÜV[Ð\]ÓV^ô.ó ð Jð Ü qò :AØ ,,¤|Ó4CØ×+Ò+´°S³ Ä#ÄuÀ Ñ0MÜ (Ð)HÌ3ÌtÐTWËyË>Ñ)YÓ ZÐZÜ! #¤sÔ+Ü !jj¨oØ #||¬LÓ 9CHð :ð ×$Ñ$Ð0Ø ×+Ñ+¨CÓ0CØJØ gÒ Ø Ø (?ØyyÜCjð Jð jj ¨$×*>Ñ*>Ó?ØJØ (?Ü:Ð Ø (?ØBwÜ ×)Ñ)¬%°«*Ó5Ø?? aÒ'Ø ::<Ð'Ø__¨Ò)Ø ??Ó,Ð,Ø__¨Ò)Ø >>Ó+Ð+à Ià~~ a¬¨s«Ó4Ð4ØnÒ$Ð$Ð$Ø
|
r c ó | S r
|
r" r s r Ú__iter__zUnpacker.__iter__2 s Ø r c ó´ | j t « }| j « |S # t $ r | j « t t
|
$ r t w xY wr
|
)r@ rÑ r¥ r) Ú StopIterationrA r* ©r rG s r Ú__next__zUnpacker.__next__5 sO ð Ø,,|Ó,CØ MMOØJøÜò Ø MMOÜ Ð Ü ò Ü Ð ð ús &) ©.Ac óN | j t « | j « y r
|
)r@ rØ r¥ r s r Úskipz Unpacker.skipB s Ø WÔ Ø r c óx | j t « }| j « |S # t $ r t w xY wr
|
)r@ rÑ rA r* r¥ rë s r ÚunpackzUnpacker.unpackF s< ð Ø,,|Ó,Cð Ø
|
øô ò Ü Ð ð ús ) ©9c óP | j t « }| j « |S r
|
)r@ rÖ r¥ rë s r Úread_array_headerzUnpacker.read_array_headerN s ØllÔ/Ó0Ø Ø
|
r c óP | j t « }| j « |S r
|
)r@ r× r¥ rë s r Úread_map_headerzUnpacker.read_map_headerS s ØllÔ-Ó.Ø Ø
|
r c ó | j S r
|
)r r s r Útellz Unpacker.tellX s Ø×"Ñ"Ð"r r
|
)T)r r r! Ú__doc__r+ r r? r¥ rB rC r® r« r° rÎ rÑ r@ rè rì Únextrî rð rò rô rö r" r r r> r> s® ñ]ðB ðZ:ð ØØ ØØØØ ØØØ)ØØØØØØô'Z:òxò ,ò
|
0ò,òó
|
ó òD^ð@ +ó HòTò ð Dòòòò
|
ó
|
#r r> c ó e Zd ZdZddddddddddZeeefdZd Z d Z
|
d
|
Z d Z d Z d Zd ZefdZd Zd Zd Zd Zd Zy)ÚPackeraÐ
|
MessagePack Packer
|
|
Usage::
|
|
packer = Packer()
|
astream.write(packer.pack(a))
|
astream.write(packer.pack(b))
|
|
Packer's constructor has some keyword arguments:
|
|
:param default:
|
When specified, it should be callable.
|
Convert user type to builtin type that Packer supports.
|
See also simplejson's document.
|
|
:param bool use_single_float:
|
Use single precision float type for float. (default: False)
|
|
:param bool autoreset:
|
Reset buffer after each pack and return its content as `bytes`. (default: True).
|
If set this to false, use `bytes()` to get content and `.reset()` to clear buffer.
|
|
:param bool use_bin_type:
|
Use bin type introduced in msgpack spec 2.0 for bytes.
|
It also enables str8 type for unicode. (default: True)
|
|
:param bool strict_types:
|
If set to true, types will be checked to be exact. Derived classes
|
from serializable types will not be serialized and will be
|
treated as unsupported type and forwarded to default.
|
Additionally tuples will not be serialized as lists.
|
This is useful when trying to implement accurate serialization
|
for python types.
|
|
:param bool datetime:
|
If set to true, datetime with tzinfo is packed into Timestamp type.
|
Note that the tzinfo is stripped in the timestamp.
|
You can get UTC datetime with `timestamp=3` option of the Unpacker.
|
|
:param str unicode_errors:
|
The error handler for encoding unicode. (default: 'strict')
|
DO NOT USE THIS!! This option is kept for very specific usage.
|
|
:param int buf_size:
|
Internal buffer size. This option is used only for C implementation.
|
NFT)ÚdefaultÚuse_single_floatÚ autoresetÚ use_bin_typeÚ strict_typesr r{ Úbuf_sizec óÎ || _ || _ || _ || _ t « | _ t |« | _ |xs d| _ |t |« s t d« || _ y )Nr zdefault must be callable) Ú _strict_typesÚ
|
_use_floatÚ
|
_autoresetÚ _use_bin_typer r r Ú _datetimer r
r Ú_default) r rû rü rý rþ rÿ r r{ r s r r zPacker.__init__ sc ð *ÔØ*Ø#Ø )ÔÜ y Ü h Ø -Ò 9°Ô Ø Ð ¤x°Ô'8ÜÐ 6Ó7Ð 7Ø r c ó$ d}| j r |}t }n t t f} |dk r t d« || j j d« S ||t « r8|r| j j d« S | j j d« S ||t « rd|cxk rdk r2n n/| j j t j d |« « S d
|
|cxk rdk r2n n/| j j t j d |« « S d|cxk rd k r3n n0| j j t j d d|« « S d|cxk rdk r3n n0| j j t j dd|« « S d |cxk rdk r3n n0| j j t j dd|« « S d|cxk rdk r3n n0| j j t j dd|« « S d|cxk rdk r3n n0| j j t j dd|« « S d|cxk rdk r3n n0| j j t j d d |« « S d|cxk rd k r3n n0| j j t j d d |« « S d!|cxk rdk r3n n0| j j t j d"d#|« « S |s!| j | j |« }d}t d$« ||t t f« r]t |« }|d%k\ r!t d&t |« j z « | j# |« | j j |« S ||t$ « rc|j' d'| j( « }t |« }|d%k\ r t d(« | j+ |« | j j |« S ||t, « rH|j. }|d%k\ r t d)« | j# |« | j j |« S ||t0 « rl| j2 r0| j j t j d*d+|« « S | j j t j d,d-|« « S ||t4 t6 f« rô ||t6 « rd.}|j9 « } n|j: }|j< } t? |t « sJ t? | t « sJ t | « }
|
|
|
d/k( r | j j d0« n |
|
d1k( r | j j d2« nÿ|
|
d3k( r | j j d4« nÞ|
|
d5k( r | j j d6« n½|
|
d7k( r | j j d8« n|
|
d k r1| j j t j d9d:|
|
« « nf|
|
dk r1| j j t j dd;|
|
« « n0| j j t j dd<|
|
« « | j j t j d |« « | j j | « y |||« rEt |« }| jA |« tC |« D ] } | jE || |d/z
|
« y ||tF « r-| jI t |« |jK « |d/z
|
« S | jL r2 ||tN « r%|jP t7 jR |« }d/}|s!| j | j |« }d/}¸| jL r ||tN « rt d=|d>« tU d=|« )?NFTr zrecursion limit exceededó Àó Ãó Âr¸ ÚBiàÿÿÿr[ rº ÚBBrV iÿÿÿz>BbrZ éÿÿ ú>BHrW i ÿÿz>Bhr\ ì ÿÿ ú>BIrX i z>Bir] l ÿÿÿÿ z>BQrY lûÿÿÿ z>Bqr^ zInteger value out of rangeì z%s is too largezutf-8zString is too largezMemoryview is too largez>BfrS z>BdrT rr r% ó Ôr- ó Õr/ ó ÖrU ó ×rd ó Øú>BBrO rQ rR zCannot serialize z where tzinfo=None)+r Úlistr5 r9 r r r ÚintrÉ Úpackr Ú OverflowErrorr r r r4 r Ú_pack_bin_headerrÚ Úencoder Ú_pack_raw_headerr ÚnbytesÚfloatr r+ r, Úto_bytesÚcodeÚdatar Ú_pack_array_headerrÙ Ú_packÚdictÚ_pack_map_pairsÚitemsr Ú _DateTimeÚtzinfoÚ from_datetimer ) r r2 Ú
|
nest_limitÚcheckÚcheck_type_strictÚ default_usedÚ
|
list_typesr r# r$ rÍ r± s r r& z Packer._pack¤ sr ð Ø × Ò Ø%EÜ Jä ¤ JØØA~Ü Ð!;Ó<Ð<Ø{Ø||×)Ñ)¨'Ó2Ð2ÙS$Ô ÙØ <<×-Ñ-¨gÓ6Ð6Ø||×)Ñ)¨'Ó2Ð2ÙS#Ø?d?Ø <<×-Ñ-¬f¯k©k¸#¸sÓ.CÓDÐDØCÔ# !Õ#Ø <<×-Ñ-¬f¯k©k¸#¸sÓ.CÓDÐDØ3Ô& $Õ&Ø <<×-Ñ-¬f¯k©k¸$ÀÀcÓ.JÓKÐKØCÔ# !Õ#Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLØ#Ô' Õ'Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLØcÔ) EÕ)Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLØCÔ- :Õ-Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLØ #Ô/¨Õ/Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLØ Ô9Ð'9Õ9Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLØ&¨#Ô;° Õ;Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLÙ#¨¯ © Ð(AØ --¨Ó,CØ#'LÙ Ü#Ð$@ÓAÐAÙS5¤)Ð,Ô-ÜHØ:Ü$Ð%6¼¸c»×9KÑ9KÑ%KÓLÐLØ×%Ñ% aÔ(Ø||×)Ñ)¨#Ó.Ð.ÙS#Øjj ¨$×*>Ñ*>Ó?ÜHØ:Ü$Ð%:Ó;Ð;Ø×%Ñ% aÔ(Ø||×)Ñ)¨#Ó.Ð.ÙS*Ô%ØJJØ:Ü$Ð%>Ó?Ð?Ø×%Ñ% aÔ(Ø||×)Ñ)¨#Ó.Ð.ÙS%Ô Ø??Ø <<×-Ñ-¬f¯k©k¸%ÀÀsÓ.KÓLÐLØ||×)Ñ)¬&¯+©+°e¸TÀ3Ó*GÓHÐHÙS7¤IÐ.Õ/ÙiÔ(Ø DØ <<>Dà 88DØ 88DÜ! $¬Ô,Ð,Ð,Ü! $¬Ô.Ð.Ð.ÜIØ6ØLL×&Ñ& wÖ/Ø!VØLL×&Ñ& wÕ/Ø!VØLL×&Ñ& wÕ/Ø!VØLL×&Ñ& wÕ/Ø"WØLL×&Ñ& wÕ/Ø$YØLL×&Ñ&¤v§{¡{°5¸$ÀÓ'BÕCØ&[ØLL×&Ñ&¤v§{¡{°5¸$ÀÓ'BÕCàLL×&Ñ&¤v§{¡{°5¸$ÀÓ'BÔCØ ×"Ñ"¤6§;¡;¨s°DÓ#9Ô:Ø ×"Ñ" 4Ô(ØÙS*Ô%ÜHØ×'Ñ'¨Ô*Ü qò 7AØJJs 1v z°A¡~Õ6ð7àÙS$Ô Ø×+Ñ+¬C°«H°c·i±i³kÀ:ÐPQÁ>ÓRÐRà~~¡%¨¬YÔ"7¸C¿J¹JÐ<RÜ ×-Ñ-¨cÓ2Ø Ùá D§M¡MÐ$=Ømm CÓ(Ø Ùà~~¡%¨¬YÔ"7Ü Ð#4°S°GÐ;MÐ!NÓOÐOäÐ /°¨wÐ 7Ó8Ð 8r c óÀ | j |« | j r+| j j « }t « | _ |S y # t « | _ xY wr
|
)r& r r r r )r r2 rG s r r z Packer.pack sS ð Ø JJsOð ??Ø,,×'Ñ'Ó)CÜ"9DLØJð øð Ü"9DLØ ús A Á A c ó¨ | j t |« |« | j r+| j j « }t « | _ |S y r
|
)r( r r r r r )r ÚpairsrG s r Úpack_map_pairszPacker.pack_map_pairs+ sB Ø × Ñ S Z¨Ô/Ø ??Ø,,×'Ñ'Ó)CÜ"9DLØJð r c óª |dk\ rt | j |« | j r+| j j « }t « | _ |S y ©Nr )r9 r% r r r r r¬ s r Úpack_array_headerzPacker.pack_array_header2 sI Ø :Ü Ð Ø × Ñ Ô"Ø ??Ø,,×'Ñ'Ó)CÜ"9DLØJð r c óª |dk\ rt | j |« | j r+| j j « }t « | _ |S y r7 )r9 Ú_pack_map_headerr r r r r¬ s r Úpack_map_headerzPacker.pack_map_header; sI Ø :Ü Ð Ø × Ñ aÔ Ø ??Ø,,×'Ñ'Ó)CÜ"9DLØJð r c ó t |t « s t d« d|cxk rdk st d« t d« t |t « s t d« t |« }|dkD r t d« |dk( r | j j d « n'|d
|
k( r | j j d « n|d k( r | j j d « nä|dk( r | j j d« nÃ|dk( r | j j d« n¢|dk r3| j j dt j d|« z « nj|dk r3| j j dt j d|« z « n2| j j dt j d|« z « | j j t j d|« « | j j |« y )Nz typecode must have int type.r é ztypecode should be 0-127zdata must have bytes typer zToo large datar% r r- r r/ r rU r rd r rº ó Çr r ó ÈrL ó ÉrN )
|
r r r r9 r r r r rÉ r )r Útypecoder$ rÍ s r Ú pack_ext_typezPacker.pack_ext_typeD s Ü(¤CÔ(ÜÐ :Ó;Ð ;ØHÔ# Ò#Ü Ð 7Ó8Ð 8ð $Ü Ð 7Ó8Ð 8Ü$¤Ô&ÜÐ 7Ó8Ð 8Ü IØ z>Ü Ð -Ó.Ð .Ø 6Ø LL× Ñ wÖ 'Ø !VØ LL× Ñ wÖ 'Ø !VØ LL× Ñ wÕ 'Ø !VØ LL× Ñ wÕ 'Ø "WØ LL× Ñ wÕ 'Ø $YØ LL× Ñ w¬¯©°S¸!Ó)<Ñ <Õ =Ø &[Ø LL× Ñ w¬¯©°T¸1Ó)=Ñ =Õ >à LL× Ñ w¬¯©°T¸1Ó)=Ñ =Ô >Ø ×Ñ6;; s¨HÓ5Ô6Ø ×Ñ4Õ r c óZ |dk r2| j j t j dd|z « « S |dk r0| j j t j dd|« « S |dk r0| j j t j dd |« « S t d
|
« ) NrÀ r r¿ r r rm r r rn zArray is too large©r r rÉ r r9 ©r r s r r% zPacker._pack_array_headera s Ø 9Ø<<×%Ñ%¤f§k¡k°#°t¸a±xÓ&@ÓAÐ AØ ;Ø<<×%Ñ%¤f§k¡k°%¸¸qÓ&AÓBÐ BØ
|
?Ø<<×%Ñ%¤f§k¡k°%¸¸qÓ&AÓBÐ BÜÐ-Ó.Ð.r c óZ |dk r2| j j t j dd|z « « S |dk r0| j j t j dd|« « S |dk r0| j j t j dd |« « S t d
|
« ) NrÀ r r¸ r r ro r r rp zDict is too largerD rE s r r: zPacker._pack_map_headerj s Ø 9Ø<<×%Ñ%¤f§k¡k°#°t¸a±xÓ&@ÓAÐ AØ ;Ø<<×%Ñ%¤f§k¡k°%¸¸qÓ&AÓBÐ BØ
|
?Ø<<×%Ñ%¤f§k¡k°%¸¸qÓ&AÓBÐ BÜÐ,Ó-Ð-r c ó | j |« |D ]/ \ }}| j ||dz
|
« | j ||dz
|
« 1 y )Nr% )r: r& )r r r4 r- ÚkÚvs r r( zPacker._pack_map_pairss sG Ø × Ñ aÔ Øò *DAqØ JJq* q.Ô )Ø JJq* q.Õ )ñ *r c óä |dk r3| j j t j dd|z « « y | j r6|dk r1| j j t j dd|« « y |dk r1| j j t j dd |« « y |d
|
k r1| j j t j d d |« « y t d « )Nr¼ r r» rº r rj r r rk r r rl zRaw is too large)r r rÉ r r r9 rE s r r zPacker._pack_raw_headery s° Ø 9Ø LL× Ñ v{{¨3°°q±Ó 9Õ :Ø × Ò A¨¢IØ LL× Ñ v{{¨5°$¸Ó :Õ ;Ø &[Ø LL× Ñ v{{¨5°$¸Ó :Õ ;Ø *_Ø LL× Ñ v{{¨5°$¸Ó :Õ ;ä Ð /Ó0Ð 0r c ó | j s| j |« S |dk r0| j j t j
|
dd|« « S |dk r0| j j t j
|
dd|« « S |dk r0| j j t j
|
dd |« « S t d
|
« ) Nrº r rJ r r rK r r rM zBin is too large)r r r r rÉ r r9 rE s r r zPacker._pack_bin_header
s£ Ø×!Ò!Ø×(Ñ(¨Ó+Ð +Ø $YØ<<×%Ñ%¤f§k¡k°%¸¸qÓ&AÓBÐ BØ &[Ø<<×%Ñ%¤f§k¡k°%¸¸qÓ&AÓBÐ BØ *_Ø<<×%Ñ%¤f§k¡k°%¸¸qÓ&AÓBÐ Bä Ð /Ó0Ð 0r c ó6 | j j « S )z/Return internal buffer contents as bytes object)r r r s r r z Packer.bytes s à||×$Ñ$Ó&Ð&r c ó" t « | _ y)zYReset internal buffer.
|
|
This method is useful only when autoreset=False.
|
N)r r r s r Úresetz Packer.reset s ô
|
y r c ót t rt | j « « S | j j « S )z Return view of internal buffer.)Ú_USING_STRINGBUILDERr r r Ú getbufferr s r rQ zPacker.getbuffer s) å Ü djjlÓ+Ð +à<<×)Ñ)Ó+Ð +r )r r r! r÷ r ÚDEFAULT_RECURSE_LIMITr r6 r& r r5 r8 r; rB r% r: r( r r r rN rQ r" r r rú rú \ s ñ.ðf Ø ØØØØØØô ð4 )ØØ,ó z9òx òòòò!ò:/ò.ð 4Ió *ò
|
1ò
|
1ò'ò!ó,r rú )*r÷ rÉ rÛ r r* ÚhasattrÚ__pypy__r Ú__pypy__.buildersr rP r ÚioÚ
|
exceptionsr& r' r( r) r* Úextr+ r, rØ rÑ rÖ r× rÄ rÆ rÇ rÅ rÞ rß rR r4 r5 r6 r; rH Ú_NO_FORMAT_USEDrÈ r> rú r" r r ú<module>rZ s: ðÙ 4ã Û
|
Ý *á
|
3Ð#Ô$Ý%Ý.à Ð÷(ò (õ& à Ðò÷ RÕ Qß #à
|
Ø ØÐ ØÐ àØ
|
Ø Ø Ø Ø àÐ ð %)°ó òòð2 ð Ø1oxÐ
|
(ð à1dHÐ
|
ð ð 1dHÐ
|
ð ð 1dHÐ
|
ð ð
|
1eXÐ
|
ð ð 1eXÐ
|
ð ð )ð ð )ð ð 1oÐ
|
ð ð )ð ð )ð ð )ð ð (ð ð )ð ð )ð ð )ð! ð" 1eXÐ
|
ð# ð$ eXÐ
|
Ø eXÐ
|
Ø eXÐ
|
Ø vxÐ
|
Ø oxÐ
|
(Ø dHÐ
|
Ø dHÐ
|
Ø dJÐ
|
Ø dJÐ
|
Ø dHÐ
|
Ø dHÐ
|
ò9 Ð ÷@W#ñ W#÷tE,ò E,r
|
