$35 GRAYBYTE WORDPRESS FILE MANAGER $42

U

i�f~N�@sh
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZm	Z	m
Z
mZmZm
Z
mZmZmZmZmZmZmZ
eee
eeeeh�
Zze
Wnek
r�


iZYnXdd�ZGdd�de�ZeeefZdd	�Zd
d�Z dd
�Z!dd�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�
rdGd"d#�d#�Z,Gd$d%�d%e'�Z-dS)*a�Basic infrastructure for asynchronous socket service clients and servers.

There are only two ways to have a program on a single processor do "more
than one thing at a time".  Multi-threaded programming is the simplest and
most popular way to do it, but there is another very different technique,
that lets you have nearly all the advantages of multi-threading, without
actually using multiple threads. it's really only practical if your program
is largely I/O bound. If your program is CPU bound, then pre-emptive
scheduled threads are probably what you really need. Network servers are
rarely CPU-bound, however.

If your operating system supports the select() system call in its I/O
library (and nearly all do), then you can use it to juggle multiple
communication channels at once; doing other work while your I/O is taking
place in the "background."  Although this strategy can seem strange and
complex, especially at first, it is in many ways easier to understand and
control than multi-threaded programming. The module documented here solves
many of the difficult problems for you, making the task of building
sophisticated high-performance network servers and clients a snap.
�N)
�EALREADY�EINPROGRESS�EWOULDBLOCK�
ECONNRESET�EINVAL�ENOTCONN�	ESHUTDOWN�EISCONN�EBADF�ECONNABORTED�EPIPE�EAGAIN�	errorcodec


CsHzt�
|�
WStttfk
rB


|tkr6t|YSd
|YSXdS)NzUnknown error %s)�os�strerror�
ValueError�
OverflowError�	NameErrorr)
�err�r�-/opt/alt/python38/lib64/python3.8/asyncore.py�	_strerrorDs




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

Cs:z|��
Wn(t
k
r"


�Yn


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





r"c

Cs:z|��
Wn(t
k
r"


�Yn


|��
YnXdSr)�handle_write_eventrrr rrr�writeYs





r$c

Cs:z|��
Wn(t
k
r"


�Yn


|��
YnXdSr)�handle_expt_eventrrr rrr�
_exceptionas





r&c
Cs�zX|
tj
@r|��
|
tj@r&|��
|
tj@r8|��
|
tjtjBtj	B@rV|�
�
Wnhtk
r�
}
z$|jd
t
kr�|��
n|�
�
W5d}~XYn(tk
r�


�Yn


|��
YnXdS�Nr
)�select�POLLINr�POLLOUTr#�POLLPRIr%ZPOLLHUPZPOLLERRZPOLLNVAL�handle_close�OSError�args�
_DISCONNECTEDrr)r!�flags�
errr�	readwriteis"



















r2�c	Cs<
|
dkrt}
|
�
r8g}g}g}t
|
���
D]L\}}|��}|��}|rP|�|�

|rd|jsd|�|�

|sl|r*|�|�

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

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

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

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

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















"





















rCcCs�|
dkrt}
|dk	r t
|d
�
}t��}|
r�t|
���
D]L\}}d}|��r\|tjtjBO}|�	�rt|j
st|tjO}|r8|�||�
q8|�|�
}|D]&\}}|
�
|�
}|dkr�q�t||�
q�dS)Ni�r
)r4�intr(rCr5r6r7r)r+r8r:r*�registerr=r2)r>r?ZpollsterrBr!r0r@rrr�poll2�s(


















rF�>@FcCsb|dkrt}|
r t
td
�r t}nt}|dkr>|r^|||�
q,n |r^|dkr^|||�
|d}q>dS)NrCr
�
)r4�hasattrr(rFrC)r>Zuse_pollr?�countZpoll_funrrr�loop�s







rKc@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�|dkrt|_
n||_
d|_|
r�|
�d
�

|�|
|�
d|_z|
��|_Wq�tk
r�
}
z*|j	d
t
tfkrvd|_n|�|�

�W5d}~XYq�Xnd|_
dS�Nr
TF)r4�_map�_fileno�setblocking�
set_socket�	connectedZgetpeername�addrr-r.rr�del_channel�socket)�self�sockr?rrrr�__init__�s 









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

n|jr>|
�d�

|jdk	r�z|
�d|j�

Wn$tk
r�


|
�t|j�
�

YnXdd�	|
�
t
|�
fS)N�
.Z	listeningrSz%s:%dz<%s at %#x>�
 )�	__class__rrr:rTr9rS�	TypeError�repr�join�id)rWZstatusrrr�__repr__�s












zdispatcher.__repr__cCs|
dkr|j}
||
|j
<dSr)rOrP)rWr?rrr�add_channel	
s

zdispatcher.add_channelcCs,|j}|
dkr|j
}
||
kr"|
|=d|_dSr)rPrO)rWr?rBrrrrU
s




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

|�|�

dSr')Zfamily_and_typerVrQrR)rWZfamily�typerXrrr�
create_socket
s





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

dSr)rV�filenorPrb�rWrXr?rrrrR
s



zdispatcher.set_socketc

CsDz*|j�
tjtj|j�tjtj�d
B�
Wntk
r>


YnXdS)NrH)rVZ
setsockopt�
SOL_SOCKETZSO_REUSEADDR�
getsockoptr-�
rWrrr�set_reuse_addr#
s




�
��
zdispatcher.set_reuse_addrc


Csd
S�NTrrirrrr74
s
zdispatcher.readablec


Csd
Srkrrirrrr87
s
zdispatcher.writablecCs(d
|_t
jdkr|
dkrd}
|j�|
�
S)NT�nt�)r:r�namerV�listen)rWZnumrrrro>
s



zdispatcher.listencCs|
|_|j
�|
�
Sr)rTrV�bind)rWrTrrrrpD
s

zdispatcher.bindcCspd
|_d|_
|j�|
�
}|tttfks8|tkrBtj	dkrB|
|_
dS|dtfkr^|
|_
|��
nt
|t|��
dS)NFTrlr
)rS�
connectingrVZ
connect_exrrrrrrnrTr	�handle_connect_eventr-r)rWZaddressrrrr�connectH
s




�
�




zdispatcher.connectc

Csvz|j�
�\}
}WnVtk
r(


YdStk
rh
}
z$|jd
tttfkrVWY�
dS�W5d}~XYn
X|
|fSdSr')rV�acceptr]r-r.rrr
)rWZconnrT�whyrrrrtV
s






zdispatcher.acceptc
Cstz|j�
|
�
}|WStk
rn
}
z>|jd
tkr<WY�*d
S|jd
tkr\|��
WY�
d
S�W5d}~XYnXdSr')rV�sendr-r.rr/r,)rW�data�resultrurrrrvd
s










zdispatcher.sendc
Csrz(|j�
|
�
}|s |��
Wd
S|WSWnDtk
rl
}
z&|jdtkrZ|��
WY�
d
S�W5d}~XYnXdS)N�r
)rV�recvr,r-r.r/)rWZbuffer_sizerwrurrrrzq
s








zdispatcher.recvc

Csnd
|_d
|_
d
|_|��
|jdk	rjz|j��
Wn6tk
rh
}

z|
jdtt	fkrX�W5d}
~
XYnXdS)NFr
)
rSr:rqrUrV�closer-r.rr
)rWrurrrr{�
s










zdispatcher.closecCstj
�d
t|
�
�

dS)Nzlog: %s
)�sys�stderrr$�str)rW�messagerrr�log�
s
zdispatcher.log�infocCs||jkrt
d
||
f�

dS)Nz%s: %s)�ignore_log_types�print)rWrrcrrr�log_info�
s


zdispatcher.log_infoc

Cs:|jr|�
�
n&|js.|jr$|��
|��
n|��
dSr)r:�
handle_acceptrSrqrr�handle_readrirrrr�
s






zdispatcher.handle_read_eventc
Cs@|j�
tjtj�}
|
d
kr(t|
t|
�
��
|��
d|_d|_dSrN)	rVrhrg�SO_ERRORr-r�handle_connectrSrq�rWrrrrrr�
s





zdispatcher.handle_connect_eventc

Cs*|jr
dS|j
s|jr|��
|��
dSr)r:rSrqrr�handle_writerirrrr#�
s



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

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


d
t|�
}YnX|�d||||fd�
|��
dS)Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)�error)�compact_tracebackr^r`r�r,)rWZnil�
t�
v�tbinfoZ	self_reprrrrr�
s








��	zdispatcher.handle_errorc

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

Cs|�d
d�
dS)Nzunhandled read eventrMr�rirrrr��
s
zdispatcher.handle_readc

Cs|�d
d�
dS)Nzunhandled write eventrMr�rirrrr��
s
zdispatcher.handle_writec

Cs|�d
d�
dS)Nzunhandled connect eventrMr�rirrrr��
s
zdispatcher.handle_connectc
Cs|��}
|
dk	r|j
|
�
dSr)rt�handle_accepted)rWZpairrrrr��
s


zdispatcher.handle_acceptcCs|
��
|�
d
d�
dS)Nzunhandled accepted eventrM)r{r�)rWrXrTrrrr��
s

zdispatcher.handle_acceptedc

Cs|�d
d�
|�
�
dS)Nzunhandled close eventrM)r�r{rirrrr,�
s

zdispatcher.handle_close)NN)
N)
N)
N)
r�),rrr�debugrSr:rq�closingrT�	frozensetr�rYrarbrUrVZAF_INETZSOCK_STREAMrdrRrjr7r8rorprsrtrvrzr{r�r�rrrr#r%rr�r�r�r�r�r�r,rrrrrL�sJ







 

	


rLc@s6eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zd
S)
�dispatcher_with_sendNcCst�
||
|�
d
|_dS)Nry)rLrY�
out_bufferrfrrrrY�
s

zdispatcher_with_send.__init__c
Cs.d
}
t�
||jdd��}
|j|
d�|_dS)Nr
i
)rLrvr�)rWZnum_sentrrr�
initiate_sends


z"dispatcher_with_send.initiate_sendc

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

Cs|jpt
|j�
Sr)rS�lenr�rirrrr8s
zdispatcher_with_send.writablecCs0|jr|�
d
t|
�
�

|j|
|_|��
dS)Nz
sending %s)r�r�r^r�r�)rWrwrrrrvs



zdispatcher_with_send.send)NN)rrrrYr�r�r8rvrrrrr��
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>&sz%compact_traceback.<locals>.<listcomp>)r|�exc_info�AssertionErrorr9�tb_frame�f_code�co_filename�co_namer~�	tb_lineno�tb_nextr_)r�r��tbr��fileZfunction�liner�rrrr�s








�

r�cCs�|dkrt}t
|���
D]n}z|��
Wqtk
r`
}
z|jd
tkrJn|
sP�W5d}~XYqtk
rt


�Yq


|
s��YqXq|��
dSr')	r4r5�valuesr{r-r.r
r�clear)r?Z
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�duprB�rWrBrrrrYNs
zfile_wrapper.__init__c

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




�zfile_wrapper.__del__c
Gstj
|jf
|
��Sr)rr"rB�rWr.rrrrzWs
zfile_wrapper.recvc
Gstj
|jf
|
��Sr)rr$rBr�rrrrvZs
zfile_wrapper.sendNcCs(|
tj
kr|tjkr|sd
Std�
�
dS)Nr
z-Only asyncore specific behaviour implemented.)rVrgr��NotImplementedError)rW�levelZoptnameZbuflenrrrrh]s


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

dS)Nr
r�)rBrr{r�rrrr{hs






zfile_wrapper.closec


Cs|jSr)
rBrirrrreos
zfile_wrapper.fileno)
N)rrrrYr�rzrvrhr"r$r{rerrrrr�Is

r�c@seZ
dZddd�
Zdd�Zd
S)�file_dispatcherNcCsPt�
|d|�
d
|_z|
��}
Wntk
r4


YnX|�|
�

t�|
d�
dS)NTF)rLrYrSre�AttributeError�set_filer�set_blocking)rWrBr?rrrrYts







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



zfile_dispatcher.set_file)
N)rrrrYr�rrrrr�rs
r�)r3N)r3N)rGFNN)NF).�__doc__r(rVr|r;r�r�errnorrrrrrrr	r
rrr
rr�r/r4rr�	Exceptionr�KeyboardInterrupt�
SystemExitrr"r$r&r2rCrFZpoll3rKrLr�r�r�rnr�r�rrrr�<module>sD




<
�





'

*

)