Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
3.0.176 ▾
|
tvault-contego-common
/
home
/
tvault
/
.virtenv
/
lib
/
python2.7
/
site-packages
/
msgpack
/
fallback.pyc
|
|---|
ó
ðEYc @ sÓ d Z d d l Z d d l Z d d l Z e j d d k ra e Z e Z e Z
e Z d Z
n! e Z e e f Z e Z
d Z
e e d rø d d l m Z y d d l m Z Wn! e k
rØ d d
l m Z n Xe Z d e f d YZ n e Z d d
l m Z d Z d d l m Z m Z m Z m! Z! m" Z" d d l# m$ 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
| j S( N( t items( t d( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt dict_iteritems s c C s
| j S( N( t iteritems( R ( ( sE /home/tvault/.virtenv/lib/python2.7/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> | r. t t | | _ | j j | n t | _ d S( N( R t lent buildert append( t selft s( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt __init__ s c C s | j j | d S( N( R R ( R
R ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt write& s c C s
| j j S( N( R t build( R
( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt getvalue( s ( t __name__t
__module__R R R ( ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR s ( t BytesIOc C s g S( N( ( t size( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt <lambda>- s ( t
BufferFullt OutOfDatat UnpackValueErrort PackValueErrort ExtraData( t ExtTypei i i i iÿ c K sC t | | } | j } | j r? t | | j 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( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt unpackH s
c K st t d | } | j | y | j } Wn t k
rK t d n X| j rp t | | j 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% ( ( sE /home/tvault/.virtenv/lib/python2.7/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 untrusted 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 k r t | _ n0 t | j s6 t d n | | _ t | _ g | _ d | _ d | _
d | _ d | _ | p~ d | _
| | j
k r¢ t d n | p· t | j
d | _ | | _ | | _ | | _ | | _ | | _ | | _ |
| _ | | _ | | _ |
| _ | | _ | | _ | d k rQt | rQt d n | d k ryt | ryt d n | d k r¡t | r¡t d
n | d k rÈ| d k rÈt d n t |
sã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( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR ® sJ c C s£ t | t j r! | j } n t | t r? t | } n | j sN t | j t | | j | j
k rz t n | j t | 7_ | j j
| d S( N( t
isinstancet arrayt tostringt bytearrayt bytesR- t AssertionErrorR6 R
R7 R8 R R3 R ( R
t
next_bytes( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR( î s c C s | j r^ x3 t | j D]" } | j t | j | 8_ q W| j | j | _ d | _ n | j rv | j | _ 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( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt _fb_sloppy_consumeú s c C s¶ | j r^ x3 t | j D]" } | j t | j | 8_ q W| j | j | _ d | _ n | j r | j d | j | j d <| j | j 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^ ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt _fb_consume s c C sP | j t | j k r t S| j r) t S| j s6 t S| j j d rL t St S( Ni ( R4 R
R3 R, R- R2 R1 R/ ( R
( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR s c C s | S( N( ( R
( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt __iter__ s c C s
| j | S( N( t _fb_read( R
t n( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt
read_bytes# s c C s d | _ | j | _ d S( Ni ( R4 R7 R5 ( R
( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt _fb_rollback& s c C s; | j | j } | r. | d | j | d <n d j | S( Ni R ( R3 R4 R5 t join( R
t bufs( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR! * s c C sÕ | j } | d k ru | j t | k ru | j | t | | j k ru | j | 7_ | | j | j | | j !Sd } xt | | k r| t | } | j t | k r'| j r Pn | } | j | k rã | j } n | j j | } | sÿ Pn | j | | j
t | 7_
q~ n | | | j | j | j | !7} | j | 7_ | j t | | j k r~ d | _ | j d 7_ q~ q~ Wt | | k r¸| j t n | d k rÑ| | n | S( NR i i (
R3 R' R4 R
R5 R- R; R1 R/ R R6 Re R ( R
Rc t write_bytest buffsR% t slicedt to_readt tmp( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyRb 0 s> !
"
c C s" t } d } d } | j d | } t | } | d @d k rI | } nÌ
| d @d k rr t j d | d } n£
| d @d k rÎ | d @} | j | | } t } | | j k r t d | | j q nG
| d @d
k r| d @} t } | | j
k r t d | | j
q ný | d @d k rb| d @} t } | | j k r t d
| | j q n³ | d k rwd } n | d k rt
} n | d k r¡t } nt | d k rt } t j d | j d | d } | | j k r t d | | j f n | j | | } n | d k rt } t j d | j d | d } | | j k rtt d | | j f n | j | | } n| d k rýt } t j d | j d | d } | | j k rèt d | | j f n | j | | } n| d k rst } t j d | j d | \ } } | | j k r^t d | | j f n | j | | } n¢| d k rét } t j d | j d | \ } } | | j k rÔt d | | j f n | j | | } n,| d k r_t } t j d! | j d" | \ } } | | j k rJt d | | j f n | j | | } n¶| d# k rt j d$ | j d | d } n
| d% k rÁt j d& | j d' | d } nT| d( k ròt j d | j d | d } n#| d) k r#t j d | j d | d } nò| d* k rTt j d | j d | d } nÁ| d+ k r
t j d, | j d' | d } n| d- k r¶t j d | j d | d } n_| d. k rçt j d/ | j d | d } n.| d0 k rt j d1 | j d | d } ný| d2 k rIt j d3 | j d' | d } nÌ| d4 k rt } | j d k rt d d | j f n t j d5 | j d | \ } } nh| d6 k rt } | j d k rêt d d | j f n t j d7 | j d | \ } } n| d8 k rut } | j d k rNt d d | j f n t j d9 | j d" | \ } } n | d: k rÙt } | j d' k r²t d d' | j f n t j d; | j d< | \ } } n<| d= k r=t } | j d> k rt d d> | j f n t j d? | j d@ | \ } } nØ| dA k rt } t j d | j d | d } | | j k rt d | | j n | j | | } nh| dB k r t } t j d | j d | d } | | j k r t d | | j n | j | | } nø| dC k r t } t j d | j d | d } | | j k rx t d | | j n | j | | } n| dD k rë t j d | j d | d } | | j
k râ t d | | j
n t } n*| dE k rI
t j d | j d | d } | | j
k r@
t d | | j
n t } nÌ | dF k r§
t j d | j d | d } | | j k r
t d
| | j n t } nn | dG k r t j d | j d | d } | | j k rü
t d
| | j 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( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt _read_headerV s0
" " " $ $ $ % % % % % % % % % % ' ' ' ' ' " " " " " " " c
s« j | \ } } } | t k rF | t k rB t d n | S| t k rq | t k rm t d n | S| t k r(| t k r´ x$ t | D] } j t q Wd St | } x- t | D] } | j
j t qÍ W j d k r j | } n j r | St | S| t k r | t k r{x4 t | D]& } j t j t qMWd S j d k rµ j f d t | D } nf i } x< t | D]. } j t } j t | | <qÈW j d k r j | } n | S| t k r/d S| t k ri j d k re| j j j } n | S| t k r
j | | S| t k r| S| t k s§t | S( Ns Expected arrays Expected mapc 3 s3 | ]) } j t j t f Vq d S( N( R t EX_CONSTRUCT( t .0t _( R
Rh ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pys <genexpr> 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 sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR ñ sb c C sL y$ | j t d } | j | SWn! t k
rG | j t n Xd S( N( R R R' R_ R R` t
StopIteration( R
R% ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt next+ s
c C s | j t | | j d S( N( R R R` ( R
Rh ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt skip5 s c C s | j t | } | j | S( N( R R R` ( R
Rh R% ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR& 9 s
c C s | j t | } | j | S( N( R R R` ( R
Rh R% ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt read_array_header> s
c C s | j t | } | j | S( N( R R R` ( R
Rh R% ( ( sE /home/tvault/.virtenv/lib/python2.7/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 ( ( ( sE /home/tvault/.virtenv/lib/python2.7/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 sp | | _ | | _ | | _ | | _ | | _ t | _ | d k rc t | sc t d qc 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( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR e s c
C sò t } xåt rí| d k r* t d n | d k rF | j j d S| | t r{ | rk | j j d S| j j d S| | t rd | k o¡ d k n r | j j t j d | Sd | k oÙ d k n rú | j j t j d | Sd | k od
k n r5| j j t j d d | Sd
| k oLd k n rp| j j t j d d | Sd
| k od k n r«| j j t j d d | Sd | k oÂd
k n ræ| j j t j d d | Sd | k oýd k n r!| j j t j d d | Sd | k o8d k n r\| j j t j d d | Sd | k osd k n r| j j t j d d | Sd | k o®d k n rÒ| j j t j d d! | S| r| j
d k r| j
| } t } q n t d" n | j rÜ| | t rÜt
| } | d
k rd| j j t j d# d$ | nh | d k r| j j t j d d% | n: | d k rÀ| j j t j d d& | n t d' | j j | S| | t t f r#| | t r9| j d k r t d( n | j | j | j } n t
| } | d) k rt| j j t j d d* | n | j r«| d
k r«| j j t j d# d+ | nh | d k rÙ| j j t j d d, | n: | d k r| j j t j d d- | n t d. | j j | S| | t ry| j rZ| j j t j d/ d0 | S| j j t j d1 d2 | S| | t r| j } | j } | | t s¯t | | t sÄt t
| } | d3 k rï| j j d4 n÷ | d5 k r| j j d6 nØ | d7 k r-| j j d8 n¹ | d9 k rL| j j d: n | d; k rk| j j d< n{ | d
k r| j j t j d# d= | nM | d k rÇ| j j t j d d> | n | j j t j d d? | | j j t j d | | j j | d S| | t t f rwt
| } | j | x, t | D] } | j | | | d3 qQWd S| | t r©| j t
| t! | | d3 S| rÚ| j
d k rÚ| j
| } 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 R 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 t
nest_limitRV t default_usedRc R¤ R¥ R R^ ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR© r sÒ " " " #" " " " "
c C sP | j | | j j } | j r4 t | _ n t rL t | | _ n | S( N( R© R R R R t USING_STRINGBUILDER( R
R R% ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR á s
c C sY | j t | | | j j } | j r= t | _ n t rU t | | _ n | S( N( R« R
R R R R R® ( R
t pairsR% ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt pack_map_pairsê s c C se | d k r t n | j | | j j } | j rI t | _ n t ra t | | _ n | S( Ni i I ( R9 R¨ R R R R R® ( R
Rc R% ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt pack_array_headeró s
c C se | d k r t n | j | | j j } | j rI t | _ n t ra t | | _ n | S( Ni i I ( R9 t _fb_pack_map_headerR R R R R® ( R
Rc R% ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt pack_map_headerþ s
c C s× t | t s t d n d | k o5 d k n sI t d n t | t sg t d n t | } | d k r t d n | d k r | j j d nú | d
k rÌ | j j d nÛ | d k rë | j j d
n¼ | d k r
| j j d n | d k r)| j j d n~ | d k rX| j j d t j d | nO | d k r| j j d t j d | n | j j d t j d | | j j t j d | | j j | 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 ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt
pack_ext_type s4 # # c C s | d k r, | j j t j d d | S| d k rW | j j t j d d | S| d k r | j j t j 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 ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR¨ & s c C s | d k r, | j j t j d d | S| d k rW | j j t j d d | S| d k r | j j t j 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 ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR² / s c C sP | j | x< | D]4 \ } } | j | | d | j | | d q Wd S( Ni ( R² R© ( R
Rc R¯ R¬ t kt v( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR« 8 s
c C s
| j j S( N( R R ( R
( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyRZ > s c C s t | _ d S( N( R R ( R
( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt resetA s N( R R R R' R2 R, R t DEFAULT_RECURSE_LIMITRV R© R R° R± R³ Rµ R¨ R² R« RZ R¸ ( ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyR I s o (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 ( ( ( sE /home/tvault/.virtenv/lib/python2.7/site-packages/msgpack/fallback.pyt <module> sT
( ÿ â