File: //usr/local/lib/python3.9/site-packages/billiard/__pycache__/synchronize.cpython-39.pyc
a
X>h�2 � @ sr d dl Z d dlZd dlZd dlZddlmZ ddlmZ ddlmZ ddlm Z m
Z
d dl m Z g d�Z
e
� eed ��\ZZe jjZz e jjZW n: ey� zd d
lmZ W n ey� dZY n0 Y n0 d d � ZG d
d� d�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�Z G dd� d�Z G dd� d�Z e ed��r`G d d� dej �Z nG d d� d�Z dS ) � N� )�context)�process)�util)� _billiard�ensure_SemLock)� monotonic)�Lock�RLock� Semaphore�BoundedSemaphore� Condition�Event� )�
sem_unlinkc C s z| j W S ty Y n0 d S �N)�name�AttributeError)�sl� r �>/usr/local/lib/python3.9/site-packages/billiard/synchronize.py�_semname4 s r c @ s^ e Zd Ze�� Zddd�Zedd� �Zdd� Z dd � Z
d
d � Z d d
� Z dd� Z
edd� �ZdS )�SemLockNc C sL |d u rt j�� }|�� }tjdkp*|dk}tr�td�D ]f}z t� |||| �
� |� }| _ W n< t t
fy� } z t| dd �tjkr�� W Y d } ~ q8d } ~ 0 0 q�q8t
d�} tj| _| �nt� |||� }| _ t�d|j� | �� t�rHtjdk�rdd� }
t�| |
� t| j �d u�rHd d
lm} | | j j� tj| t j| j jfd d � d S )
N�win32�fork�d �errnoz cannot find file for semaphorez created semlock with handle %sc S s | j �� d S r )�_semlock� _after_fork)�objr r r r [ s z%SemLock.__init__.<locals>._after_forkr )�registerr )Z exitpriority) r Z_default_contextZ get_contextZget_start_method�sys�platformr �ranger r �
_make_namer �OSError�IOError�getattrr �EEXISTr �debug�handle�
_make_methodsZregister_after_forkr �semaphore_trackerr r ZFinalize�_cleanup) �self�kind�value�maxvalue�ctxr Z
unlink_now�ir �excr r r r r �__init__> s<
� �zSemLock.__init__c C s ddl m} t| � || � d S )Nr )�
unregister)r, r6 r )r r6 r r r r- h s zSemLock._cleanupc C s | j j| _| j j| _d S r )r �acquire�release�r. r r r r+ n s
zSemLock._make_methodsc C s
| j �� S r )r � __enter__r9 r r r r: r s zSemLock.__enter__c G s | j j|� S r )r �__exit__�r. �argsr r r r; u s zSemLock.__exit__c C sh t �| � | j}tjdkr,t �� �|j�}n|j}||j|j f}z||j
f7 }W n t yb Y n0 |S )Nr ) r �assert_spawningr r! r" Zget_spawning_popenZduplicate_for_childr* r/ r1 r r )r. r �h�stater r r � __getstate__x s
zSemLock.__getstate__c C s* t jj|� | _t�d|d � | �� d S )Nz recreated blocker with handle %rr )r r Z_rebuildr r r) r+ �r. r@ r r r � __setstate__� s zSemLock.__setstate__c C s dt �� jd ttj�f S )Nz%s-%sZ semprefix)r �current_process�_config�nextr �_randr r r r r$ � s �zSemLock._make_name)N)�__name__�
__module__� __qualname__�tempfile�_RandomNameSequencerG r5 � staticmethodr- r+ r: r; rA rC r$ r r r r r ; s
*
r c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
r r Nc C s t j| t|t|d� d S �N�r2 )r r5 � SEMAPHORE�
SEM_VALUE_MAX�r. r0 r2 r r r r5 � s zSemaphore.__init__c C s
| j �� S r )r �
_get_valuer9 r r r � get_value� s zSemaphore.get_valuec C s6 z| j �� }W n ty$ d}Y n0 d| jj|f S )N�unknownz<%s(value=%s)>)r rS � Exception� __class__rH �r. r0 r r r �__repr__� s
zSemaphore.__repr__)r N)rH rI rJ r5 rT rY r r r r r � s
r c @ s e Zd Zddd�Zdd� ZdS )r r Nc C s t j| t|||d� d S rN �r r5 rP rR r r r r5 � s zBoundedSemaphore.__init__c C s< z| j �� }W n ty$ d}Y n0 d| jj|| j jf S )NrU z<%s(value=%s, maxvalue=%s)>)r rS rV rW rH r1 rX r r r rY � s
�zBoundedSemaphore.__repr__)r N)rH rI rJ r5 rY r r r r r � s
r c @ s" e Zd ZdZddd�Zdd� ZdS )r z
Non-recursive lock.
Nc C s t j| tdd|d� d S �Nr rO rZ �r. r2 r r r r5 � s z
Lock.__init__c C s� zf| j �� r8t�� j}t�� jdkrd|dt�� j 7 }n,| j �� dkrLd}n| j �� dkr`d}nd}W n t y| d}Y n0 d | j
j |f S )
N�
MainThread�|r �Noner �SomeOtherThread�SomeOtherProcessrU z<%s(owner=%s)>) r �_is_miner rD r � threading�current_threadrS �_countrV rW rH )r. r r r r rY � s
z
Lock.__repr__)N�rH rI rJ �__doc__r5 rY r r r r r � s
r c @ s" e Zd ZdZddd�Zdd� ZdS )r
z
Recursive lock
Nc C s t j| tdd|d� d S r[ )r r5 �RECURSIVE_MUTEXr\ r r r r5 � s zRLock.__init__c C s� z|| j �� rBt�� j}t�� jdkr6|dt�� j 7 }| j �� }n8| j �� dkrZd\}}n | j �� dkrrd\}}nd\}}W n t y� d\}}Y n0 d | j
j ||f S )
Nr] r^ r )r_ r r )r` �nonzero)ra ri )rU rU � <%s(%s, %s)>) r rb r rD r rc rd re rS rV rW rH )r. r �countr r r rY � s
zRLock.__repr__)Nrf r r r r r
� s
r
c @ sn e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
ddd�Z dd� Z dd� Z
ddd�ZdS ) r
z
Condition variable
Nc C sF |sJ �|p|� � | _|�d�| _|�d�| _|�d�| _| �� d S �Nr )r
�_lockr �_sleeping_count� _woken_count�_wait_semaphorer+ )r. �lockr2 r r r r5 � s zCondition.__init__c C s t �| � | j| j| j| jfS r )r r> rm rn ro rp r9 r r r rA � s
�zCondition.__getstate__c C s |\| _ | _| _| _| �� d S r )rm rn ro rp r+ rB r r r rC � s �
zCondition.__setstate__c C s
| j �� S r )rm r: r9 r r r r: � s zCondition.__enter__c G s | j j|� S r )rm r; r< r r r r; � s zCondition.__exit__c C s | j j| _| j j| _d S r )rm r7 r8 r9 r r r r+ � s
zCondition._make_methodsc C sH z | j j�� | jj�� }W n ty2 d}Y n0 d| jj| j|f S )NrU rj )rn r rS ro rV rW rH rm )r. Z num_waitersr r r rY s
�
�zCondition.__repr__c C s� | j j�� sJ d��| j�� | j j�� }t|�D ]}| j �� q2zD| j�d|�W | j �� t|�D ]}| j �� qdS ]}| j �� qvn$| j �� t|�D ]}| j �� q�0 d S )Nz,must acquire() condition before using wait()T)
rm r rb rn r8 re r# rp r7 ro )r. �timeoutrk r3 r r r �wait s& �
� �
zCondition.waitc C sv | j j�� sJ d��| j�d�r$J �| j�d�rF| j�d�}|s$J �q$| j�d�rr| j�� | j�� | j�d� d S )N�lock is not ownedF)rm r rb rp r7 ro rn r8 )r. �resr r r �notify# s
zCondition.notifyc C s� | j j�� sJ d��| j�d�r$J �| j�d�rF| j�d�}|s$J �q$d}| j�d�rj| j�� |d7 }qJ|r�t|�D ]}| j�� qv| j�d�r�q�d S )Nrt Fr r ) rm r rb rp r7 ro rn r8 r# )r. ru Zsleepersr3 r r r �
notify_all4 s
zCondition.notify_allc C s` |� }|r|S |d ur"t � | }nd }d }|s\|d urJ|t � }|dkrJq\| �|� |� }q*|S rl )r rs )r. � predicaterr �result�endtime�waittimer r r �wait_forK s
zCondition.wait_for)NN)N)N)rH rI rJ rg r5 rA rC r: r; r+ rY rs rv rw r| r r r r r
� s
r
c @ s8 e Zd Zd dd�Zdd� Zdd� Zdd � Zd
d
d �ZdS )r Nc C s( |sJ �|� |�� �| _|�d�| _d S rl )r
r �_condr �_flagr\ r r r r5 ` s zEvent.__init__c C sR | j �8 | j�d�r.| j�� W d � dS W d � dS 1 sD0 Y d S �NFT)r} r~ r7 r8 r9 r r r �is_sete s
z Event.is_setc C sJ | j �0 | j�d� | j�� | j �� W d � n1 s<0 Y d S �NF)r} r~ r7 r8 rw r9 r r r �setl s
z Event.setc C s6 | j � | j�d� W d � n1 s(0 Y d S r� )r} r~ r7 r9 r r r �clearr s z Event.clearc C sv | j �\ | j�d�r | j�� n | j �|� | j�d�rR| j�� W d � dS W d � dS 1 sh0 Y d S r )r} r~ r7 r8 rs )r. rr r r r rs v s
z
Event.wait)N)N)rH rI rJ r5 r� r� r� rs r r r r r ^ s
r �Barrierc @ sZ e Zd Zddd�Zdd� Zdd� Zedd � �Zejd
d � �Zed d � �Z e jd
d � �Z dS )r� Nc C sZ |sJ �dd l }ddlm} ||�d�d �}|�� }| �|||||f� d| _d| _d S )Nr r )�
BufferWrapperr3 r )�struct�heapr� �calcsizer
rC �_statere ) r. �parties�actionrr r2 r� r� �wrapperZcondr r r r5 � s �Barrier.__init__c C s. |\| _ | _| _| _| _| j�� �d�| _d S )Nr3 )�_parties�_action�_timeoutr} �_wrapperZcreate_memoryview�cast�_arrayrB r r r rC � s �zBarrier.__setstate__c C s | j | j| j| j| jfS r )r� r� r� r} r� r9 r r r rA � s �zBarrier.__getstate__c C s
| j d S rl �r� r9 r r r r� � s zBarrier._statec C s || j d< d S rl r� rX r r r r� � s c C s
| j d S �Nr r� r9 r r r re � s zBarrier._countc C s || j d< d S r� r� rX r r r re � s )NNN)
rH rI rJ r5 rC rA �propertyr� �setterre r r r r r� � s
c @ s e Zd Zdd� ZdS )r� c O s t d��d S )Nz Barrier only supported on Py3)�NotImplementedError)r. r= �kwargsr r r r5 � s r� N)rH rI rJ r5 r r r r r� � s )!r r! rK rc � r r r Z_extr r �timer �__all__�listr# rh rP r rQ r r �_multiprocessing� ImportErrorr r r r r
r
r �hasattrr� r r r r �<module>
s< V|) (