Warning: file_get_contents(https://raw.githubusercontent.com/Den1xxx/Filemanager/master/languages/ru.json): Failed to open stream: HTTP request failed! HTTP/1.1 404 Not Found
in /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php on line 107
Warning: Cannot modify header information - headers already sent by (output started at /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php:1) in /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php on line 234
Warning: Cannot modify header information - headers already sent by (output started at /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php:1) in /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php on line 235
Warning: Cannot modify header information - headers already sent by (output started at /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php:1) in /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php on line 236
Warning: Cannot modify header information - headers already sent by (output started at /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php:1) in /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php on line 237
Warning: Cannot modify header information - headers already sent by (output started at /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php:1) in /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php on line 238
Warning: Cannot modify header information - headers already sent by (output started at /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php:1) in /home/zoomride2022/public_html/myzoomride.com/wp-includes/certificates/system.php on line 239
U
i_~N @ sh d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZ ee e
eeeehZze W n ek
r i ZY nX dd ZG dd deZee e fZ dd Z d
d Z d d
Z!dd Z"d&ddZ#d'ddZ$e$Z%d(ddZ&G dd dZ'G dd d e'Z(d d Z)d)d d Z*ej+d!krdG d"d# d#Z,G d$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
ECONNRESETEINVALENOTCONN ESHUTDOWNEISCONNEBADF ECONNABORTEDEPIPEEAGAIN errorcodec
C sH z t | W S tttfk
rB | tkr6t| Y S d| Y S X d S )NzUnknown error %s)osstrerror
ValueError
OverflowError NameErrorr )err r '/opt/python38/lib/python3.8/asyncore.py _strerrorD s r c @ s e Zd ZdS )ExitNowN)__name__
__module__ __qualname__r r r r r L s r c C s: z | W n( tk
r" Y n | Y nX d S N)handle_read_event_reraised_exceptions handle_errorobjr r r readQ s r" c C s: z | W n( tk
r" Y n | Y nX d S r )handle_write_eventr r r r r r writeY s r$ c C s: z | W n( tk
r" Y n | Y nX d S r )handle_expt_eventr r r r r r
_exceptiona s r& c
C s zX|t j@ r| |t j@ r&| |t j@ r8| |t jt jB t j B @ rV|
W nh t k
r } z$|j d t
kr| n|
W 5 d }~X Y n( tk
r Y n | Y nX d S Nr )selectPOLLINr POLLOUTr# POLLPRIr% POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorargs
_DISCONNECTEDr r )r! flagser r r readwritei s"
r5 c C s< |d kr t }|r8g }g }g }t| D ]L\}}| }| }|rP|| |rd|jsd|| |sl|r*|| q*g | kr| kr|krn nt| d S t |||| \}}}|D ] }|
|}|d krqt | q|D ]"}|
|}|d krqt | q|D ]&}|
|}|d kr,qt
| qd S r )
socket_maplistitemsreadablewritableappend acceptingtimesleepr( getr" r$ r& ) timeoutmaprwr4 fdr! Zis_rZis_wr r r poll} sD
"
rF c C s |d kr t }| d k r t| d } t }|rt| D ]L\}}d}| r\|tjtjB O }| rt|j
st|tj O }|r8| || q8|| }|D ]&\}}|
|}|d krqt|| qd S )Ni r )r7 intr( rF r8 r9 r: r) r+ r; r= r* registerr@ r5 )rA rB ZpollsterrE r! r3 rC r r r poll2 s(
rI >@Fc C sb |d kr t }|r ttdr t}nt}|d kr>|r^|| | q,n |r^|dkr^|| | |d }q>d S )NrF r )r7 hasattrr( rI rF )rA Zuse_pollrB countZpoll_funr r r loop s
rN c @ s2 e Zd ZdZdZdZdZdZdZe dhZ
dAddZ dd Z dBdd Z
dCd
d Zejejfd d
ZdDddZdd Zdd Zdd Zdd Zdd Zdd Zd d Zd d Zd d! Z d"d# Z d$d% Z dEd'd(Z d)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
dispatcherFNwarningc
C s |d krt | _n|| _d | _|r|d | || d| _z| | _W q tk
r } z*|j d t
t fkrvd| _n | | W 5 d }~X Y qX nd | _
d S Nr TF)r7 _map_fileno setblocking
set_socket connected getpeernameaddrr0 r1 r r del_channelsocket)selfsockrB r r r r __init__ s
zdispatcher.__init__c C s | j jd | j j g}| jr.| jr.|d n| jr>|d | jd k rz|d| j W n$ tk
r |t| j Y nX dd |t
| f S )N.Z listeningrV z%s:%dz <%s at %#x> ) __class__r r r= rX r< rV TypeErrorreprjoinid)r[ statusr r r __repr__ s
zdispatcher.__repr__c C s |d kr| j }| || j< d S r )rR rS )r[ rB r r r add_channel s zdispatcher.add_channelc C s, | j }|d kr| j}||kr"||= d | _ d S r )rS rR )r[ rB rE r r r rY s zdispatcher.del_channelc C s. ||f| _ t||}|d | | d S r' )Zfamily_and_typerZ rT rU )r[ familytyper\ r r r
create_socket s
zdispatcher.create_socketc C s || _ | | _| | d S r )rZ filenorS rg r[ r\ rB r r r rU s
zdispatcher.set_socketc C sD z*| j t jt j| j t jt jdB W n tk
r> Y nX d S )NrK )rZ
setsockopt
SOL_SOCKET SO_REUSEADDR
getsockoptr0 r[ r r r set_reuse_addr# s
zdispatcher.set_reuse_addrc C s dS NTr rq r r r r: 4 s zdispatcher.readablec C s dS rs r rq r r r r; 7 s zdispatcher.writablec C s( d| _ tjdkr |dkr d}| j|S )NTnt )r= r namerZ listen)r[ numr r r rw > s zdispatcher.listenc C s || _ | j|S r )rX rZ bind)r[ rX r r r ry D s zdispatcher.bindc C sp d| _ d| _| j|}|tttfks8|tkrBtj dkrB|| _
d S |dt fkr^|| _
| nt
|t| d S )NFTrt r )rV
connectingrZ
connect_exr r r r r rv rX r handle_connect_eventr0 r )r[ addressr r r r connectH s
zdispatcher.connectc
C sv z| j \}}W nV tk
r( Y d S tk
rh } z$|jd tttfkrVW Y
d S W 5 d }~X Y n
X ||fS d S r' )rZ acceptra r0 r1 r r r
)r[ connrX whyr r r r V s
zdispatcher.acceptc
C st z| j |}|W S tk
rn } z>|jd tkrz:uncaptured python exception, closing channel %s (%s:%s %s)error)compact_tracebackrb rd r r/ )r[ niltvtbinfoZ self_reprr r r r s zdispatcher.handle_errorc C s | dd d S )Nz!unhandled incoming priority eventrP r rq r r r r s zdispatcher.handle_exptc C s | dd d S )Nzunhandled read eventrP r rq r r r r s zdispatcher.handle_readc C s | dd d S )Nzunhandled write eventrP r rq r r r r s zdispatcher.handle_writec C s | dd d S )Nzunhandled connect eventrP r rq r r r r s zdispatcher.handle_connectc C s | }|d k r| j| d S r )r handle_accepted)r[ Zpairr r r r s zdispatcher.handle_acceptc C s | | dd d S )Nzunhandled accepted eventrP )r r )r[ r\ rX r r r r s zdispatcher.handle_acceptedc C s | dd | d S )Nzunhandled close eventrP )r r rq r r r r/ s zdispatcher.handle_close)NN)N)N)N)r ),r r r debugrV r= rz closingrX frozensetr r] rf rg rY rZ AF_INET SOCK_STREAMrj rU rr r: r; rw ry r~ r r r r r r r r| r# r% r r r r r r r r/ r r r r rO sJ
rO c @ s6 e Zd Zd ddZdd Zdd Zdd Zd
d ZdS )
dispatcher_with_sendNc C s t | || d| _d S )Nr )rO r]
out_bufferrl r r r r] s z dispatcher_with_send.__init__c C s. d}t | | jd d }| j|d | _d S )Nr i )rO r r )r[ Znum_sentr r r
initiate_send s z"dispatcher_with_send.initiate_sendc C s | d S r )r rq r r r r s z!dispatcher_with_send.handle_writec C s | j pt| jS r )rV lenr rq r r r r; s z dispatcher_with_send.writablec C s0 | j r| dt| | j| | _| d S )Nz
sending %s)r r rb r r )r[ r r r r r s zdispatcher_with_send.send)NN)r r r r] r r r; r r r r r r s
r c C s t \} }}g }|s td|rL||jjj|jjjt|j f |j
}q ~|d \}}}d dd |D }|||f| ||fS )Nztraceback does not existr_ c S s g | ] }d | qS )z
[%s|%s|%s]r ).0xr r r
& s z%compact_traceback..) r exc_infoAssertionErrorr< tb_framef_code co_filenameco_namer tb_linenotb_nextrc )r r tbr filefunctionliner r r r r s r c C s | d kr t } t| D ]n}z | W q tk
r` } z|jd tkrJn|sP W 5 d }~X Y q tk
rt Y q |s Y qX q| d S r' ) r7 r8 valuesr r0 r1 r
r clear)rB Z
ignore_allr r r r close_all) s
r posixc @ sN e Zd Zdd Zdd Zdd Zdd Zdd
d ZeZeZ d d
Z
dd Z d S ) file_wrapperc C s t || _d S r )r duprE r[ rE r r r r] N s zfile_wrapper.__init__c C s* | j dkr tjd| t| d | d S )Nr zunclosed file %r)source)rE warningswarnResourceWarningr rq r r r __del__Q s
zfile_wrapper.__del__c G s t j| jf| S r )r r" rE r[ r1 r r r r W s zfile_wrapper.recvc G s t j| jf| S r )r r$ rE r r r r r Z s zfile_wrapper.sendNc C s( |t jkr |t jkr |s dS tdd S )Nr z-Only asyncore specific behaviour implemented.)rZ rn r NotImplementedError)r[ levelZoptnamebuflenr r r rp ] s
zfile_wrapper.getsockoptc C s( | j dk rd S | j }d| _ t| d S )Nr r )rE r r r r r r r h s
zfile_wrapper.closec C s | j S r )rE rq r r r rk o s zfile_wrapper.fileno)N) r r r r] r r r rp r" r$ r rk r r r r r I s
r c @ s e Zd ZdddZdd ZdS )file_dispatcherNc C sP t | d | d| _z | }W n tk
r4 Y nX | | t|d d S )NTF)rO r] rV rk AttributeErrorset_filer set_blocking)r[ rE rB r r r r] t s
zfile_dispatcher.__init__c C s" t || _| j | _| d S r )r rZ rk rS rg r r r r r s
zfile_dispatcher.set_file)N)r r r r] r r r r r r r s
r )r6 N)r6 N)rJ FNN)NF).__doc__r( rZ r r> r r errnor r r r r r r r r
r r r
r r r2 r7 r r Exceptionr KeyboardInterrupt
SystemExitr r" r$ r& r5 rF rI Zpoll3rN rO r r r rv r r r r r r sD <
'
*
)