$90 GRAYBYTE WORDPRESS FILE MANAGER $59

�
j fR�@sdZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZm	Z	m
Z
mZmZm
Z
mZmZmZmZmZmZmZ
eee
eeeef�
Zye
Wnek
r�


iZYn
Xdd�ZGdd�de�ZeeefZdd	�Zd
d�Z dd
�Z!dd�Z"dddd�Z#dddd�Z$e$Z%dddddd�Z&Gdd�d�Z'Gdd�de'�Z(dd�Z)dddd �Z*ej+d!krd
dl,Z,Gd"d#�d#�Z-Gd$d%�d%e'�Z.ndS)&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


CsOytj
|�
SWn7tttfk
rJ


|tkr>t|Sd
|SYn
XdS)NzUnknown error %s)�os�strerror�
ValueError�
OverflowError�	NameErrorr)
�err�r�-/opt/alt/python34/lib64/python3.4/asyncore.py�	_strerrorDs





rc
@seZ
dZd
S)�ExitNowN)�__name__�
__module__�__qualname__rrrrrLs
rc

Cs;y|j�
Wn&t
k
r%


�Yn


|j�
Yn
XdS)
N)�handle_read_event�_reraised_exceptions�handle_error)
�objrrr�readQs






r c

Cs;y|j�
Wn&t
k
r%


�Yn


|j�
Yn
XdS)
N)�handle_write_eventrr)
rrrr�writeYs






r"c

Cs;y|j�
Wn&t
k
r%


�Yn


|j�
Yn
XdS)
N)�handle_expt_eventrr)
rrrr�
_exceptionas






r$cCs�yz|
tj
@r|j�
n|
tj@r7|j�
n|
tj@rQ|j�
n|
tjtjBtj	B@ry|j
�
nWnttk
r�
}
z/|jd
t
kr�|j�
n
|j
�
WYdd}~Xn&tk
r�


�Yn


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























r/gc	Cs�
|
dkrt}
n|
r�
g}g}g}x�t
|
j��
D]v\}}|j�}|j�}|rz|j|�

n|r�|jr�|j|�

n|s�|r@|j|�

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

dSy%t	j	||||�\}}}Wnt
k
r/



dSYn
Xx9|D]1}|
j|�
}|dkr^
q7
nt|�

q7
Wx9|D]1}|
j|�
}|dkr�
qs
nt
|�

qs
Wx<|D]1}|
j|�
}|dkr�
q�
nt|�

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










'



%


	














r?cCsK
|
dkrt}
n|dk	r4t
|d
�
}ntj�}|
rG
x�t|
j��
D]t\}}d}|j�r�|tjtjBO}n|j	�r�|j
r�|tjO}n|rY|j||�
qYqYWy|j|�
}Wnt
k
r�


g}Yn
XxE|D]:\}}|
j|�
}|dkr3
q
nt||�
q
WndS)Ni�r
)r0�intr%r?r1r2r3r&r(r4r6r'�registerr8r9r/)r:r;Zpollsterr>rr-r<rrr�poll2�s.
	



















rBg>@FcCs�|dkrt}n|
r3t
td
�r3t}nt}|dkrbxJ|r^|||�
qHWn0x-|r�|dkr�|||�
|d}qeWdS)Nr?r
�
)r0�hasattrr%rBr?)r:Zuse_pollr;�countZpoll_funrrr�loop�s

	
	
	



rFc@s�
eZ
dZd
Zd
Zd
Zd
Zd
ZdZe	dg
�
Z
dddd�Zdd�ZeZ
ddd	�
Zdd
d�
Zejejdd
�Zddd�
Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�Zd&d'�Z d(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,dAdB�Z-dS)C�
dispatcherFN�warningcCs�|dkrt|_
n	||_
d|_|
r�|
jd
�

|j|
|�
d|_y|
j�|_Wq�tk
r�
}
z:|j	d
t
tfkr�d|_n|j|�

�WYdd}~Xq�Xn	d|_
dS)Nr
TF)r0�_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|jrX|
jd�

n|jdk	r�y|
jd|j�

Wq�tk
r�


|
jt|j�
�

Yq�Xnddj	|
�
t
|�
fS)N�
.Z	listeningrMz%s:%dz<%s at %#x>�
 )�	__class__rrr6rNr5rM�	TypeError�repr�join�id)rQZstatusrrr�__repr__

s



	







zdispatcher.__repr__cCs)|
dkr|j}
n||
|j
<dS)
N)rIrJ)rQr;rrr�add_channel
s

zdispatcher.add_channelcCsD|j}|
dkr!|j
}
n||
kr7|
|=nd|_dS)
N)rJrI)rQr;r>rrrrO
s
	




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

|j|�

dS)Nr
)Zfamily_and_typerPrKrL)rQZfamily�typerRrrr�
create_socket
s




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

dS)
N)rP�filenorJr\)rQrRr;rrrrL%
s
	
zdispatcher.set_socketc

CsRy9|jj
tjtj|jjtjtj�d
B�
Wntk
rM


Yn
XdS)NrC)rPZ
setsockopt�
SOL_SOCKETZSO_REUSEADDR�
getsockoptr*)
rQrrr�set_reuse_addr+
s
	




zdispatcher.set_reuse_addrc


Csd
S)NTr)
rQrrrr3<
s
zdispatcher.readablec


Csd
S)NTr)
rQrrrr4?
s
zdispatcher.writablecCs=d
|_t
jdkr-|
dkr-d}
n|jj|
�
S)NT�nt�)r6r�namerP�listen)rQZnumrrrrfF
s
	

	
zdispatcher.listencCs|
|_|j
j|
�
S)
N)rNrP�bind)rQrNrrrrgL
s
	
zdispatcher.bindcCs�d
|_d|_
|jj|
�
}|tttfksT|tkratj	dkra|
|_
dS|dtfkr�|
|_
|j�
nt
|t|��
dS)NFTrc�cer
)zntrh)rM�
connectingrPZ
connect_exrrrrrrerNr	�handle_connect_eventr*r)rQZaddressrrrr�connectP
s
	
	



	


	

zdispatcher.connectc
Cs�y|jj
�\}
}Wn]tk
r1


dSYnRtk
rx
}
z(|jd
tttfkrcdS�WYdd}~XnX|
|fSdS)Nr
)rP�acceptrWr*r+rrr
)rQZconnrN�whyrrrrl^
s






zdispatcher.acceptcCs�y|jj
|
�
}|SWn`tk
r|
}
z@|jd
tkrFd
S|jd
tkrg|j�
d
S�WYdd}~Xn
XdS)Nr
)rP�sendr*r+rr,r))rQ�data�resultrmrrrrnl
s









zdispatcher.sendcCs~y.|jj
|
�
}|s)|j�
d
S|SWnItk
ry
}
z)|jdtkrd|j�
d
S�WYdd}~Xn
XdS)N�r
)rP�recvr)r*r+r,)rQZbuffer_sizerormrrrrry
s








zdispatcher.recvc
Cs�d
|_d
|_
d
|_|j�
|jdk	r�y|jj�
Wq�tk
r�
}

z$|
jdtt	fkry�nWYdd}
~
Xq�XndS)NFr
)
rMr6rirOrP�closer*r+rr
)rQrmrrrrs�
s
	
	
	







zdispatcher.closec
Cs�yt|j
|
�}Wn.tk
rF


td
|jj|
f�
�
Yn9Xdi|jjd6|
d6}tj|tdd�

|SdS)Nz!%s instance has no attribute '%s'zA%(me)s.%(attr)s is deprecated; use %(me)s.socket.%(attr)s instead�me�attr�
stacklevel�)�getattrrP�AttributeErrorrVr�warnings�warn�DeprecationWarning)rQruZretattr�msgrrr�__getattr__�
s








zdispatcher.__getattr__cCstj
jd
t|
�
�

dS)Nzlog: %s
)�sys�stderrr"�str)rQ�messagerrr�log�
s
zdispatcher.log�infocCs*||jkr&t
d
||
f�

ndS)Nz%s: %s)�ignore_log_types�print)rQr�r]rrr�log_info�
s

zdispatcher.log_infoc


CsP|jr|j
�
n6|jsB|jr5|j�
n|j�
n
|j�
dS)
N)r6�
handle_acceptrMrirj�handle_read)
rQrrrr�
s
	

	
	



zdispatcher.handle_read_eventc
Cs_|jj
tjtj�}
|
d
kr?t|
t|
�
��
n|j�
d|_d|_dS)Nr
TF)	rPrar`�SO_ERRORr*r�handle_connectrMri)rQrrrrrj�
s





	
zdispatcher.handle_connect_eventc


Cs=|jr
dS|j
s/|jr/|j�
q/n|j�
dS)
N)r6rMrirj�handle_write)
rQrrrr!�
s
		
	

zdispatcher.handle_write_eventc
CsB|jj
tjtj�}
|
d
kr4|j�
n
|j�
dS)Nr
)rPrar`r�r)�handle_expt)rQrrrrr#�
s

zdispatcher.handle_expt_eventc
Csnt�\}
}}}yt
|�
}Wn


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








zdispatcher.handle_errorc

Cs|jd
d�
dS)Nz!unhandled incoming priority eventrH)
r�)
rQrrrr��
s
zdispatcher.handle_exptc

Cs|jd
d�
dS)Nzunhandled read eventrH)
r�)
rQrrrr��
s
zdispatcher.handle_readc

Cs|jd
d�
dS)Nzunhandled write eventrH)
r�)
rQrrrr��
s
zdispatcher.handle_writec

Cs|jd
d�
dS)Nzunhandled connect eventrH)
r�)
rQrrrr��
s
zdispatcher.handle_connectc
Cs,|j�}
|
dk	r(|j
|
�
ndS)
N)rl�handle_accepted)rQZpairrrrr��
s


zdispatcher.handle_acceptcCs|
j�
|j
d
d�
dS)Nzunhandled accepted eventrH)rsr�)rQrRrNrrrr�s


zdispatcher.handle_acceptedc

Cs|jd
d�
|j
�
dS)Nzunhandled close eventrH)r�rs)
rQrrrr)s

zdispatcher.handle_close).rrr�debugrMr6ri�closingrN�	frozensetr�rSr[�__str__r\rOrPZAF_INETZSOCK_STREAMr^rLrbr3r4rfrgrkrlrnrrrsr~r�r�rrjr!r#rr�r�r�r�r�r�r)rrrrrG�sN





 
	
rGc@sReZ
dZd
d
dd�Zdd�Zdd�Zdd	�Zd
d�Zd
S)�dispatcher_with_sendNcCs tj
||
|�
d
|_dS)Nrq)rGrS�
out_buffer)rQrRr;rrrrSs

zdispatcher_with_send.__init__c
Cs?d
}
tj
||jdd��}
|j|
d�|_dS)Nr
i
)rGrnr�)rQZnum_sentrrr�
initiate_sends


z"dispatcher_with_send.initiate_sendc


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

Cs|jpt
|j�
S)
N)rM�lenr�)
rQrrrr4s
zdispatcher_with_send.writablecCsA|jr#|j
d
t|
�
�

n|j|
|_|j�
dS)Nz
sending %s)r�r�rXr�r�)rQrorrrrn!s
	


zdispatcher_with_send.send)rrrrSr�r�r4rnrrrrr�s
r�cCs�tj
�\}}
}g}|s0td
�
�
nxD|rv|j|jjj|jjjt|j	�
f�

|j
}q3W~|d\}}}djdd�|D�
�
}|||f||
|fS)Nztraceback does not existrCrUc
Ssg|]}
d|
�qS)
z
[%s|%s|%s]r)�.0�
xrrr�
<listcomp><s	z%compact_traceback.<locals>.<listcomp>���)r�exc_info�AssertionErrorr5�tb_frame�f_code�co_filename�co_namer��	tb_lineno�tb_nextrY)r�r��tbr��fileZfunction�liner�rrrr�+s




	






r�cCs�|dkrt}nx�t
|j��
D]�}y|j�
Wq(tk
r�
}
z'|jd
tkrgn|
ss�nWYdd}~Xq(tk
r�


�Yq(


|
s��nYq(Xq(W|j�
dS)Nr
)	r0r1�valuesrsr*r+r
r�clear)r;Z
ignore_allr�rrr�	close_all?s 

	














r��posixc@sseZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
d�
ZeZeZ	dd
�Z
dd�Zd	S)�file_wrappercCstj
|
�
|_dS)
N)r�dupr>)rQr>rrrrSfs
zfile_wrapper.__init__c

Cs4|jd
kr&t
jd|t�
n|j�
dS)Nr
zunclosed file %r)r>rzr{�ResourceWarningrs)
rQrrr�__del__is


zfile_wrapper.__del__c
Gstj
|j|
�
S)
N)rr r>)rQr+rrrrrns
zfile_wrapper.recvc
Gstj
|j|
�
S)
N)rr"r>)rQr+rrrrnqs
zfile_wrapper.sendNcCs9|
tj
kr)|tjkr)|r)d
Std�
�
dS)Nr
z-Only asyncore specific behaviour implemented.)rPr`r��NotImplementedError)rQ�levelZoptnameZbuflenrrrrats





zfile_wrapper.getsockoptc

Cs0|jd
krdSt
j|j�

d|_dS)Nr
rCr�)r>rrs)
rQrrrrss



zfile_wrapper.closec


Cs|jS)
N)
r>)
rQrrrr_�s
zfile_wrapper.fileno)rrrrSr�rrrnrar r"rsr_rrrrr�as
r�c@s+eZ
dZd
dd�
Zdd�Zd
S)�file_dispatcherNcCs�tj
|d|�
d
|_y|
j�}
Wntk
r@


Yn
X|j|
�

tj|
tjd�}|tj	B}tj|
tj
|�
dS)NTr
)rGrSrMr_ry�set_file�fcntlZF_GETFLr�
O_NONBLOCKZF_SETFL)rQr>r;r-rrrrS�s

	









zfile_dispatcher.__init__cCs/t|
�
|_
|j
j�|_|j�
dS)
N)r�rPr_rJr\)rQr>rrrr��s


zfile_dispatcher.set_file)rrrrSr�rrrrr��s
r�)/�__doc__r%rPrr7rzr�errnorrrrrrrr	r
rrr
rr�r,r0rr�	Exceptionr�KeyboardInterrupt�
SystemExitrr r"r$r/r?rBZpoll3rFrGr�r�r�rer�r�r�rrrr�<module>/sB




X




*�:
'