ó
̍EYc@s¿dd
lZdd
l
Z
ddlmZ
ddlmZ
ddlmZ
ddl	m
Z

ddl	mZ
ddlm
Z

ejdƒ
Zejd	ƒ
Zejeƒ
Zd
ef
d„ƒYZd
S(iÿÿÿÿN(
tpatcher(
tlog(
t
_(
t	constants(
t
exceptions(
tioutilst	threadingttimetNamedPipeHandlercBs³eZ
dZd
Zddddd„Zd„Zd„Zd„Zd„Z	d„Z
d„Zd	„Zd
„Z
d„Zdd„
Zd
„Zd„Zd„Zd„Zd„ZRS(s=Handles asyncronous I/O operations on a specified named pipe.icCsz|
|_||_
||_||_||_tjƒ|_g|_d|_
tjƒ|_t
jƒ|_|jƒ
dS(
N(t
_pipe_namet_input_queuet
_output_queuet_log_file_patht_connect_eventRtEventt_stoppedt_workerstNonet_pipe_handletLockt_lockRtIOUtilst_ioutilst_setup_io_structures(tselft	pipe_nametinput_queuetoutput_queuet
connect_eventtlog_file((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyt__init__&s	
	
	
		

	
	
c
Cs
y­|jƒ
|j
r1t|j
d
dƒ|_n|jg
}
|jrb|jrb|
j|jƒ

nxG|
D]?}t	j
d|ƒ
}|jtƒ

|j
ƒ
|jj|ƒ

qiWWnZtk
r	

}
tdƒ
i|jd6|d6}tj|ƒ

|jƒ
tj|ƒ
‚
n
XdS(Ntabi
ttargetsPNamed pipe handler failed to initialize. Pipe Name: %(pipe_name)s Error: %(err)sRterr(t
_open_pipeRtopent_log_file_handlet_read_from_pipeR
R
tappendt_write_to_pipeRtThreadt	setDaemontTruetstartRt	ExceptionRR	tLOGterrortstopRtOSWinException(RtjobstjobtworkerR!tmsg((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR+7s&


	











	






c
Cs€|jj
ƒ
|js#|jƒ
nxM|jD]B}
x9|
jƒrn|
tjƒk	rn|jƒ
|
jd
ƒ

q6Wq-Wg|_dS(Ngà?(	RtsetRt_cleanup_handlestis_aliveRtcurrent_threadt
_cancel_iotjoin(RR3((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR/Qs

	





c

Cs’|jƒ
|j
r,|j
jƒ
d|_
n|jjr]|jj|jjƒ

d|j_n|jjrŽ|jj|jjƒ

d|j_ndS(
N(	t_close_pipeR$tcloseRt
_r_overlappedthEventRtclose_handlet
_w_overlapped(
R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR6gs

	






c

Cs‹|jj
tjƒ
|_|jj
tjƒ
|_|jjƒ|_|jjƒ|_|jj	|j
ƒ
|_|jj	ƒ|_d|_dS(
N(Rt
get_bufferRtSERIAL_CONSOLE_BUFFER_SIZEt	_r_buffert	_w_buffertget_new_overlapped_structureR=R@tget_completion_routinet_read_callbackt_r_completion_routinet_w_completion_routineRR$(
R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyRvs
	

	

	

c


Csa|jj
|jƒ

|jj|jd
tjtjBdtjtjBdtj	dtj
ƒ
|_dS(s:Opens a named pipe in overlapped mode for asyncronous I/O.tdesired_accesst
share_modetcreation_dispositiontflags_and_attributesN(Rtwait_named_pipeR	R#RtGENERIC_READt
GENERIC_WRITEtFILE_SHARE_READtFILE_SHARE_WRITEt
OPEN_EXISTINGtFILE_FLAG_OVERLAPPEDR(
R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR"…s	
	


	
c

Cs,|jr(|j
j|jƒ

d|_ndS(
N(RRR?R(
R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR;s
	

c

CsN|jrJ|j
j|j|jd
tƒ

|j
j|j|jd
tƒ

ndS(Ntignore_invalid_handle(RRt	cancel_ioR=R*R@(
R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR9•s

	


c

Cs)|j|j
j|j|j|jƒ
dS(
N(t_start_io_workerRtreadRCR=RH(
R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR% s



c

Cs/|j|j
j|j|j|j|jƒ
dS(
N(RWRtwriteRDR@RIt_get_data_to_write(
R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR'¦s





cCs¤z‚y]xV|jj
ƒs^|r6|ƒ}|sBq	qBnt|ƒ
}|
|j||||ƒ
q	WWntk
r€


|jjƒ
n
XWd|j
|jƒ
WdQXXdS(
N(RtisSettlenRR,R5RR6(Rtfunctbufftoverlapped_structuretcompletion_routinetbuff_update_funct	num_bytes((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyRW­s


	

	





cCsQ|jj
|j|
ƒ}|jr4|jj|ƒ

n|jrM|j|ƒ

ndS(
N(Rtget_buffer_dataRCRtputR$t
_write_to_log(RRbtdata((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyRGÀs

	
	
	
c
Cskx/|jj
ƒp|jj
ƒs1tjd
ƒ

qW|jjƒ}
|
rg|jj|j	|
ƒ
t
|
ƒ
SdS(Ni
i(RR[R
RtsleepR
tgetRtwrite_buffer_dataRDR\(RRf((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyRZÉs
!





cCs|jj
ƒrdSyI|jjƒt|
ƒ
}|tjkrK|jƒ
n|jj|
ƒ

Wnt	k
r|


|jj
ƒ
n
XdS(
N(RR[R$ttellR\RtMAX_CONSOLE_LOG_FILE_SIZEt_rotate_logsRYR,R5(RRftlog_size((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyReÓs









c
Cs„|jj
ƒ
|jjƒ
|jd
}
tjj|
ƒ
rO|jtj|
ƒ
n|jtj	|j|
ƒ
t
|jddƒ|_dS(Ns.1Ri
(R$tflushR<Rtostpathtexistst_retry_if_file_in_usetremovetrenameR#(Rtlog_archive_path((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyRlßs










cOs|d
}xotrwy|
||ŽSWq	t
k
rs
}
|jtjkrm||jkrm|d7}tjdƒ

qt‚q	Xq	WdS(Nii
(R*tWindowsErrorterrnotEACCESt_MAX_LOG_ROTATE_RETRIESRRg(Rt
ftargstkwargstretry_countR!((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyRrðs
	







N(t__name__t
__module__t__doc__RyRRR+R/R6RR"R;R9R%R'RWRGRZReRlRr(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyR!s&

												
		(RwRoteventletRtoslo_logR
tloggingtos_win._i18nRtos_winRRtos_win.utils.ioRtoriginalRRt	getLoggerR~R-tobjectR(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/namedpipe.pyt<module>s