GRAYBYTE WORDPRESS FILE MANAGER2844

a

�DOg�N�@sb
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZmZm	Z	m
Z
mZmZm
Z
mZmZmZmZmZmZ
ee
ee
eeeh�
Zze
Wney�


iZYn0dd�ZGdd�de�ZeeefZdd�Zd	d
�Zdd�Z d
d�Z!d%dd�
Z"d&dd�
Z#e#Z$d'dd�
Z%Gdd�d�Z&Gdd�de&�Z'dd�Z(d(dd�
Z)ej*d k�
r^Gd!d"�d"�Z+Gd#d$�d$e&�Z,d
S))�N)
�EALREADY�EINPROGRESS�EWOULDBLOCK�
ECONNRESET�EINVAL�ENOTCONN�	ESHUTDOWN�EISCONN�EBADF�ECONNABORTED�EPIPE�EAGAIN�	errorcodec


CsFzt�
|�
WStttfy@


|tvr4t|YSd
|YS0dS)NzUnknown error %s)�os�strerror�
ValueError�
OverflowError�	NameErrorr)
�err�r� /usr/lib64/python3.9/asyncore.py�	_strerrorDs





rc
@seZ
dZd
S)�ExitNowN)�__name__�
__module__�__qualname__rrrrrLs
rc

Cs8z|��
Wn&t
y 


�Yn


|��
Yn0dS�
N)�handle_read_event�_reraised_exceptions�handle_error�
�objrrr�readQs





r"c

Cs8z|��
Wn&t
y 


�Yn


|��
Yn0dSr)�handle_write_eventrrr rrr�writeYs





r$c

Cs8z|��
Wn&t
y 


�Yn


|��
Yn0dSr)�handle_expt_eventrrr rrr�
_exceptionas





r&c
Cs�zX|
tj
@r|��
|
tj@r&|��
|
tj@r8|��
|
tjtjBtj	B@rV|�
�
Wnhty�
}
z,|jd
t
v
r�|��
n|�
�
WYd}~n.d}~0ty�


�Yn


|��
Yn0dS�Nr
)�select�POLLINr�POLLOUTr#�POLLPRIr%�POLLHUP�POLLERR�POLLNVAL�handle_close�OSError�args�
_DISCONNECTEDrr)r!�flags�
errr�	readwriteis"



















r5�c	Cs<
|
durt}
|
�
r8g}g}g}t
|
���
D]L\}}|��}|��}|rP|�|�

|rd|jsd|�|�

|sl|r*|�|�

q*g|kr�|kr�|kr�n
nt�|�

dSt	�	||||�\}}}|D] }|
�
|�
}|dur�q�t|�

q�|D]"}|
�
|�
}|du�
rq�t|�

q�|D]&}|
�
|�
}|du�
r,�
qt
|�

�
qdSr)�
socket_map�list�items�readable�writable�append�	accepting�time�sleepr(�getr"r$r&)	�timeout�map�
r�
wr4�fdr!Zis_rZis_wrrr�poll}s@















"





















rFcCs�|
durt}
|du
r t
|d
�
}t��}|
r�t|
���
D]L\}}d}|��r\|tjtjBO}|�	�rt|j
st|tjO}|r8|�||�
q8|�|�
}|D]&\}}|
�
|�
}|dur�q�t||�
q�dS)Ni�r
)r7�intr(rFr8r9r:r)r+r;r=r*�registerr@r5)rArBZpollsterrEr!r3rCrrr�poll2�s(


















rI�>@FcCsb|durt}|
r t
td
�r t}nt}|dur>|r^|||�
q,n |r^|dkr^|||�
|d}q>dS)NrFr
�
)r7�hasattrr(rIrF)rAZuse_pollrB�countZpoll_funrrr�loop�s







rNc@s2
eZ
dZd
Zd
Zd
Zd
Zd
ZdZe	dh
�
Z
dAdd�
Zdd�ZdBdd	�
Z
dCd
d�
Zejejfdd
�
ZdDdd�
Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�ZdEd'd(�
Zd)d*�Z d+d,�Z!d-d.�Z"d/d0�Z#d1d2�Z$d3d4�Z%d5d6�Z&d7d8�Z'd9d:�Z(d;d<�Z)d=d>�Z*d?d@�Z+dS)F�
dispatcherFN�warningc
Cs�|durt|_
n||_
d|_|
r�|
�d
�

|�|
|�
d|_z|
��|_Wq�ty�
}
z2|j	dt
tfvrtd
|_n|�|�

�WYd}~q�d}~00nd|_
dS)NFTr
)r7�_map�_fileno�setblocking�
set_socket�	connected�getpeername�addrr0r1rr�del_channel�socket)�self�sockrBrrrr�__init__�s 









zdispatcher.__init__c
Cs�|jj
d
|jjg
}
|jr.|jr.|
�d�

n|jr>|
�d�

|jdu
r�z|
�d|j�

Wn"ty~


|
�t|j�
�

Yn0dd�	|
�
t
|�
fS)N�
.Z	listeningrUz%s:%dz<%s at %#x>�
 )�	__class__rrr=rWr<rU�	TypeError�repr�join�id)rZ�statusrrr�__repr__�s












zdispatcher.__repr__cCs|
dur|j}
||
|j
<dSr)rQrR)rZrBrrr�add_channel	
s

zdispatcher.add_channelcCs,|j}|
dur|j
}
||
vr"|
|=d|_dSr)rRrQ)rZrBrErrrrX
s




zdispatcher.del_channelcCs.|
|f|_t
�
|
|�}|�d
�

|�|�

dS)NF)Zfamily_and_typerYrSrT)rZ�family�typer[rrr�
create_socket
s





zdispatcher.create_socketcCs|
|_|
�
�|_|�|�

dSr)rY�filenorRrf�rZr[rBrrrrT
s



zdispatcher.set_socketc

CsBz*|j�
tjtj|j�tjtj�d
B�
Wnty<


Yn0dS)NrK)rY�
setsockopt�
SOL_SOCKET�SO_REUSEADDR�
getsockoptr0�
rZrrr�set_reuse_addr#
s




�
��
zdispatcher.set_reuse_addrc


Csd
S�NTrrprrrr:4
s
zdispatcher.readablec


Csd
Srrrrprrrr;7
s
zdispatcher.writablecCs(d
|_t
jdkr|
dkrd}
|j�|
�
S)NT�nt�)r=r�namerY�listen)rZ�numrrrrv>
s



zdispatcher.listencCs|
|_|j
�|
�
Sr)rWrY�bind)rZrWrrrrxD
s

zdispatcher.bindcCspd
|_d|_
|j�|
�
}|tttfvs8|tkrBtj	dkrB|
|_
dS|dtfvr^|
|_
|��
nt
|t|��
dS)NFTrsr
)rU�
connectingrY�
connect_exrrrrrrurWr	�handle_connect_eventr0r)rZ�addressrrrr�connectH
s




�
�




zdispatcher.connectc

Cszz|j�
�\}
}WnZty&


YdStyl
}
z0|jd
tttfvrVWYd}~dS�WYd}~nd}~00|
|fSdSr')rY�acceptr`r0r1rrr
)rZ�connrW�whyrrrr~V
s





zdispatcher.acceptc
Cs~z|j�
|
�
}|WStyx
}
zN|jd
tkr>WYd}~d
S|jd
tvrb|��
WYd}~d
S�WYd}~n
d}~00dSr')rY�sendr0r1rr2r/)rZ�data�resultr�rrrr�d
s








zdispatcher.sendc
Csxz(|j�
|
�
}|s |��
Wd
S|WSWnJtyr
}
z2|jdtvr\|��
WYd}~d
S�WYd}~n
d}~00dS)N�r
)rY�recvr/r0r1r2)rZZbuffer_sizer�r�rrrr�q
s







zdispatcher.recvc

Cspd
|_d
|_
d
|_|��
|jdu
rlz|j��
Wn8tyj
}

z |
jdtt	fv
rV�WYd}
~
n
d}
~
00dS)NFr
)
rUr=ryrXrY�closer0r1rr
)rZr�rrrr��
s










zdispatcher.closecCstj
�d
t|
�
�

dS)Nzlog: %s
)�sys�stderrr$�str)rZ�messagerrr�log�
s
zdispatcher.log�infocCs||jv
rt
d
||
f�

dS)Nz%s: %s)�ignore_log_types�print)rZr�rhrrr�log_info�
s


zdispatcher.log_infoc

Cs:|jr|�
�
n&|js.|jr$|��
|��
n|��
dSr)r=�
handle_acceptrUryr{�handle_readrprrrr�
s






zdispatcher.handle_read_eventc
Cs@|j�
tjtj�}
|
d
kr(t|
t|
�
��
|��
d|_d|_dS)Nr
TF)	rYrorm�SO_ERRORr0r�handle_connectrUry�rZrrrrr{�
s





zdispatcher.handle_connect_eventc

Cs*|jr
dS|j
s|jr|��
|��
dSr)r=rUryr{�handle_writerprrrr#�
s



zdispatcher.handle_write_eventc
Cs0|j�
tjtj�}
|
d
kr$|��
n|��
dSr')rYrormr�r/�handle_exptr�rrrr%�
s

zdispatcher.handle_expt_eventc
CsXt�\}
}}}zt
|�
}Wn


d
t|�
}Yn0|�d||||fd�
|��
dS)Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)�error)�compact_tracebackrarcr�r/)rZ�nil�
t�
v�tbinfoZ	self_reprrrrr�
s








��	zdispatcher.handle_errorc

Cs|�d
d�
dS)Nz!unhandled incoming priority eventrP�
r�rprrrr��
s
zdispatcher.handle_exptc

Cs|�d
d�
dS)Nzunhandled read eventrPr�rprrrr��
s
zdispatcher.handle_readc

Cs|�d
d�
dS)Nzunhandled write eventrPr�rprrrr��
s
zdispatcher.handle_writec

Cs|�d
d�
dS)Nzunhandled connect eventrPr�rprrrr��
s
zdispatcher.handle_connectc
Cs|��}
|
du
r|j
|
�
dSr)r~�handle_accepted)rZZpairrrrr��
s


zdispatcher.handle_acceptcCs|
��
|�
d
d�
dS)Nzunhandled accepted eventrP)r�r�)rZr[rWrrrr��
s

zdispatcher.handle_acceptedc

Cs|�d
d�
|�
�
dS)Nzunhandled close eventrP)r�r�rprrrr/�
s

zdispatcher.handle_close)NN)
N)
N)
N)
r�),rrr�debugrUr=ry�closingrW�	frozensetr�r\rerfrXrY�AF_INET�SOCK_STREAMrirTrqr:r;rvrxr}r~r�r�r�r�r�rr{r#r%rr�r�r�r�r�r�r/rrrrrO�sJ







 

	


rOc@s6eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zd
S)
�dispatcher_with_sendNcCst�
||
|�
d
|_dS)Nr�)rOr\�
out_bufferrkrrrr\�
s

zdispatcher_with_send.__init__c
Cs.d
}
t�
||jdd��}
|j|
d�|_dS)Nr
i
)rOr�r�)rZZnum_sentrrr�
initiate_sends


z"dispatcher_with_send.initiate_sendc

Cs|��
dSr)
r�rprrrr�s
z!dispatcher_with_send.handle_writec

Cs|jpt
|j�
Sr)rU�lenr�rprrrr;s
zdispatcher_with_send.writablecCs0|jr|�
d
t|
�
�

|j|
|_|��
dS)Nz
sending %s)r�r�rar�r�)rZr�rrrr�s



zdispatcher_with_send.send)NN)rrrr\r�r�r;r�rrrrr��
s

r�cCs�t�
�\}}
}g}|std
�
�
|rL|�|jjj|jjjt|j	�
f�

|j
}q~|d\}}}d�dd�|D�
�
}|||f||
|fS)Nztraceback does not exist���r^c
Ssg|]}
d|
�qS)
z
[%s|%s|%s]r)�.0�
xrrr�
<listcomp>&r�z%compact_traceback.<locals>.<listcomp>)r��exc_info�AssertionErrorr<�tb_frame�f_code�co_filename�co_namer��	tb_lineno�tb_nextrb)r�r��tbr��file�function�liner�rrrr�s








�

r�cCs�|durt}t
|���
D]n}z|��
Wqtyb
}
z"|jd
tkrHn|
sN�WYd}~qd}~0tyt


�Yq


|
s��Yq0q|��
dSr')	r7r8�valuesr�r0r1r
r�clear)rBZ
ignore_allr�rrr�	close_all)s 
















r��posixc@sNeZ
dZd
d�Zdd�Zdd�Zdd�Zdd
d�
ZeZeZ	dd
�Z
dd�Zd	S)�file_wrappercCst�
|
�
|_dSr)r�duprE�rZrErrrr\Ns
zfile_wrapper.__init__c

Cs*|jd
krt
jd|t|d�
|��
dS)Nr
zunclosed file %r)
�source)rE�warnings�warn�ResourceWarningr�rprrr�__del__Qs




�zfile_wrapper.__del__c
Gstj
|jg
|
�
R�Sr)rr"rE�rZr1rrrr�Ws
zfile_wrapper.recvc
Gstj
|jg
|
�
R�Sr)rr$rEr�rrrr�Zs
zfile_wrapper.sendNcCs(|
tj
kr|tjkr|sd
Std�
�
dS)Nr
z-Only asyncore specific behaviour implemented.)rYrmr��NotImplementedError)rZ�levelZoptname�buflenrrrro]s


��
zfile_wrapper.getsockoptc
Cs(|jd
krdS|j}
d|_t
�|
�

dS)Nr
r�)rErr�r�rrrr�hs






zfile_wrapper.closec


Cs|jSr)
rErprrrrjos
zfile_wrapper.fileno)
N)rrrr\r�r�r�ror"r$r�rjrrrrr�Is

r�c@seZ
dZddd�
Zdd�Zd
S)�file_dispatcherNcCsNt�
|d|�
d
|_z|
��}
Wnty2


Yn0|�|
�

t�|
d�
dS)NTF)rOr\rUrj�AttributeError�set_filer�set_blocking)rZrErBrrrr\ts







zfile_dispatcher.__init__cCs"t|
�
|_
|j
��|_|��
dSr)r�rYrjrRrfr�rrrr�s



zfile_dispatcher.set_file)
N)rrrr\r�rrrrr�rs
r�)r6N)r6N)rJFNN)NF)-r(rYr�r>r�r�errnorrrrrrrr	r
rrr
rr�r2r7rr�	Exceptionr�KeyboardInterrupt�
SystemExitrr"r$r&r5rFrIZpoll3rNrOr�r�r�rur�r�rrrr�<module>1sB




<
�





'

*

)