$34 GRAYBYTE WORDPRESS FILE MANAGER $98

3

� f�N�@sh
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZm	Z	m
Z
mZmZm
Z
mZmZmZmZmZmZmZ
eee
eeeeh�
Zye
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


Cs>y
tj
|�
Stttfk
r8


|tkr0t|Sd
|SXdS)NzUnknown error %s)�os�strerror�
ValueError�
OverflowError�	NameErrorr)
�err�r�-/opt/alt/python36/lib64/python3.6/asyncore.py�	_strerrorDs






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

Cs:y|j�
Wn(t
k
r"


�Yn


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





r c

Cs:y|j�
Wn(t
k
r"


�Yn


|j�
YnXdS)
N)�handle_write_eventrr)
rrrr�writeYs





r"c

Cs:y|j�
Wn(t
k
r"


�Yn


|j�
YnXdS)
N)�handle_expt_eventrr)
rrrr�
_exceptionas





r$cCs�yX|
tj
@r|j�
|
tj@r&|j�
|
tj@r8|j�
|
tjtjBtj	B@rV|j
�
Wnhtk
r�
}
z&|jd
t
kr�|j�
n|j
�
WYdd}~Xn(tk
r�


�Yn


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



















r/�c	CsN
|
dkrt}
|
�
rJg}g}g}x^t
|
j��
D]N\}}|j�}|j�}|rR|j|�

|rh|jrh|j|�

|sp|r,|j|�

q,Wg|ko�|ko�|kn
r�tj|�

dSt	j	||||�\}}}x(|D] }|
j
|�
}|dkr�q�t|�

q�Wx*|D]"}|
j
|�
}|dk�
rq�t|�

q�Wx.|D]&}|
j
|�
}|dk�
r<�
q t
|�

�
q WdS)
N)�
socket_map�list�items�readable�writable�append�	accepting�timeZsleepr%�getr r"r$)	�timeout�map�
r�
wr.�fdrZis_rZis_wrrr�poll}sD














"






















r?cCs�|
dkrt}
|dk	r t
|d
�
}tj�}|
r�x^t|
j��
D]N\}}d}|j�r^|tjtjBO}|j	�rx|j
rx|tjO}|r:|j||�
q:W|j|�
}x.|D]&\}}|
j
|�
}|dkr�q�t||�
q�WdS)Ni�r
)r1�intr%r?r2r3r4r&r(r5r7r'�registerr9r/)r:r;Zpollsterr>rr-r<rrr�poll2�s(


















rB�>@FcCsj|dkrt}|
r t
td
�r t}nt}|dkrBx8|r>|||�
q.Wn$x"|rd|dkrd|||�
|d}qDWdS)Nr?r
�
)r1�hasattrr%rBr?)r:Zuse_pollr;�countZpoll_funrrr�loop�s







rGc@s6
eZ
dZd
Zd
Zd
Zd
Zd
ZdZe	dh
�
Z
dAdd�
Zdd�ZeZ
dBdd	�
ZdCd
d�
Zejejfdd
�
ZdDdd�
Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�ZdEd'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�
dispatcherFN�warningcCs�|dkrt|_
n||_
d|_|
r�|
jd
�

|j|
|�
d|_y|
j�|_Wq�tk
r�
}
z,|j	d
t
tfkrvd|_n|j|�

�WYdd}~Xq�Xnd|_
dS)Nr
TF)r1�_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.|
jd�

n|jr>|
jd�

|jdk	r�y|
jd|j�

Wn$tk
r�


|
jt|j�
�

YnXddj	|
�
t
|�
fS)N�
.Z	listeningrNz%s:%dz<%s at %#x>�
 )�	__class__rrr7rOr6rN�	TypeError�repr�join�id)rRZstatusrrr�__repr__�s












zdispatcher.__repr__cCs|
dkr|j}
||
|j
<dS)
N)rJrK)rRr;rrr�add_channel
s

zdispatcher.add_channelcCs,|j}|
dkr|j
}
||
kr"|
|=d|_dS)
N)rKrJ)rRr;r>rrrrP
s




zdispatcher.del_channelcCs.|
|f|_t
j
|
|�}|jd
�

|j|�

dS)Nr
)Zfamily_and_typerQrLrM)rRZfamily�typerSrrr�
create_socket
s





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

dS)
N)rQ�filenorKr])rRrSr;rrrrM 
s


zdispatcher.set_socketc

CsDy*|jj
tjtj|jjtjtj�d
B�
Wntk
r>


YnXdS)NrD)rQZ
setsockopt�
SOL_SOCKETZSO_REUSEADDR�
getsockoptr*)
rRrrr�set_reuse_addr&
s





zdispatcher.set_reuse_addrc


Csd
S)NTr)
rRrrrr47
s
zdispatcher.readablec


Csd
S)NTr)
rRrrrr5:
s
zdispatcher.writablecCs(d
|_t
jdkr|
dkrd}
|jj|
�
S)NT�nt�)r7r�namerQ�listen)rRZnumrrrrgA
s



zdispatcher.listencCs|
|_|j
j|
�
S)
N)rOrQ�bind)rRrOrrrrhG
s

zdispatcher.bindcCspd
|_d|_
|jj|
�
}|tttfks8|tkrBtj	dkrB|
|_
dS|dtfkr^|
|_
|j�
nt
|t|��
dS)NFTrdr
)rN�
connectingrQZ
connect_exrrrrrrfrOr	�handle_connect_eventr*r)rRZaddressrrrr�connectK
s










zdispatcher.connectc
Csny|jj
�\}
}WnNtk
r&


dStk
r`
}
z |jd
tttfkrNdS�WYdd}~Xn
X|
|fSdS)Nr
)rQ�acceptrXr*r+rrr
)rRZconnrO�whyrrrrlY
s





zdispatcher.acceptcCsfy|jj
|
�
}|Stk
r`
}
z4|jd
tkr4d
S|jd
tkrN|j�
d
S�WYdd}~XnXdS)Nr
)rQ�sendr*r+rr,r))rR�data�resultrmrrrrng
s








zdispatcher.sendcCshy$|jj
|
�
}|s|j�
d
S|SWn>tk
rb
}
z"|jdtkrP|j�
d
S�WYdd}~XnXdS)N�r
)rQ�recvr)r*r+r,)rR�buffer_sizerormrrrrrt
s






zdispatcher.recvc
Csnd
|_d
|_
d
|_|j�
|jdk	rjy|jj�
Wn6tk
rh
}

z|
jdtt	fkrX�WYdd}
~
XnXdS)NFr
)
rNr7rirPrQ�closer*r+rr
)rRrmrrrrt�
s










zdispatcher.closecCstj
jd
t|
�
�

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

dS)Nz%s: %s)�ignore_log_types�print)rRrxr^rrr�log_info�
s


zdispatcher.log_infoc


Cs:|jr|j
�
n&|js.|jr$|j�
|j�
n|j�
dS)
N)r7�
handle_acceptrNrirj�handle_read)
rRrrrr�
s






zdispatcher.handle_read_eventc
Cs@|jj
tjtj�}
|
d
kr(t|
t|
�
��
|j�
d|_d|_dS)Nr
TF)	rQrbra�SO_ERRORr*r�handle_connectrNri)rRrrrrrj�
s





zdispatcher.handle_connect_eventc


Cs*|jr
dS|j
s|jr|j�
|j�
dS)
N)r7rNrirj�handle_write)
rRrrrr!�
s



zdispatcher.handle_write_eventc
Cs0|jj
tjtj�}
|
d
kr$|j�
n|j�
dS)Nr
)rQrbrar�r)�handle_expt)rRrrrrr#�
s

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


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








zdispatcher.handle_errorc

Cs|jd
d�
dS)Nz!unhandled incoming priority eventrI)
r})
rRrrrr��
s
zdispatcher.handle_exptc

Cs|jd
d�
dS)Nzunhandled read eventrI)
r})
rRrrrr�
s
zdispatcher.handle_readc

Cs|jd
d�
dS)Nzunhandled write eventrI)
r})
rRrrrr��
s
zdispatcher.handle_writec

Cs|jd
d�
dS)Nzunhandled connect eventrI)
r})
rRrrrr��
s
zdispatcher.handle_connectc
Cs|j�}
|
dk	r|j
|
�
dS)
N)rl�handle_accepted)rRZpairrrrr~�
s


zdispatcher.handle_acceptcCs|
j�
|j
d
d�
dS)Nzunhandled accepted eventrI)rtr})rRrSrOrrrr��
s

zdispatcher.handle_acceptedc

Cs|jd
d�
|j
�
dS)Nzunhandled close eventrI)r}rt)
rRrrrr)�
s

zdispatcher.handle_close)NN)
N)
N)
N)
rz)-rrr�debugrNr7ri�closingrO�	frozensetr{rTr\�__str__r]rPrQZAF_INETZSOCK_STREAMr_rMrcr4r5rgrhrkrlrnrrrtryr}rrjr!r#rr�rr�r�r~r�r)rrrrrH�sL







 


	


rHc@s6eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zd
S)
�dispatcher_with_sendNcCstj
||
|�
d
|_dS)Nrq)rHrT�
out_buffer)rRrSr;rrrrT�
s

zdispatcher_with_send.__init__c
Cs.d
}
tj
||jdd��}
|j|
d�|_dS)Nr
i
)rHrnr�)rRZnum_sentrrr�
initiate_sends


z"dispatcher_with_send.initiate_sendc


Cs|j�
dS)
N)
r�)
rRrrrr�s
z!dispatcher_with_send.handle_writec

Cs|jpt
|j�
S)
N)rN�lenr�)
rRrrrr5s
zdispatcher_with_send.writablecCs0|jr|j
d
t|
�
�

|j|
|_|j�
dS)Nz
sending %s)r�r}rYr�r�)rRrorrrrns



zdispatcher_with_send.send)NN)rrrrTr�r�r5rnrrrrr��
s

r�cCs�tj
�\}}
}g}|std
�
�
x0|rN|j|jjj|jjjt|j	�
f�

|j
}q W~|d\}}}djdd�|D�
�
}|||f||
|fS)Nztraceback does not existrDrVc
Ssg|]}
d|
�qS)
z
[%s|%s|%s]r)�.0�
xrrr�
<listcomp>)sz%compact_traceback.<locals>.<listcomp>���)ru�exc_info�AssertionErrorr6�tb_frame�f_code�co_filename�co_namerw�	tb_lineno�tb_nextrZ)r�r��tbr��fileZfunction�linerzrrrr�s











r�cCs�|dkrt}x~t
|j��
D]n}y|j�
Wqtk
rb
}
z|jd
tkrLn|
sR�WYdd}~Xqtk
rv


�Yq


|
s��YqXqW|j�
dS)Nr
)	r1r2�valuesrtr*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_wrappercCstj
|
�
|_dS)
N)r�dupr>)rRr>rrrrTQs
zfile_wrapper.__init__c

Cs*|jd
krt
jd|t|d�
|j�
dS)Nr
zunclosed file %r)
�source)r>�warnings�warn�ResourceWarningrt)
rRrrr�__del__Ts




zfile_wrapper.__del__c
Gstj
|jf
|
��S)
N)rr r>)rRr+rrrrrZs
zfile_wrapper.recvc
Gstj
|jf
|
��S)
N)rr"r>)rRr+rrrrn]s
zfile_wrapper.sendNcCs*|
tj
kr|tjkr|rd
Std�
�
dS)Nr
z-Only asyncore specific behaviour implemented.)rQrar��NotImplementedError)rR�levelZoptnameZbuflenrrrrb`s







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

dS)Nr
rDr�)r>rrt)rRr>rrrrtks






zfile_wrapper.closec


Cs|jS)
N)
r>)
rRrrrr`rs
zfile_wrapper.fileno)
N)rrrrTr�rrrnrbr r"rtr`rrrrr�Ls

r�c@seZ
dZddd�
Zdd�Zd
S)�file_dispatcherNcCsPtj
|d|�
d
|_y|
j�}
Wntk
r4


YnX|j|
�

tj|
d�
dS)NTF)rHrTrNr`�AttributeError�set_filer�set_blocking)rRr>r;rrrrTws







zfile_dispatcher.__init__cCs"t|
�
|_
|j
j�|_|j�
dS)
N)r�rQr`rKr])rRr>rrrr��s



zfile_dispatcher.set_file)
N)rrrrTr�rrrrr�us
r�)r0N)r0N)rCFNN)NF).�__doc__r%rQrur8r�r�errnorrrrrrrr	r
rrr
rr�r,r1rr�	Exceptionr�KeyboardInterrupt�
SystemExitrr r"r$r/r?rBZpoll3rGrHr�r�r�rfr�r�rrrr�<module>/sB




<






'

-

)