Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
idna / lib / python2.7 / site-packages / os_win / utils / io / ioutils.pyc
Size: Mime:
ó
̍EYc@sSddlZddlZddlZddlmZddlmZddlm	Z	ddl
Z
ddlmZddlm
Z
ddlmZddlmZejeƒZejd#krÐejdƒZnejdƒZejd
kr›ddlmZejjZdejfd„ƒYZejeƒZejdej!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?fd „ƒYZ@d!ejfd"„ƒYZAdS($iÿÿÿÿN(tpatcher(tlog(tunits(t_utils(t	constants(t
exceptions(t
win32utilsiitqueuetQueuetwin32(twintypest
OVERLAPPEDcBsSeZdejfdejfdejfdejfdejfgZd„ZRS(tInternaltInternalHightOffsett
OffsetHighthEventcCsd|_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@iiI€iiiIÿÿÿÿiiçiéiigš™™™™™©?tIOUtilscBsûeZdZd„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.cCstjƒ|_dS(N(Rt
Win32Utilst_win32_utils(R((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyRbscOsD|jdtƒ}|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*|jtjtj|ƒ|tjƒdS(s<Wait a given ammount of time for a pipe to become available.N(R(tkernel32tWaitNamedPipeWtctypest	c_wchar_pRtk(Rt	pipe_namettimeout((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytwait_named_pipelscCsCtg}|jtjtj|ƒ||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|jtj|ƒdS(N(R(R*tCloseHandle(RR;((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pytclose_handle‚scCsZtg}|r|jtƒ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&|jtj|ttdtgƒ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|jtj|ƒdS(N(R(R*tSetEvent(RRL((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt	set_eventŸscCs|jtj|ƒdS(N(R(R*t
ResetEvent(RRL((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyt_reset_event¢scCs%|jtj||||ddgƒ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ˆ|ƒndS(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¬scCs"|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ÒscCstt|| ƒƒ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]/\}}tjdtj|ƒƒd||<q
WdS(NtBi(t	enumeratetstructtunpacktsixtb(ReRntitc((sL/home/tvault/.virtenv/lib/python2.7/site-packages/os_win/utils/io/ioutils.pyRkÝsN(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		
										tIOQueuecBsAeZd„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äscCsXxQ|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èscCsQxJ|jjƒrLytjj||d|ƒSWqtjk
rHqqXqWdS(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|ƒ|kr\|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_logRtloggingt
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`

„