ó
̍EYc@sSdd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
ddlm	Z	
dd
l
Z
ddlmZ
ddlm
Z

ddlmZ
ddlmZ
ejeƒ
Zejd#krÐejdƒ
Znejdƒ
Zejd
kr›
ddlmZ
ejjZdejf
d„ƒYZejeƒ
Zejd
ej!ej!eƒZ"ej#ej$ej!ee"gej%_&ej#ej'ej!ee"gej(_&ndZ)dZ*dZ+dZ,dZ-d	Z.dZ/dZ0dZ1dZ2dZ3d
Z4dZ5dZ6dZ7dZ8dZ9de	j:Z;dZ<dZ=dZ>de?f
d „ƒYZ@d!ejf
d"„ƒYZAd
S($iÿÿÿÿN(
tpatcher(
tlog(
tunits(
t_utils(
t	constants(
t
exceptions(
t
win32utilsiitqueuetQueuetwin32(
twintypest
OVERLAPPEDcBsSeZ
dejfd
ejfdejfdejfdejfgZd„ZRS(tInternaltInternalHightOffsett
OffsetHighthEventc

Csd
|_d
|_
dS(Ni(RR(
tself((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt__init__4s
	
(t__name__t
__module__R
tULONGtDWORDtHANDLEt_fields_R(((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyR+s



i@i
iI€ii
iIÿÿÿÿiiçiéiigš™™™™™©?tIOUtilscBsûeZ
dZd
„Zd„Zejdejddƒe	d„
ƒ
Z
ddddd„Zd„Z
ded	„Zd
„Zd„Zd„Zdeedd
„Zdd„
Zd„Zd„Zd„Zedd„
ƒ
Zed„ƒ
Zed„ƒ
ZRS(sAsyncronous IO helper class.c

Cstj
ƒ|_dS(
N(Rt
Win32Utilst_win32_utils(
R((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyRbs
c
OsD|jd
t
ƒ}|jdtdtjd
|ƒ
|jj|
|ŽS(Nteventlet_nonblocking_modetkernel32_lib_functfailure_exc(tgettFalsetupdatetTrueRtWin32IOExceptionRtrun_and_check_output(Rtargstkwargsteventlet_blocking_mode((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt_run_and_check_outputes



	

Rtmax_sleep_timeicCs*|jt
jtj|
ƒ
|tjƒ
d
S(s<Wait a given ammount of time for a pipe to become available.N(R(tkernel32tWaitNamedPipeWtctypest	c_wchar_pRt
k(Rt	pipe_namettimeout((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytwait_named_pipels

cCsCtg
}|j
tjtj|
ƒ
||d||dd
|ƒ
}|S(Nterror_ret_vals(tINVALID_HANDLE_VALUER(R*tCreateFileWR,R-tNone(Rtpathtdesired_accesst
share_modetcreation_dispositiontflags_and_attributesR2thandle((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytopents	








	
cCs|jt
j|
ƒ
dS(
N(R(R*tCloseHandle(RR;((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytclose_handle‚s
cCsZtg
}|r|j
tƒ

n|r4tj|ƒ
nd}|jtj|
|d
|ƒ

dS(sÃCancels pending IO on specified handle.

        If an overlapped structure is passed, only the IO requests that
        were issued with the specified overlapped structure are canceled.
        tignored_error_codesN(	tERROR_NOT_FOUNDtappendtERROR_INVALID_HANDLER,tbyrefR5R(R*t
CancelIoEx(RR;toverlapped_structuretignore_invalid_handleR?t
lp_overlapped((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt	cancel_io…s		




cCs&|jt
j|
ttd
tg
ƒ

dS(NR2(R(R*tWaitForSingleObjectExtWAIT_INFINITE_TIMEOUTR"tWAIT_FAILED(Rtevent((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt_wait_io_completion™s

cCs|jt
j|
ƒ
dS(
N(R(R*tSetEvent(RRL((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt	set_eventŸs
cCs|jt
j|
ƒ
dS(
N(R(R*t
ResetEvent(RRL((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt_reset_event¢s
cCs%|jt
j|
|||d
dg
ƒ
S(NR2(R(R*tCreateEventWR5(Rtevent_attributestmanual_resett
initial_statetname((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt
_create_event¥s

	
cs‡‡
fd
†}t|ƒ
S(Ncs<tj
|tƒj}ˆ
j|jƒ

ˆr8ˆ|
ƒ

nd
S(s;Sets the completion event and executes callback, if passed.N(R,tcasttLPOVERLAPPEDtcontentsROR(t
error_codet	num_bytestlpOverLappedt
overlapped(tcallbackR(sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt_completion_routine­s

(
tLPOVERLAPPED_COMPLETION_ROUTINE(RR_R`((R_RsL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytget_completion_routine¬s
c
Cs"|jƒ}
t
ƒ}|
|_|S(
s-Structure used for asyncronous IO operations.(RWRR(RRRE((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytget_new_overlapped_structure·s	
	
cCsL|j|j
ƒ

|jtj|
||tj|ƒ
|ƒ
|j|j
ƒ

dS(
N(RQRR(R*t
ReadFileExR,RCRM(RR;tbuffR\REtcompletion_routine((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytreadÀs

	


cCsL|j|j
ƒ

|jtj|
||tj|ƒ
|ƒ
|j|j
ƒ

dS(
N(RQRR(R*tWriteFileExR,RCRM(RR;ReR\RERf((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytwriteÉs

	


cCs-tj
|
ƒ}|r)|j||ƒ
n|S(
N(R,tc_ubytetwrite_buffer_data(tclst	buff_sizetdataRe((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt
get_bufferÒs


cCstt
||
 ƒ
ƒ
S(
N(tbytest	bytearray(ReR\((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytget_buffer_dataÙscCsDx=t|
ƒ
D]/\}}t
jd
tj|ƒ
ƒd||<q
WdS(Nt
Bi(t	enumeratetstructtunpacktsixt
b(ReRnt
it
c((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyRkÝs
N(RRt__doc__RR(Rtretry_decoratorRR#tWAIT_PIPE_DEFAULT_TIMEOUTR1R5R<R>R RHRMRORQR"RWRbRcRgRitclassmethodRotstaticmethodRrRk(((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyR_s0
		



	
			
						
tIOQueuecBsAeZ
d„Zeed
„Zed„
Zeeej	d„Z
RS(cCstjj
|ƒ

|
|_dS(
N(RRt_client_connected(Rtclient_connected((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyRäs

cCsXxQ|jj
ƒrSytjj|d
|
ƒ

SWqtjk
rO


|rKqqPPqXqWdS(NR0(RtisSetRRtEmpty(RR0tcontinue_on_timeout((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyRès





cCsQxJ|jj
ƒrLytjj||
d
|ƒ
SWqtjk
rH


qqXqWdS(NR0(RRƒRtputtFull(RtitemR0((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyR†òs





cCsa|jd
|
ƒ
}xH|r\t
|ƒ
|k
r\|jd
|dtƒ}|rX||7}qPqW|S(NR0R…(RtlenR (RR0t
burst_timeouttmax_sizeRntchunk((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt	get_burstùs

	



(RRRtIO_QUEUE_TIMEOUTR"RR†tIO_QUEUE_BURST_TIMEOUTRtSERIAL_CONSOLE_BUFFER_SIZER(((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyR€ãs
	


(ii(BR,RutsysteventletRtoslo_logR
tloggingt
oslo_utilsRRwtos_winRRRtos_win.utilsRt	getLoggerRtLOGtversion_infotoriginalRtplatformR
twindllR*t	StructureRtPOINTERRYtWINFUNCTYPER5RRaRtLPVOIDRdtargtypestLPCVOIDRhtFILE_FLAG_OVERLAPPEDtFILE_SHARE_READtFILE_SHARE_WRITEtGENERIC_READt
GENERIC_WRITEt
OPEN_EXISTINGtFORMAT_MESSAGE_FROM_SYSTEMtFORMAT_MESSAGE_ALLOCATE_BUFFERtFORMAT_MESSAGE_IGNORE_INSERTSR3RKt
WAIT_FINISHEDRBtERROR_PIPE_BUSYtERROR_PIPE_NOT_CONNECTEDR@R}R.tWAIT_IO_COMPLETION_TIMEOUTRJRŽRtobjectRR€(((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt<module>s`































„