✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

3

��2a�!�@s�dd
lZdd
l
Z
dd
lZddlmZ
ejd�
Zdd
lZdd
lZdd
l	Z	ddlm
Z

dZdZdZ
ej�Zdd	�ZGd
d�de
j�ZGdd
�d
e�ZGdd�d�ZGdd�de�ZGdd�de
j�ZGdd�de
j�Zedkr�e
j�
d
S)�N)
�support�_thread)
�
lock_tests�
�g{�G�z�?c

	Cs"tj
rt�
t|�

WdQRXdS)
N)r�verbose�_print_mutex�print)
�arg�r�0/opt/alt/python36/lib64/python3.6/test_thread.py�
verbose_prints

r
c@seZ
dZd
d�ZdS)�BasicThreadTestc
CsXtj
�|_|jj�
tj
�|_tj
�|_d
|_d
|_d
|_t	j
�}
|jt	jf
|
��
dS)Nr
)
�thread�
allocate_lock�
done_mutex�acquire�
running_mutex�random_mutex�created�running�
next_identrZthreading_setupZ
addCleanupZthreading_cleanup)�self�keyrrr�setUps











zBasicThreadTest.setUpN)�__name__�
__module__�__qualname__rrrrrrsrc@sVeZ
dZd
d�Zdd�Zdd�Zdd�Zeje	j
dkd�dd
��
Zdd�Zdd�Z
dS)�ThreadRunningTestsc


Cs`|j�P
|j
d
7_
td|j
�

tj|j|j
f
�
|jd
7_|jd
7_WdQRXdS)N�
zcreating task %s)rrr
r�start_new_thread�taskrr)
rrrr�newtask*s





zThreadRunningTests.newtaskcCs�|j�
t
j
�d
}WdQRXtd|
t|d�
f�

tj|�

td|
�

|j�2
|jd8_|jt	kr�|jdkr�|j
j�
WdQRXdS)Ng��@ztask %s will run for %susg��.Aztask %s donerr
)r�randomr
�round�time�sleeprrr�NUMTASKSr�release)r�ident�delayrrrr!2s









zThreadRunningTests.taskc
	CsLtj
��:
xtt�
D]}
|j�
qWtd
�

|jj�
td�

WdQRXdS)Nz waiting for tasks to complete...zall tasks done)r�wait_threads_exit�ranger'r"r
rr)r�
irrr�test_starting_threads=s






z(ThreadRunningTests.test_starting_threadsc

Cs2|jt
j�d
d�
t
jd
�

|jt
j�d
d�
dS)Nr
zinitial stack size is not 0zstack_size not reset to default)�assertEqualr�
stack_size)
rrrr�test_stack_sizeFs

z"ThreadRunningTests.test_stack_size�nt�posixztest meant for nt and posixc
Cs
ytj
d
�

Wn:tk
r*


td�

Yn tjk
rH


|jd�

YnXd}
x8dD]0}tj
|�

|jtj
�||
|�
td|�

qTWxld
D]d}td	|�

d|_d|_t	j
��:
xtt�
D]}|j
�
q�Wtd
�

|jj�
td�

WdQRXq�Wtj
d�

dS)Niz3caught expected ValueError setting stack_size(4096)z4platform does not support changing thread stack sizez&stack_size(%d) failed - should succeed��r
zsuccessfully set stack_size(%d)ztrying stack_size = (%d)z!waiting for all tasks to completezall tasks done)r4r5r
)r4r5)rr0�
ValueErrorr
�errorZskipTestr/rrrr+r,r'r"rr)rZfail_msgZtssr-rrr�test_nt_and_posix_stack_sizeMs,




















z/ThreadRunningTests.test_nt_and_posix_stack_sizec
s�tj
�}
tj��
�
j�
g��
�fd
d�}tj���
tj|f�
x�sRtjt	�

qBW|j
tj
�|
d�
�
j�
g�tj
|�f
dd��}~x�s�tjt	�

q�W|j
tj
�|
�
WdQRXdS)Ncs�
jd�

�j
�
�j�
dS)
N)�appendrr(r)�mut�startedrrr!ss



z,ThreadRunningTests.test__count.<locals>.taskrc

s
�jd�
S)
N)
r9)
�
_)
�donerr�<lambda>�sz0ThreadRunningTests.test__count.<locals>.<lambda>)r�_countrrrr+r r%r&�
POLL_SLEEPr/r(�weakref�ref)rZorigr!�wrr)r=r:r;r�test__countls"












zThreadRunningTests.test__countc
s��
f
d
d�}
�f
dd�}tj
��
tjd�
�B}|j�||_�
j�
tj��
tj|
f�
�
j�
WdQRXWdQRX|jd|j	��
dS)Nc
s�j�
t
�
dS)
N)r(�SyntaxErrorr)
r;rrr!�s

zCThreadRunningTests.test_save_exception_state_on_error.<locals>.taskc
s0yt�
Wntk
r


YnX�|f
|
��
dS)
N)
r6)r�args)
�
real_writerr�mywrite�s





zFThreadRunningTests.test_save_exception_state_on_error.<locals>.mywrite�stderrZ	Traceback)
rrrZcaptured_output�writerr+r ZassertIn�getvalue)rr!rHrIr)rGr;r�"test_save_exception_state_on_error�s








z5ThreadRunningTests.test_save_exception_state_on_errorN)r2r3)rrrr"r!r.r1�unittestZskipIf�os�namer8rDrLrrrrr(s	rc@seZ
dZd
d�Zdd�ZdS)�BarriercCs.|
|_d
|_
tj�|_tj�|_|jj�
dS)Nr
)�num_threads�waitingrr�
checkin_mutex�checkout_mutexr)rrQrrr�__init__�s







zBarrier.__init__c

Cs�|jj
�
|jd
|_|j|jkr<|jd
|_|jj�
dS|jj�
|jj
�
|jd
|_|jdkrt|jj�
dS|jj�
dS)Nrr
)rSrrRrQrTr()
rrrr�enter�s

















z
Barrier.enterN)rrrrUrVrrrrrP�s
rPc@seZ
dZd
d�Zdd�ZdS)�BarrierTestc
Csdtj
��R
tt�
|_t|_x tt�
D]}
tj|j	|
f
�
q$Wt
d
�

|jj�
t
d�

WdQRXdS)Nzwaiting for tasks to endz
tasks done)
rr+rPr'�barrr,rr �task2r
rr)rr-rrr�test_barrier�s










zBarrierTest.test_barriercCs�x�tt
�
D]x}|
d
krd
}n|j�
tj�d}WdQRXtd|
t|d�
f�

tj|�

td|
|f�

|jj	�
td|
�

q
W|j
�
|jd8_|jd
k}WdQRX|r�|jj
�
dS)Nr
g��@ztask %s will run for %susg��.Aztask %s entering %sztask %s leaving barrierr)r,�NUMTRIPSrr#r
r$r%r&rXrVrrrr()rr)r-r*ZfinishedrrrrY�s 














zBarrierTest.task2N)rrrrZrYrrrrrW�s
rWc
@seZ
dZejZd
S)�	LockTestsN)rrrrrZlocktyperrrrr\�s
r\c@s<eZ
dZd
d�Zejeed�d�ej	dd��
�
Z
dd�Zd	S)
�TestForkInThreadc

Cstj
�\|_|_dS)
N)rN�pipe�read_fd�write_fd)
rrrrr�s
zTestForkInThread.setUp�forkzneed os.forkc
sZd
�
��
fdd�}
tj
��*
tj|
f�
�jtj�jd�dd�
WdQRX�j�
d�
dS)Nznot setc
s^tj
�}|d
kr>ztj�j�

tj�jd�
Wdtjd
�

Xntj�j�

tj|d
�\}�
dS)Nr
sOK)rNra�closer_rJr`�_exit�waitpid)
�pid)r�statusrr�thread1�s



z3TestForkInThread.test_forkinthread.<locals>.thread1�sOKzUnable to fork() in threadr
)rr+rr r/rN�readr_)rrgr)rrfr�test_forkinthread�s




z"TestForkInThread.test_forkinthreadc

CsPytj
|j�

Wntk
r$


YnXytj
|j�

Wntk
rJ


YnXdS)
N)rNrbr_�OSErrorr`)
rrrr�tearDown

s






zTestForkInThread.tearDownN)rrrrrMZ
skipUnless�hasattrrNrZreap_threadsrjrlrrrrr]�s

r]�__main__)rNrMr#Ztestr�
import_modulerr%�sysrArr'r[r@rrr
ZTestCaserrrPrWr\r]r�mainrrrr�<module>
s*









w%,