File "semaphore_tracker.cpython-37.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/semaphore_tracker.cpython-37.pyc
File size: 3.65 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
B
f[ @ 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)utilensure_runningregister
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 | jdk rRt| jtj\}}|s0dS t| j d| _d| _td 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 dt| X W dQ R X dS )zMake 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 oswaitpidWNOHANGcloser warningswarnappendsysstderrfileno Exceptionpiper Zget_executabler Z _args_from_interpreter_flagsZspawnv_passfds) r
pidZstatusZ fds_to_passcmdrwZexeargsr r r r & s8
z SemaphoreTracker.ensure_runningc C s | d| dS )z2Register name of semaphore with semaphore tracker.ZREGISTERN)_send)r
namer r r r Q s zSemaphoreTracker.registerc C s | d| dS )z4Unregister name of semaphore with semaphore tracker.Z
UNREGISTERN)r# )r
r$ r r r r U s zSemaphoreTracker.unregisterc C s` | d||d}t|dkr.tdt| j|}|t|ks\td|t|d S )Nz{0}:{1}
asciii z
name too longz nbytes {0:n} but len(msg) {1:n}) r formatencodelen
ValueErrorr writer AssertionError)r
r r$ msgnbytesr 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 }zt
| d}x|D ]}yJ| d\}}|dkr|
| n |dkr|| n td| W qr tk
r ytjt W n Y nX Y qrX qrW W dQ R X W d|r<ytdt| W n tk
r: Y nX xf|D ]^}zT|d}yt| W n6 tk
r } ztd ||f W dd}~X Y nX W dX qBW X dS )
zRun semaphore tracker.rb :s REGISTERs
UNREGISTERzunrecognized command %rNzRsemaphore_tracker: There appear to be %d leaked semaphores to clean up at shutdownr% zsemaphore_tracker: %r: %s)signalSIGINTSIG_IGNSIGTERMr stdinstdoutr r setopenstripsplitaddremove RuntimeError
excepthookexc_infor r r( decode_multiprocessingZ
sem_unlink)fdfcacheliner r$ er r r mainl sJ
(rI )r r3 r r r rC r r __all__objectr Z_semaphore_trackerr r r r rI r r r r <module> s
J