]0Q @ s 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 l Z d d Z d d Z d d d Z Gd d d e j Z 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)% Nc C s t j | } | S)N)marshalloads)msco r (/opt/alt/python35/lib64/python3.5/rpc.py
unpickle_code/ s r c C s t j | } t | f f S)N)r dumpsr )r r r r r pickle_code4 s r
c C s2 t j } t | | } | j | | j S)N)ioBytesIO CodePicklerdumpgetvalue)objprotocolfpr r r r 9 s
r c @ s/ e Z d Z e j e i Z e j e j d S)r
N) __name__
__module__ __qualname__typesCodeTyper
dispatch_tableupdatecopyregr r r r r
? s r
i z 127.0.0.1c @ sO e Z d Z d d d Z d d Z d d Z d d Z d
d Z d S) RPCServerNc C s, | d k r t } t j j | | | d S)N)
RPCHandler socketserver TCPServer__init__)selfaddrZ handlerclassr r r r! H s zRPCServer.__init__c C s d S)Nr )r" r r r server_bindM s zRPCServer.server_bindc C s | j j | j d S)N)socketconnectserver_address)r" r r r server_activateQ s zRPCServer.server_activatec C s | j | j f S)N)r% r' )r" r r r get_requestZ s zRPCServer.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) N
-( filezUnhandled server exception!z
Thread: %szClient Address: z Request: z#
*** Unrecoverable, server exiting!r )
SystemExitsys
__stderr__print threadingcurrent_threadnamerepr traceback print_excos_exit)r" requestZclient_addresserfr r r handle_error^ s
zRPCServer.handle_error)r r r r! r$ r( r) r< r r r r r F s
r c @ sr e 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/ d0 Z d1 d2 Z d3 d4 Z d5 d6 Z d7 d8 Z d9 d: Z! d S);SocketIOr Nc C s^ t j | _ | d k r$ | | _ | | _ | d k r? t } | | _ i | _ i | _ d S)N) r2 r3
sockthread debuggingsock objecttableobjtable responsescvars)r" r@ rB r? r r r r! s zSocketIO.__init__c C s, | j } d | _ | d k r( | j d S)N)r@ close)r" r@ r r r rE s zSocketIO.closec C s t j d d S)Nr )r8 r9 )r" r r r exithook s zSocketIO.exithookc G si | j s
d S| j d t t j j } x" | D] } | d t | } q4 Wt | d t j d S)N r- ) r? locationstrr2 r3 r4 r1 r/ r0 )r" argssar r r debug s
zSocketIO.debugc C s | | j | ConditionrD rM
putmessage)r" rN rl rJ rm r: rj cvarr r r ru s
zSocketIO.asynccallc C s d | | | | f f } | j } t j | j k rR t j } | | j | <| j d | | | | | | j | | f | S)NrY zasyncqueue:%d:)rz r2 r3 r> r{ rD rM r| )r" rN rl rJ rm r: rj r} r r r rx s
zSocketIO.asyncqueuec C sG | j d | | j | d d } | j d | | | j | S)Nz#asyncreturn:%d:call getresponse(): waitg?zasyncreturn:%d:response: )rM getresponsedecoderesponse)r" rj responser r r rv s zSocketIO.asyncreturnc 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 | | d k r | j d
| | t | | d S) NrV rZ r\ zdecoderesponse: EXCEPTIONEOFzdecoderesponse: EOFrS z decoderesponse: Internal ERROR:r[ z decoderesponse: Call Exception:)rM decode_interrupthook RuntimeError SystemError)r" r rk whatr r r r s&
zSocketIO.decoderesponsec C s
t d S)N)EOFError)r" r r r r s z SocketIO.decode_interrupthookc C sD y | j d d d d Wn# t k
r? | j d d SYn Xd S)Nmyseqr~ g?zmainloop:return)r r rM )r" r r r mainloop s
zSocketIO.mainloopc C sO | j | | } | d k rK | \ } } | d k rK | | j | f } | S)NrV ) _getresponse_proxify)r" r r~ r rk r r r r r s zSocketIO.getresponsec C sH t | t r t | | j St | t rD t t | j | S| S)N)rb RemoteProxyRPCProxyrN listmapr )r" r r r r r ' s
zSocketIO._proxifyc 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)Nz_getresponse:myseq:z-_getresponse:%s: thread woke up: response: %s)
rM r2 r3 r> pollresponserD acquirerC r~ release)r" r r~ r r} r r r r / s"
zSocketIO._getresponsec C s | j d | _ } | S)N )nextseq)r" rj r r r rz E s zSocketIO.newseqc C s | j d | d y t | } Wn4 t j k
r[ t d t | d t j Yn Xt j d t
| | } x t
| d k r yD t j g | j g g \ } } } | j j
| d t } Wn$ t t f k
r t d Yn X| | d } q{ Wd S)Nzputmessage:%d:r zCannot pickle:r- z } | j | } | j d | j | <| j | j q! W| j d S)Nr r )r N)EOFhookrM rD r rC r r rF )r" keyr r r r r s
zSocketIO.handle_EOFc C s d S)Nr )r" r r r r s zSocketIO.EOFhook)"r r r r r! rE rF rM rP rR rt rw ry ru rx rv r r r r r r rz r| r r r r r r r r r r r r r r r= } s> .
I
r= c @ s e Z d Z d S)rc N)r r r r r r r rc s rc c C s t | } | t | sH
2 j