Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/billiard/__pycache__/synchronize.cpython-39.pyc
Ðазад
a i�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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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|) (
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка