| Server IP : 156.238.232.47 / Your IP : 216.73.216.150 Web Server : nginx/1.25.3 System : Linux C202504152095410 3.10.0-1160.119.1.el7.x86_64 #1 SMP Tue Jun 4 14:43:51 UTC 2024 x86_64 User : www ( 1000) PHP Version : 8.3.25 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/lib64/python3.6/multiprocessing/__pycache__/ |
Upload File : |
3
\ � @ 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 j� | _d | _d | _d S )N)� threadingZLock�_lock�_fd�_pid)�self� r �)/usr/lib64/python3.6/semaphore_tracker.py�__init__ s
zSemaphoreTracker.__init__c C s | j � | jS )N)r r )r
r r r �getfd" s zSemaphoreTracker.getfdc C s | j �� | jdk rRtj| jtj�\}}|s0dS tj| j� d| _d| _tjd� g }y|j t
j j � � W n t
k
r~ Y nX d}tj� \}}zlyB|j |� tj� }|gtj� }|d|| g7 }tj|||�}W n tj|� � Y nX || _|| _W dtj|� X W dQ R X dS )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�piper Zget_executabler Z _args_from_interpreter_flagsZspawnv_passfds) r
�pidZstatusZ fds_to_pass�cmd�r�wZexe�argsr r r r & s8
z SemaphoreTracker.ensure_runningc C s | j d|� dS )z2Register name of semaphore with semaphore tracker.ZREGISTERN)�_send)r
�namer r r r Q s zSemaphoreTracker.registerc C s | j d|� dS )z4Unregister name of semaphore with semaphore tracker.Z
UNREGISTERN)r# )r
r$ r r r r U s zSemaphoreTracker.unregisterc C s@ | j � dj||�jd�}t|�dkr.td��tj| 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 j t jt j� t j t jt j� x6tjtjfD ]&}y |j� W q. tk
rR Y q.X q.W t � }z�t
| d���}x�|D ]�}yJ|j � j d�\}}|dkr�|j
|� n |dkr�|j|� n td| ��W qr tk
r� ytjtj� � W n Y nX Y qrX qrW W dQ R X W d|�r<ytjdt|� � W n tk
�r: Y nX xf|D ]^}zT|jd�}ytj|� W n6 tk
�r� } ztjd ||f � W Y dd}~X 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)�signal�SIGINT�SIG_IGN�SIGTERMr �stdin�stdoutr r �set�open�strip�split�add�remove� RuntimeError�
excepthook�exc_infor r r( �decode�_multiprocessingZ
sem_unlink)�fd�f�cache�liner r$ �er r r �maink sJ
(rH )r r2 r r r rB � r r �__all__�objectr Z_semaphore_trackerr r r r rH r r r r �<module> s
I