File "synchronize.cpython-37.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/synchronize.cpython-37.pyc
File size: 10.92 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
B
fA- @ s, d dddddgZ ddlZddlZddlZddlZddlZdd lmZ dd
lmZ dd lm Z ydd lm
Z
m Z W n e k
r e d
Y nX e
ed\ZZej
jZG dd deZ
G dd de
ZG dd deZG dd d e
ZG dd de
ZG dd deZG dd deZG dd dejZdS )LockRLock SemaphoreBoundedSemaphore ConditionEvent N )context)process)util)SemLock
sem_unlinkzThis platform lacks a functioning sem_open implementation, therefore, the required synchronization primitives needed will not function, see issue 3770. c @ s\ e Zd Ze Zdd Zedd Zdd Z dd Z
d d
Z d d Z d
d Z
edd ZdS )r c C s |d krt j }| }tjdkp*|dk}xPtdD ]<}y t|||| | }| _
W n t k
rn Y q6X P q6W t dt
d|j | tjdkrdd } t | | | j
jd k rdd lm}
|
| j
j t j| tj| j
jfd
d d S ) Nwin32forkd z cannot find name for semaphorez created semlock with handle %sc S s | j d S )N)_semlock _after_fork)obj r @/opt/alt/python37/lib64/python3.7/multiprocessing/synchronize.pyr G s z%SemLock.__init__.<locals>._after_forkr )registerr )Z exitpriority)r Z_default_contextZ get_contextZget_start_methodsysplatformrange_multiprocessingr
_make_namer FileExistsErrorr debughandle
_make_methodsZregister_after_forknamesemaphore_trackerr ZFinalize_cleanup) selfkindvaluemaxvaluectxr! Z
unlink_nowislr r r r r __init__2 s.
zSemLock.__init__c C s ddl m} t| || d S )Nr )
unregister)r" r, r
)r! r, r r r r# T s zSemLock._cleanupc C s | j j| _| j j| _d S )N)r acquirerelease)r$ r r r r Z s
zSemLock._make_methodsc C s
| j S )N)r __enter__)r$ r r r r/ ^ s zSemLock.__enter__c G s | j j| S )N)r __exit__)r$ argsr r r r0 a s zSemLock.__exit__c C sD t | | j}tjdkr,t |j}n|j}||j|j |j
fS )Nr ) r assert_spawningr r r Zget_spawning_popenZduplicate_for_childr r% r' r! )r$ r* hr r r __getstate__d s
zSemLock.__getstate__c C s, t jj| | _td|d | d S )Nz recreated blocker with handle %rr )r r Z_rebuildr r r r )r$ stater r r __setstate__m s zSemLock.__setstate__c C s dt jd ttjf S )Nz%s-%sZ semprefix)r
current_processZ_confignextr _randr r r r r r s zSemLock._make_nameN)__name__
__module__ __qualname__tempfileZ_RandomNameSequencer9 r+ staticmethodr# r r/ r0 r4 r6 r r r r r r . s " r c @ s& e Zd Zd ddZdd Zdd ZdS )
r r c C s t j| t|t|d d S )N)r( )r r+ SEMAPHORE
SEM_VALUE_MAX)r$ r& r( r r r r+ } s zSemaphore.__init__c C s
| j S )N)r
_get_value)r$ r r r get_value s zSemaphore.get_valuec C s8 y| j }W n tk
r& d}Y nX d| jj|f S )Nunknownz<%s(value=%s)>)r rA Exception __class__r: )r$ r& r r r __repr__ s
zSemaphore.__repr__N)r )r: r; r< r+ rB rF r r r r r { s
c @ s e Zd ZdddZdd ZdS )r r c C s t j| t|||d d S )N)r( )r r+ r? )r$ r& r( r r r r+ s zBoundedSemaphore.__init__c C s> y| j }W n tk
r& d}Y nX d| jj|| j jf S )NrC z<%s(value=%s, maxvalue=%s)>)r rA rD rE r: r' )r$ r& r r r rF s
zBoundedSemaphore.__repr__N)r )r: r; r< r+ rF r r r r r s
c @ s e Zd Zdd Zdd ZdS )r c C s t j| tdd|d d S )Nr )r( )r r+ r? )r$ r( r r r r+ s z
Lock.__init__c C s yf| j r8t j}t jdkrd|dt j 7 }n,| j dkrLd}n| j dkr`d}nd}W n t k
r~ d}Y nX d | j
j |f S )
N
MainThread|r Noner SomeOtherThreadSomeOtherProcessrC z<%s(owner=%s)>) r _is_miner
r7 r! threadingcurrent_threadrA _countrD rE r: )r$ r! r r r rF s
z
Lock.__repr__N)r: r; r< r+ rF r r r r r s c @ s e Zd Zdd Zdd ZdS )r c C s t j| tdd|d d S )Nr )r( )r r+ RECURSIVE_MUTEX)r$ r( r r r r+ s zRLock.__init__c C s y|| j rBt j}t jdkr6|dt j 7 }| j }n8| j dkrZd\}}n | j dkrrd\}}nd\}}W n t k
r d\}}Y nX d | j
j ||f S )
NrG rH r )rI r r )rJ nonzero)rK rQ )rC rC z <%s(%s, %s)>) r rL r
r7 r! rM rN rO rA rD rE r: )r$ r! countr r r rF s
zRLock.__repr__N)r: r; r< r+ rF r r r r r s c @ sl e Zd ZdddZdd Zdd Zdd Zd
d Zd d
Zdd Z dddZ
dddZ dd Z d ddZ
dS ) r Nc C s> |p
| | _|d| _|d| _|d| _| d S )Nr )r _lockr _sleeping_count _woken_count_wait_semaphorer )r$ lockr( r r r r+ s
zCondition.__init__c C s t | | j| j| j| jfS )N)r r2 rS rT rU rV )r$ r r r r4 s
zCondition.__getstate__c C s |\| _ | _| _| _| d S )N)rS rT rU rV r )r$ r5 r r r r6 s zCondition.__setstate__c C s
| j S )N)rS r/ )r$ r r r r/ s zCondition.__enter__c G s | j j| S )N)rS r0 )r$ r1 r r r r0 s zCondition.__exit__c C s | j j| _| j j| _d S )N)rS r- r. )r$ r r r r s
zCondition._make_methodsc C sJ y | j j | jj }W n tk
r4 d}Y nX d| jj| j|f S )NrC z <%s(%s, %s)>)rT r rA rU rD rE r: rS )r$ Z num_waitersr r r rF s
zCondition.__repr__c C s | j j std| j | j j }xt|D ]}| j q4W z| j d|S | j
xt|D ]}| j qjW X d S )Nz,must acquire() condition before using wait()T) rS r rL AssertionErrorrT r. rO r rV r- rU )r$ timeoutrR r) r r r wait s
zCondition.waitr c C s | j j std| jdr(tdx(| jdrP| jd}|s*tdq*W d}x*||k r| jdr| j |d7 }qXW |rxt |D ]}| j qW x| jdrqW d S )Nzlock is not ownedFz;notify: Should not have been able to acquire_wait_semaphorez>notify: Bug in sleeping_count.acquire- res should not be Falser r )
rS r rL rX rV r- rU rT r. r )r$ nZresZsleepersr) r r r notify s
zCondition.notifyc C s | j tjd d S )N)r[ )r\ r maxsize)r$ r r r
notify_all( s zCondition.notify_allc C sh | }|r|S |d k r$t | }nd }d }x6|sb|d k rP|t }|dkrPP | | | }q.W |S )Nr )timeZ monotonicrZ )r$ Z predicaterY resultZendtimeZwaittimer r r wait_for+ s
zCondition.wait_for)N)N)r )N)r: r; r< r+ r4 r6 r/ r0 r rF rZ r\ r^ ra r r r r r s
c @ s6 e Zd Zdd Zdd Zdd Zdd Zd d
d Zd S )
r c C s | | | _|d| _d S )Nr )r r _condr _flag)r$ r( r r r r+ C s zEvent.__init__c C s0 | j | jdr"| j dS dS Q R X d S )NFT)rb rc r- r. )r$ r r r is_setG s
z Event.is_setc C s6 | j & | jd | j | j W d Q R X d S )NF)rb rc r- r. r^ )r$ r r r setN s
z Event.setc C s" | j | jd W d Q R X d S )NF)rb rc r- )r$ r r r clearT s z Event.clearNc C sT | j D | jdr | j n | j | | jdrF| j dS dS Q R X d S )NFT)rb rc r- r. rZ )r$ rY r r r rZ X s
z
Event.wait)N)r: r; r< r+ rd re rf rZ r r r r r A s
c @ sZ e Zd ZdddZdd Zdd Zedd Zejd
d Zed d Z e jd
d Z dS )BarrierNc C sR dd l }ddlm} ||dd }| }| |||||f d| _d| _d S )Nr r )
BufferWrapperr) r )structheaprh Zcalcsizer r6 _staterO ) r$ ZpartiesactionrY r( ri rh wrapperZcondr r r r+ j s zBarrier.__init__c C s. |\| _ | _| _| _| _| j d| _d S )Nr) )_parties_action_timeoutrb _wrapperZcreate_memoryviewcast_array)r$ r5 r r r r6 s s zBarrier.__setstate__c C s | j | j| j| j| jfS )N)rn ro rp rb rq )r$ r r r r4 x s zBarrier.__getstate__c C s
| j d S )Nr )rs )r$ r r r rk | s zBarrier._statec C s || j d< d S )Nr )rs )r$ r& r r r rk s c C s
| j d S )Nr )rs )r$ r r r rO s zBarrier._countc C s || j d< d S )Nr )rs )r$ r& r r r rO s )NN)
r: r; r< r+ r6 r4 propertyrk setterrO r r r r rg h s
rg )__all__rM r r= r r_ r r
r r r
ImportErrorlistr rP r? r@ objectr r r r r r rg r r r r <module> s. Mo'