//usr/lib64/lib64//lib64/lib64//
ۜSec @ s d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l
Z
d d l Z d d l Z d d l
Z
d d l Z d Z d Z e j e
j e e d d Z d Z d e j f d YZ i Z e
j
d
Z e
j
d
Z d e f d YZ d
e f d YZ d Z d e f d YZ d e j e f d YZ d e f d YZ d e f d YZ! d Z" d Z# d e f d YZ$ d S( s RPC Implemention, originally written for the Python Idle IDE
For security reasons, GvR requested that Idle's Python execution server process
connect to the Idle process, which listens for the connection. Since Idle has
only one client per server, this was not a limitation.
+---------------------------------+ +-------------+
| SocketServer.BaseRequestHandler | | SocketIO |
+---------------------------------+ +-------------+
^ | register() |
| | unregister()|
| +-------------+
| ^ ^
| | |
| + -------------------+ |
| | |
+-------------------------+ +-----------------+
| RPCHandler | | RPCClient |
| [attribute of RPCServer]| | |
+-------------------------+ +-----------------+
The RPCServer handler class is expected to provide register/unregister methods.
RPCHandler inherits the mix-in class SocketIO, which provides these methods.
See the Idle run.main() docstring for further information on how this was
accomplished in Idle.
iNc C s t j | } | S( N( t marshalt loads( t mst co( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt
unpickle_code- s c C s t j | } t | f f S( N( R t dumpsR ( R R ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt pickle_code2 s i i s 127.0.0.1t RPCServerc B s8 e Z d d Z d Z d Z d Z d Z RS( c C s/ | d k r t } n t j j | | | d S( N( t Nonet
RPCHandlert SocketServert TCPServert __init__( t selft addrt handlerclass( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR G s c C s d S( s@ Override TCPServer method, no bind() phase for connecting entityN( ( R
( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt server_bindL s c C s | j j | j d S( s Override TCPServer method, connect() instead of listen()
Due to the reversed connection, self.server_address is actually the
address of the Idle Client to which we are connecting.
N( t sockett connectt server_address( R
( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt server_activateP s c C s | j | j f S( s: Override TCPServer method, return already connected socket( R R ( R
( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt get_requestY s c C s y Wn t k
r n t j } | d d d IJ| d IJ| d t j j IJ| d I| IJ| d It | IJt j d | | d IJ| d d IJt j
d
n Xd S( s Override TCPServer method
Error message goes to __stderr__. No error message if exiting
normally or socket raised EOF. Other exceptions not handled in
server code will cause os._exit.
s
t -i( s Unhandled server exception!s
Thread: %ss Client Address: s Request: t files#
*** Unrecoverable, server exiting!i N( t
SystemExitt syst
__stderr__t threadingt
currentThreadt getNamet reprt tracebackt print_exct ost _exit( R
t requestt client_addresst erf( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt handle_error] s
N( t __name__t
__module__R R R R R R& ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR E s
i t SocketIOc B s e Z d 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 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( i c C sd t j | _ | d k r' | | _ n | | _ | d k rE t } n | | _ i | _ i | _ d S( N(
R R t
sockthreadR t debuggingt sockt objecttablet objtablet responsest cvars( R
R, R. R+ ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR s c C s/ | j } d | _ | d k r+ | j n d S( N( R, R t close( R
R, ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR1 s c C s t j d d S( s! override for specific exit actioni N( R! R" ( R
( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt exithook s c G sf | j s
d S| j d t t j j } x" | D] } | d t | } q7 Wt j | IJd S( Nt ( R+ t locationt strR R R R R ( R
t argst st a( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt debug s #
c C s | | j | 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 Rj N( s EOFN( t EOFhookR9 R0 R{ R R/ R R| R2 ( 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 R1 R2 R9 R< R> R\ R_ Ra R] R` R^ Rh Rk Rr Rg Rt Rs Rb Rd R R R R R R R Rz R R ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR) | s> *
I
RM c B s e Z RS( ( R' R( ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRM s c C s t | } | t | sB
2 f