File: //proc/thread-self/root/usr/local/lib/python3.7/test/__pycache__/test_fork1.cpython-37.pyc
B
��g� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z m
Z
mZmZ e
ed� G dd� de
�Zdd � Zed
kr�e�� dS ) z.This test checks for correct fork() behavior.
� N)�ForkWait)�
reap_children�
get_attribute�
import_module�verbose�forkc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�ForkTestc C sr t �� d }x6t �� |krBt�|tj�\}}||kr6P t �d� qW | �||� | �|dd|d@ |d? f � d S )Ng $@g�������?r zcause = %d, exit = %d� � )�timeZ monotonic�os�waitpid�WNOHANG�sleepZ assertEqual)�selfZcpidZdeadlineZspid�status� r �+/usr/local/lib/python3.7/test/test_fork1.py� wait_impl s zForkTest.wait_implc s� t �� �d�d�d� � ���fdd�}t j|d�}|�� ��� t�� }zR|s�t��}|� krlt�d� q�t dkr|t
d � t�d� n|� � | � |� W d
yt�
|tj� W n tk
r� Y nX X d
S ) zFCheck fork() in main thread works while a subthread is doing an importzfake test module�partialZcompletec s: t �� �tj�< ��� t�d� � tj�< t �� d S )Ng{�G�z�?)�imp� acquire_lock�sys�modules�setr r � release_lockr )�complete_module�fake_module_name�import_started�partial_moduler r �importer( s
z9ForkTest.test_threaded_import_lock_fork.<locals>.importer)�targetr � z Child encountered partial moduleN)� threadingZEventZThread�start�waitr r �
__import__�_exitr �print�joinr �kill�signal�SIGKILL�OSError)r r �t�pid�mr )r r r r r � test_threaded_import_lock_fork" s. z'ForkTest.test_threaded_import_lock_forkc s* � fdd�}xt d�D ] }||� qW dS )zJCheck fork() in main thread works while the main thread is doing an importc s� d}d}yVz4x t | �D ]}t�� |d7 }qW t�� }| }W d xt |�D ] }t�� qJW X W n4 tk
r� |r�tdkr�td� t� d� � Y nX |r�t� d� � �
|� d S )Nr Fr" zRuntimeError in child) �ranger r r r r � RuntimeErrorr r( r' r )�level�releaseZin_child�ir/ )r r r �fork_with_import_lockO s(
zDForkTest.test_nested_import_lock_fork.<locals>.fork_with_import_lock� N)r2 )r r7 r4 r )r r � test_nested_import_lock_forkL s z%ForkTest.test_nested_import_lock_forkN)�__name__�
__module__� __qualname__r r1 r9 r r r r r s
*r c C s
t � d S )N)r r r r r �tearDownModulel s r= �__main__)�__doc__�_impr r r+ r r# r ZunittestZtest.fork_waitr Z test.supportr r r r r r= r: �mainr r r r �<module> s
X