B
YI~d[ ã @ sŒ d dl Z d dlZd dlZd dlZd dlZd dlZddlmZ ddlmZ dddgZ G dd „ d e
ƒZ e ƒ Z e j
Z
e jZe jZe jZd
d „ ZdS ) é Né )Úspawn)ÚutilÚensure_runningÚregisterÚ
unregisterc @ s< e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
S )ÚSemaphoreTrackerc C s t ¡ | _d | _d | _d S )N)Ú threadingZLockÚ_lockÚ_fdÚ_pid)Úself© r úF/opt/alt/python37/lib64/python3.7/multiprocessing/semaphore_tracker.pyÚ__init__ s
zSemaphoreTracker.__init__c C s | ¡ | jS )N)r r )r
r r r Úgetfd" s zSemaphoreTracker.getfdc
C s | j | jd k rRt | jtj¡\}}|s0d S t | j¡ d | _d | _t d¡ g }y| t
j ¡ ¡ W n t
k
r~ Y nX d}t ¡ \}}zlyB| |¡ t ¡ }|gt ¡ }|d|| g7 }t |||¡}W n t |¡ ‚ Y nX || _|| _W d t |¡ X W d Q R X d S )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Úpiper Zget_executabler Z _args_from_interpreter_flagsZspawnv_passfds) r
ÚpidÚstatusZ fds_to_passÚcmdÚrÚwZexeÚargsr r r r & s8
z SemaphoreTracker.ensure_runningc C s | d|¡ d S )NZREGISTER)Ú_send)r
Únamer r r r Q s zSemaphoreTracker.registerc C s | d|¡ d S )NZ
UNREGISTER)r$ )r
r% r r r r U s zSemaphoreTracker.unregisterc C s@ | ¡ d ||¡ d¡}t|ƒdkr.tdƒ‚t | j|¡}d S )Nz{0}:{1}
Úasciii z
name too long)r ÚformatÚencodeÚlenÚ
ValueErrorr Úwriter )r
r r% ÚmsgÚnbytesr r r r$ Y s zSemaphoreTracker._sendN) Ú__name__Ú
__module__Ú __qualname__r r r r r r$ r r r r r s +r c C sª t t jt j¡ t t jt j¡ x6tjtjfD ]&}y | ¡ W q. tk
rR Y q.X q.W t ƒ }z¨t
| dƒ”}xŒ|D ]„}yJ| ¡ d¡\}}|dkrž|
|¡ n |dkr²| |¡ n td| ƒ‚W qr tk
rô ytjt ¡ Ž W n Y nX Y qrX qrW W d Q R X W d |r s
J