3 _Af9/@s(ddlZddlZddlZddlZddlZddlZddlmZerPddlm Z n ddl m Z ddl m Z ddZ Gddde ZGd d d eZGd d d eZd dZddZddZddZd/ddZddZddZddZd0dd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Z dS)1N) is_python3)Queue)ThreadcCs tjdkS)z Returns True when running with the native port of Python for Windows, False when running on any other platform (including the Cygwin port of Python). ZWindows)platformsystemrr@/home/qytech/356xLinux510-101server/.repo/repo/platform_utils.py isWindows!sr c@sPeZdZdZeddZddZddZdd Ze d d Z d d Z ddZ dS)FileDescriptorStreamsz Platform agnostic abstraction enabling non-blocking I/O over a collection of file descriptors. This abstraction is required because fctnl(os.O_NONBLOCK) is not supported on Windows. cCstr tStSdS)z\ Factory method: instantiates the concrete class according to the current platform. N)r _FileDescriptorStreamsThreads!_FileDescriptorStreamsNonBlocking)clsrrrcreate/szFileDescriptorStreams.createcCs g|_dS)N)streams)selfrrr__init__9szFileDescriptorStreams.__init__cCs|jj|j|||dS)z4 Wraps an existing file descriptor as a stream. N)rappend_create_stream)rfddeststd_namerrradd<szFileDescriptorStreams.addcCs|jj|dS)z* Removes a stream, when done with it. N)rremove)rstreamrrrrAszFileDescriptorStreams.removecCst|jdkS)z8 Returns True when all streams have been processed. r)lenr)rrrris_doneFszFileDescriptorStreams.is_donecCstdS)z Returns the set of streams that have data available to read. The returned streams each expose a read() and a close() method. When done with a stream, call the remove(stream) method. N)NotImplementedError)rrrrselectLszFileDescriptorStreams.selectcCstdS)z@ Creates a new stream wrapping an existing file descriptor. N)r)rrrrrrrrSsz$FileDescriptorStreams._create_streamN) __name__ __module__ __qualname____doc__ classmethodrrrrpropertyrrrrrrrr *s  r c@s0eZdZdZGdddeZddZddZdS) r zZ Implementation of FileDescriptorStreams for platforms that support non blocking I/O. c@s8eZdZdZddZddZddZdd Zd d Zd S) z(_FileDescriptorStreamsNonBlocking.Streamz Encapsulates a file descriptor cCs||_||_||_|jdS)N)rrrset_non_blocking)rrrrrrrr`sz1_FileDescriptorStreamsNonBlocking.Stream.__init__cCs4ddl}|j|j|j}|j|j|j|tjBdS)Nr)fcntlrZF_GETFLZF_SETFLos O_NONBLOCK)rr%flagsrrrr$fsz9_FileDescriptorStreamsNonBlocking.Stream.set_non_blockingcCs |jjS)N)rfileno)rrrrr)ksz/_FileDescriptorStreamsNonBlocking.Stream.filenocCs |jjdS)Ni)rread)rrrrr*nsz-_FileDescriptorStreamsNonBlocking.Stream.readcCs|jjdS)N)rclose)rrrrr+qsz._FileDescriptorStreamsNonBlocking.Stream.closeN) rrr r!rr$r)r*r+rrrrStream]s r,cCs|j|||S)N)r,)rrrrrrrrtsz0_FileDescriptorStreamsNonBlocking._create_streamcCstj|jgg\}}}|S)N)rr)rZ ready_streams_rrrrwsz(_FileDescriptorStreamsNonBlocking.selectN)rrr r!objectr,rrrrrrr Ysr csPeZdZdZfddZddZddZGdd d eZGd d d eZ Z S) r z Implementation of FileDescriptorStreams for platforms that don't support non blocking I/O. This implementation requires creating threads issuing blocking read operations on file descriptors. cstt|jtd|_dS)N )superr rrqueue)r) __class__rrrsz&_FileDescriptorStreamsThreads.__init__cCs|j||||jS)N)r,r1)rrrrrrrrsz,_FileDescriptorStreamsThreads._create_streamcCs|jj}|j}|j|_|gS)N)r1getrdata)ritemrrrrrs z$_FileDescriptorStreamsThreads.selectc@seZdZdZddZdS)z'_FileDescriptorStreamsThreads.QueueItemz Item put in the shared queue cCs||_||_dS)N)rr4)rrr4rrrrsz0_FileDescriptorStreamsThreads.QueueItem.__init__N)rrr r!rrrrr QueueItemsr6c@s0eZdZdZddZddZddZdd Zd S) z$_FileDescriptorStreamsThreads.Streamz Encapsulates a file descriptor cCsB||_||_||_||_d|_t|jd|_d|j_|jj dS)N)targetT) rrrr1r4r read_to_queuethreaddaemonstart)rrrrr1rrrrsz-_FileDescriptorStreamsThreads.Stream.__init__cCs|jjdS)N)rr+)rrrrr+sz*_FileDescriptorStreamsThreads.Stream.closecCs|j}d|_|S)N)r4)rr4rrrr*sz)_FileDescriptorStreamsThreads.Stream.readcCsNx*t|jjdD]}|jjtj||qW|jj|jjtj|ddS)z The thread function: reads everything from the file descriptor into the shared queue and terminates when reaching EOF. N)iterrreadliner1Zputr r6r+)rlinerrrr8s z2_FileDescriptorStreamsThreads.Stream.read_to_queueN)rrr r!rr+r*r8rrrrr,s  r,) rrr r!rrrr.r6r, __classcell__rr)r2rr |s  r cCsptr`ddl}t|}t|}tjjtjj||}t|rN|jt ||ql|j t ||n tj ||SdS)zCreates a symbolic link pointing to source named link_name. Note: On Windows, source must exist on disk, as the implementation needs to know whether to create a "File" or a "Directory" symbolic link. rN) r platform_utils_win32_validate_winpathr&pathjoindirnameisdirZcreate_dirsymlink _makelongpathZcreate_filesymlinksymlink)sourceZ link_namerAr7rrrrHsrHcCs*tjj|}t|r|Stdj|dS)NzRPath "%s" must be a relative path or an absolute path starting with a drive letter)r&rCnormpath_winpath_is_valid ValueErrorformat)rCrrrrBs  rBcCsVts ttjj|}tjj|\}}|rL|s<|dtjkS|dtjkSn| SdS)zWindows only: returns True if path is relative (e.g. ".\foo") or is absolute including a drive letter (e.g. "c:\foo"). Returns False if path is ambiguous (e.g. "x:foo" or "\foo"). rN)r AssertionErrorr&rCrJ splitdrivesep)rCZdrivetailrrrrKs  rKcCsLtrDt|dkr|S|jdr$|Stjj|s4|Sdtjj|S|SdS)zReturn the input path normalized to support the Windows long path syntax ("\\?\" prefix) if needed, i.e. if the input path is longer than the MAX_PATH limit. z\\?\N)r r startswithr&rCisabsrJ)rCrrrrGs   rGFcCs*d}trt|}t}tj|||ddS)zcshutil.rmtree(path) wrapper with support for long paths on Windows. Availability: Unix, Windows.N) ignore_errorsonerror)r rGhandle_rmtree_errorshutilrmtree)rCrUrVrrrrYs rYcCstj|tj||dS)N)r&chmodstatS_IWRITE)functionrCZexcinforrrrWsrWcCstrvytjt|t|Wqtk rr}z8|jtjkr`tjt|tjt|t|nWYdd}~XqXn tj||dS)zcos.rename(src, dst) wrapper with support for long paths on Windows. Availability: Unix, Windows.N)r r&renamerGOSErrorerrnoEEXISTr)srcdsterrrr^ s r^cCstrt|}ytj|Wqtk r}zJ|jtjkrptj|tj t |rdt |rdtj |qrtj|nWYdd}~XqXn tj|dS)zRemove (delete) the file path. This is a replacement for os.remove that allows deleting read-only files on Windows, with support for long paths and for deleting directory symbolic links. Availability: Unix, Windows.N) r rGr&rr_r`ZEACCESrZr[r\islinkrFrmdir)rCZlongpathrdrrrrs   rTcCs(trt||||Stj||||SdS)z`os.walk(path) wrapper with support for long paths on Windows. Availability: Windows, Unix. N)r _walk_windows_implr&walk)toptopdownrV followlinksrrrrh4srhc csy t|}Wn0tk r<}z|dk r.||dSd}~XnXgg}}x4|D],}ttjj||rp|j|qN|j|qNW|r|||fVxF|D]>}tjj||} |st|  rxt| |||D] } | VqWqW|s|||fVdS)N) listdir ExceptionrFr&rCrDrrerg) rirjrVrknameserrdirsnondirsnamenew_pathxrrrrg?s(      rgcCstjt|S)zcos.listdir(path) wrapper with support for long paths on Windows. Availability: Windows, Unix. )r&rlrG)rCrrrrlYsrlcCstjt|dS)zaos.rmdir(path) wrapper with support for long paths on Windows. Availability: Windows, Unix. N)r&rfrG)rCrrrrfasrfcCstjjt|S)zfos.path.isdir(path) wrapper with support for long paths on Windows. Availability: Windows, Unix. )r&rCrFrG)rCrrrrFisrFcCs,trddl}|jt|Stjj|SdS)zgos.path.islink(path) wrapper with support for long paths on Windows. Availability: Windows, Unix. rN)r rArerGr&rC)rCrArrrreqsrecCs*trddl}|jt|Stj|SdS)aReturn a string representing the path to which the symbolic link points. The result may be either an absolute or relative pathname; if it is relative, it may be converted to an absolute pathname using os.path.join(os.path.dirname(path), result). Availability: Windows, Unix. rN)r rAreadlinkrGr&)rCrArrrru}srucCstrtjj|}g}xptddD]b}t|rNt|}tjjtjj||}q"tjj |}|dkrn|j |P|j |tjj|}q"W|j tjj tjj|}|Stjj |SdS)zReturn the canonical path of the specified filename, eliminating any symbolic links encountered in the path. Availability: Windows, Unix. rdN)r r&rCabspathrangererurDrEbasenamerreverserJrealpath)rCZ current_pathZ path_tailcr7rzresultrrrr|s"    r|)F)TNF)!r`r&rrrXr[ pyversionrr1r threadingrr r.r r r rHrBrKrGrYrWr^rrhrgrlrfrFrerur|rrrrs<    /#=