; Ñâ"Ic@s¾dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z d„Zd„Ze je jeeƒddZdZGd„d ejƒZiZe jdƒZe jdƒZGd „d eƒZGd „d eƒZd„ZGd„deƒZGd„dejeƒZGd„deƒZ Gd„deƒZ!d„Z"d„Z#Gd„deƒZ$dS(uRPC 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 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. iNcCs-tj|ƒ}t|tjƒpt‚|S(N(umarshaluloadsu isinstanceutypesuCodeTypeuAssertionError(umsuco((u(/mit/python/lib/python3.0/idlelib/rpc.pyu unpickle_code-scCs6t|tjƒpt‚tj|ƒ}t|ffS(N(u isinstanceutypesuCodeTypeuAssertionErrorumarshaludumpsu unpickle_code(ucoums((u(/mit/python/lib/python3.0/idlelib/rpc.pyu pickle_code2siiu 127.0.0.1cBs>|EeZdd„Zd„Zd„Zd„Zd„ZdS(cCs1|dko t}ntjj|||ƒdS(N(uNoneu RPCHandleru socketserveru TCPServeru__init__(uselfuaddru handlerclass((u(/mit/python/lib/python3.0/idlelib/rpc.pyu__init__Gs  cCsdS(u@Override TCPServer method, no bind() phase for connecting entityN((uself((u(/mit/python/lib/python3.0/idlelib/rpc.pyu server_bindLscCs|jj|jƒdS(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(usocketuconnectuserver_address(uself((u(/mit/python/lib/python3.0/idlelib/rpc.pyuserver_activatePscCs|j|jfS(u:Override TCPServer method, return already connected socket(usocketuserver_address(uself((u(/mit/python/lib/python3.0/idlelib/rpc.pyu get_requestYscCsêy‚WnÜtk o ‚YnÇtj}tdddd|ƒtdd|ƒtdtjƒjƒd|ƒtd|d|ƒtdt|ƒd|ƒtj d|ƒtd d|ƒtddd|ƒt j d ƒYnXd 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(ufileuUnhandled server exception!u Thread: %suClient Address: u Request: u# *** Unrecoverable, server exiting!iN( u SystemExitusysu __stderr__uprintu threadingucurrent_threaduget_nameurepru tracebacku print_excuosu_exit(uselfurequestuclient_addressuerf((u(/mit/python/lib/python3.0/idlelib/rpc.pyu handle_error]s  N(u__name__u __module__uNoneu__init__u server_binduserver_activateu get_requestu handle_error(u __locals__((u(/mit/python/lib/python3.0/idlelib/rpc.pyu RPCServerEs    u RPCServercBs|EeZdZddd„Zd„Zd„Zd„Zd„Zd„Z d„Z d„Z d „Z d „Z d „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZdZdZdZd„Zd„Zd„Zd„Zd„Zd„Z d„Z!dS(icCshtjƒ|_|dk o ||_n||_|dko t}n||_i|_i|_ dS(N( u threadingucurrent_threadu sockthreaduNoneu debuggingusocku objecttableuobjtableu responsesucvars(uselfusockuobjtableu debugging((u(/mit/python/lib/python3.0/idlelib/rpc.pyu__init__€s       cCs1|j}d|_|dk o|jƒndS(N(usockuNoneuclose(uselfusock((u(/mit/python/lib/python3.0/idlelib/rpc.pyuclose‹s   cCstjƒdS(u!override for specific exit actionN(uosu_exit(uself((u(/mit/python/lib/python3.0/idlelib/rpc.pyuexithook‘scGsn|jpdS|jdttjƒjƒƒ}x"|D]}|dt|ƒ}q9Wt|dtjƒdS(Nu ufile( u debuggingulocationustru threadingucurrent_threaduget_nameuprintusysu __stderr__(uselfuargsusua((u(/mit/python/lib/python3.0/idlelib/rpc.pyudebug•s #cCs||j|}|j|}|jƒd|j|<|jƒ|jƒq!W|jƒdS(u+action taken upon link being closed by peeru handle_EOFuEOFN(uEOFN( uEOFhookudebugucvarsuacquireuNoneu responsesunotifyureleaseuexithook(uselfukeyucv((u(/mit/python/lib/python3.0/idlelib/rpc.pyu handle_EOFÎs       cCsdS(uBClasses using rpc client/server can override to augment EOF actionN((uself((u(/mit/python/lib/python3.0/idlelib/rpc.pyuEOFhookÛsN("u__name__u __module__unextsequNoneu__init__ucloseuexithookudebuguregisteru unregisteru localcallu remotecallu remotequeueu asynccallu asyncqueueu asyncreturnudecoderesponseudecode_interrupthookumainloopu getresponseu_proxifyu _getresponseunewsequ putmessageubuffubufneedubufstateu pollpacketu_stage0u_stage1u pollmessageu pollresponseu handle_EOFuEOFhook(u __locals__((u(/mit/python/lib/python3.0/idlelib/rpc.pyuSocketIO|s>       *               I uSocketIOcBs|EeZdS(N(u__name__u __module__(u __locals__((u(/mit/python/lib/python3.0/idlelib/rpc.pyu RemoteObjectás u RemoteObjectcCs t|ƒ}|t||EeZdZdZd„Zd„Zd„Zd„ZdS(cCs||_||_dS(N(usockiouoid(uselfusockiouoid((u(/mit/python/lib/python3.0/idlelib/rpc.pyu__init__ s cCs¬|jdko|jƒn|jj|ƒot|j|j|ƒS|jdko|jƒn||jko&|jj |jd|fiƒ}|St |ƒ‚dS(Nu__getattribute__( u_RPCProxy__methodsuNoneu_RPCProxy__getmethodsugetu MethodProxyusockiouoidu_RPCProxy__attributesu_RPCProxy__getattributesu remotecalluAttributeError(uselfunameuvalue((u(/mit/python/lib/python3.0/idlelib/rpc.pyu __getattr__$scCs%|jj|jddiƒ|_dS(Nu__attributes__((usockiou remotecalluoidu_RPCProxy__attributes(uself((u(/mit/python/lib/python3.0/idlelib/rpc.pyu__getattributes2scCs%|jj|jddiƒ|_dS(Nu __methods__((usockiou remotecalluoidu_RPCProxy__methods(uself((u(/mit/python/lib/python3.0/idlelib/rpc.pyu __getmethods6sN( u__name__u __module__uNoneu_RPCProxy__methodsu_RPCProxy__attributesu__init__u __getattr__u_RPCProxy__getattributesu_RPCProxy__getmethods(u __locals__((u(/mit/python/lib/python3.0/idlelib/rpc.pyuRPCProxys    uRPCProxycCs}xAt|ƒD]3}t||ƒ}t|dƒod||sB                2ÿf