$22 GRAYBYTE WORDPRESS FILE MANAGER $65

3

��2a�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+ZdZGd
d�de	j�ZiZejd�
Zejd�
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
Cstj
|�
}
|
S)
N)�marshal�loads)�ms�co�r�(/opt/alt/python36/lib64/python3.6/rpc.py�
unpickle_code-s
rc
Cstj
|�
}
t|
f
fS)
N)r�dumpsr)rrrrr�pickle_code3s

r
cCs$tj
�}t||
�}|j|�

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




r	c@s"eZ
dZejei
Zejej�

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


r
�iz	127.0.0.1c@s6eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zd
S)
�	RPCServerNcCs |dkrt}t
jj||
|�
dS)
N)�
RPCHandler�socketserver�	TCPServer�__init__)�self�addrZhandlerclassrrrr Ls


zRPCServer.__init__c


CsdS)
Nr)
r!rrr�server_bindQszRPCServer.server_bindc

Cs|jj
|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
dd|d�
td|d�
tdtj�j|d�
td||d�
tdt|
�
|d�
tj	|d�

td	|d�
tdd|d�
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_addressZerfrrr�handle_errorbs













zRPCServer.handle_error)
N)rrrr r#r&r'r9rrrrrJs

	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@tj
�|_|dk	r||_|
|_|dkr*t}||_i|_i|_dS)
N)	r0r1�
sockthread�	debugging�sock�objecttable�objtable�	responses�cvars)r!r=r?r<rrrr �s









zSocketIO.__init__c
Cs |j}
d|_|
dk	r|
j
�
dS)
N)r=�close)r!r=rrrrB�s



zSocketIO.closec

Cstj
d
�

dS)Nr
)r6r7)
r!rrr�exithook�szSocketIO.exithookc
GsR|js
dS|j
d
ttj�j�
}x|
D]}|d
t|�
}q(Wt|tjd�
dS)N�
 )
r+)	r<�location�strr0r1r2r/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!rKrrr�
unregister�s



zSocketIO.unregistercCs�
|jd
|�
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
j|
|||ff�

dSdd|fSWn�tk
�
r,


�Yn�t
k
�
rB


�Ynntk
�
rX


�YnXtk
�
r|
}

zd
|
fSd}
~
Xn4


d}t||||ftjd�
tjtjd�

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

 Object: %s 
 Method: %s 
 Args: %s
)
r+�	EXCEPTION)rPrQ)rWN)rYN)rJ�	TypeErrorr?�_getmethods�_getattributes�hasattr�getattr�
isinstance�RemoteObject�	remoteref�
request_queueZputr,�KeyboardInterrupt�OSError�	Exceptionr/r-r.r4r5)r!�seqr8�howrK�
methodnamerG�kwargsr�methods�
attributes�method�retZex�msgrrr�	localcall�sT
















































zSocketIO.localcallcCs(|jd
|
|�
|j
|
|||�}|j|�
S)Nzremotecall:asynccall: )rJ�	asynccall�asyncreturn)r!rKrhrGrirfrrr�
remotecall�s


zSocketIO.remotecallcCs(|jd
|
|�
|j
|
|||�}|j|�
S)Nzremotequeue:asyncqueue: )rJ�
asyncqueuerq)r!rKrhrGrirfrrr�remotequeue�s


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

|S)NrUz
asynccall:%d:)�newseqr0r1r;�	ConditionrArJ�
putmessage)r!rKrhrGrir8rf�cvarrrrrp�s








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

|S)NrVzasyncqueue:%d:)rur0r1r;rvrArJrw)r!rKrhrGrir8rfrxrrrrs�s








zSocketIO.asyncqueuecCs6|jd
|
�

|j
|
dd�}|jd|
|�
|j|�
S)Nz#asyncreturn:%d:call getresponse(): g�������?)
�waitzasyncreturn:%d:response: )rJ�getresponse�decoderesponse)r!rf�responserrrrq�s



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

dS|dkrT|jd�

|j
�
dS|dkrp|jd|�
t|�
�
|d	kr�|jd
|�
|�
t||��
dS)NrSrWrYzdecoderesponse: EXCEPTION�EOFzdecoderesponse: EOFrPzdecoderesponse: Internal ERROR:rXzdecoderesponse: Call Exception:)rJ�decode_interrupthook�RuntimeError�SystemError)r!r|rg�whatrrrr{�s&




















zSocketIO.decoderesponsec


Cst�
dS)
N)
�EOFError)
r!rrrr~
szSocketIO.decode_interrupthookc

Cs6y|jdd
d�
Wnt
k
r0


|jd�

dSXdS)Ng�������?)�myseqryzmainloop:return)rzr�rJ)
r!rrr�mainloop
s





zSocketIO.mainloopcCs6|j|
|�}|dk	r2|\}}|d
kr2||j
|�
f}|S)NrS)�_getresponse�_proxify)r!r�ryr|rgr�rrrrz#
s





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






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

|j|
=|j|
=|j	�
|SdS)Nz_getresponse:myseq:z-_getresponse:%s: thread woke up: response: %s)
rJr0r1r;�pollresponserA�acquirer@ry�release)r!r�ryr|rxrrrr�3
s"

















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

zSocketIO.newseqcCs�|jd
|
d�

yt
|
�
}Wn,tjk
rJ


tdt|
�
tjd�
�YnXtj	dt
|�
�|}xnt
|�
dkr�y0tjg|jg
g�\}}}|jj
|dt��
}Wn ttfk
r�


td�
�
YnX||d�}qbWdS)Nzputmessage:%d:r
zCannot pickle:)
r+z<izsocket no longer exists)rJr	�pickleZ
PicklingErrorr/r3r-r.�struct�pack�len�selectr=�send�BUFSIZE�AttributeErrorrZrd)r!�messagerH�
r�
w�
x�
nrrrrwM
s













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


t
�
YnXt
|�
d
kr�t
�
|j|7_|j�
|j�S)Nr
)�_stage0r��buff�bufneedr�r=�filenoZrecvr�rdr��_stage1)r!ryr�r�r�rHrrr�
pollpacketa
s














zSocketIO.pollpacketc
CsR|jd
krNt
|j�
dkrN|jdd�}
|jdd�|_tjd|
�d
|_d|_dS)Nr
r�z<i�
)�bufstater�r�r��unpackr�)r!rHrrrr�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�|j|
�
}|dkrdSyt
j|�
}WnVt
jk
rz


td
tjd�
tdt|�
tjd�
tj	tjd�

td
tjd�
�YnX|S)Nz-----------------------)
r+zcannot unpickle packet:)
r�r�rZUnpicklingErrorr/r-r.r3r4�print_stack)r!ryr�r�rrr�pollmessage�
s












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


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

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


|j�
dStk
r�


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

|dk�
r|j	d|�

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

|dk�
r|j||f�

q|dkrqq||
k�
r|S|jj
|d�}	|	dk	r|	j�
||j
|<|	j�
|	j�
qqWdS)	Nr
rSzpollresponse:%d:myseq:%srUrVzpollresponse:%d:localcall:call:z%pollresponse:%d:localcall:response:%s)rUrV)�response_queue�get�queueZEmptyrwr�r��
handle_EOFr�rJrorAr�r@�notifyr�)
r!r�ryZqmsgrfr|r�Zresqrg�cvrrrr��
sL


































zSocketIO.pollresponsec
CsZ|j�
|j
d
�

x:|jD]0}
|j|
}|j�
d|j|
<|j�
|j�
qW|j�
dS)Nr�r})r}N)�EOFhookrJrAr�r@r�r�rC)r!�keyr�rrrr��
s









zSocketIO.handle_EOFc


CsdS)
Nr)
r!rrrr��
szSocketIO.EOFhook)NN)"rrrr�r rBrCrJrMrOrorrrtrprsrqr{r~r�rzr�r�rurwr�r�r�r�r�r�r�r�r�r�rrrrr:�s>
.




I
r:c
@seZ
dZd
S)r`N)rrrrrrrr`�
sr`c
Cst|�
}
|t
|
<t|
�
S)
N)�idr>r�)rrKrrrra�
s


rac@seZ
dZd
d�ZdS)r�cCs
|
|_dS)
N)
rK)r!rKrrrr �
s
zRemoteProxy.__init__N)rrrr rrrrr��
sr�c@s,eZ
dZd
ZdZdd�Zdd�Zdd�Zd	S)
rFz#ScCs(||_t
j||
�
tjj||
||�
dS)
N)Zcurrent_handlerr:r r�BaseRequestHandler)r!r=r"Zsvrrrrr s


zRPCHandler.__init__c


Cs|j�
dS)
N)
r�)
r!rrr�handleszRPCHandler.handlecCs
t||
�S)
N)
r�)r!rKrrr�get_remote_proxy	s
zRPCHandler.get_remote_proxyN)rrrr<rEr r�r�rrrrr�
s

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

|j
jd
�

dS)Nr�)r$�listening_sockZbindZlisten)r!�addressZfamily�typerrrr s


zRPCClient.__init__c
CsV|jj
�\}
}|jr$td
|tjd�
|dtkr>tj||
�
ntd|tjd�
t	�
dS)Nz****** Connection request from )
r+r
z** Invalid host: )
r��acceptr<r/r-r.�	LOCALHOSTr:r rd)r!Zworking_sockr�rrrr�s





zRPCClient.acceptcCs
t||
�S)
N)
r�)r!rKrrrr�#s
zRPCClient.get_remote_proxyN)rrrr<rEr�r$ZAF_INETZSOCK_STREAMr r�r�rrrrr�
s

r�c@s4eZ
dZd
Zd
Zdd�Zdd�Zdd�Zdd	�Zd
S)
r�NcCs|
|_||_
dS)
N)�sockiorK)r!r�rKrrrr ,s

zRPCProxy.__init__cCsp|jdkr|j
�
|jj|
�
r.t|j|j|
�S|jdkr@|j�
|
|jkrd|jj|jd
|
f
i�}|St	|
�
�
dS)N�__getattribute__)
�_RPCProxy__methods�_RPCProxy__getmethodsr��MethodProxyr�rK�_RPCProxy__attributes�_RPCProxy__getattributesrrr�)r!r2�valuerrr�__getattr__0s













zRPCProxy.__getattr__c

Cs|jj
|jd
fi�|_dS)NrT)r�rrrKr�)
r!rrrZ__getattributes>s


zRPCProxy.__getattributesc

Cs|jj
|jd
fi�|_dS)NrR)r�rrrKr�)
r!rrrZ__getmethodsBs


zRPCProxy.__getmethods)	rrrr�r�r r�r�r�rrrrr�'s
r�cCsTx*t|�
D]}t
||�}t|�
r
d
|
|<q
Wt|t�rPx|jD]}t||
�
q>WdS)Nr�)�dirr^�callabler_r��	__bases__r[)rrjr2�attr�superrrrr[Fs







r[cCs0x*t|�
D]}t
||�}t|�
s
d
|
|<q
WdS)Nr�)r�r^r�)rrkr2r�rrrr\Qs




r\c@seZ
dZd
d�Zdd�ZdS)r�cCs|
|_||_
||_dS)
N)r�rKr2)r!r�rKr2rrrr Zs


zMethodProxy.__init__c
Os|jj
|j|j|
|�}|S)
N)r�rrrKr2)r!rGrir�rrr�__call___s

zMethodProxy.__call__N)rrrr r�rrrrr�Xsr�c
Cs~|dkrdSdt_
t|�
}
ytjj|
�

Wn<tk
rf


d
}|
j|d�}|j|d�}
tjj|
�

YnXtjjd�

|t_
dS)N�ascii�backslashreplace�strictr()	�builtins�
_r3r-�stdout�write�UnicodeEncodeError�encode�decode)r��text�encoding�bytesrrr�displayhookgs









r��__main__)
�mainzidlelib.idle_test.test_rpcr�)
�	verbosity)
Ni ),r�rrrr6r�r�r�r$rr�r-r0r4rrr
r	ZPicklerr
r�r�rrr>ZQueuerbr�rLr:r`rar�r�rr�r�r[r\r�r�rZunittestr�rrrr�<module>sP














	
2



k