/usr/lib/python2.6/site-packages/supervisor
Edit: /usr/lib/python2.6/site-packages/supervisor/http_client.pyc (8759B)
Ñò
FATc @ s d d k Z d d k Z d d k Z d d k Z d d k Z d d k l Z d Z d Z e e Z d e f d „ ƒ YZ
d e e i f d „ ƒ YZ e
d j or e i d
Z e
ƒ Z e e ƒ Z y e i e ƒ Wn) e j
o Z e i e d e ƒ n Xe i ƒ d GHn d S(
iÿÿÿÿN( t urlparses
s
t Listenerc B s> e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( c C s d S( N( ( t selft urlt status( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR s c C s d S( N( ( R R t error( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR s c C s d S( N( ( R R t namet value( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt response_header s c C s d S( N( ( R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt done s c C s! t i i | ƒ t i i ƒ d S( N( t syst stdoutt writet flush( R R t data( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt feed s c C s d S( N( ( R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt close s ( t __name__t
__module__R R R R R R ( ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR s t HTTPHandlerc B s° e Z d d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
d „ Z d
„ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( t c C sµ t t | ƒ i ƒ t i i | ƒ | | _ d | _ d | _ | i t ƒ d | _
| i | _ d | _
d | _ d | _ d | _ d | _ | | _ | | _ d | _ t | _ d S( Ns Supervisor HTTP ClientR i ( t superR t __init__t asynchatt
async_chatt listenert
user_agentt buffert set_terminatort CRLFt connectedt status_linet partt
chunk_sizet
chunk_readt length_readt lengtht Nonet encodingt usernamet passwordR t Falset
error_handled( R R R' R( ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR $ s"
c
C sC | i d j d f p t ‚ | | | _ t | i ƒ \ } } } } } } | d j o
t ‚ n | | _ d | j o( | i d d ƒ \ } }
t |
ƒ }
n
| } d }
| | _ |
| _ | d j o6 | } | i
t i t i
ƒ | i | | i f ƒ n? | d j o1 | d } | i
t i t i
ƒ | i | ƒ n d S( Ns Already doing a gett httpt unixt :i iP i ( R+ R, ( R R% t AssertionErrorR t NotImplementedErrort hostt splitt intt patht portt
create_sockett sockett AF_INETt SOCK_STREAMt connectt AF_UNIX(
R t serverurlR3 t schemeR0 t path_ignoredt paramst queryt fragmentt hostnameR4 t ipt
socketname( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt get7 s*
!
c C s@ | i i | i ƒ d | _ | i ƒ | i i ƒ d | _ d S( Ni t CLOSED( R R R R t del_channelR6 ( R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR Q s
c C s( | i d | | f ƒ | i t ƒ d S( Ns %s: %s( t pushR ( R R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt headerX s c C s‡ | i t j o d Sd p
| i o] t i ƒ \ } } } | G| G| GHd | i | f } | i | _ | i ƒ | GHt | _ n d S( Ni s Cannot connect to %s, error: %s( R* t TrueR R
t exc_infoR t ignoreR R ( R t tt vt tbt msg( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt handle_error\ s
c C sð d | _ d } d } | i d | | i | f ƒ | i t ƒ | i d | i ƒ | i d d ƒ | i d d ƒ | i d
| i ƒ | i oC d | i | i f } t i
| ƒ i ƒ } | i d d
| ƒ n | i t ƒ | i t ƒ d S( Ni t GETs HTTP/1.1s %s %s %st Hosts Accept-Encodingt chunkedt Accepts */*s
User-agents %s:%st
Authorizations Basic %s( R RG R3 R RH R0 R R( R' t base64t encodestringt strip( R t methodt versiont auth( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt handle_connecth s
c C s | i i | i | ƒ d S( N( R R R ( R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR { s c C sD | i | | _ | i | i j o | i | i ƒ d | _ n d S( NR ( R R t bodyR ( R t bytes( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt collect_incoming_data~ s c C s | i ƒ d | _ d S( NR ( R R ( R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt found_terminator„ s
c C s
d | _ d S( NR ( R ( R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyRK ˆ s c C s¸ | i } | i d d ƒ \ } } } t | ƒ } | i d ƒ p t | ƒ ‚ n | i i | i | ƒ | d j o | i | _
n) | i | _
d | i | f GH| i ƒ | | | f S( Ni s HTTP/iÈ s Cannot read %s, status code %s(
R R1 R% R2 t
startswitht
ValueErrorR R R t headersR RK R ( R t lineRZ R t reason( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR ‹ s
c C sì | i } | p@ | i d j o | i | _ qè | i | _ | i | i ƒ n™ | i d d ƒ \ } } | oy | or | i ƒ } | i ƒ } | d i ƒ j o
| | _ n' | d i ƒ j o t
| ƒ | _ n | i | | ƒ n d S( NRS R- i s Transfer-Encodings Content-Length( R R& t chunked_sizeR R] R R$ R1 t lowerRX R2 R ( R Rd R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyRc s
c C s | i i | i | | ƒ d S( N( R R R ( R R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR ° s c C s | i ƒ | i ƒ d S( N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR] ³ s
c C s | i i | i ƒ d S( N( R R R ( R ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR · s c C sw | i } | p d St | i ƒ d d ƒ } | d j o | i | _ n | i | ƒ | i | _ | i | 7_ d S( Ni i ( R R2 R1 t trailerR R t chunked_bodyR$ ( R Rd R! ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyRf º s
c C s3 | i } | i t ƒ | i | _ | i | ƒ d S( N( R R R Rf R R ( R Rd ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyRi Æ s
c C s2 | i } | t j o | i ƒ | i ƒ n d S( N( R R R R ( R Rd ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyRh Ì s
N( R R R% R RD R RH RP R\ R R_ R` RK R Rc R R] R Rf Ri Rh ( ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyR # s$ t __main__i s Error connecting '%s't -( R
R6 t asyncoreR RV R t CRt LFR t objectR R R R t argvR R t handlerRD t Exceptiont eR t loop( ( ( s: /usr/lib/python2.6/site-packages/supervisor/http_client.pyt
s(
±