Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/billiard/__pycache__/ |
a
��Sh� � @ 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 �D/usr/local/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�wZexe�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�
*
��
*rM )r< r r5 r r rE Z_extr � r r �compatr �__all__r
Z_semaphore_trackerr r r r rM r r r r �<module> s" ;