$72 GRAYBYTE WORDPRESS FILE MANAGER $75

B

YI~d�R�@s�
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZdd
lZdd
l	Z	dd
l
Z
dd
lZdd
lZdd
l
Z
dd
lZdd�Zdd�Zd)dd�
ZGdd	�d	ej�Zd
ZdZGdd
�d
e	j�ZiZe�d�
Ze�d�
ZGdd�de�ZGdd�de�Zdd�ZGdd�de�Z Gdd�de	j!e�Z"Gdd�de�Z#Gdd�de�Z$dd�Z%dd�Z&Gd d!�d!e�Z'd"d#�Z(e)d$k�
r�dd%l*m+Z+
e+d&d'd(�
d
S)*�Nc
Cst�
|�
}
|
S)
N)�marshal�loads)�ms�co�r�0/opt/alt/python37/lib64/python3.7/idlelib/rpc.py�
unpickle_code-s
rc
Cst�
|�
}
t|
f
fS)
N)r�dumpsr)rrrrr�pickle_code3s

r
cCs$t�
�}t||
�}|�|�

|��S)
N)�io�BytesIO�CodePickler�dump�getvalue)�objZprotocol�
f�
prrrr	9s




r	c@s"eZ
dZejei
Ze�ej�

d
S)r
N)	�__name__�
__module__�__qualname__�types�CodeTyper
�dispatch_table�update�copyregrrrrr
Bs


r
i z	127.0.0.1c@s6eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zd
S)
�	RPCServerNcCs |dkrt}t
j�||
|�
dS)
N)�
RPCHandler�socketserver�	TCPServer�__init__)�self�addrZhandlerclassrrrrLs


zRPCServer.__init__c


CsdS)
Nr)
r rrr�server_bindQszRPCServer.server_bindc

Cs|j�
|j�

dS)
N)�socketZconnect�server_address)
r rrr�server_activateUszRPCServer.server_activatec

Cs|j|j
fS)
N)r#r$)
r rrr�get_request^szRPCServer.get_requestcCs�y�Wn�tk
r


�Yn�


t
j}td
|d�
td|d�
tdt��j|d�
td||d�
tdt|
�
|d�
tj	|d�

td|d�
td|d�
t
�d	�

YnXdS)
Nz)
----------------------------------------)
�filezUnhandled server exception!z
Thread: %szClient Address: z	Request: z#
*** Unrecoverable, server exiting!z(----------------------------------------r
)�
SystemExit�sys�
__stderr__�print�	threading�current_thread�name�repr�	traceback�	print_exc�os�_exit)r �requestZclient_addressZerfrrr�handle_errorbs













zRPCServer.handle_error)
N)rrrrr"r%r&r5rrrrrJs

	rc@s�eZ
dZd
Zd;dd�
Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+Zd,Zd
Zd-d.�Zd/d0�Zd1d2�Zd3d4�Zd5d6�Zd7d8�Z d9d:�Z!dS)<�SocketIOr
NcCs@t�
�|_|dk	r||_|
|_|dkr*t}||_i|_i|_dS)
N)	r,r-�
sockthread�	debugging�sock�objecttable�objtable�	responses�cvars)r r9r;r8rrrr�s









zSocketIO.__init__c
Cs |j}
d|_|
dk	r|
�
�
dS)
N)r9�close)r r9rrrr>�s



zSocketIO.closec

Cst�
d
�

dS)Nr
)r2r3)
r rrr�exithook�szSocketIO.exithookc
GsR|js
dS|j
d
tt��j�
}x|
D]}|d
t|�
}q(Wt|tjd�
dS)N�
 )
r')	r8�location�strr,r-r.r+r)r*)r �args�
s�
arrr�debug�s






zSocketIO.debugcCs||j|
<dS)
N)
r;)r �oid�objectrrr�register�s
zSocketIO.registercCs&y|j|
=Wnt
k
r 


YnXdS)
N)r;�KeyError)r rGrrr�
unregister�s



zSocketIO.unregisterc
Cs�
|�d
|�
y|\}\}}}}Wnt
k
r4


dSX||jkrNdd|f
fS|j|}|dkrvi}	t||	�
d|	fS|dkr�i}
t||
�
d|
fSt||�s�dd|f
fSt||�}y^|d	kr�|||�
}t|t�r�t	|�
}d|fS|d
k�
rt
�|
|||ff�

dSdd|fSWn�tk
�
r,


�Yn�t
k
�
rB


�Ynptk
�
rX


�YnZtk
�
r~
}

zd
|
fSd}
~
XYn4


d}t||||ftjd�
tjtjd�

dSdS)Nz
localcall:)�ERRORzBad request formatrLzUnknown object id: %r�__methods__�OK�__attributes__zUnsupported method name: %r�CALL�QUEUE)�QUEUEDNzUnsupported message type: %s�CALLEXCzU*** Internal Error: rpc.py:SocketIO.localcall()

 Object: %s 
 Method: %s 
 Args: %s
)
r')�	EXCEPTIONN)rF�	TypeErrorr;�_getmethods�_getattributes�hasattr�getattr�
isinstance�RemoteObject�	remoteref�
request_queueZputr(�KeyboardInterrupt�OSError�	Exceptionr+r)r*r0r1)r �seqr4�howrG�
methodnamerC�kwargsr�methods�
attributes�method�retZex�msgrrr�	localcall�sT
















































zSocketIO.localcallcCs(|�d
|
|�
|�
|
|||�}|�|�
S)Nzremotecall:asynccall: )rF�	asynccall�asyncreturn)r rGrcrCrdrarrr�
remotecall�s


zSocketIO.remotecallcCs(|�d
|
|�
|�
|
|||�}|�|�
S)Nzremotequeue:asyncqueue: )rF�
asyncqueuerl)r rGrcrCrdrarrr�remotequeue�s


zSocketIO.remotequeuecCs`d
|
|||ff}|��}t
��|jkr8t
��}||j|<|�d||
|||�
|�||f�

|S)NrPz
asynccall:%d:)�newseqr,r-r7�	Conditionr=rF�
putmessage)r rGrcrCrdr4ra�cvarrrrrk�s








zSocketIO.asynccallcCs`d
|
|||ff}|��}t
��|jkr8t
��}||j|<|�d||
|||�
|�||f�

|S)NrQzasyncqueue:%d:)rpr,r-r7rqr=rFrr)r rGrcrCrdr4rarsrrrrn�s








zSocketIO.asyncqueuecCs6|�d
|
�

|j
|
dd�}|�d|
|�
|�|�
S)Nz#asyncreturn:%d:call getresponse(): g�������?)
�waitzasyncreturn:%d:response: )rF�getresponse�decoderesponse)r ra�responserrrrl�s



zSocketIO.asyncreturncCs�|
\}}|d
kr|S|dkr dS|dkr6|�d�

dS|dkrT|�d�

|�
�
dS|dkrp|�d|�
t|�
�
|d	kr�|�d
|�
|�
t||��
dS)NrNrRrTzdecoderesponse: EXCEPTION�EOFzdecoderesponse: EOFrLzdecoderesponse: Internal ERROR:rSzdecoderesponse: Call Exception:)rF�decode_interrupthook�RuntimeError�SystemError)r rwrb�whatrrrrv�s&




















zSocketIO.decoderesponsec


Cst�
dS)
N)
�EOFError)
r rrrry
szSocketIO.decode_interrupthookc

Cs6y|jdd
d�
Wnt
k
r0


|�d�

dSXdS)Ng�������?)�myseqrtzmainloop:return)rur}rF)
r rrr�mainloop
s





zSocketIO.mainloopcCs6|�|
|�}|dk	r2|\}}|d
kr2||�
|�
f}|S)NrN)�_getresponse�_proxify)r r~rtrwrbr|rrrru#
s





zSocketIO.getresponsecCs4t|
t
�rt||
j�St|
t�r0tt|j|
��
S|
S)
N)rZ�RemoteProxy�RPCProxyrG�list�mapr�)r rrrrr�+
s






zSocketIO._proxifycCs�|�d
|
�
t
��|jkr:x�|�|
|�}|dk	r|SqWnb|j|
}|��
x|
|jkrb|��
qNW|j|
}|�d|
|f�

|j|
=|j|
=|�	�
|SdS)Nz_getresponse:myseq:z-_getresponse:%s: thread woke up: response: %s)
rFr,r-r7�pollresponser=�acquirer<rt�release)r r~rtrwrsrrrr�3
s"

















zSocketIO._getresponsec
Cs|jd
|_}
|
S)N�)
�nextseq)r rarrrrpI
s

zSocketIO.newseqc	Cs�|�d
|
d�

yt
|
�
}Wn,tjk
rJ


tdt|
�
tjd�
�YnXt�	dt
|�
�|}xnt
|�
dkr�y0t�g|jg
g�\}}}|j�
|dt��
}Wn ttfk
r�


td�
�
YnX||d�}qbWdS)Nzputmessage:%d:r
zCannot pickle:)
r'z<izsocket no longer exists)rFr	�pickleZ
PicklingErrorr+r/r)r*�struct�pack�len�selectr9�send�BUFSIZE�AttributeErrorrUr_)r �messagerD�
r�
w�
x�
nrrrrrM
s













zSocketIO.putmessage��cCs�|��
t
|j�
|jkr�t�|j��g
gg|
�\}}}t
|�
d
krFdSy|j�t�
}Wnt	k
rn


t
�
YnXt
|�
d
kr�t
�
|j|7_|��
|��S)Nr
)�_stage0r��buff�bufneedr�r9�filenoZrecvr�r_r}�_stage1)r rtr�r�r�rDrrr�
pollpacketa
s














zSocketIO.pollpacketc
CsR|jd
krNt
|j�
dkrN|jdd�}
|jdd�|_t�d|
�d
|_d|_dS)Nr
r�z<i�
)�bufstater�r�r��unpackr�)r rDrrrr�q
s





zSocketIO._stage0c
CsP|jd
krLt
|j�
|jkrL|jd|j�}
|j|jd�|_d|_d|_|
SdS)Nr�r�r
)r�r�r�r�)r �packetrrrr�x
s





zSocketIO._stage1cCs�|�|
�
}|dkrdSyt
�|�
}WnVt
jk
rz


td
tjd�
tdt|�
tjd�
tj	tjd�

td
tjd�
�YnX|S)Nz-----------------------)
r'zcannot unpickle packet:)
r�r�rZUnpicklingErrorr+r)r*r/r0�print_stack)r rtr�r�rrr�pollmessage�
s












zSocketIO.pollmessagec
Cs`
�
xXyt�
d
�
}Wntjk
r(


Yn X|\}}|d|ff}|�|�

y|�|�
}|dkr`dSWn.tk
r~


|��
dStk
r�


dSX|\}}|d
}|�	d||
f�

|dk�
r|�	d|�

|�
||�}|�	d||f�

|dk�
r|�||f�

q|dkrqq||
k�
r|S|j�
|d�}	|	dk	r|	��
||j
|<|	��
|	��
qqWdS)	Nr
rNzpollresponse:%d:myseq:%s)rPrQzpollresponse:%d:localcall:call:z%pollresponse:%d:localcall:response:%srPrQ)�response_queue�get�queueZEmptyrrr�r}�
handle_EOFr�rFrjr=r�r<�notifyr�)
r r~rtZqmsgrarwr�Zresqrb�cvrrrr��
sL


































zSocketIO.pollresponsec
CsZ|��
|�
d
�

x:|jD]0}
|j|
}|��
d|j|
<|��
|��
qW|��
dS)Nr�)rxN)�EOFhookrFr=r�r<r�r�r?)r �keyr�rrrr��
s









zSocketIO.handle_EOFc


CsdS)
Nr)
r rrrr��
szSocketIO.EOFhook)NN)"rrrr�rr>r?rFrIrKrjrmrorkrnrlrvryrrur�r�rprrr�r�r�r�r�r�r�r�r�r�rrrrr6�s>
.




I
r6c
@seZ
dZd
S)r[N)rrrrrrrr[�
sr[c
Cst|�
}
|t
|
<t|
�
S)
N)�idr:r�)rrGrrrr\�
s


r\c@seZ
dZd
d�ZdS)r�cCs
|
|_dS)
N)
rG)r rGrrrr�
s
zRemoteProxy.__init__N)rrrrrrrrr��
sr�c@s,eZ
dZd
ZdZdd�Zdd�Zdd�Zd	S)
rFz#ScCs(||_t
�||
�
tj�||
||�
dS)
N)Zcurrent_handlerr6rr�BaseRequestHandler)r r9r!Zsvrrrrrs


zRPCHandler.__init__c

Cs|��
dS)
N)
r)
r rrr�handleszRPCHandler.handlecCs
t||
�S)
N)
r�)r rGrrr�get_remote_proxy	s
zRPCHandler.get_remote_proxyN)rrrr8rArr�r�rrrrr�
s

rc@s:eZ
dZd
ZdZdZejejfdd�
Z	dd�Z
dd	�Zd
S)�	RPCClientFz#Cr�cCs*t�||�|_
|j
�|
�

|j
�d
�

dS)Nr�)r#�listening_sockZbindZlisten)r �addressZfamily�typerrrrs


zRPCClient.__init__c
CsV|j�
�\}
}|jr$td
|tjd�
|dtkr>t�||
�
ntd|tjd�
t	�
dS)Nz****** Connection request from )
r'r
z** Invalid host: )
r��acceptr8r+r)r*�	LOCALHOSTr6rr_)r Zworking_sockr�rrrr�s





zRPCClient.acceptcCs
t||
�S)
N)
r�)r rGrrrr�#s
zRPCClient.get_remote_proxyN)rrrr8rAr�r#ZAF_INETZSOCK_STREAMrr�r�rrrrr�
s

r�c@s4eZ
dZd
Zd
Zdd�Zdd�Zdd�Zdd	�Zd
S)
r�NcCs|
|_||_
dS)
N)�sockiorG)r r�rGrrrr,s

zRPCProxy.__init__cCsp|jdkr|�
�
|j�|
�
r.t|j|j|
�S|jdkr@|��
|
|jkrd|j�|jd
|
f
i�}|St	|
�
�
dS)N�__getattribute__)
�_RPCProxy__methods�_RPCProxy__getmethodsr��MethodProxyr�rG�_RPCProxy__attributes�_RPCProxy__getattributesrmr�)r r.�valuerrr�__getattr__0s













zRPCProxy.__getattr__c

Cs|j�
|jd
di�|_dS)NrOr)r�rmrGr�)
r rrrZ__getattributes>s


zRPCProxy.__getattributesc

Cs|j�
|jd
di�|_dS)NrMr)r�rmrGr�)
r rrrZ__getmethodsBs


zRPCProxy.__getmethods)	rrrr�r�rr�r�r�rrrrr�'s
r�cCsTx*t|�
D]}t
||�}t|�
r
d
|
|<q
Wt|t�rPx|jD]}t||
�
q>WdS)Nr�)�dirrY�callablerZr��	__bases__rV)rrer.�attr�superrrrrVFs







rVcCs0x*t|�
D]}t
||�}t|�
s
d
|
|<q
WdS)Nr�)r�rYr�)rrfr.r�rrrrWQs




rWc@seZ
dZd
d�Zdd�ZdS)r�cCs|
|_||_
||_dS)
N)r�rGr.)r r�rGr.rrrrZs


zMethodProxy.__init__c
Os|j�
|j|j|
|�}|S)
N)r�rmrGr.)r rCrdr�rrr�__call___s

zMethodProxy.__call__N)rrrrr�rrrrr�Xsr�c
Cs~|dkrdSdt_
t|�
}
ytj�|
�

Wn<tk
rf


d
}|
�|d�}|�|d�}
tj�|
�

YnXtj�d�

|t_
dS)N�ascii�backslashreplace�strict�

)	�builtins�
_r/r)�stdout�write�UnicodeEncodeError�encode�decode)r��text�encoding�bytesrrr�displayhookgs









r��__main__)
�mainzidlelib.idle_test.test_rpcr�)
�	verbosity)
N),r�rrrr2r�r�r�r#rr�r)r,r0rrr
r	ZPicklerr
r�r�rrr:ZQueuer]r�rHr6r[r\r�r�rr�r�rVrWr�r�rZunittestr�rrrr�<module>sP














	
2



k