/usr/lib/python2.6/site-packages/supervisor/medusa
Edit: /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyc (12285B)
Ñò
FATc
@ s6 d Z d d k Z d d k Z d d k Z d d k Z d d k Z e i e ƒ d Z d d k Z d d k Z d d k
l
Z
d d k Z d e i f d „ ƒ YZ
d e i f d „ ƒ YZ d „ Z d
e
f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ d d d „ ƒ YZ e d j o d e i j o! e i i d ƒ d Ge ƒ Z n d Z d e i j o e i i d ƒ d Z n d Z e e i ƒ d j o e i e i d ƒ Z n d Z e d j o? e e d e ƒ Z e o" e e _ d d k! Z! e! e _" q n e d e ƒ Z e i# d d ƒ n d S( s: $Id: monitor.py,v 1.1.1.1 2006/06/26 06:36:05 chrism Exp $iÿÿÿÿNi ( t countert monitor_channelc B sM e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( i c C sÓ t i i | | ƒ | | _ | | _ | i d ƒ d | _ t i d i i
ƒ | _ | i d t i
d ƒ | i t i d ƒ | i d | ƒ | i d ƒ | i ƒ | i i ƒ | _ t ƒ | _ g | _ d S( Ns
t t __main__s Python s Welcome to %s
s& [Hint: try 'from __main__ import *']
( t asynchatt
async_chatt __init__t servert addrt set_terminatort datat syst modulest __dict__t copyt local_envt pusht versiont copyrightt promptt total_sessionst as_longt numberR t line_countert
multi_line( t selfR t sockR ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR s
c C s | i d ƒ d S( Ns ÿý"( R ( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt handle_connect, s c C s$ | i i i ƒ t i i | ƒ d S( N( R t closed_sessionst incrementR R t close( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR 0 s c C s | i d ƒ d S( Ns >>> ( R ( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR 4 s c C sE | i | | _ t | i ƒ d j o | i d ƒ | i ƒ n d S( Ni s BCNU
( R
t lenR t close_when_done( R R
( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt collect_incoming_data7 s
c B s
| i | i ƒ } d | _ | i i ƒ | o | i o | i ƒ d S| d j o | i d ƒ | i ƒ d Se i } e i
} z.e | | ƒ } | e _ | e _
y²yq | i o
e ‚ n e
| e | ƒ d ƒ } e | | i ƒ } d } | d j o e | ƒ GHn | | i d
%s( s s exit( R% s ( t
clean_lineR
R R R R R R R t stdoutt stderrt output_producert SyntaxErrort compilet reprR# R t Nonet appendt stringt joint exc_infot asyncoret compact_tracebackt log_infoR t push_with_producer( R t linet oldoutt olderrt pt cot resultt methodt whyt tt vt tbt filet funt tbinfo( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt found_terminator> s|
!%
c C sl g } xS | D]K } t | ƒ } | d j o, | d j o | d } qX | i | ƒ q
q
Wt i | d ƒ S( Ni i i± iÿÿÿÿR ( i i± ( t ordR1 R2 R3 ( R R9 t charst cht oc( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR) s
(
t __name__t
__module__t try_linemodeR R R R R! RG R) ( ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR s Rt monitor_serverc B sB e Z d e Z e Z d d d „ Z d „ Z d „ Z d „ Z RS( s Monitor Server (V%s)s 127.0.0.1iW c C sš | | _ | | _ | i t i t i ƒ | i ƒ | i | | f ƒ | i d | i | f ƒ | i
d ƒ d | _ d | _ t
ƒ | _ t
ƒ | _ d S( Ns %s started on port %di i ( t hostnamet portt
create_sockett sockett AF_INETt SOCK_STREAMt set_reuse_addrt bindR7 t SERVER_IDENTt listent closedt failed_authsR R R ( R RP RQ ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR ¢ s
c C s d S( Ni ( ( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt writable¯ s c C sG | i ƒ \ } } | i d | ƒ | i | | | ƒ | i i ƒ d S( Ns& Incoming monitor connection from %s:%d( t acceptR7 t
channel_classR R ( R t connR ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt
handle_accept² s c C s= t i d | i d | i d | i i ƒ | i i ƒ ƒ S( Ns %s
s
Total Sessions: %ss
Current Sessions: %d( t producerst simple_producerRX R R R ( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt status¸ s (
RL RM t VERSIONRX R R^ R R\ R` Rc ( ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyRO œ s
c C sD t i ƒ } | i | ƒ t i t d „ t d | i ƒ ƒ ƒ d ƒ S( Nc S s t t | ƒ ƒ d S( i ( t hexRH ( t x( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt Å s R ( t md5t updateR2 t
joinfieldst mapR0 t digest( t st m( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt
hex_digestÁ s
t secure_monitor_channelc B s e Z d Z d „ Z d „ Z RS( i c C s§ t i i | | ƒ | | _ | | _ | i d ƒ d | _ h | _ t t i ƒ ƒ | _
d | _ t ƒ | _
t | i i ƒ ƒ | _ g | _ | i | i
d ƒ d S( Ns
R i ( R R R R R R R
R t strt timet timestampt countR R t intR R R R R ( R R R R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR Ì s
c C sÙ | i p¾ t d | i | i i f ƒ | i j o8 | i d | d ƒ | i i d | i _ | i ƒ qÕ d | _ | i d t
i d ƒ | i t
i d ƒ | i d | ƒ | i
ƒ d | _ n t i | ƒ d S( Ns %s%ss %s: failed authorizationR( i s Python s
s Welcome to %s
R ( t
authorizedRo Rs R t passwordR
R7 R[ R R R R R R R RG ( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyRG Ü s
)
( RL RM Rv R RG ( ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyRp É s t secure_encrypted_monitor_channelc B s) e Z d Z d „ Z d „ Z d „ Z RS( s+ Wrap send() and recv() with a stream cipherc C sM | i } | i i | ƒ | _ | i i | ƒ | _ t i | | | | ƒ d S( N( Rw t ciphert newt outgoingt incomingRp R ( R R R_ R t key( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR ï s c C s" | i i | ƒ } t i | | ƒ S( N( R{ t encryptRp t send( R R
t ed( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR õ s c C s8 t i | | ƒ } | o | i i | ƒ } | S| Sd S( N( Rp t recvR| t decrypt( R t
block_sizeR
t dd( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR ú s
( RL RM t __doc__R R R ( ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyRx ì s t secure_monitor_serverc B s& e Z e Z d d d „ Z d „ Z RS( R iW c C s t i | | | ƒ | | _ d S( N( RO R Rw ( R Rw RP RQ ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR s c C s* t i | ƒ } | i d | i | _ | S( Ns$
Failed Authorizations: %d( RO Rc R
R[ ( R R< ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyRc s ( RL RM Rp R^ R Rc ( ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR† s R, c B sP e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( c C s | | _ d | _ | | _ d S( NR ( t channelR
R+ ( R R‡ t real_stderr( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR s c C s+ t | i ƒ d j o | i i ƒ n d S( Ni i i ( R R
R‡ R ( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt
check_data s c C sB t i | d ƒ } t i | d ƒ } | i | | _ | i ƒ d S( Ns
s
( R2 t splitfieldsR3 R
R‰ ( R R
t lines( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt write s c C s" | i | d | _ | i ƒ d S( Ns
( R
R‰ ( R R9 ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt writeline$ s c C s. | i t i | d ƒ d | _ | i ƒ d S( Ns
( R
R2 Rj R‰ ( R R‹ ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt
writelines( s c C s d S( N( ( R ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt flush/ s c G s d S( N( ( R t args( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt softspace2 s c C s4 | i o" | i d } | i d | _ | Sd Sd S( Ni R ( R
( R R> ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt more5 s
(
RL RM R R‰ RŒ R RŽ R R‘ R’ ( ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyR, s R s -ss Enter password: s -ei i iW R t use_poll( ($ t RCS_IDRh RS R2 R Rr t splitRd R5 R R Ra R R t
dispatcherRO Ro Rp Rx R† R, RL t argvt removet raw_inputRw R0 R~ R t atoiRQ Rm R^ t sapphireRy t loop( ( ( s= /usr/lib/python2.6/site-packages/supervisor/medusa/monitor.pyt sL „% #+