Mܶi\8ddlZddlZddlZGddZdS)Nc>eZdZdZd d dZdedzfdZd dZd dZdS) FileBatonz0A primitive, file-based synchronization utility.皙?Nreturnc>||_||_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)selfrr r s [/root/projects/openclaw-proxy/venv/lib64/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|jJtj|z |jkr+|s)tj d|jd|jddd}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.) stacklevelT) timerpathexistsrsleepr r warningswarn)r has_warned start_times r waitzFileBaton.wait(s Y[[ gnnT011 & Jt( ) ) )&29;;+d.EEEjEM#H$:M#H#H%)%<#H#H#HTUWWWW!%JgnnT011 & & & & &rcx|jtj|jtj|jdS)z'Release the baton and removes its file.N)r rcloseremoverrs r releasezFileBaton.release;s5 7  HTW    $%&&&&&r)rN)rN) __name__ __module__ __qualname____doc__rboolrr#r'rr rrsz::55555 TD[    &&&&&''''''rr)rrrrr-rr r.sR 9'9'9'9'9'9'9'9'9'9'r