SrSSKJr SSKrSSKrSSKrSSKrSSKJr Sr \R"\ 5r "SS\ 5r"SS \ 5rS r"S S \5r"S S\5r"SS\5rg)aLocked file interface that should work on Unix and Windows pythons. This module first tries to use fcntl locking to ensure serialized access to a file, then falls back on a lock file if that is unavialable. Usage:: f = LockedFile('filename', 'r+b', 'rb') f.open_and_lock() if f.is_locked(): print('Acquired filename with r+b mode') f.file_handle().write('locked data') else: print('Acquired filename with rb mode') f.unlock_and_close() )print_functionN)utilz$cache@google.com (David T McWherter)c\rSrSrSrSrg) CredentialsFileSymbolicLinkError0z-Credentials files must not be symbolic links.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r3lib/third_party/oauth2client/contrib/locked_file.pyrr0s7rrc\rSrSrSrSrg)AlreadyLockedException4zETrying to lock a file that has already been locked by the LockedFile.rNr rrrrr4sOrrc[RRU5(a[SR U55eg)NzFile: {0} is a symbolic link.)ospathislinkrformat)filenames r validate_filer9s5 ww~~h. + 2 28 <> > rc<\rSrSrSrSrSrSrSrSr Sr S r g ) _Opener?z,Base class for different locking primitives.cRSUlXlX lX0lSUlSUlg)zCreate an Opener. Args: filename: string, The pathname of the file. mode: string, The preferred mode to access the file with. fallback_mode: string, The mode to use if locking fails. FN)_locked _filename_mode_fallback_mode_fh_lock_fd)selfrmode fallback_modes r__init___Opener.__init__Bs) ! + rcUR$)zWas the file locked.)r r&s r is_locked_Opener.is_lockedQs ||rcUR$)z5The file handle to the file. Valid only after opened.)r$r,s r file_handle_Opener.file_handleUs xxrcUR$)z"The filename that is being locked.)r!r,s rr_Opener.filenameYs ~~rcg)zOpen the file and lock it. Args: timeout: float, How long to try to lock for. delay: float, How long to wait between retries. Nrr&timeoutdelays r open_and_lock_Opener.open_and_lock]s rcg)zUnlock and close the file.Nrr,s runlock_and_close_Opener.unlock_and_closefs r)r#r$r!r%r r"N) r r r r rr)r-r0rr8r;rrrrrr?s#6   rrc*\rSrSrSrSrSrSrSrg) _PosixOpenerkz+Lock files using Posix advisory lock files.cfUR(a$[SRUR55eSUl[ UR5 [ URUR 5UlURUR5n[R"5n[R "U[R[R -[R"-5UlSUlg![aRnUR[R:Xa*[ URUR5UlSnAgSnANSnAff=f![&anUR[R(:wae[R"5U- U:ak[*R-SXA5 UR(aURR/5 [ URUR5UlSnAg[R0"U5 SnAOSnAff=fGM)awOpen the file and lock it. Tries to create a .lock file next to the file we're trying to open. Args: timeout: float, How long to try to lock for. delay: float, How long to wait between retries. Raises: AlreadyLockedException: if the lock is already acquired. IOError: if the open fails. CredentialsFileSymbolicLinkError if the file is a symbolic link. zFile {0} is already lockedFNTz'Could not acquire lock %s in %s seconds)r rrr!ropenr"r$IOErrorerrnoEACCESr#_posix_lockfiletimerO_CREATO_EXCLO_RDWRr%OSErrorEEXISTloggerwarnclosesleep)r&r6r7e lock_filename start_times rr8_PosixOpener.open_and_lockns <<(,33DNNCE E dnn% DNNDJJ7DH,,T^^< YY[  " " (* RYY(>(J!L #  ww%,,&0C0CD'  "77ell*IIK*,8KK I -8xx(#DNND4G4GHDH 5!! "s9%C>*AE> EAEE H-'B!H( H((H-c<UR(a_URUR5n[R"UR 5 [R "U5 SUlSUlUR(aURR 5 gg)z?Unlock a file by removing the .lock file, and close the handle.FN)r rEr!rrNr%unlinkr$)r&rQs rr;_PosixOpener.unlock_and_closesa << 00@M HHT]] # IIm $ DL DM 88 HHNN  rc$SRU5$)z3The name of the lock file to use for posix locking.z{0}.lock)r)r&rs rrE_PosixOpener._posix_lockfiles  **r)r$r%r N) r r r r rr8r;rErrrrr>r>ks50"d +rr>cn\rSrSrSr\R "S5S Sj5rSrSr Sr S Sjr S r S r g ) LockedFilez+Represent a file that has exclusive access.cSnU(dU(aSSKJn U"XU5nU(d [ XU5nXPlg![a$ SSKJn U"XU5nN6![a NCf=ff=f)a+Construct a LockedFile. Args: filename: string, The path of the file to open. mode: string, The mode to try to open the file with. fallback_mode: string, The mode to use if locking fails. use_native_locking: bool, Whether or not fcntl/win32 locking is used. Nr) _Win32Opener) _FcntlOpener)"oauth2client.contrib._win32_openerr^ ImportError"oauth2client.contrib._fcntl_openerr_r>_opener)r&rr'r(use_native_lockingopenerr^r_s rr)LockedFile.__init__sp, K%hmD!(-@F  O)(-HF"  s'; A)A A%!A)$A%%A)c.URR$)z-Return the filename we were constructed with.)rcr!r,s rrLockedFile.filenames||%%%rc6URR5$)z*Return the file_handle to the opened file.)rcr0r,s rr0LockedFile.file_handles||''))rc6URR5$)z/Return whether we successfully locked the file.)rcr-r,s rr-LockedFile.is_lockeds||%%''rc:URRX5 g)aOpen the file, trying to lock it. Args: timeout: float, The number of seconds to try to acquire the lock. delay: float, The number of seconds to wait between retry attempts. Raises: AlreadyLockedException: if the lock is already acquired. IOError: if the open fails. N)rcr8r5s rr8LockedFile.open_and_locks ""72rc8URR5 g)zUnlock and close a file.N)rcr;r,s rr;LockedFile.unlock_and_closes %%'r)rcN)T)rg?)r r r r rr positionalr)rr0r-r8r;rrrrrZrZs95 __Q6&*( 3(rrZ)r __future__rrCloggingrrF oauth2clientr __author__ getLoggerr rL Exceptionrrrobjectrr>rZrrrrysz$&  4   8 $8y8 Y > ) f) XB+7B+J:(:(r