← Back
Editing: rpc.pyc
� { fc @ 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 Implementation, 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. i����Nc C s+ t j | � } t | t j � s' t � | S( N( t marshalt loadst isinstancet typest CodeTypet AssertionError( t mst co( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt unpickle_code- s c C s4 t | t j � s t � t j | � } t | f f S( N( R R R R 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 R0 R2 R/ ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR � s c C s/ | j } d | _ | d k r+ | j � n d S( N( R0 R t close( R R0 ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR5 � 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 | <d S( N( R2 ( R t oidt object( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt register� s c C s& y | j | =Wn t k r! n Xd S( N( R2 t KeyError( R R> ( ( 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 | <n | j d | | | | | � | j | | f � | S( NRG s asynccall:%d:( t newseqR R R. t ConditionR4 R= t putmessage( R R> 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 | <n | j d | | | | | � | j | | f � | S( NRH s asyncqueue:%d:( Re R R R. Rf R4 R= Rg ( R R> 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 rQ x� | j | | � } | d k r( | Sq( Wn} | j | } | j � x | | j k r� | j � qk 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 r� y> t j g | j g g � \ } } } | j j | t � } Wn t t f k r� t d � n X| | } qz Wd S( Ns putmessage:%d:i s Cannot pickle:s <is socket no longer exists( R= t pickleR t PicklingErrorR R R" t structt packt lent selectR0 t sendt BUFSIZEt AttributeErrorRK t IOError( R t messageR; t rt wt xt n( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRg A s $ Rr i c C s� | j � t | j � | j k r� t j | j j � g g g | � \ } } } t | � d k re d Sy | j j t � } Wn t j k r� t � n Xt | � d k r� t � n | j | 7_ | j � n | j � S( Ni ( t _stage0R� t buffert bufneedR� R0 t filenoR t recvR� R RT Rs t _stage1( R Ri R� R� R� R; ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt pollpacketU s - c C sj | j d k rf t | j � d k rf | j d } | j d | _ t j d | � d | _ d | _ n d S( Ni i s <ii ( t bufstateR� R� R� t unpackR� ( R R; ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR� e s $ c C sd | j d k r` t | j � | j k r` | j | j } | j | j | _ d | _ d | _ | Sd S( Ni i i ( R� R� R� R� ( R t packet( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR� l s ' c C s� | j | � } | d k r d Sy t j | � } Wn] t j k r� t j d IJt j d It | � IJt j d t j � t j d IJ� n X| S( Ns -----------------------s cannot unpickle packet:R ( R� R R� R t UnpicklingErrorR R R" R# t print_stack( R Ri R� R� ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyt pollmessaget s c C s� x�y t j d � } Wn t j k r, n, X| \ } } | d | f f } | j | � y# | j | � } | d k rz d SWn- t k r� | j � d St k r� d SX| \ } } | d } | j d | | f � | d k rU| j d | � | j | | � } | j d | | f � | d k r@| j | | f � q | d k r q q q | | k re| S| j j | d � } | d k r | j � | | j | <| j � | j � q q q Wd S( sR Handle messages received on the socket. Some messages received may be asynchronous 'call' or 'queue' requests, and some may be responses for other threads. 'call' requests are passed to self.localcall() with the expectation of immediate execution, during which time the socket is not serviced. 'queue' requests are used for tasks (which may block or hang) to be processed in a different thread. These requests are fed into request_queue by self.localcall(). Responses to queued requests are taken from response_queue and sent across the link with the associated sequence numbers. Messages in the queues are (sequence_number, request/response) tuples and code using this module removing messages from the request_queue is responsible for returning the correct sequence number in the response_queue. pollresponse() will loop until a response message with the myseq sequence number is received, and will save other responses in self.responses and notify the owning thread. i RE s pollresponse:%d:myseq:%sRG RH s pollresponse:%d:localcall:call:s% pollresponse:%d:localcall:response:%sN( RG RH ( t response_queuet gett Queuet EmptyRg R� R Rs t handle_EOFR� R= R_ R4 R} R3 t notifyR~ ( R Rt Ri t qmsgRU Rl R� t resqRV t cv( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR| � sN c C sq | j � | j d � xI | j D]> } | j | } | j � d | j | <| j � | j � q! W| j � d S( s+ action taken upon link being closed by peerR� Rm N( Rm N( 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 | <t | � S( N( t idR1 Rx ( RY R> ( ( 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 __getattributes- 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 __getmethods1 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 | | <q q Wt | � t j k rj t | j | � n t | � t j k r� x! | j D] } t | | � q� Wn d S( Nt __call__i ( t dirRO RN R� R t InstanceTypeRL t __class__t ClassTypet __bases__( RY RZ R� t attrt super( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRL 5 s c C sF x? t | � D]1 } t | | � } t | d � s d | | <q q Wd S( NR� i ( R� RO RN ( RY R[ R� R� ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyRM B s R� c B s e Z d � Z d � Z RS( c C s | | _ | | _ | | _ d S( N( R� R> R� ( R R� R> R� ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR J 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� O s !( R+ R, R R� ( ( ( s# /usr/lib64/python2.7/idlelib/rpc.pyR� H 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 <module> sB 2� c
Save File
Cancel