Advanced Web Server Manager
Complete File Manager & Terminal - Standalone Version
By Sid Gifari | Gifari Industries
Current path:
/
/
opt
/
alt
/
python37
/
lib64
/
python3.7
/
multiprocessing
/
__pycache__
✏️
Editing: semaphore_tracker.cpython-37.opt-2.pyc
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<yt�dt|� � W n tk �r: Y nX xf|D ]^}zT|�d�}yt�|� W n6 tk �r� } zt�d||f � W d d }~X Y nX W d X �qBW X d S ) N�rb� :s REGISTERs UNREGISTERzunrecognized command %rzRsemaphore_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 �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
💾 Save Changes
❌ Cancel