( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt
unregister s
c C s | j d | y | \ } \ } } } } Wn t k
r@ d SX| | j k ra d d | f f S| j | } | d k r i } t | | d | f S| d k r i }
t | |
d |
f St | | s d d | f f St | | } y | d k r5| | | } t | t r+t | } n d | f S| d
k rat
j | | | | f f d Sd d | f SWnd t
k
r nQ t j k
r n; d
}
t j |
| | | f IJt j d t j d SXd S( Ns
localcall:t ERRORs Bad request formats Unknown object id: %rt __methods__t OKt __attributes__s Unsupported method name: %rt CALLt QUEUEt QUEUEDs Unsupported message type: %ssU *** Internal Error: rpc.py:SocketIO.localcall()
Object: %s
Method: %s
Args: %s
R t EXCEPTION( RC s Bad request format( RI N( RJ N( R= t TypeErrorR2 t _getmethodst _getattributest hasattrt getattrR t RemoteObjectt remotereft
request_queuet putR R R t errorR R R# R$ ( R t seqR' t howR> t
methodnameR: t kwargst objt methodst
attributest methodt rett msg( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt localcall sL
c C s8 | j d | | | j | | | | } | j | S( Ns remotecall:asynccall: ( R= t asynccallt asyncreturn( R R> RW R: RX RU ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt
remotecall s c C s8 | j d | | | j | | | | } | j | S( Ns remotequeue:asyncqueue: ( R= t
asyncqueueRa ( R R> RW R: RX RU ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt remotequeue s c C s d | | | | f f } | j } t j | j k rU t j } | | j | RW R: RX R' RU t cvar( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR` s c C s d | | | | f f } | j } t j | j k rU t j } | | j | RW R: RX R' RU Rh ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRc s c C sG | j d | | j | d d } | j d | | | j | S( Ns# asyncreturn:%d:call getresponse(): t waitg?s asyncreturn:%d:response: ( R= t getresponset decoderesponse( R RU t response( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRa s c C s | \ } } | d k r | S| d k r, d S| d k rI | j d d S| d k rp | j d | j d S| d k r | j d | t | n t | | f d S( NRE RI RJ s decoderesponse: EXCEPTIONt EOFs decoderesponse: EOFRC s decoderesponse: Internal ERROR:( R R= t decode_interrupthookt RuntimeErrort SystemError( R Rl RV t what( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRk s
c C s
t d S( t N( t EOFError( R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRn s c C s@ y | j d d d d Wn t k
r; | j d d SXd S( s Listen on socket until I/O not ready or EOF
pollresponse() will loop looking for seq number None, which
never comes, and exit on EOFError.
t myseqRi g?s mainloop:returnN( Rj R Rs R= ( R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt mainloop
s
c C sU | j | | } | d k rQ | \ } } | d k rQ | | j | f } qQ n | S( NRE ( t _getresponseR t _proxify( R Rt Ri Rl RV Rq ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRj s c C sE t | t r t | | j St | t j rA t | j | S| S( N( R t RemoteProxyt RPCProxyR> R t ListTypet mapRw ( R RY ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRw s
c C s | j d | t j | j k rP x | j | | } | d k r( | Sq( n} | j | } | j x | | j k r | j qj W| j | } | j d | | f | j | =| j | =| j
| Sd S( Ns _getresponse:myseq:s- _getresponse:%s: thread woke up: response: %s( R= R R R. t pollresponseR R4 t acquireR3 Ri t release( R Rt Ri Rl Rh ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRv ' s"
c C s | j d | _ } | S( Ni ( t nextseq( R RU ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRe = s c C s | j d | d y t j | } Wn0 t j k
rZ t j d It | IJ n Xt j d t | | } x t | d k ry> t
j
g | j g g \ } } } | j j | t
} Wn6 t t f k
r t d qz t j k
r qz X| | } qz Wd S( Ns putmessage:%d:i s Cannot pickle:s } | j | } | j d | j | <| j | j q! W| j d S( s+ action taken upon link being closed by peerR Rm N( s EOFN( t EOFhookR= R4 R} R R3 R R~ R6 ( R t keyR ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s
c C s d S( sB Classes using rpc client/server can override to augment EOF actionN( ( R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s N(" R+ R, R R R R5 R6 R= R@ RB R_ Rb Rd R` Rc Ra Rk Rn Ru Rj Rw Rv Re Rg R R R R R R R R| R R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR- | s> *
I
RP c B s e Z RS( ( R+ R, ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRP s c C s t | } | t | ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRQ s
Rx c B s e Z d Z RS( c C s
| | _ d S( N( R> ( R R> ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s ( R+ R, R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRx s R
c B s/ e Z e Z d Z d Z d Z d Z RS( s #Sc C s6 | | _ t j | | t j j | | | | d S( N( t current_handlerR- R R t BaseRequestHandler( R R0 R t svr( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s c C s | j d S( s( handle() method required by SocketServerN( Ru ( R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt handle s c C s
t | | S( N( Ry ( R R> ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt get_remote_proxy s ( R+ R, t FalseR/ R8 R R R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR
s
t RPCClientc B sA e Z e Z d Z d Z e j e j d Z d Z
d Z RS( s #Ci c C s9 t j | | | _ | j j | | j j d d S( Ni ( R t listening_sockt bindt listen( R t addresst familyt type( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s c C sw | j j \ } } | j r4 t j d I| IJn | d t k rW t j | | n t j d I| IJt j d S( Ns ****** Connection request from i s ** Invalid host: (
R t acceptR/ R R t LOCALHOSTR- R R RT ( R t working_sockR ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s c C s
t | | S( N( Ry ( R R> ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s ( R+ R, R R/ R8 R R t AF_INETt SOCK_STREAMR R R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s
Ry c B s8 e Z d Z d Z d Z d Z d Z d Z RS( c C s | | _ | | _ d S( N( t sockioR> ( R R R> ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s c C s | j d k r | j n | j j | rD t | j | j | S| j d k r` | j n | | j k r | j j | j d | f i } | St
| d S( Nt __getattribute__( t _RPCProxy__methodsR t _RPCProxy__getmethodsR t MethodProxyR R> t _RPCProxy__attributest _RPCProxy__getattributesRb R ( R t namet value( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt __getattr__" s
c C s% | j j | j d d i | _ d S( NRF ( ( R Rb R> R ( R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt __getattributes0 s c C s% | j j | j d d i | _ d S( NRD ( ( R Rb R> R ( R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt __getmethods4 s N( R+ R, R R R R R R R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRy s c C s x? t | D]1 } t | | } t | d r
d | | R ( R R R> R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR M s c O s% | j j | j | j | | } | S( N( R Rb R> R ( R R: RX R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR R s !( R+ R, R R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR K s (% t __doc__R R% R R R R t cPickleR R R R# t copy_regR R R R
R R R R R R1 RR R R? R- RP RQ Rx R R
R Ry RL RM R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt sB
2 f