ej UddlmZgdZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z ddlmZddlmZmZmZddlmZdd lmZerdd lmZejd krddlZddlZdd lmZd Zded<dZ ded<dZ!ded<dZ"ded<ee ze!zZ#ded<dZ$ded<dZ%ded<dZ&ded<dZ'ded<dZ(ded<dZ)ded <dZ*ded!<d"Z+ded#<d$Z,ded%<d&Z-ded'<d(Z.ded)<d*Z/ded+<d,Z0ded-<e,e-ze/ze0zZ1ded.<dZ2ded/<dZ3ded0<e,e3ze0zZ4ded1<d&Z5ded2<dZ6ded3<d4Z7ded5<d6Z8d7ed8<dZ9ded9<ej:d:j;ZZ>ded?<d@Z?dedA<dBZ@dedC<dDZAdedE<dZBdedF<dGZCdedH<dIZDdedJ<dKZEdedL<dMZFdedN<dOZGdedP<dQZHdedR<dSZIdedT<dUZJdVedW<dXZKdVedY<ejLdZZMd[ed\<ejLd]d^_ZNd[ed`<ejLdad^_ZOd[edb<GdcddejPZQGdedfejPZRGdgdhejPZSGdidjejPZTGdkdlejPZUGdmdnejPZVejWeMjX_YejZej[ej\ejZeRejZeSejZej]ej^ej^ej^ej^ej:ej^g eMjX__ejWeMj`_YejaejZeQej:ej:geMj`__deMjb_YejZeQgeMjb__ej^eMjc_YejWgeMjc__ej[geNjd__ejeeNjd_Yej[ejZeVgeNjf__ejeeNjf_Yej[ej\ej\ej\ej\ejZeUgeNjg__ejeeNjg_Yej[ej\ej\ej\ejZeUgeNjh__ejeeNjh_Yejaej\ejZej:ejZej^geOji__ejeeOji_Yejaejjej\ejZej:ejZej:ejZej:ejZej:ejZej:geOjk__ej\eOjk_Yej[ej\ejeejZej[geOjl__ejeeOjl_Yej[ej\ejZej[geOjm__ejeeOjm_Yej[ejjej:ej\ejZej\geOjn__ejeeOjn_Yej[eNjo_Yej[eNjp_Yej:geNjq__ej:eNjq_YejaejZeTgeNjr__ejeeNjr_Yejaej\ej\ej:ej\ej\ej[geNjs__ej:eNjs_YddsZtdduZuGdvdweZveJdxddZwddZxddZyddZzddZ{ddZ|ddZ}ddZ~ddZddZddZddZeddZe1fddddZddZddZddZddZddZddZeddZddZddZeddZddZnGddweZvgdZdS)) annotations)zfilelock._utilmsvcrtstructN)contextmanagersuppress)ENOENTENOTDIR EWOULDBLOCK)cache) TYPE_CHECKINGFinalcast) BaseFileLock)raise_on_not_writable_file) Generatorwin32)wintypeslz Final[int] _GENERIC_READi@_GENERIC_WRITEi _SYNCHRONIZEi_DELETE_DESIRED_ACCESS_FILE_SHARE_READ_WRITE _FILE_OPEN _FILE_OPEN_IF_FILE_READ_ATTRIBUTES_FILE_SHARE_ALL_FILE_ATTRIBUTE_READONLY_FILE_ATTRIBUTE_NORMALi_FILE_ATTRIBUTE_REPARSE_POINT _FILE_SYNCHRONOUS_IO_NONALERT@_FILE_NON_DIRECTORY_FILEi_FILE_DELETE_ON_CLOSE_FILE_COMPLETE_IF_OPLOCKEDi _FILE_OPEN_REPARSE_POINT_CREATE_OPTIONS_FILE_LIST_DIRECTORY_FILE_DIRECTORY_FILE_DIRECTORY_OPTIONS_OBJ_CASE_INSENSITIVE _OWNER_WRITE?_GROUP_AND_OTHERS'D:P(A;;FA;;;SY)(A;;FA;;;BA)(A;;FA;;;OW)z Final[str]_OWNER_ONLY_SDDL_SDDL_REVISION_1zFinal[int | None]_INVALID_HANDLE_VALUE_LOCKFILE_FAIL_IMMEDIATELY_LOCKFILE_EXCLUSIVE_LOCK_ERROR_ACCESS_DENIED!_ERROR_LOCK_VIOLATION_ERROR_NOT_LOCKED_STATUS_SUCCESSi _STATUS_OPLOCK_BREAK_IN_PROGRESSl"_STATUS_ACCESS_DENIEDl4_STATUS_OBJECT_NAME_NOT_FOUNDl:_STATUS_OBJECT_PATH_NOT_FOUNDlC_STATUS_SHARING_VIOLATIONlV_STATUS_DELETE_PENDING_ACCESS_DENIED_PROBESg?z Final[float]_ACCESS_DENIED_GRACEgMb`?_ACCESS_DENIED_RETRYntdllzFinal[ctypes.WinDLL]_ntdllkernel32T)use_last_error _kernel32advapi32 _advapi32cBeZdZdejfdejfdejffZdS)_UNICODE_STRINGLength MaximumLengthBufferN)__name__ __module__ __qualname__rUSHORTLPWSTR_fields_Y/home/spazio/cosmos_universe_media/venv/lib/python3.11/site-packages/filelock/_windows.pyrVrVas3 x ' ho . x ' rarVceZdZdejfdejfdejefdejfdej fdej ffZ dS)_OBJECT_ATTRIBUTESrW RootDirectory ObjectName AttributesSecurityDescriptorSecurityQualityOfServiceN) rZr[r\rULONGHANDLEctypesPOINTERrVc_void_pr_r`rarbrdrdhs[ x~ & ho . >6>/:: ; 8> * !6? 3 ' 9  rardc2eZdZdejfdejffZdS)_IO_STATUS_BLOCKStatus InformationN)rZr[r\rlrnr_r`rarbrprprs) v ' FO , rarpcBeZdZdejfdejfdejffZdS)_SECURITY_ATTRIBUTESnLengthlpSecurityDescriptorbInheritHandleN) rZr[r\rDWORDrlrnBOOLr_r`rarbrtrtxs3  ' #V_ 5 x} - rartcbeZdZdejfdejfdejfdejfdejffZdS) _OVERLAPPEDInternal InternalHighOffset OffsetHighhEventN) rZr[r\rlrnrrxrkr_r`rarbr{r{sG  ) V_ - x~ & 8> * x '  rar{c eZdZdejfdejfdejfdejfdejfdejfdejfdejfd ejfd ejff Zd S) _BY_HANDLE_FILE_INFORMATIONdwFileAttributesftCreationTimeftLastAccessTimeftLastWriteTimedwVolumeSerialNumber nFileSizeHigh nFileSizeLownNumberOfLinksnFileIndexHigh nFileIndexLowN)rZr[r\rrxFILETIMEr_r`rarbrrs|  0 x0 1 !2 3  1 2 #X^ 4 hn - X^ , x~ . x~ . hn -  rarfdintreturnboolc .t}ttz}tt j||dddtj|rdStj }|tkrdStj |)NrrTF) r{r<r:rR LockFileExr get_osfhandlerlbyrefget_last_errorr@WinError)r overlappedflagserrs rb_lock_fd_nonblockingrs!]] (+EE    4R 8 8%Aq&,WaJbJb c c 4#%% ' ' '5oc"""raNonec t}ttj|dddt j|s2t jx}tkrt j |dSdS)Nrr) r{rR UnlockFileExrrrlrrrBr)rrrs rb _unlock_fdrsy ]] &&v';B'?'?Aq&,WaJbJbcc '-///4EEE/#&& &  ' 'EErac"eZdZdZddZddZdS)WindowsFileLockay Uses ``LockFileEx`` to hard lock a byte range of the lock file on Windows systems. Lock file cleanup: Windows attempts to delete the lock file after release, but deletion is not guaranteed in multi-threaded scenarios where another thread holds an open handle. The lock file may persist on disk, which does not affect lock correctness. rrct|j t|j|}n#t$rYdSwxYw|dS t |}|r||n7#t$r*|tj |wxYw|stj |dSdSN) r _lock_path_open_non_reparse_fd _open_modeBlockingIOErrorr_mark_descriptor_owned BaseException_mark_descriptor_releasedosclose)selfrlockeds rb_acquirezWindowsFileLock._acquires &t 7 7 7 )$/4??;L;LMM"    z -b114//333    ..000        s'> A  A &A;;4B/cBtd|jj}t||||d|jsCtt5t|j ddddS#1swxYwYdSdS)NrF)default_suppresses) r_context lock_file_fdrr_close_released_fd_preserve_lock_filerOSErrorunlink_without_oplock_waitr)rrs rb_releasezWindowsFileLock._release/seT]788B rNNN  * * , , ,  # #B5 # A A A+ @g&&@@.t???@@@@@@@@@@@@@@@@@@ @ @s0BBBNrrrZr[r\__doc__rrr`rarbrrsL      . @ @ @ @ @ @rar) oplock_waitpathstrmoderfloat int | Nonectjd|dtjtjz|t z }|dz }t |||\}}d}tj|z} |tkr|tkrnZ|dz }n%|tkrtj|krn1nn/tj tt |||\}}q|tkrd} tt| ||t kr"|t"t$hvrdSt'||t)||tjS) a Open *path* for locking while refusing reparse points, bound to the handle actually locked. The file is opened through ``NtCreateFile`` with ``FILE_OPEN_REPARSE_POINT`` so a symlink or junction planted at the path is not followed, and the reparse decision is read from *that* handle via ``GetFileInformationByHandle`` rather than from a prior pathname query. Reading the held handle closes the check-then-open race: an attacker cannot swap the path between validation and use because both act on the same handle. Share mode omits delete so a peer cannot unlink or rename the file out from under a live holder, matching ``os.open``'s ``_SH_DENYNO``. ``NtCreateFile`` is used instead of ``CreateFileW`` because its return value carries the raw ``NTSTATUS``. Windows collapses a transient delete-pending name and a permanent access denial into the same Win32 ``ERROR_ACCESS_DENIED``; the status keeps them apart, so a real denial fails fast instead of spinning until the caller's timeout (#604). The reparse option only guards the final path component; Windows still follows reparse points in intermediate directories. This assumes the lock file sits in a lock directory untrusted users cannot modify. A path with attacker-controlled parent directories would need component-by-component handle validation. :param path: the lock file path. :param mode: the permission mode; as ``os.open`` does on Windows, a cleared owner-write bit creates the file read-only. A mode without group and other bits creates it with an owner-only DACL (discretionary access control list, the Windows permission list); any other mode has no Windows counterpart and leaves the file the entries its directory hands down. Both only take effect when the file is created, not when an existing one is opened. :param oplock_wait: seconds to wait for the holder of an oplock on the file to answer its break. :returns: a file descriptor owning the opened handle, or ``None`` on a sharing violation or a delete-pending name, which the caller should treat as contention and retry. :raises BlockingIOError: if an oplock break stays unanswered for *oplock_wait* seconds. :raises OSError: if the path resolves to a reparse point, or the open fails for any other reason, raised with the Win32 error the status maps to. An access denial is raised only once it outlasts a run of probes, since a peer unlinking the file as it releases can make the open answer ``STATUS_ACCESS_DENIED`` for a moment. openNr3) read_only owner_onlyrTroplock break in progress)sysauditrO_RDWRO_CREATr2_nt_opentime monotonicrErKrDsleeprMrr rCrHrI _status_error_descriptor_for_non_reparse) rrrrrhandlestatus denied_probesoplock_deadlinemsgs rbrr;s_N &$bi"*&<===|++ % !$) SSS .**[8 X... $999" ;;;>##667 J+ , , ,%diJWWWNFF X 5 5 5,C!+sD99 9 _ $ $35KLLLt-- -*64CCCractjd|dtjt |t t ztjS)a Open *path* read-only and return a descriptor, without waiting for an oplock holder to answer its break. ``os.open`` waits inside the system call until the holder of an oplock on the file answers or closes its handle, so no timeout or ``blocking=False`` ends the wait. A reparse point at *path* is refused rather than followed. :param path: the file to read. :returns: a read-only file descriptor. :raises BlockingIOError: if an oplock break is in progress, which callers treat as contention. :raises FileNotFoundError: if *path* does not exist. :raises OSError: if the open fails for any other reason, or *path* is a reparse point. rN)rrrO_RDONLY"_open_existing_without_oplock_waitrrrs rbopen_read_without_oplock_waitr~s7 &$bk2221$ 8TVXVabbbracbt|ttztztjS)a Open *path* with delete access and return a descriptor, without waiting for an oplock holder to answer. The open handle shares read, write and delete, so a rename of *path* can proceed while the caller keeps it. A holder that took an oplock through another handle is asked to answer by this open, which then raises, so the caller skips the rename instead of waiting for it. :param path: the file to rename. :returns: a file descriptor owning the handle; the caller closes it. :raises BlockingIOError: if an oplock break is in progress, which callers treat as contention. :raises FileNotFoundError: if *path* does not exist. :raises OSError: if the open fails for any other reason, or *path* is a reparse point. )rrrrrrrs rb#open_for_delete_without_oplock_waitrs&"2$BW8WZf8fhjhstttrac 8tjd|dt|ttzt t tttz\}}|tkrt |dS|tkrt||dS)a  Delete *path* through a handle that does not wait for an oplock holder to answer its break. ``os.unlink`` waits like ``os.open`` does. Here an unanswered break leaves the file in place, which callers accept since deleting a lock file is best effort. A symlink at *path* is deleted as a link. :param path: the file to delete. :raises FileNotFoundError: if *path* does not exist. :raises OSError: if the open fails for any other reason, such as a sharing violation. z os.removeN)options)rr _nt_createrrr#r!rr-r)rCrR CloseHandlerDrrrrs rbrrs +tT***#  l " "  #&;;     _ $ $  ! !& ) ) ) ) ) 7 7 7-- -8 7raaccessrct||ttt\}}|tkrt ||t |||Sr)rr#r!rrCrr)rrrrrs rbrrsJ#D&2H/[eff _ $ $-- -*64???rarrc^|tkrttd|S|tthvr-t t tjt |St |}tdtj |||S)Nr)rDrr rFrGFileNotFoundErrorrrstrerrorrORtlNtStatusToDosErrorrrl FormatErrorstrip)rrwinerrors rbrrs 5 5 5";0JDQQ Q 35RS S S$VR[-@-@$GG G//77tV/99??AA4RRRrarc t}t|tj|sAtj}t|tj||jtzr.t|d|}t| tj ||tjzS#t$rt|wxYw)Nz1Lock file is a reparse point (symlink/junction): )rrRGetFileInformationByHandlerlrrrrrr$rropen_osfhandler O_NOINHERITr)rrrinforrs rbrrs*,,33FFL'+B+B  (+@  (3=  0_&&F(**I##L((L!233L++    "  ' ' W(=(= > > > >F ' ' W(=(= > > > > 5 5 5  ! !& ) ) ) _ $ $f9 | q&((s CE.Fc tjtjtj}}}t|ddtj|dtj|dtj|}|t krdS|rtj| ddD}|tt|j oIttd|j |vo%ttd|j |k t|S#t|wxYw)aM Report whether only the current user, ``SYSTEM`` and ``Administrators`` can create or remove names in *path*. A directory whose owner is anyone else can have its ACL rewritten by that owner. Entries that only a child inherits count too, since the DACL says nothing more precise about who may write. rr=NFc,h|]}t|Sr`)_sid_from_text).0texts rb z(_directory_is_private..s kkk~d++kkkra)zS-1-5-18z S-1-5-32-544zS-1-3-0zS-1-3-4r)rlrnrTGetNamedSecurityInfoWrr>radd _user_sidrr _sid_atr _name_writersrR LocalFree)rownerdaclrrtrusteds rb_directory_is_privaternsY#)/"3"3V_5F5FHYHYZt//   L    L    L $ $    ( ( (5  )/%(( ( ,kk8jkkkG KK $ $ $TZ  FD 4455@F!$udj"9"9::gE     + + + +I   + + + +s 5B EE7r set[bytes]cjtjdtj|d\}t }d}t |D]h}tjdtj||zd\}}}}|dvr-|dzr(|t||zdz||z }i|S)Nz<4xH2xzr iF P)runpackrl string_atsetrangerr) rcountwritersoffset_ace_type_flagsace_sizemasks rbrrs=6+;D!+D+DEE%%u  A/5}WfFVW[^dWdfgFhFh/i/i ,Hfh6!!d.l&m! GD6MA$566777 h FFrabytesc tj}d}d}tt||t j|sjtt |t j|s%t j t j  tj }t |dddt j|t j|j}t |d||t j|s%t j t j t!t#dt j|jt|S#t|wxYw)Nr"Trrr)rrkrTOpenThreadTokenrRGetCurrentThreadrlrOpenProcessTokenGetCurrentProcessrrrxGetTokenInformationcreate_string_bufferr rrrn from_bufferr)token token_query open_as_selfsizebuffers rbrrs!!# "   % %i&@&@&B&BKQ]_e_klq_r_r s s ;)))*E*E*G*GV\VbchViVijj ;/&"7"9"9:: : )>##D  ) )%D!V\$=O=O P P P0<>>4v'B'B6'J'J'PQQRR  ! !% ( ( ( (I ! !% ( ( ( (s C/GG/rc(d|ddD^}}}tjd|t ||ddztjdt |dg|RzS) Nc34K|]}t|VdSr)r)rparts rb z!_sid_from_text..s(/i/idD /i/i/i/i/i/irazS--zr@rBrCrDrErFrGrHrIrKrLrMWinDLLrOrRrT StructurerVrdrprtr{rLONGr restypermrkrx c_longlongrjargtypesrLPCWSTRr rrryrrrrc_intrr2r4r6r5r3rrSrarrrrrrrrrrrrrrrrrrrrrrrTrZr\r^rWrX__all__r`rarbr~s """""""999 ////////..........----------&&&&&&555555*))))))<7MMMMMM *M****!+N++++)L))))$G$$$$"/."@<"OOOOOOJ !M!!!!(22222"FOFFFF+55555)333330:!::::1;!::::+55555(22222-77777+55555%(@@C]]`xx (21111'11111%BEY%Y\t%ttttt(22222$L$$$$$)))))$MLLLL#$$$$$/>vr/B/B/HHHHH .87777+55555'((((((*****$''''' #-O,,,,3=$====(222220:!::::0:!::::,66666)33333),++++),,,,,).....#06=#9#9F9999&3fmJt&T&T&TITTTT&3fmJt&T&T&TITTTT     &*        V-        6+        v/        f&         f&6    #+-Fx'')**'((v()) $F >F]F2:'' ?F2; +/F',:FN?,K,K+LF(+3>F (-5]OF )&.o%6I"$,MI!5=_nfnUpFqFq4rI(13;=I(0{## %I!$,=I {## 'I#&.]I"v''x~&& OIBK NV]IBJ v''v''v''v''v'' 0I#,/7nI#+ x'' *I& )1 I%+3?HNNFN[c[jLkLk*lI')1I& x~&& .I!*-5MI!)*2/I')1I&$*O#4I "(/I+3+;^V^L`=a=a*bI')1I&&I"%+OI! # # # #''''*@*@*@*@*@,*@*@*@XL`ADADADADADADFcccc&uuuu&....6@@@@ SSSS&&8&&&& Q Q Q Q          U "' 5).25)5)5)5)5)5)n",",",",H    )))),    VVVV;;;;'''^' ((((6666***^*$YYYYY&&&&&,&&&   ra