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
/
amqp
/
serialization.pyc
|
|---|
ó
õEYc @@ sÌ d Z d d l m Z m Z d d l Z d d l Z d d l m Z d d l m Z d d l m
Z
d d l m Z m
Z
d d l m Z d d
l m Z d d l m Z m Z m Z m Z m Z d d l m Z m Z e j d d
k rñ e n d Z d Z d Z! d Z" d e
e d Z# d e$ e
e# e d Z% e d Z& d Z' e d Z( e d Z) e e e* e e+ e, e e e e- e. e/ d d
Z0 d e
e d Z1 i e1 e j2 6Z3 d e4 f d YZ5 d S( ue Convert between bytestreams and higher-level AMQP types.
2007-11-05 Barry Pederson <bp@barryp.org>
i ( t absolute_importt unicode_literalsN( t datetime( t Decimal( t BytesIO( t packt unpack_fromi ( t Basic( t FrameSyntaxError( t int_typest long_tt stringt string_tt items( t bytes_to_strt str_to_bytesi u* Table type {0!r} not handled by amqp.
uC Table type {0!r} for key {1!r} not handled by amqp. [value: {2!r}]
u9 Table type {0!r} not handled by amqp. [value: {1!r}]
c C@ sÌ | r | | | n | | } | d 7} | d k ry | d | | \ } | d 7} t | | | | ! } | | 7} nI| d k rÈ | d | | \ } | d 7} t | | | | ! } | | 7} nú| d k rö | d | | \ } | d 7} nÌ| d k r$| d | | \ } | d 7} n| d
k rR| d | | \ } | d 7} np| d
k r| d | | \ } | d 7} nB| d k r®| d | | \ } | d 7} n| d k rÜ| d | | \ } | d 7} næ| d k r
| d | | \ } | d 7} n¸| d k r8| d | | \ } | d 7} n| d k rf| d | | \ } | d 7} n\| d k r| d | | \ } | d 7} n.| d k rû| d | | \ } | d 7} | d | | \ } | d 7} t | t d | } nÇ| d k r¥| d | | \ } | d 7} | | }
i } x| |
k r¡| d | | \ } | d 7} t | | | | ! } | | 7} t | | \ | | <} q9Wn | d k r| d | | \ }
| d 7} | |
}
g } xß | |
k rt | | \ } } | j | qãWnª | d k rR| d | | \ } t | } | d 7} np | d k r| d | | \ } | d 7} t j | } n3 | d! k r¤d } n t d" j | t
| | | f S(# Ni u Ss >Ii u ss >Bu bu Bs >bu Us >hi u us >Hu Is >iu iu Ls >qi u ls >Qu fs >fu ds >du Di
u Fu Au tu Tu Vu% Unknown value in table: {0!r} ({1!r})( t pstr_tR t
_read_itemt appendt boolR t utcfromtimestampt NoneR t formatt type( t buft offsetR t ftype_tt ftypet slent valt dt nt tlent limitt keylent keyt alent v( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyR 3 s¢
c C@ s
d } } g } | j }
| | } xØ| D]Ð} | d k r | s^ | | | | d ! } n d } | d @d k } | d L} | d 8} | d 7} n]| d k rÍ d } } | d | | \ } | d 7} n%| d k rd } } | d | | \ } | d 7} ní| d
k r=d } } | d | | \ } | d 7} nµ| d
k rud } } | d | | \ } | d 7} n}| d k rd } } | d | | \ } | d 7} nE| d k r d } } | d | | \ }
| d 7} | | | |
!j d } | |
7} né| d k red } } | d | | \ }
| d 7} | | | |
!j d } | |
7} n| d k rd } } | d | | \ } | d 7} | | } i } xE| | k r| d | | \ } | d 7} | | | | | ! } | | 7} | | | \ | | <} qWnÙ | d k rd } } | d | | \ } | d 7} | | } g } x | | k r| | | \ } } | j | qaWn\ | d k rÝd } } | d | | \ } | d 7} t j | } n t t j | |
| q, W| | f S( u Deserialize amqp format.
bit = b
octet = o
short = B
long = l
long long = L
float = f
shortstr = s
longstr = S
table = F
array = A
timestamp = T
i u bi i u os >Bu Bs >Hi u ls >Ii u Ls >Qu fs >fu st Bu utf-8u Su Fu Au T( R t decodeR R R t ILLEGAL_TABLE_TYPER ( R R R t ordR R R t bitcountt bitst valuesR t pR R R R! R" R# R$ t aval( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt loads s
c C@ s1 | r- | | d t | | g | (n d S( NR& i ( t len( R+ t writeR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt
_flushbitsû s
c
C@ sC d } g } t } | j } t | } xÿt | D]ñ\ } } | | } | d k r² | re d n d } | d } | d k r | j d n | d c | | >O<| d 7} q7 | d k rã t | | } | t d | q7 | d k rt | | } | t d t | q7 | d
k rKt | | } | t d | q7 | d k r|t | | } | t d
| q7 | d k rt | | } | t d | q7 | d k r| pÂd } t | | } t | t rõ| j
d } n | t d t | | | q7 | d k r| p0d } t | | } t | t rc| j
d } n | t d t | | | q7 | d k r½t | | } t | p°i | | q7 | d k rñt | | } t
| päg | | q7 | d k r7 | t d
t t j | j q7 q7 Wt | | | j S( uÓ "Serialize AMQP arguments.
Notes:
bit = b
octet = o
short = B
long = l
long long = L
shortstr = s
longstr = S
table = F
array = A
i u bi i iÿÿÿÿu oR& u Bs >Hu ls >Iu Ls >Qu fs >fu su u utf-8u Su Fu Au T( R R1 R t enumerateR R2 R t intt
isinstanceR t encodeR0 t _write_tablet _write_arrayR
t calendart timegmt utctimetuplet getvalue(
R R, R* R+ t outR1 t iR R- t shift( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt dumps sj
/
c C@ sï t } | j } x§ t | D] \ } } t | t rL | j d } n | | d t | | | y t | | | Wq t k
r· t t
j t | | | q Xq W| j
} | | d t | | | d S( Nu utf-8R& s >I( R R1 R
R5 R R6 R0 t _write_itemt
ValueErrorR t ILLEGAL_TABLE_TYPE_WITH_KEYR R R< ( R R1 R+ R R= t twritet kR% t
table_data( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyR7 J s
& c C@ s t } | j } xT | D]L } y t | | | Wq t k
rd t t j t | | q Xq W| j } | | d t | | | d S( Ns >I(
R R1 RA RB R t ILLEGAL_TABLE_TYPE_WITH_VALUER R R< R0 ( t lR1 R+ R R= t awriteR% t
array_data( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyR8 \ s
# c C@ sE t | | | f r_ t | | r6 | j d } n | | d d t | | | nât | | r | | d d t | n´t | | rµ | | d d | nt | | r| d k sÜ | d k rõ | | d
d | qA| | d d
| n3t | |
r| j \ } } } d } x | D] } | d | } q?W| rg| } n | | d d | | n½ t | | rÁ| | d d t t j | j n t | | rí| d t | | | nT t | |
| f r | d t
| | | n" | | k r8| d n t d S( Nu utf-8s >cIt Ss >cBt ts >cdR iÿÿÿi s >cqt Ls >cit Ii i
s >cBit Ds >cQt Tt Ft At V( R5 R6 R0 R4 t as_tupleR
R9 R: R; R7 R8 RB ( R% R1 R+ R R t bytesR R t floatR R R t dictt listt tuplet None_tt signt digitst exponentR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyRA j s@
.
c C@ s i } | d | | \ } | d 7} | d @rv | d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @rÇ | d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @rù t d
| | \ } } | \ | d <n | d @r)| d | | \ | d
<| d 7} n | d @rY| d | | \ | d <| d 7} n | d @rª| d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @rû| d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @rL| d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @r| d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @rÍ| d | | \ | d <| d 7} n | d @r | d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @ro| d | | \ } | d 7} | | | | | ! | d <| | 7} n | d @rÀ| d | | \ } | d 7} | | | | | ! | d <| | 7} n | d! @r| d | | \ } | d 7} | | | | | ! | d" <| | 7} n | | f S(# u Decode basic properties.s >Hi i s >Bi u content_typei @ u content_encodingi u Fu application_headersi u
delivery_modei u priorityi u correlation_idi u reply_toi u
expirationi u
message_idi@ s >Qu timestampi i u typei u user_idu app_idi u
cluster_id( R/ ( R R R R t
propertiest flagsR t _f( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt decode_properties_basic s
t GenericContentc B@ se e Z d Z d
Z d g Z d
d
d Z d Z d e e d Z
d Z d d Z d Z
RS( ud Abstract base class for AMQP content.
Subclasses should override the PROPERTIES attribute.
u dummyu sc K@ sC | | _ | | _ | | _ g | _ d | _ d | _ t | _ d S( Ni ( t frame_methodt
frame_argsR^ t _pending_chunkst
body_receivedt body_sizet Falset ready( t selfRc Rd t props( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt __init__ê s c C@ sE | d k r t d n | | j k r5 | j | St | d S( Nu __setstate__( t AttributeErrorR^ ( Rj t name( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt __getattr__ô s
i c C@ s& | | | | \ } } | | _ | S( uõ Load AMQP properties.
Given the raw bytes containing the property-flags and property-list
from a content-frame-header, parse and insert into a dictionary
stored in this object as an attribute named 'properties'.
( R^ ( Rj t class_idR R t classesR Rk ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt _load_propertiesÿ s c C@ sK d } d } g } g g } } | j } | j d d x§ | j D] \ } } | j | d } | d k rÔ | d k r | j | d } d } n | d | >O} | d k rÔ | j t | | j | qÔ n | d 8} qB W| j | t }
|
j } x! | D] } | t d | qW| t
d j | | |
j S(
uì Serialize AMQP properties.
Serialize the 'properties' attribute (a dictionary) into
the raw bytes making up a set of property flags and a
property list, suitable for putting into a content frame header.
i i u content_encodingu utf-8i u bits >Ht N(
R^ t
setdefaultt
PROPERTIESt getR R R R R1 R R@ t joinR< ( Rj R? t flag_bitsR_ t sformatt svaluesRk R# t proptypeR t resultR1 ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt _serialize_properties s2
c C@ sQ t d | | \ } | _ | d 7} | j | | | | j sM t | _ n | S( Ns >HxxQi ( R Rg Rr t TrueRi ( Rj R R Rp ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt inbound_header0 s
c C@ s | j } | j t | 7_ | j | j k rw | rb | j | t j | | _ g | (n | | _ t | _ n
| j | d S( N(
Re Rf R0 Rg R RU Rw t bodyR~ Ri ( Rj R t chunks( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt inbound_body8 s
N( u dummyu s( t __name__t
__module__t __doc__R t CLASS_IDRu Rl Ro t PROPERTY_CLASSESR Rr R} R R ( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyRb á s
$ (6 R
t
__future__R R R9 t sysR t decimalR t ioR t structR R t specR t
exceptionsR t fiveR R
R R R
t utilsR R R t version_infot chrR R R( RC RG R R) R/ R2 R@ R7 R8 RU R RV RW RX RY RA Ra R R t objectRb ( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/serialization.pyt <module> sB ( h^ H %H