Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/billiard/__pycache__/semaphore_tracker.cpython-39.pyc
Ðазад
a i�h� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZddlmZ ddlm Z ddlm Z ddl m Z g d�Z G dd � d �Ze� ZejZejZejZejZd d � ZdS ) � N� )� _billiard)�spawn)�util)�spawnv_passfds)�ensure_running�register� unregisterc @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�SemaphoreTrackerc C s t �� | _d | _d S �N)� threading�Lock�_lock�_fd��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/billiard/semaphore_tracker.py�__init__ s zSemaphoreTracker.__init__c C s | � � | jS r )r r r r r r �getfd$ s zSemaphoreTracker.getfdc C s� | j �� | jdur"W d � dS g }z|�tj�� � W n tyL Y n0 d}t�� \}}znz@|�|� t � � }|gt � � }|d|| g7 }t |||� W n t�|� � Y n0 || _W t�|� n t�|� 0 W d � n1 s�0 Y 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.Nz4from billiard.semaphore_tracker import main;main(%d)z-c)r r �append�sys�stderr�fileno� Exception�os�piper �get_executabler � _args_from_interpreter_flagsr �close)r Z fds_to_pass�cmd�r�w�exe�argsr r r r ( s* z SemaphoreTracker.ensure_runningc C s | � d|� dS )z2Register name of semaphore with semaphore tracker.ZREGISTERN��_send�r �namer r r r F s zSemaphoreTracker.registerc C s | � d|� dS )z4Unregister name of semaphore with semaphore tracker.Z UNREGISTERNr% r' r r r r J s zSemaphoreTracker.unregisterc C sP | � � d�||��d�}t|�dkr.td��t�| j|�}|t|�ksLJ �d S )Nz{0}:{1} �asciii z name too long)r �format�encode�len� ValueErrorr �writer )r r r( �msg�nbytesr r r r& N s zSemaphoreTracker._sendN) �__name__� __module__� __qualname__r r r r r r& r r r r r s r c C sL t � t jt j� t � t jt j� tjtjfD ]$}z |�� W q, tyN Y q,0 q,t � }�zRt � | d���}|D ]�}zJ|� � � d�\}}|dkr�|�|� n |dkr�|�|� n td| ��W qn ty� ztjt�� � W n Y n0 Y qn0 qnW d � n1 �s0 Y W |�rFzt�dt|� � W n t�yD Y n0 |D ]`}zV|�d�}zt�|� W n8 t�y� } z t�d ||f � W Y d}~n d}~0 0 W n0 �qJn�|�r�zt�dt|� � W n t�y� Y n0 |D ]`}zV|�d�}zt�|� W n8 t�y: } z t�d ||f � W Y d}~n d}~0 0 W n0 �q�0 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�io�open�strip�split�add�remove� RuntimeError� excepthook�exc_info�warnings�warnr, �decoder Z sem_unlink)�fd�f�cache�liner r( �er r r �main` sj 0� * �� *rN )r= r r6 r r rF Z_extr � r r �compatr �__all__r Z_semaphore_trackerr r r r rN r r r r �<module> s" ;
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка