File manager

�
��fQc@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"de#dd�Z$de#dd�Z%e%Z&de'e#e#dd�Z(Gdd�d�Z)Gdd�de)�Z*dd�Z+e#e'dd�Z,ej-d krd
dl.Z.Gd!d"�d"�Z/Gd#d$�d$e)�Z0ndS(%u�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.
iN(
uEALREADYuEINPROGRESSuEWOULDBLOCKu
ECONNRESETuEINVALuENOTCONNu	ESHUTDOWNuEISCONNuEBADFuECONNABORTEDuEPIPEuEAGAINu	errorcodec


CsOytj
|�
SWn7tttfk
rJ


|tkr>t|Sd
|SYn
XdS(NuUnknown error %s(uosustrerroru
ValueErroru
OverflowErroru	NameErroru	errorcode(
uerr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu	_strerrorDs





u	_strerrorc


Bs|EeZ
dZd
S(uExitNowN(u__name__u
__module__u__qualname__(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuExitNowLs
uExitNowc

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


�Yn


|j�
Yn
XdS(
N(uhandle_read_eventu_reraised_exceptionsuhandle_error(
uobj((u-/opt/alt/python33/lib64/python3.3/asyncore.pyureadQs






ureadc

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


�Yn


|j�
Yn
XdS(
N(uhandle_write_eventu_reraised_exceptionsuhandle_error(
uobj((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuwriteYs






uwritec

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


�Yn


|j�
Yn
XdS(
N(uhandle_expt_eventu_reraised_exceptionsuhandle_error(
uobj((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
_exceptionas






u
_exceptioncCs�yz|
tj
@r|j�
n|
tj@r7|j�
n|
tj@rQ|j�
n|
tjtjBtj	B@ry|j
�
nWnwtjk
r�
}
z/|j
d
tkr�|j�
n
|j
�
WYdd}~Xn&tk
r�


�Yn


|j�
Yn
XdS(Ni(uselectuPOLLINuhandle_read_eventuPOLLOUTuhandle_write_eventuPOLLPRIuhandle_expt_eventuPOLLHUPuPOLLERRuPOLLNVALuhandle_closeusocketuerroruargsu
_DISCONNECTEDuhandle_erroru_reraised_exceptions(uobjuflagsu
e((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu	readwriteis"























u	readwritegc	
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
||||�\}}}Wntk
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(uNoneu
socket_mapulistuitemsureadableuwritableuappendu	acceptingutimeusleepuselectuInterruptedErrorugetureaduwriteu
_exception(	utimeoutumapu
ru
wu
eufduobjuis_ruis_w((u-/opt/alt/python33/lib64/python3.3/asyncore.pyupoll}sJ

	










'



%


	














upollcCsK
|
dkrt
}
n|dk	r4t|d
�
}ntj�}|
rG
x�t|
j��
D]t\}}d}|j�r�|tjtj	BO}n|j
�r�|jr�|tjO}n|rY|j
||�
qYqYWy|j|�
}Wntk
r�


g}Yn
XxE|D]:\}}|
j|�
}|dkr3
q
nt||�
q
WndS(Ni�i(uNoneu
socket_mapuintuselectupollulistuitemsureadableuPOLLINuPOLLPRIuwritableu	acceptinguPOLLOUTuregisteruInterruptedErrorugetu	readwrite(utimeoutumapupollsterufduobjuflagsu
r((u-/opt/alt/python33/lib64/python3.3/asyncore.pyupoll2�s.
	



















upoll2g>@cCs�|dkrt
}n|
r3ttd
�r3t}nt}|dkrbxJ|r^|||�
qHWn0x-|r�|dkr�|||�
|d}qeWdS(Nupollii
(uNoneu
socket_mapuhasattruselectupoll2upoll(utimeoutuuse_pollumapucountupoll_fun((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuloop�s

	
	
	



uloopc

Bs�
|EeZ
dZdBZdBZdBZdBZdBZdAZ
ed
g
�
ZdAdAdd�Z
dd�ZeZdAdd�
ZdAdd	�
Zejejd
d�ZdAdd
�
Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd d!�Z d"d#�Z!d$d%�Z"d&d'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/dAS(Cu
dispatcheruwarningcCs�|dkrt
|_n	||_d|_|
r�|
jd
�

|j|
|�
d|_y|
j�|_	Wq�t
jk
r�
}
z:|jd
t
tfkr�d|_n|j|�

�WYdd}~Xq�Xn	d|_
dS(NiTF(uNoneu
socket_mapu_mapu_filenousetblockingu
set_socketuTrueu	connectedugetpeernameuaddrusocketuerroruargsuENOTCONNuEINVALuFalseudel_channel(uselfusockumapuerr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu__init__�s 

		


	




udispatcher.__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(Nu
.u	listeningu	connectedu%s:%du<%s at %#x>u
 (u	__class__u
__module__u__name__u	acceptinguaddruappendu	connecteduNoneu	TypeErrorureprujoinuid(uselfustatus((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu__repr__

s



	







udispatcher.__repr__cCs)|
dkr|j
}
n||
|j<dS(
N(uNoneu_mapu_fileno(uselfumap((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuadd_channel
s

udispatcher.add_channelcCsD|j}|
dkr!|j}
n||
kr7|
|=nd|_dS(
N(u_filenouNoneu_map(uselfumapufd((u-/opt/alt/python33/lib64/python3.3/asyncore.pyudel_channel
s
	




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

|j|�

dS(Ni(ufamily_and_typeusocketusetblockingu
set_socket(uselfufamilyutypeusock((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
create_socket
s




udispatcher.create_socketcCs)|
|_|
j
�|_|j|�

dS(
N(usocketufilenou_filenouadd_channel(uselfusockumap((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
set_socket%
s
	
udispatcher.set_socketc

CsUy9|jj
tjtj|jjtjtj�d
B�
Wntjk
rP


Yn
XdS(Ni
(usocketu
setsockoptu
SOL_SOCKETuSO_REUSEADDRu
getsockoptuerror(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuset_reuse_addr+
s
	



udispatcher.set_reuse_addrc


Csd
S(NT(
uTrue(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyureadable<
s
udispatcher.readablec


Csd
S(NT(
uTrue(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuwritable?
s
udispatcher.writablecCs=d|_
tjd
kr-|
dkr-d}
n|jj|
�
S(NuntiT(uTrueu	acceptinguosunameusocketulisten(uselfunum((u-/opt/alt/python33/lib64/python3.3/asyncore.pyulistenF
s
	

	
udispatcher.listencCs|
|_|j
j|
�
S(
N(uaddrusocketubind(uselfuaddr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyubindL
s
	
udispatcher.bindcCs�d|_
d|_|jj|
�
}|tttfksT|t	krat
jdkra|
|_dS|dt
fkr�|
|_|j�
ntj|t|��
dS(NuntuceiFT(untuce(uFalseu	connecteduTrueu
connectingusocketu
connect_exuEINPROGRESSuEALREADYuEWOULDBLOCKuEINVALuosunameuaddruEISCONNuhandle_connect_eventuerroru	errorcode(uselfuaddressuerr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuconnectP
s
	
	



	


	

udispatcher.connectc
Cs�y|jj
�\}
}Wn`tk
r1


dSYnUtjk
r{
}
z(|jd
tttfkrfdS�WYdd}~XnX|
|fSdS(Ni(	usocketuacceptu	TypeErroruNoneuerroruargsuEWOULDBLOCKuECONNABORTEDuEAGAIN(uselfuconnuaddruwhy((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuaccept^
s






udispatcher.acceptcCs�y|jj
|
�
}|SWnctjk
r
}
z@|jd
tkrId
S|jd
tkrj|j�
d
S�WYdd}~Xn
XdS(Ni(usocketusenduerroruargsuEWOULDBLOCKu
_DISCONNECTEDuhandle_close(uselfudatauresultuwhy((u-/opt/alt/python33/lib64/python3.3/asyncore.pyusendl
s









udispatcher.sendcCs�y.|jj
|
�
}|s)|j�
d
S|SWnLtjk
r|
}
z)|jdtkrg|j�
d
S�WYdd}~Xn
XdS(Nsi(usocketurecvuhandle_closeuerroruargsu
_DISCONNECTED(uselfubuffer_sizeudatauwhy((u-/opt/alt/python33/lib64/python3.3/asyncore.pyurecvy
s








udispatcher.recvc
Cs�d|_
d|_d|_|j�
y|jj�
WnGtjk
r
}

z$|
jd
t	t
fkrm�nWYdd}
~
Xn
XdS(NiF(uFalseu	connectedu	acceptingu
connectingudel_channelusocketucloseuerroruargsuENOTCONNuEBADF(uselfuwhy((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuclose�
s
	
	
	






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


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

|SdS(Nu!%s instance has no attribute '%s'uA%(me)s.%(attr)s is deprecated; use %(me)s.socket.%(attr)s insteadumeuattru
stackleveli(ugetattrusocketuAttributeErroru	__class__u__name__uwarningsuwarnuDeprecationWarning(uselfuattruretattrumsg((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu__getattr__�
s








udispatcher.__getattr__cCstj
jd
t|
�
�

dS(Nulog: %s
(usysustderruwriteustr(uselfumessage((u-/opt/alt/python33/lib64/python3.3/asyncore.pyulog�
s
udispatcher.loguinfocCs*||jkr&t
d
||
f�

ndS(Nu%s: %s(uignore_log_typesuprint(uselfumessageutype((u-/opt/alt/python33/lib64/python3.3/asyncore.pyulog_info�
s

udispatcher.log_infoc


CsP|jr|j
�
n6|jsB|jr5|j�
n|j�
n
|j�
dS(
N(u	acceptingu
handle_acceptu	connectedu
connectinguhandle_connect_eventuhandle_read(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_read_event�
s
	

	
	



udispatcher.handle_read_eventc
Csb|jj
tjtj�}
|
d
krBtj|
t|
�
��
n|j�
d|_d|_
dS(NiTF(usocketu
getsockoptu
SOL_SOCKETuSO_ERRORuerroru	_strerroruhandle_connectuTrueu	connecteduFalseu
connecting(uselfuerr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_connect_event�
s





	
udispatcher.handle_connect_eventc


Cs=|jr
dS|j
s/|jr/|j�
q/n|j�
dS(
N(u	acceptingu	connectedu
connectinguhandle_connect_eventuhandle_write(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_write_event�
s
		
	

udispatcher.handle_write_eventc
CsB|jj
tjtj�}
|
d
kr4|j�
n
|j�
dS(Ni(usocketu
getsockoptu
SOL_SOCKETuSO_ERRORuhandle_closeuhandle_expt(uselfuerr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_expt_event�
s

udispatcher.handle_expt_eventc
Csnt�\}
}}}yt
|�
}Wn


d
t|�
}Yn
X|jd||||fd�
|j�
dS(Nu)<__repr__(self) failed for object at %0x>u:uncaptured python exception, closing channel %s (%s:%s %s)uerror(ucompact_tracebackurepruidulog_infouhandle_close(uselfunilu
tu
vutbinfou	self_repr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_error�
s








udispatcher.handle_errorc

Cs|jd
d�
dS(Nu!unhandled incoming priority eventuwarning(
ulog_info(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_expt�
s
udispatcher.handle_exptc

Cs|jd
d�
dS(Nuunhandled read eventuwarning(
ulog_info(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_read�
s
udispatcher.handle_readc

Cs|jd
d�
dS(Nuunhandled write eventuwarning(
ulog_info(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_write�
s
udispatcher.handle_writec

Cs|jd
d�
dS(Nuunhandled connect eventuwarning(
ulog_info(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_connect�
s
udispatcher.handle_connectc
Cs,|j�}
|
dk	r(|j|
�
ndS(
N(uacceptuNoneuhandle_accepted(uselfupair((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
handle_accept�
s


udispatcher.handle_acceptcCs|
j�
|j
d
d�
dS(Nuunhandled accepted eventuwarning(ucloseulog_info(uselfusockuaddr((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_accepteds


udispatcher.handle_acceptedc

Cs|jd
d�
|j
�
dS(Nuunhandled close eventuwarning(ulog_infouclose(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_closes

udispatcher.handle_closeNF(0u__name__u
__module__u__qualname__uFalseudebugu	connectedu	acceptingu
connectinguclosinguNoneuaddru	frozensetuignore_log_typesu__init__u__repr__u__str__uadd_channeludel_channelusocketuAF_INETuSOCK_STREAMu
create_socketu
set_socketuset_reuse_addrureadableuwritableulistenubinduconnectuacceptusendurecvucloseu__getattr__ulogulog_infouhandle_read_eventuhandle_connect_eventuhandle_write_eventuhandle_expt_eventuhandle_erroruhandle_exptuhandle_readuhandle_writeuhandle_connectu
handle_acceptuhandle_accepteduhandle_close(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
dispatcher�sN





 
	

u
dispatcherc

BsV|EeZ
dZddd
d�Zdd�Zdd�Zdd�Zd	d
�ZdS(udispatcher_with_sendcCs tj
||
|�
d
|_dS(Ns(u
dispatcheru__init__u
out_buffer(uselfusockumap((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu__init__s

udispatcher_with_send.__init__c
Cs?d
}
tj
||jdd��}
|j|
d�|_dS(Nii(u
dispatcherusendu
out_buffer(uselfunum_sent((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
initiate_sends


u"dispatcher_with_send.initiate_sendc


Cs|j�
dS(
N(
u
initiate_send(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuhandle_writes
u!dispatcher_with_send.handle_writec

Cs|jpt
|j�
S(
N(u	connectedulenu
out_buffer(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuwritables
udispatcher_with_send.writablecCsA|jr#|j
d
t|
�
�

n|j|
|_|j�
dS(Nu
sending %s(udebugulog_infourepru
out_bufferu
initiate_send(uselfudata((u-/opt/alt/python33/lib64/python3.3/asyncore.pyusend s
	


udispatcher_with_send.sendN(	u__name__u
__module__u__qualname__uNoneu__init__u
initiate_senduhandle_writeuwritableusend(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asyncore.pyudispatcher_with_sends
udispatcher_with_sendcCs�tj
�\}}
}g}|s0td
�
�
nxD|rv|j|jjj|jjjt|j	�
f�

|j
}q3W~|d\}}}djdd�|D�
�
}|||f||
|fS(Nutraceback does not existi
u
 c
Ssg|]}
d|
�qS(
u
[%s|%s|%s]((u.0u
x((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
<listcomp>;s	u%compact_traceback.<locals>.<listcomp>i����(usysuexc_infouAssertionErroruappendutb_frameuf_codeuco_filenameuco_nameustru	tb_linenoutb_nextujoin(u
tu
vutbutbinfoufileufunctionulineuinfo((u-/opt/alt/python33/lib64/python3.3/asyncore.pyucompact_traceback*s




	






ucompact_tracebackcCs�|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(Ni(
uNoneu
socket_mapulistuvaluesucloseuOSErroruargsuEBADFu_reraised_exceptionsuclear(umapu
ignore_allu
x((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu	close_all>s 

	














u	close_alluposixc

Bsk|EeZ
dZd
d�Zdd�Zdd�Zd
dd�
ZeZeZ	d	d
�Z
dd�Zd
S(ufile_wrappercCstj
|
�
|_dS(
N(uosudupufd(uselfufd((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu__init__es
ufile_wrapper.__init__c
Gstj
|j|
�
S(
N(uosureadufd(uselfuargs((u-/opt/alt/python33/lib64/python3.3/asyncore.pyurecvhs
ufile_wrapper.recvc
Gstj
|j|
�
S(
N(uosuwriteufd(uselfuargs((u-/opt/alt/python33/lib64/python3.3/asyncore.pyusendks
ufile_wrapper.sendcCs9|
tj
kr)|tjkr)|r)d
Std�
�
dS(Niu-Only asyncore specific behaviour implemented.(usocketu
SOL_SOCKETuSO_ERRORuNotImplementedError(uselfuleveluoptnameubuflen((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu
getsockoptns





ufile_wrapper.getsockoptc

Cstj
|j�

dS(
N(uosucloseufd(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyucloseys
ufile_wrapper.closec


Cs|jS(
N(
ufd(
uself((u-/opt/alt/python33/lib64/python3.3/asyncore.pyufileno|s
ufile_wrapper.filenoN(u__name__u
__module__u__qualname__u__init__urecvusenduNoneu
getsockoptureaduwriteucloseufileno(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asyncore.pyufile_wrapper`s
ufile_wrapperc

Bs/|EeZ
dZdd
d�
Zdd�ZdS(ufile_dispatchercCs�tj
|d|�
d|_y|
j�}
Wntk
r@


Yn
X|j|
�

tj|
tj	d
�}|t
jB}tj|
tj|�
dS(NiT(
u
dispatcheru__init__uNoneuTrueu	connectedufilenouAttributeErroruset_fileufcntluF_GETFLuosu
O_NONBLOCKuF_SETFL(uselfufdumapuflags((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu__init__�s

	









ufile_dispatcher.__init__cCs/t|
�
|_
|j
j�|_|j�
dS(
N(ufile_wrapperusocketufilenou_filenouadd_channel(uselfufd((u-/opt/alt/python33/lib64/python3.3/asyncore.pyuset_file�s


ufile_dispatcher.set_fileN(u__name__u
__module__u__qualname__uNoneu__init__uset_file(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asyncore.pyufile_dispatchers
ufile_dispatcher(1u__doc__uselectusocketusysutimeuwarningsuosuerrnouEALREADYuEINPROGRESSuEWOULDBLOCKu
ECONNRESETuEINVALuENOTCONNu	ESHUTDOWNuEISCONNuEBADFuECONNABORTEDuEPIPEuEAGAINu	errorcodeu	frozensetu
_DISCONNECTEDu
socket_mapu	NameErroru	_strerroru	ExceptionuExitNowuKeyboardInterruptu
SystemExitu_reraised_exceptionsureaduwriteu
_exceptionu	readwriteuNoneupollupoll2upoll3uFalseuloopu
dispatcherudispatcher_with_senducompact_tracebacku	close_allunameufcntlufile_wrapperufile_dispatcher(((u-/opt/alt/python33/lib64/python3.3/asyncore.pyu<module>/sB




X




*�9