Әh8ddlZddlZddlZGddZdS)Nc,eZdZdZddZdZdZdZdS) FileBatonz0A primitive, file-based synchronization utility.皙?Nc>||_||_d|_||_dS)an Create a new :class:`FileBaton`. Args: lock_file_path: The path to the file used for locking. wait_seconds: The seconds to periodically sleep (spin) when calling ``wait()``. warn_after_seconds: The seconds to wait before showing lock file path to warn existing lock file. N)lock_file_path wait_secondsfdwarn_after_seconds)selfrrr s ^/var/www/html/services/rag-service/venv/lib/python3.11/site-packages/torch/utils/file_baton.py__init__zFileBaton.__init__ s)-("4c tj|jtjtjz|_dS#t $rYdSwxYw)z Try to atomically create a file under exclusive access. Returns: True if the file could be created, else False. TF)osopenrO_CREATO_EXCLr FileExistsErrorr s r try_acquirezFileBaton.try_acquiresM gd12: 3IJJDG4   55 s6: AAcd}tj}tj|jrtj|j|jHtj|z |jkr)|s'tj d|jd|jdd}tj|jdSdS)z Periodically sleeps for a certain amount until the baton is released. The amount of time slept depends on the ``wait_seconds`` parameter passed to the constructor. FNzWaited on lock file "z" for z seconds.T) timerpathexistsrsleeprr warningswarn)r has_warned start_times r waitzFileBaton.wait's Y[[ gnnT011 & Jt( ) ) )&29;;+d.EEEjEM#H$:M#H#H%)%<#H#H#HIII!%JgnnT011 & & & & &rcx|jtj|jtj|jdS)z'Release the baton and removes its file.N)r rcloseremoverrs r releasezFileBaton.release:s5 7  HTW    $%&&&&&r)rN)__name__ __module__ __qualname____doc__r rr r$rr rrs[::5555   &&&&'''''rr)rrrrr)rr r*sR 8'8'8'8'8'8'8'8'8'8'r