ž
©ÿ fÙQ c @ 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 d l Z d d „ Z d d „ Z e j e j e e ƒ d d Z d Z Gd
d „ d e j ƒ Z i Z e j d ƒ Z e j d ƒ Z Gd d
„ d
e ƒ Z Gd d „ d e ƒ Z d d „ Z Gd d „ d e ƒ Z Gd d „ d e j e ƒ Z Gd d „ d e ƒ Z! Gd d „ d e ƒ Z" d d „ Z# d d „ Z$ Gd d „ d e ƒ Z% d d! „ Z& d S(" u 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.
i Nc C s+ t j | ƒ } t | t j ƒ s' t ‚ | S( N( u marshalu loadsu
isinstanceu typesu CodeTypeu AssertionError( u msu co( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu
unpickle_code. s u
unpickle_codec C s4 t | t j ƒ s t ‚ t j | ƒ } t | f f S( N( u
isinstanceu typesu CodeTypeu AssertionErroru marshalu dumpsu
unpickle_code( u cou ms( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu pickle_code3 s u pickle_codei i u 127.0.0.1c B sS | Ee Z d Z d d d „ Z d d „ Z d d „ Z d d „ Z d d
„ Z d S( u RPCServerc C s/ | d k r t } n t j j | | | ƒ d S( N( u Noneu
RPCHandleru socketserveru TCPServeru __init__( u selfu addru handlerclass( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu __init__H s u RPCServer.__init__c C s d S( u@ Override TCPServer method, no bind() phase for connecting entityN( ( u self( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu server_bindM s u RPCServer.server_bindc C s | j j | j ƒ d S( uÎ 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( u socketu connectu server_address( u self( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu server_activateQ s u RPCServer.server_activatec C s | j | j f S( u: Override TCPServer method, return already connected socket( u socketu server_address( u self( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu get_requestZ s u RPCServer.get_requestc C så y ‚ Wn× t k
r ‚ Ynà t j } t d d d d | ƒt d d | ƒt d t j ƒ j d | ƒt d | d | ƒt d t | ƒ d | ƒt j d | ƒ t d d | ƒt d d d | ƒt
j d
ƒ Yn Xd S( uÜ 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.
u
u -i( u fileu Unhandled server exception!u
Thread: %su Client Address: u Request: u#
*** Unrecoverable, server exiting!i N( u
SystemExitu sysu
__stderr__u printu threadingu current_threadu nameu repru tracebacku print_excu osu _exit( u selfu requestu client_addressu erf( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu handle_error^ s
u RPCServer.handle_errorN( u __name__u
__module__u __qualname__u Noneu __init__u server_bindu server_activateu get_requestu handle_error( u
__locals__( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu RPCServerF s
u RPCServerc B sv | Ee Z d Z d Z d: d: d d „ Z d d „ Z d d „ Z d d „ Z d
d „ Z d d
„ Z
d d „ Z d d „ Z d d „ Z
d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z d d! „ Z d" d# „ Z d$ d% „ Z d& d' „ Z d( d) „ Z d* Z d+ Z d Z d, d- „ Z d. d/ „ Z d0 d1 „ Z d2 d3 „ Z d4 d5 „ Z d6 d7 „ Z! d8 d9 „ Z" d: S(; u SocketIOi c C sd t j ƒ | _ | d k r' | | _ n | | _ | d k rE t } n | | _ i | _ i | _ d S( N(
u threadingu current_threadu
sockthreadu Noneu debuggingu socku objecttableu objtableu responsesu cvars( u selfu socku objtableu debugging( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu __init__ s u SocketIO.__init__c C s/ | j } d | _ | d k r+ | j ƒ n d S( N( u socku Noneu close( u selfu sock( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu closeŒ s u SocketIO.closec C s t j d ƒ d S( u! override for specific exit actioni N( u osu _exit( u self( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu exithook’ s u SocketIO.exithookc G si | j s
d S| j d t t j ƒ j ƒ } x" | D] } | d t | ƒ } q4 Wt | d t j ƒd S( Nu u file( u debuggingu locationu stru threadingu current_threadu nameu printu sysu
__stderr__( u selfu argsu su a( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu debug– s
u SocketIO.debugc C s | | j | } | j | } | j ƒ d | j | <| j ƒ | j ƒ q! W| j ƒ d S( u+ action taken upon link being closed by peeru
handle_EOFu EOFN( u EOFN( u EOFhooku debugu cvarsu acquireu Noneu responsesu notifyu releaseu exithook( u selfu keyu cv( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu
handle_EOFÖ s
u SocketIO.handle_EOFc C s d S( uB Classes using rpc client/server can override to augment EOF actionN( ( u self( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu EOFhookã s u SocketIO.EOFhookN(# u __name__u
__module__u __qualname__u nextsequ Noneu __init__u closeu exithooku debugu registeru
unregisteru localcallu
remotecallu remotequeueu asynccallu
asyncqueueu asyncreturnu decoderesponseu decode_interrupthooku mainloopu getresponseu _proxifyu _getresponseu newsequ
putmessageu buffu bufneedu bufstateu
pollpacketu _stage0u _stage1u pollmessageu pollresponseu
handle_EOFu EOFhook( u
__locals__( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu SocketIO} s> .
I
u SocketIOc B s | Ee Z d Z d S( u RemoteObjectN( u __name__u
__module__u __qualname__( u
__locals__( ( u0 /opt/alt/python33/lib64/python3.3/idlelib/rpc.pyu RemoteObjecté s u RemoteObjectc C s t | ƒ } | t | sF
2ÿ m