Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

�
��^c@s�dZd
dl
Z
ddd��YZd�Zd
dlmZmZmZ
def
d��YZd	ef
d
��YZ	def
d��YZ
e
d
di�Zd�Ze
dkr�e�
e�
ndS(s`Synchronization metaclass.

This metaclass  makes it possible to declare synchronized methods.

i����NtLockcBs,eZ
dZd
�Zdd�
Zd�ZRS(s�Reentrant lock.

    This is a mutex-like object which can be acquired by the same
    thread more than once.  It keeps a reference count of the number
    of times it has been acquired by the same thread.  Each acquire()
    call must be matched by a release() call and only the last
    release() call actually releases the lock for acquisition by
    another thread.

    The implementation uses two locks internally:

    __mutex is a short term lock used to protect the instance variables
    __wait is the lock for which other threads wait

    A thread intending to acquire both locks should acquire __wait
    first.

   The implementation uses two other instance variables, protected by
   locking __mutex:

    __tid is the thread ID of the thread that currently has the lock
    __count is the number of times the current thread has acquired it

    When the lock is released, __tid is None and __count is zero.

    c

Cs4tj
�|_tj
�|_d|_d
|_dS(s0Constructor.  Initialize all instance variables.iN(tthreadt
allocate_lockt_Lock__mutext_Lock__waittNonet
_Lock__tidt_Lock__count(
tself((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyt__init__*s

	
i
cCs�|jj
�
z-|jtj�kr9|jd
|_d
SWd|jj�
X|jj
|
�
}|
ro|rodSz-|jj
�
tj�|_d
|_d
SWd|jj�
XdS(s}
Acquire the lock.

        If the optional flag argument is false, returns immediately
        when it cannot acquire the __wait lock without blocking (it
        may still block for a little while in order to acquire the
        __mutex lock).

        The return value is only relevant when the flag argument is
        false; it is 1 if the lock is acquired, 0 if not.

        i
Ni(RtacquireRR
t	get_identRtreleaseR(Rtflagtlocked((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR
1s











	
c

Cs^|jj
�
z<|jd
|_|jdkrHd|_|jj�
nWd|jj�
XdS(s�Release the lock.

        If this thread doesn't currently have the lock, an assertion
        error is raised.

        Only allow another thread to acquire the lock when the count
        reaches zero after decrementing it.

        i
iN(RR
RRRRR(
R((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyRQs




	
(t__name__t
__module__t__doc__R	R
R(((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR
s	 cCs�g}|d
�
}
|
|d�}t�}|j
�
||�

|j�
|j
�
tj||f
�
tj|||f�
tj|
|f
�
tj|
|f
�
|j�
ddl}x.t|�
dkr�t|�
GH|jd�

q�Wt|�
GHdS(NcSs3|j�
d
t
j�G|j�
|
jd�

dS(Nsf2 running in thread %d
i
(R
R
RRtappend(tlocktdone((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pytf2ks





cSsE|j�
d
t
j�Gz|
|�

Wd|j�
X|jd�

dS(Nsf1 running in thread %d
i
(R
R
RRR(RRR((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pytf1qs





i����i	g����MbP?(RR
RR
tstart_new_threadttimetlentsleep(RRRRR((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyt	_testLockgs$		















(t	MetaClasst
MetaHelpertMetaMethodWrappertLockingMethodWrapperc
BseZ
d�ZRS(
c
Os�|jd
 dkrC|jd
dkrCt
|j|jf
|
|�S|jjj�
z!t
|j|jf
|
|�SWd|jjj�
XdS(Ni
t
_(Rtapplytfunctinstt__lock__R
R(Rtargstkw((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyt__call__�s
&



!(RRR'(((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR�s
t
LockingHelperc
BseZ
eZd�ZRS(
cCs tj
||
�
t�|_dS(
N(Rt__helperinit__RR$(Rtformalclass((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR)�s

(RRRt__methodwrapper__R)(((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR(�s

tLockingMetaClassc
BseZ
eZRS((RRR(t
__helper__(((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR,�s
tLockingcCs�d
tf
d��Y}dd�
}
dd�
}t
j�}|j�
t
j�}|j�
|d�
}d}t
j||||f�
t
j|
|||f�
|j�
dGH|j�
dGHd	Gt|j�
GHdS(
NtBufferc
Bs#eZ
d�Zd
�Zd�ZRS(cSs0|
|_dg
|j|_d
|_|_dS(Ni(tsizeRtbuffertfirsttlast(Rtinitialsize((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR	�s	

cSsI
|jd
|j
|jkrH|
|j|j<|jd
|j
|_dSdG|jGHd|j|j|j
fGH|j|jk
r�|j|j|j!}n|j|j|j|j }dG|GH|dg
|j
d
|_d|_|j
d
|_|j
d|_
dG|j
GHdG|jGHd|j|j|j
fGH|j|
�

dS(	Ni
sbuffer =s first = %d, last = %d, size = %dstemp =iisBuffer size doubled tosnew buffer =(R3R0R2R1Rtput(Rtitemttemp((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR5�s(






	

	






c
SsF|j|j
krt�
n|j|j}
|jd
|j|_|
S(Ni
(R2R3tEOFErrorR1R0(RR6((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pytget�s

	


(RRR	R5R9(((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyR/�s
		i�cSs`d
dl}d}x0||krDdG|GH|j
|�

|d}qWdG|GdGH|
j�
dS(Ni����iR5i
sProducer: done producingtitems(RR5R(R1twaitt
nRt
i((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pytproducer�s



	





cSs�d
dl}d}d}x�||kr�yK|j
�}||krXtd||f�ndG|GH|d}d}Wqtk
r�


|j|�

|d}qXqWdG|Gd	GH|
j�
dS(
Ni����ig����MbP?sget() returned %s, expected %stgoti
isConsumer: done consumingR:(RR9tAssertionErrorR8RR(R1R;R<RR=ttoutt
x((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pytconsumer�s"









	











i
s
Producer donesAll donesbuffer size ==(R.R
RR
RRR1(R/R>RCtpwaittcwaitR1R<((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyt_test�s (
















t__main__(((RR
RRtMetaRRRRR(R,R.RFR(((s./usr/lib64/python2.7/Demo/metaclasses/Synch.pyt<module>sZ	+
	U