��]0Q�@sddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddlZddlZddl Z ddlZdd�Zdd�Zddd�ZGdd �d ej�Zd dZdZGd d�dej�ZiZe jd�Ze jd�ZGdd�de�ZGdd�de�Zdd�ZGdd�de�Z Gdd�dej!e�Z"Gdd�de�Z#Gdd�de�Z$dd�Z%dd �Z&Gd!d"�d"e�Z'd#d$�Z(dS)%�NcCstj|�}|S)N)�marshal�loads)�ms�co�r�(/opt/alt/python35/lib64/python3.5/rpc.py� unpickle_code/srcCstj|�}t|ffS)N)r�dumpsr)rrrrr�pickle_code4sr cCs2tj�}t||�}|j|�|j�S)N)�io�BytesIO�CodePickler�dump�getvalue)�obj�protocol�f�prrrr 9s r c@s/eZdZejeiZejej�dS)r N) �__name__� __module__�__qualname__�types�CodeTyper �dispatch_table�update�copyregrrrrr ?sr �iz 127.0.0.1c@sOeZdZddd�Zdd�Zdd�Zdd �Zd d�ZdS)� RPCServerNcCs,|dkrt}tjj|||�dS)N)� RPCHandler�socketserver� TCPServer�__init__)�self�addrZhandlerclassrrrr!HszRPCServer.__init__cCsdS)Nr)r"rrr�server_bindMszRPCServer.server_bindcCs|jj|j�dS)N)�socket�connect�server_address)r"rrr�server_activateQszRPCServer.server_activatecCs|j|jfS)N)r%r')r"rrr�get_requestZszRPCServer.get_requestcCs�y�Wn�tk r�Yn�tj}tdddd|�tdd|�tdtj�jd|�td|d|�tdt|�d|�tj d|�td d|�tddd|�t jd �YnXdS)N� �-�(�filezUnhandled server exception!z Thread: %szClient Address: z Request: z# *** Unrecoverable, server exiting!r)� SystemExit�sys� __stderr__�print� threading�current_thread�name�repr� traceback� print_exc�os�_exit)r"�requestZclient_address�erfrrr�handle_error^s zRPCServer.handle_error)rrrr!r$r(r)r<rrrrrFs rc@sreZdZdZdddd�Zdd�Zdd�Zd d �Zdd�Zd d�Z dd�Z dd�Zdd�Zdd�Z dd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+Zd,ZdZd-d.�Zd/d0�Zd1d2�Zd3d4�Zd5d6�Zd7d8�Z d9d:�Z!dS);�SocketIOrNcCs^tj�|_|dk r$||_||_|dkr?t}||_i|_i|_dS)N) r2r3� sockthread� debugging�sock�objecttable�objtable� responses�cvars)r"r@rBr?rrrr!�s zSocketIO.__init__cCs,|j}d|_|dk r(|j�dS)N)r@�close)r"r@rrrrE�s zSocketIO.closecCstjd�dS)Nr)r8r9)r"rrr�exithook�szSocketIO.exithookcGsi|js dS|jdttj�j�}x"|D]}|dt|�}q4Wt|dtj�dS)N� r-) r?�location�strr2r3r4r1r/r0)r"�args�s�arrr�debug�s zSocketIO.debugcCs||j|� ConditionrDrM� putmessage)r"rNrlrJrmr:rj�cvarrrrru�s zSocketIO.asynccallcCs�d||||ff}|j�}tj�|jkrRtj�}||j|<|jd|||||�|j||f�|S)NrYzasyncqueue:%d:)rzr2r3r>r{rDrMr|)r"rNrlrJrmr:rjr}rrrrx�s zSocketIO.asyncqueuecCsG|jd|�|j|dd�}|jd||�|j|�S)Nz#asyncreturn:%d:call getresponse(): �waitg��?zasyncreturn:%d:response: )rM�getresponse�decoderesponse)r"rj�responserrrrv�szSocketIO.asyncreturncCs�|\}}|dkr|S|dkr,dS|dkrI|jd�dS|dkrp|jd�|j�dS|dkr�|jd|�t|��|d kr�|jd |�|�t||��dS)NrVrZr\zdecoderesponse: EXCEPTION�EOFzdecoderesponse: EOFrSzdecoderesponse: Internal ERROR:r[zdecoderesponse: Call Exception:)rM�decode_interrupthook�RuntimeError�SystemError)r"r�rk�whatrrrr��s& zSocketIO.decoderesponsecCs t�dS)N)�EOFError)r"rrrr�szSocketIO.decode_interrupthookcCsDy|jdddd�Wn#tk r?|jd�dSYnXdS)N�myseqr~g��?zmainloop:return)rr�rM)r"rrr�mainloops zSocketIO.mainloopcCsO|j||�}|dk rK|\}}|dkrK||j|�f}|S)NrV)�_getresponse�_proxify)r"r�r~r�rkr�rrrrszSocketIO.getresponsecCsHt|t�rt||j�St|t�rDtt|j|��S|S)N)rb�RemoteProxy�RPCProxyrN�list�mapr�)r"rrrrr�'s zSocketIO._proxifycCs�|jd|�tj�|jkrQx�|j||�}|dk r(|Sq(Wn}|j|}|j�x||jkr�|j�qkW|j|}|jd||f�|j|=|j|=|j �|SdS)Nz_getresponse:myseq:z-_getresponse:%s: thread woke up: response: %s) rMr2r3r>�pollresponserD�acquirerCr~�release)r"r�r~r�r}rrrr�/s" zSocketIO._getresponsecCs|jd|_}|S)N�)�nextseq)r"rjrrrrzEszSocketIO.newseqcCs|jd|d�yt|�}Wn4tjk r[tdt|�dtj��YnXtj dt |��|}x�t |�dkryDtjg|jgg�\}}}|jj |dt��}Wn$ttfk r�td��YnX||d�}q{WdS)Nzputmessage:%d:rzCannot pickle:r-z}|j|}|j�d|j|<|j�|j�q!W|j�dS)Nr�r�)r�N)�EOFhookrMrDr�rCr�r�rF)r"�keyr�rrrr��s zSocketIO.handle_EOFcCsdS)Nr)r"rrrr��szSocketIO.EOFhook)"rrrr�r!rErFrMrPrRrtrwryrurxrvr�r�r�rr�r�rzr|r�r�r�r�r�r�r�r�r�r�rrrrr=}s>. I r=c@seZdZdS)rcN)rrrrrrrrc�srccCs t|�}|t|sH 2�j