£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyÊ¦•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~èŠ©ÊÇí`ÔÑ©úë™µ'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶ê×Ó¼ãžªéUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£ÔÏ¯rs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowÐø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! B � f[�@s�ddlZddlZddlZddlZddlZddlZddlmZddlmZdddgZ Gdd �d e �Ze�Zej Z ejZejZejZd d�ZdS)�N�)�spawn)�util�ensure_running�register� unregisterc@s<eZdZdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd S)�SemaphoreTrackercCst��|_d|_d|_dS)N)� threadingZLock�_lock�_fd�_pid)�self�r�F/opt/alt/python37/lib64/python3.7/multiprocessing/semaphore_tracker.py�__init__s zSemaphoreTracker.__init__cCs|��|jS)N)rr)r rrr�getfd"szSemaphoreTracker.getfdc Cs|j��|jdk rRt�|jtj�\}}|s0dSt�|j�d|_d|_t�d�g}y|� t j��Wnt k r~YnXd}t��\}}zlyB|� |�t��}|gt��}|d||g7}t�|||�}Wnt�|��YnX||_||_Wdt�|�XWdQRXdS)z�Make sure that semaphore tracker process is running. This can be run from any process. Usually a child process will use the semaphore created by its parent.NzWsemaphore_tracker: process died unexpectedly, relaunching. Some semaphores might leak.z;from multiprocessing.semaphore_tracker import main;main(%d)z-c)r r�os�waitpid�WNOHANG�closer�warnings�warn�append�sys�stderr�fileno� Exception�piperZget_executablerZ_args_from_interpreter_flagsZspawnv_passfds) r �pidZstatusZfds_to_pass�cmd�r�wZexe�argsrrrr&s8 zSemaphoreTracker.ensure_runningcCs|�d|�dS)z2Register name of semaphore with semaphore tracker.ZREGISTERN)�_send)r �namerrrrQszSemaphoreTracker.registercCs|�d|�dS)z4Unregister name of semaphore with semaphore tracker.Z UNREGISTERN)r#)r r$rrrrUszSemaphoreTracker.unregistercCs`|��d�||��d�}t|�dkr.td��t�|j|�}|t|�ks\td�|t|��dS)Nz{0}:{1} �asciiiz name too longznbytes {0:n} but len(msg) {1:n}) r�format�encode�len� ValueErrorr�writer�AssertionError)r rr$�msg�nbytesrrrr#YszSemaphoreTracker._sendN) �__name__� __module__�__qualname__rrrrrr#rrrrrs+rcCs�t�tjtj�t�tjtj�x6tjtjfD]&}y|��Wq.tk rRYq.Xq.Wt �}z�t |d��}x�|D]�}yJ|��d�\}}|dkr�|� |�n |dkr�|�|�ntd|��Wqrtk r�ytjt��WnYnXYqrXqrWWdQRXWd|�rs J