/usr/lib64/python2.6/site-packages/msgpack
Edit: /usr/lib64/python2.6/site-packages/msgpack/fallback.pyc (26687B)
Ñò
DVc
@ sÙ d Z d d k Z d d k Z d d k Z e i d d j o% e Z e Z e Z
e Z d „ Z
n" e Z e e f Z e Z
d „ Z
e e d ƒ oj d d k l Z y d d k l Z Wn# e j
o d d
k l Z n Xe Z d e f d „ ƒ YZ n e Z d d
k l Z d „ Z d d k l Z l Z l Z l! Z! l" Z" d d k# l$ Z$ d Z% d Z& d Z' d Z( d Z) d Z* d Z+ d Z, d Z- d Z. d Z/ d „ Z0 d „ Z1 d e f d „ ƒ YZ2 d e f d „ ƒ YZ3 d S( s. Fallback pure Python implementation of msgpackiÿÿÿÿNi i c C s
| i ƒ S( N( t items( t d( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt dict_iteritems s c C s
| i ƒ S( N( t iteritems( R ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR s t pypy_version_info( t newlist_hint( t BytesBuilder( t
StringBuildert StringIOc B s& e Z d d „ Z d „ Z d „ Z RS( t c C s@ | o) t t | ƒ ƒ | _ | i i | ƒ n
t ƒ | _ d S( N( R t lent buildert append( t selft s( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt __init__ s c C s | i i | ƒ d S( N( R R ( R
R ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt write& s c C s
| i i ƒ S( N( R t build( R
( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt getvalue( s ( t __name__t
__module__R R R ( ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR s ( t BytesIOc C s g S( ( ( t size( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt
- s ( t
BufferFullt OutOfDatat UnpackValueErrort PackValueErrort ExtraData( t ExtTypei i i i iÿ c K sE t | | } | i ƒ } | i ƒ o t | | i ƒ ƒ ‚ n | S( sŒ
Unpack an object from `stream`.
Raises `ExtraData` when `packed` contains extra bytes.
See :class:`Unpacker` for options.
( t Unpackert
_fb_unpackt _fb_got_extradataR t _fb_get_extradata( t streamt kwargst unpackert ret( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt unpackH s
c K sx t d | } | i | ƒ y | i ƒ } Wn t j
o t d ƒ ‚ n X| i ƒ o t | | i ƒ ƒ ‚ n | S( sŒ
Unpack an object from `packed`.
Raises `ExtraData` when `packed` contains extra bytes.
See :class:`Unpacker` for options.
s Data is not enough.N( R t Nonet feedR R R R R R! ( t packedR# R$ R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt unpackbV s
R c B sõ e Z d Z d d e d d d d d d e d d d d d d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
d „ Z d d
„ Z e d d „ Z e d d „ Z d „ Z e Z d d „ Z d d „ Z d d „ Z d d „ Z RS( s^ Streaming unpacker.
arguments:
:param file_like:
File-like object having `.read(n)` method.
If specified, unpacker reads serialized data from it and :meth:`feed()` is not usable.
:param int read_size:
Used as `file_like.read(read_size)`. (default: `min(1024**2, max_buffer_size)`)
:param bool use_list:
If true, unpack msgpack array to Python list.
Otherwise, unpack to Python tuple. (default: True)
:param callable object_hook:
When specified, it should be callable.
Unpacker calls it with a dict argument after unpacking msgpack map.
(See also simplejson)
:param callable 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 encoding:
Encoding used for decoding msgpack raw.
If it is None (default), msgpack raw is deserialized to Python bytes.
:param str unicode_errors:
Used for decoding msgpack raw with *encoding*.
(default: `'strict'`)
:param int max_buffer_size:
Limits size of data waiting unpacked. 0 means system's INT_MAX (default).
Raises `BufferFull` exception when it is insufficient.
You shoud set this parameter when unpacking data from untrasted source.
:param int max_str_len:
Limits max length of str. (default: 2**31-1)
:param int max_bin_len:
Limits max length of bin. (default: 2**31-1)
:param int max_array_len:
Limits max length of array. (default: 2**31-1)
:param int max_map_len:
Limits max length of map. (default: 2**31-1)
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)
i t strictiÿÿÿc C sý | d j o
t | _ n3 t | i ƒ p t d ƒ ‚ n | | _ t | _ g | _ d | _ d | _
d | _ d | _ | p d | _
| | i
j o t d ƒ ‚ n | p t | i
d ƒ | _ | | _ | | _ | | _ | | _ | | _ | | _ |
| _ | | _ | | _ |
| _ | | _ | | _ | d j o t | ƒ o t d ƒ ‚ n | d j o t | ƒ o t d ƒ ‚ n | d j o t | ƒ o t d
ƒ ‚ n | d j o | d j o t d ƒ ‚ n t |
ƒ p t d ƒ ‚ n d S( Ns! `file_like.read` must be callablei i i i s. read_size must be smaller than max_buffer_sizei s `list_hook` is not callables `object_hook` is not callables# `object_pairs_hook` is not callables8 object_pairs_hook and object_hook are mutually exclusives `ext_hook` is not callableI € iÿÿÿ( R' t Truet _fb_feedingt callablet readt TypeErrort file_liket Falset _fb_bufferst _fb_buf_it _fb_buf_ot _fb_buf_nt _fb_sloppinesst _max_buffer_sizet
ValueErrort mint
_read_sizet _encodingt _unicode_errorst _use_listt
_list_hookt _object_hookt _object_pairs_hookt _ext_hookt _max_str_lent _max_bin_lent _max_array_lent _max_map_lent _max_ext_len( R
R1 t read_sizet use_listt object_hookt object_pairs_hookt list_hookt encodingt unicode_errorst max_buffer_sizet ext_hookt max_str_lent max_bin_lent
max_array_lent max_map_lent max_ext_len( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR ® sJ
c C s« t | t i ƒ o | i ƒ } n! t | t ƒ o t | ƒ } n | i p t ‚ | i t | ƒ | i | i
j o
t ‚ n | i t | ƒ 7_ | i i
| ƒ d S( N( t
isinstancet arrayt tostringt bytearrayt bytesR- t AssertionErrorR6 R
R7 R8 R R3 R ( R
t
next_bytes( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR( î s
c C s‡ | i oV x3 t | i ƒ D]" } | i t | i | ƒ 8_ q W| i | i | _ d | _ n | i o | i | _ n
d | _ d S( s3 Gets rid of some of the used parts of the buffer. i N( R4 t xrangeR6 R
R3 R5 R7 ( R
t i( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt _fb_sloppy_consumeú s
c C sº | i oV x3 t | i ƒ D]" } | i t | i | ƒ 8_ q W| i | i | _ d | _ n | i o1 | i d | i | i d <| i | i 8_ n
d | _ d | _ d | _ d S( s+ Gets rid of the used parts of the buffer. i N( R4 R] R6 R
R3 R5 R7 ( R
R^ ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt _fb_consume s
c C sX | i t | i ƒ j o t S| i o t S| i p t S| i i d ƒ o t St S( Ni ( R4 R
R3 R, R- R2 R1 R/ ( R
( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR s
c C s | S( N( ( R
( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt __iter__ s c C s
| i | ƒ S( N( t _fb_read( R
t n( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt
read_bytes# s c C s d | _ | i | _ d S( Ni ( R4 R7 R5 ( R
( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt _fb_rollback& s c C s= | i | i } | o | d | i | d j o t d d> | i f ƒ ‚ n t i d? | i d@ | ƒ ƒ \ } } nõ| dA j og t } t i d | i d | ƒ ƒ d } | | i j o t d | | i ƒ ‚ n | i | | ƒ } n| dB j og t } t i d | i d | ƒ ƒ d } | | i j o t d | | i ƒ ‚ n | i | | ƒ } n
| dC j og t } t i d | i d | ƒ ƒ d } | | i j o t d | | i ƒ ‚ n | i | | ƒ } n™| dD j oU t i d | i d | ƒ ƒ d } | | i
j o t d | | i
ƒ ‚ n t } n7| dE j oU t i d | i d | ƒ ƒ d } | | i
j o t d | | i
ƒ ‚ n t } nÕ | dF j oU t i d | i d | ƒ ƒ d } | | i j o t d
| | i ƒ ‚ n t } ns | dG j oU t i d | i d | ƒ ƒ d } | | i j o t d
| | i ƒ ‚ n t } n t dH | ƒ ‚ | | | f S(I Ni i i€ ià t bi i s %s exceeds max_str_len(%s)ið i i s %s exceeds max_array_len(%s)s %s exceeds max_map_len(%s)iÀ i ià iÄ t Bs %s exceeds max_bin_len(%s)iÅ s >Hi iÆ s >Ii iÇ t Bbs %s exceeds max_ext_len(%s)iÈ s >Hbi iÉ s >Ibi iÊ s >fiË s >di iÌ iÍ iÎ iÏ s >QiÐ iÑ s >hiÒ s >iiÓ s >qiÔ t b1siÕ t b2siÖ t b4si× t b8si iØ i t b16si iÙ iÚ iÛ iÜ iÝ iÞ iß s Unknown header: 0x%x( t TYPE_IMMEDIATER' Rb t ordt structR& t TYPE_RAWRC R9 t
TYPE_ARRAYRE t TYPE_MAPRF R2 R, t TYPE_BINRD t TYPE_EXTRG R ( R
t executeRh t typRc t objt cRm t L( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt _read_headerV s0
"
"
"
$
$
$
&
&
&
&
&
&
&
&
&
&
(
(
(
(
(
"
"
"
"
"
"
"
c
sÏ ˆ i | ˆ ƒ \ } } } | t j o" | t j o t d ƒ ‚ n | S| t j o" | t j o t d ƒ ‚ n | S| t j o² | t j o, x$ t | ƒ D] } ˆ i t ˆ ƒ q Wd St | ƒ } x- t | ƒ D] } | i
ˆ i t ˆ ƒ ƒ qØ Wˆ i d j o ˆ i | ƒ } n ˆ i o | St | ƒ S| t j oò | t j o< x4 t | ƒ D]& } ˆ i t ˆ ƒ ˆ i t ˆ ƒ q_Wd Sˆ i d j o, ˆ i ‡ ‡ f d † t | ƒ Dƒ ƒ } ni h } x< t | ƒ D]. } ˆ i t ˆ ƒ } ˆ i t ˆ ƒ | | s ( R‚ t EX_READ_ARRAY_HEADERRy R t EX_READ_MAP_HEADERRz t EX_SKIPR] R R R Rƒ R? R' R> t tupleRA R@ Rx R< t decodeR= R| RB R{ Ru R[ (
R
R} Rh R~ Rc R R^ R% R… t key( ( R
Rh s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR ñ sj
c C sN y$ | i t d ƒ } | i ƒ | SWn# t j
o | i ƒ t ‚ n Xd S( N( R Rƒ R' R_ R R` t
StopIteration( R
R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt next+ s
c C s | i t | ƒ | i ƒ d S( N( R Rˆ R` ( R
Rh ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt skip5 s c C s | i t | ƒ } | i ƒ | S( N( R Rƒ R` ( R
Rh R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR& 9 s
c C s | i t | ƒ } | i ƒ | S( N( R R† R` ( R
Rh R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt read_array_header> s
c C s | i t | ƒ } | i ƒ | S( N( R R‡ R` ( R
Rh R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt read_map_headerC s
N( R R t __doc__R' R, R R R( R_ R` R Ra Rd Re R! Rb Rƒ R‚ R R t __next__RŽ R& R R ( ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR h s6 D 8 &›: t Packerc B s• e Z d Z d d d e e e d „ Z e e d „ Z d „ Z
d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z e d „ Z d
„ Z d „ Z RS( sÐ
MessagePack Packer
usage:
packer = Packer()
astream.write(packer.pack(a))
astream.write(packer.pack(b))
Packer's constructor has some keyword arguments:
:param callable default:
Convert user type to builtin type that Packer supports.
See also simplejson's document.
:param str encoding:
Convert unicode to bytes with this encoding. (default: 'utf-8')
:param str unicode_errors:
Error handler for encoding unicode. (default: 'strict')
:param bool use_single_float:
Use single precision float type for float. (default: False)
:param bool autoreset:
Reset buffer after each pack and return it's 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 enable str8 type for unicode.
s utf-8R+ c C st | | _ | | _ | | _ | | _ | | _ t ƒ | _ | d j o! t | ƒ p t d ƒ ‚ qg n | | _
d S( Ns default must be callable( t
_use_floatt
_autoresett
_use_bin_typeR< R= R t _bufferR' R. R0 t _default( R
t defaultRM RN t use_single_floatt autoresett use_bin_type( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR e s
c
C s" t } xt o
| d j o t d ƒ ‚ n | d j o | i i d ƒ S| | t ƒ o) | o | i i d ƒ S| i i d ƒ S| | t ƒ ovd | j o
d j n o | i i t i d | ƒ ƒ Sd | j o
d j n o | i i t i d | ƒ ƒ Sd | j o
d
j n o | i i t i d d | ƒ ƒ Sd
| j o
d j n o | i i t i d d | ƒ ƒ Sd
| j o
d j n o | i i t i d d | ƒ ƒ Sd | j o
d
j n o | i i t i d d | ƒ ƒ Sd | j o
d j n o | i i t i d d | ƒ ƒ Sd | j o
d j n o | i i t i d d | ƒ ƒ Sd | j o
d j n o | i i t i d d | ƒ ƒ Sd | j o
d j n o | i i t i d d! | ƒ ƒ St d" ƒ ‚ n | i
oÉ | | t ƒ o¹ t | ƒ } | d
j o# | i i t i d# d$ | ƒ ƒ nm | d j o# | i i t i d d% | ƒ ƒ n= | d j o# | i i t i d d& | ƒ ƒ n
t d' ƒ ‚ | i i | ƒ S| | t
t f ƒ o@| | t
ƒ o< | i d j o t d( ƒ ‚ n | i | i | i ƒ } n t | ƒ } | d) j o$ | i i t i d d* | ƒ ƒ n§ | i
o0 | d
j o# | i i t i d# d+ | ƒ ƒ nm | d j o# | i i t i d d, | ƒ ƒ n= | d j o# | i i t i d d- | ƒ ƒ n
t d. ƒ ‚ | i i | ƒ S| | t ƒ oJ | i o | i i t i d/ d0 | ƒ ƒ S| i i t i d1 d2 | ƒ ƒ S| | t ƒ o¡| i } | i } | | t ƒ p t ‚ | | t ƒ p t ‚ t | ƒ } | d3 j o | i i d4 ƒ n| d5 j o | i i d6 ƒ nã | d7 j o | i i d8 ƒ n | d9 j o | i i d: ƒ n¡ | d; j o | i i d< ƒ n€ | d
j o# | i i t i d# d= | ƒ ƒ nP | d j o# | i i t i d d> | ƒ ƒ n | i i t i d d? | ƒ ƒ | i i t i d | ƒ ƒ | i i | ƒ d S| | t t f ƒ oM t | ƒ } | i | ƒ x, t | ƒ D] } | i | | | d3 ƒ qzWd S| | t ƒ o$ | i t | ƒ t | ƒ | d3 ƒ S| o, | i! d j o | i! | ƒ } d3 } q n t d@ | ƒ ‚ q Wd S(A Ni s recursion limit exceededs Às Ãs Âi€ Rn iàÿÿÿRm iÿ t BBiÌ i€ÿÿÿs >BbiÐ iÿÿ s >BHiÍ i €ÿÿs >BhiÑ Iÿÿÿÿ s >BIiÎ i €s >BiiÒ l ÿÿÿÿ s >BQiÏ I €s >BqiÓ s Integer value out of ranges >BBiÄ iÅ iÆ s Bytes is too larges5 Can't encode unicode string: no encoding is specifiedi i iÙ iÚ iÛ s String is too larges >BfiÊ s >BdiË i s Ôi s Õi s Öi s ×i s ØiÇ iÈ iÉ s Cannot serialize %r(" R2 R, R R' R— R t boolt int_typesRw t packR– RZ R
t UnicodeR< R0 t encodeR= t floatR” R t codet datat intR[ t listR‰ t _fb_pack_array_headerR] t _packt dictt _fb_pack_map_pairsR R˜ (
R
R t
nest_limitRV t default_usedRc R¤ R¥ R R^ ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR© r sÎ
#
#
#
$#
#
#
#
#
c C sT | i | ƒ | i i ƒ } | i o t ƒ | _ n t o t | ƒ | _ n | S( N( R© R— R R• R t USING_STRINGBUILDER( R
R R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR Ý s
c C s] | i t | ƒ | ƒ | i i ƒ } | i o t ƒ | _ n t o t | ƒ | _ n | S( N( R« R
R— R R• R R® ( R
t pairsR% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt pack_map_pairsæ s
c C sk | d j o
t ‚ n | i | ƒ | i i ƒ } | i o t ƒ | _ n t o t | ƒ | _ n | S( Ni i I ( R9 R¨ R— R R• R R® ( R
Rc R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt pack_array_headerï s
c C sk | d j o
t ‚ n | i | ƒ | i i ƒ } | i o t ƒ | _ n t o t | ƒ | _ n | S( Ni i I ( R9 t _fb_pack_map_headerR— R R• R R® ( R
Rc R% ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt pack_map_headerú s
c C sî t | t ƒ p t d ƒ ‚ n d | j o
d j n p t d ƒ ‚ n t | t ƒ p t d ƒ ‚ n t | ƒ } | d j o t d ƒ ‚ n | d j o | i i d ƒ n| d
j o | i i d ƒ næ | d j o | i i d
ƒ nÅ | d j o | i i d ƒ n¤ | d j o | i i d ƒ nƒ | d j o$ | i i d t i d | ƒ ƒ nR | d j o$ | i i d t i d | ƒ ƒ n! | i i d t i d | ƒ ƒ | i i t i d | ƒ ƒ | i i | ƒ d S( Ns typecode must have int type.i i s typecode should be 0-127s data must have bytes typeIÿÿÿÿ s Too large datai s Ôi s Õi s Öi s ×i s Øiÿ s ÇRn iÿÿ s Ès >Hs És >I(
RV R¦ R0 R9 RZ R
R— R Rw R ( R
t typecodeR¥ R ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt
pack_ext_type s4
$
$ c C s˜ | d j o! | i i t i d d | ƒ ƒ S| d j o | i i t i d d | ƒ ƒ S| d j o | i i t i d d | ƒ ƒ St d
ƒ ‚ d S( Ni Rn i iÿÿ s >BHiÜ Iÿÿÿÿ s >BIiÝ s Array is too large( R— R Rw R R ( R
Rc ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR¨ " s
!
c C s˜ | d j o! | i i t i d d | ƒ ƒ S| d j o | i i t i d d | ƒ ƒ S| d j o | i i t i d d | ƒ ƒ St d
ƒ ‚ d S( Ni Rn i€ iÿÿ s >BHiÞ Iÿÿÿÿ s >BIiß s Dict is too large( R— R Rw R R ( R
Rc ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR² + s
!
c C sP | i | ƒ x< | D]4 \ } } | i | | d ƒ | i | | d ƒ q Wd S( Ni ( R² R© ( R
Rc R¯ R¬ t kt v( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR« 4 s
c C s
| i i ƒ S( N( R— R ( R
( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyRZ : s c C s t ƒ | _ d S( N( R R— ( R
( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt reset= s N( R R R‘ R' R2 R, R t DEFAULT_RECURSE_LIMITRV R© R R° R± R³ Rµ R¨ R² R« RZ R¸ ( ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyR“ I s k (4 R‘ t sysRW Rw t version_infoR, t PY3R¦ RŸ t strR¡ t rangeR] R R2 t longt unicodet hasattrt __pypy__R t __pypy__.buildersR R t ImportErrorR® t objectR t ioR t msgpack.exceptionsR R R R R t msgpackR Rˆ Rƒ R† R‡ Ru Ry Rz Rx R{ R| R¹ R& R* R R“ ( ( ( s6 /usr/lib64/python2.6/site-packages/msgpack/fallback.pyt sT
( ÿ â