3
�
�^�p c @ s d Z ddlZddlZddlmZmZ ddlZddlZddlZddl m
Z
dd� Z G dd� de �Z
G d d
� d
ej�ZG d d � d e�ZG d
d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZdS ) z/
Various tests for synchronization primitives.
� N)�start_new_thread� TIMEOUT_MAX)�supportc C s t jd� d S )N�{�G�z�?)�time�sleep� r r �'/usr/lib64/python3.6/test/lock_tests.py�_wait s r c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d
� Zd S )
�Bunchz
A bunch of threads.
Fc
s| � �_ |�_g �_g �_| �_tj� �_�jj� � �fdd�}y xt |�D ]}t
|f � qNW W n d�_� Y nX dS )z�
Construct a bunch of `n` threads running the same function `f`.
If `wait_before_exit` is True, the threads won't terminate until
do_finish() is called.
c sD t j� } �jj| � z
� � W d �jj| � x�js<t� q.W X d S �N)� threadingZ get_ident�started�append�finished� _can_exitr )Ztid��f�selfr r �task% s
z Bunch.__init__.<locals>.taskTN) r �nr
r r r �wait_threads_exit� wait_threadZ __enter__�ranger )r r r Zwait_before_exitr �ir r r �__init__ s
zBunch.__init__c C s xt | j�| jk rt� qW d S r )�lenr
r r �r r r r �wait_for_started6 � zBunch.wait_for_startedc C s0 xt | j�| jk rt� qW | jjd d d � d S r )r r r r r Z__exit__r r r r �wait_for_finished: s
zBunch.wait_for_finishedc C s
d| _ d S �NT)r r r r r � do_finish@ � zBunch.do_finishN)F)�__name__�
__module__� __qualname__�__doc__r r r r! r r r r r
s
r
c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� BaseTestCasec C s t j� | _d S r )r Zthreading_setup�_threadsr r r r �setUpE r" zBaseTestCase.setUpc C s t j| j� t j� d S r )r Zthreading_cleanupr( Z
reap_childrenr r r r �tearDownH s zBaseTestCase.tearDownc C s$ | j ||d � | j||d � d S )Ng333333�?g $@)ZassertGreaterEqual�
assertLess)r ZactualZexpectedr r r �
assertTimeoutL s zBaseTestCase.assertTimeoutN)r# r$ r% r) r* r, r r r r r' D s r' c @ sx e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd S ) �
BaseLockTestsz;
Tests for both recursive and non-recursive locks.
c C s | j � }~d S r )�locktype�r �lockr r r �test_constructorZ � z BaseLockTests.test_constructorc C s | j � }| jt|�d� ~d S )Nz <unlocked .* object (.*)?at .*>)r. � assertRegex�reprr/ r r r � test_repr^ � zBaseLockTests.test_reprc C s& | j � }|j� | jt|�d� ~d S )Nz <locked .* object (.*)?at .*>)r. �acquirer3 r4 r/ r r r �test_locked_reprc s z BaseLockTests.test_locked_reprc C � | j � }|j� ~d S r )r. r7 r/ r r r �test_acquire_destroyi � z"BaseLockTests.test_acquire_destroyc C s | j � }|j� |j� ~d S r �r. r7 �releaser/ r r r �test_acquire_releasen s z"BaseLockTests.test_acquire_releasec C s$ | j � }| j|jd�� |j� d S �NF)r. �
assertTruer7 r= r/ r r r �test_try_acquiret r6 z BaseLockTests.test_try_acquirec sJ | j � � � j� g �� �fdd�}t|d�j� | j�d � � j� d S )Nc s �j � jd�� d S r? �r r7 r �r0 �resultr r r } r" z3BaseLockTests.test_try_acquire_contended.<locals>.f� r )r. r7 r
r � assertFalser= �r r r rC r �test_try_acquire_contendedy s z(BaseLockTests.test_try_acquire_contendedc sp | j � � � j� d}� fdd�}t||�}|j� t� | jt|j�d� � j� |j � | jt|j�|� d S )N� c � � j � � j� d S r �r7 r= r �r0 r r r � r2 z/BaseLockTests.test_acquire_contended.<locals>.fr )
r. r7 r
r r � assertEqualr r r= r �r �Nr �br rL r �test_acquire_contended� s
z$BaseLockTests.test_acquire_contendedc sV | j � � � fdd�}d� fdd� }|� t|d�j� | jt|t� t|d�j� d S )Nc rJ r rK r rL r r r � r2 z"BaseLockTests.test_with.<locals>.fc s � � | d k r| �W d Q R X d S r r �ZerrrL r r �_with� s z&BaseLockTests.test_with.<locals>._withrE r )r. r
r � assertRaises� TypeError)r r rS r rL r � test_with� s zBaseLockTests.test_withc s` | j � � � fdd�}ttj� �}t|d�j� ttj� �|kr\tjd� | j|ttj� �� d S )Nc rJ r rK r rL r r r � r2 z)BaseLockTests.test_thread_leak.<locals>.fi g�������?) r. r r Z enumerater
r r r rM )r r r r rL r �test_thread_leak� s
z BaseLockTests.test_thread_leakc s� | j � � | jt� jdd� | jt� jd
d� | jt� jdd� | jt� jtd d� � jtd� � j� tj� }| j� jdd�� tj� }| j || d� g �� �fdd�}t
|d�j � | j �d � | j
�d d � d S ) Nr rE id ��timeoutg}Ô%�I�TrI c s4 t j � } �j� jdd�� t j � }�j|| � d S )N� �?rX )r r r7 )�t1�t2�r0 �resultsr r r � s z%BaseLockTests.test_timeout.<locals>.frZ i����)r. rT �
ValueErrorr7 Z
OverflowErrorr r= r r@ r+ r
r rF r, )r r[ r\ r r r] r � test_timeout� s zBaseLockTests.test_timeoutc C s" | j � }tj|�}| j|� � d S r )r. �weakref�refZassertIsNotNone�r r0 rb r r r �test_weakref_exists� s
z!BaseLockTests.test_weakref_existsc C s$ | j � }tj|�}~| j|� � d S r )r. ra rb Z assertIsNonerc r r r �test_weakref_deleted� s
z"BaseLockTests.test_weakref_deletedN)r# r$ r% r& r1 r5 r8 r: r> rA rH rQ rV rW r` rd re r r r r r- U s
r- c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � LockTestszn
Tests for non-recursive, weak locks
(which can be acquired and released from different threads).
c
s� | j � � g �� �fdd�}tj� �n t|f � xt��dkrDt� q0W t� | jt��d� � j� xt��dkrzt� qfW | jt��d� W d Q R X d S )Nc s( � j � �jd � � j � �jd � d S r )r7 r r �r0 Zphaser r r � s
z#LockTests.test_reacquire.<locals>.fr rE � )r. r r r r r rM r= rG r rg r �test_reacquire� s
zLockTests.test_reacquirec sB | j � � � j� � fdd�}t|d�}|j� � j� � j� d S )Nc � � j � d S r )r= r rL r r r � r" z*LockTests.test_different_thread.<locals>.frE )r. r7 r
r r= �r r rP r rL r �test_different_thread� s
z LockTests.test_different_threadc C sN | j � }|j� | j|jdd�� |j� | j|j� � | j|jdd�� d S )Nr rX F)Zblocking)r. r7 rF r= Zlockedr@ r/ r r r �test_state_after_timeout s z"LockTests.test_state_after_timeoutN)r# r$ r% r& ri rl rm r r r r rf � s rf c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
�
RLockTestsz$
Tests for recursive locks.
c C s< | j � }|j� |j� |j� |j� |j� |j� d S r r< r/ r r r ri s zRLockTests.test_reacquirec C sX | j � }| jt|j� |j� |j� |j� |j� |j� |j� | jt|j� d S r )r. rT � RuntimeErrorr= r7 r/ r r r �test_release_unacquired � z"RLockTests.test_release_unacquiredc C sX | j � }| jt|j� |j� |j� |j� |j� |j� |j� | jt|j� d S r )r. rT ro Z
_release_saver7 r= r/ r r r � test_release_save_unacquired& rq z'RLockTests.test_release_save_unacquiredc
sJ | j � � � fdd�}t|dd�}z| jt� j� W d |j� X |j� d S )Nc rj r )r7 r rL r r r 5 r" z+RLockTests.test_different_thread.<locals>.frE T)r. r
rT ro r= r! r rk r rL r rl 2 s
z RLockTests.test_different_threadc s� | j � � | j� j� � � j� | j� j� � � j� | j� j� � g �� �fdd�}t|d�j� | j�d � � j� | j� j� � � j� | j� j� � d S )Nc s �j � j� � d S r )r � _is_ownedr rC r r r F r" z$RLockTests.test__is_owned.<locals>.frE r )r. rF rs r7 r@ r
r r= rG r rC r �test__is_owned> s zRLockTests.test__is_ownedN) r# r$ r% r& ri rp rr rl rt r r r r rn
s rn c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�
EventTestsz"
Tests for Event objects.
c C sr | j � }| j|j� � |j� | j|j� � |j� | j|j� � |j� | j|j� � |j� | j|j� � d S r )� eventtyperF Zis_set�setr@ �clear�r �evtr r r � test_is_setU s zEventTests.test_is_setc s| d}g �g �� ��fdd�}t ||�}|j� t� | jt��d� � j� |j� | j�dg| � | j�dg| � d S )NrI c s �j � j� � �j � j� � d S r �r �waitr �rz �results1�results2r r r f s z#EventTests._check_notify.<locals>.fr T)r
r r rM r rw r )r rz rO r rP r r~ r �
_check_notifya s
zEventTests._check_notifyc C s0 | j � }| j|� |j� |j� | j|� d S r )rv r� rw rx ry r r r � test_notifyr s
zEventTests.test_notifyc s� | j � � g �g �d}� ��fdd�}t||�j� | j�dg| � x&�D ] \}}| j|� | j|d� qJW g �g �� j� t||�j� | j�dg| � x�D ]\}}| j|� q�W d S )NrI c s@ �j � jd�� tj� } � jd�}tj� }�j ||| f� d S )Ng rZ )r r} r )r[ �rr\ r~ r r r s
z"EventTests.test_timeout.<locals>.fFrZ T)rv r
r rM rF r, rw r@ )r rO r r� �dtr r~ r r` z s"
zEventTests.test_timeoutc sn | j � � g �d�d}� ��fdd�}t||�}|j� tj�� � j� � j� |j� | j�dg| � d S )Ng �?rI c s �j � j�d �� d S �N� r| r �rz r^ rY r r r � r" z(EventTests.test_set_and_clear.<locals>.fT) rv r
r r r rw rx r rM rN r r� r �test_set_and_clear� s
z EventTests.test_set_and_clearc C s\ | j � }|j� | j|jjd�� W d Q R X |j� |j� | j|jjd�� W d Q R X d S r? )rv Z_condrF r7 Z_reset_internal_locksry r r r �test_reset_internal_locks� s z$EventTests.test_reset_internal_locksN)
r# r$ r% r& r{ r� r� r` r� r� r r r r ru P s ru c @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dS )�ConditionTestsz(
Tests for condition variables.
c
C s� | j � }|j� |j� |j� |j� tj� }| j |�}|j� | j|jd�� |j� | j|jd�� | j|jd�� |j� |� | j|jd�� W d Q R X d S r? )�condtyper7 r= r ZLockrF r@ )r �condr0 r r r � test_acquire� s
zConditionTests.test_acquirec C � | j � }| jt|j� d S r )r� rT ro r} �r r� r r r �test_unacquired_wait� r2 z#ConditionTests.test_unacquired_waitc C r� r )r� rT ro �notifyr� r r r �test_unacquired_notify� r2 z%ConditionTests.test_unacquired_notifyc s� d}g �g �g �d�� ����fdd�}t ||�}|j� xt��dk rPt� q<W �j� | j�g � � j� � jd� t� d�� j� xt��dk r�t� q�W | j�d
gd � | j�g � xt��dk r�t� q�W � j� � jd� t� d�� j� x"t��t�� d k �r t� � q�W | j�d gd d gd � | j�d
gd � xt��dk �rht� �qPW � j� � j � t� d�� j� xt��dk �r�t� �q�W | j�dgd dgd � | j�dgd dgd � |j
� d S )NrI r c sd � j � �j�� � j� } � j� �j| �f� � j � �j�� � j� } � j� �j| �f� d S r )r7 r r} r= �rD �r� � phase_numZreadyr r� r r r � s
z'ConditionTests._check_notify.<locals>.f� rE Trh i �TrE r� �Trh r� r� r� r� )Tr� ) r
r r r rx rM r7 r� r= Z
notify_allr )r r� rO r rP r r� r r� � sX
z ConditionTests._check_notifyc C s | j � }| j|� | j|� d S r )r� r� r� r r r r� s
zConditionTests.test_notifyc sh | j � � g �d}� �fdd�}t||�j� | jt��|� x&�D ] \}}| j|d� | j|� qBW d S )NrI c s@ � j � tj� } � jd�}tj� }� j� �j|| |f� d S )NrZ )r7 r r} r= r )r[ rD r\ �r� r^ r r r " s
z&ConditionTests.test_timeout.<locals>.frZ )r� r
r rM r r, rF )r rO r r� rD r r� r r` s zConditionTests.test_timeoutc
sv �j � � d�� ��fdd�}t|d�}|j� x:td�D ].}tjd� � � �d7 �� j� W d Q R X q8W |j� d S )Nr c s< � �. � j �fdd��} �j| � �j�d� W d Q R X d S )Nc � � dkS r� r r ��stater r �<lambda>9 � z8ConditionTests.test_waitfor.<locals>.f.<locals>.<lambda>r� )�wait_forr@ rM r� �r� r r� r r r 7 s
z&ConditionTests.test_waitfor.<locals>.frE r� r )r� r
r r r r r� r �r r rP r r r� r � test_waitfor4 s
zConditionTests.test_waitforc
s� �j � � d�g �� ���fdd�}t|d�}|j� x:td�D ].}tjd� � � �d7 �� j� W d Q R X q>W |j� �jt ��d� d S )Nr c s^ � �P t j � } � j�fdd�dd�}t j � | } �j|� �j| d� �jd � W d Q R X d S )Nc r� r� r r r� r r r� L r� z@ConditionTests.test_waitfor_timeout.<locals>.f.<locals>.<lambda>g�������?rX )r r� rF r, r )r� rD �r� r r� Zsuccessr r r I s
z.ConditionTests.test_waitfor_timeout.<locals>.frE r� r )
r� r
r r r r r� r rM r r� r r� r �test_waitfor_timeoutE s
z#ConditionTests.test_waitfor_timeoutN) r# r$ r% r& r� r� r� r� r� r` r� r� r r r r r� � s Jr� c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dS )�BaseSemaphoreTestszB
Common tests for {bounded, unbounded} semaphore objects.
c C s, | j t| jdd� | j t| jtj d� d S )NrE )Zvaluei����)rT r_ �semtype�sysZmaxsizer r r r r1 b r z#BaseSemaphoreTests.test_constructorc C sH | j d�}|j� |j� | j d�}|j� |j� |j� |j� d S )NrE rh )r� r7 r= �r �semr r r r� f s
z BaseSemaphoreTests.test_acquirec C r9 r )r� r7 r� r r r r: p r; z'BaseSemaphoreTests.test_acquire_destroyc s� | j d���j� d}g �g �g �d� � ����fdd�}t|d�}|j� x t��t�� dk rjt� qNW | j�� dgd � d� xtd�D ] }�j� q�W x t��t�� dk r�t� q�W | jt �� �dgd dgd � d � xtd�D ] }�j� q�W x"t��t�� d
k �r$t� �qW | jt �� �dgd dgd d gd � | j
�jd �� �j� |j � | j�d gd � d S )N� �
r c s4 �j �j� � �j � � �j �j� � �j � � d S r rB r �r� r r� r� Z sem_resultsr r r } s
z4BaseSemaphoreTests.test_acquire_contended.<locals>.fi rE �
rh � FTr� r� i ) r� r7 r
r r r rM r r= �sortedrF r )r rO r rP r r r� r rQ u s:
$ .z)BaseSemaphoreTests.test_acquire_contendedc C sV | j d�}| j|jd�� | j|jd�� | j|jd�� |j� | j|jd�� d S )Nrh F)r� r@ r7 rF r= r� r r r rA � s
z#BaseSemaphoreTests.test_try_acquirec sV | j d���j� g � � �fdd�}t|d�j� | jt� �dgd dgd � d S ) Nr� c s$ � j �jd�� � j �jd�� d S r? rB r �r^ r� r r r � s z8BaseSemaphoreTests.test_try_acquire_contended.<locals>.frI Fr� Tr� )r� r7 r
r rM r� rG r r� r rH � s
z-BaseSemaphoreTests.test_try_acquire_contendedc C s� | j d�}| jt|jddd� | j|jdd�� | j|jdd�� | j|jdd�� |j� | j|jdd�� tj� }| j|jdd�� tj� | }| j|d� d S )Nrh F� �?rX g{�G�zt?rZ ) r� rT r_ r7 r@ rF r= r r, )r r� Ztr� r r r �test_acquire_timeout� s
z'BaseSemaphoreTests.test_acquire_timeoutc sT | j � � � j� � fdd�}t|d�}|j� t� | j|j� � j� |j� d S )Nc rJ r rK r �r� r r r � r2 z0BaseSemaphoreTests.test_default_value.<locals>.frE ) r� r7 r
r r rF r r= r rk r r� r �test_default_value� s
z%BaseSemaphoreTests.test_default_valuec sb � j d��d� �fdd� }|� � j�jd�� �j� � jt|t� � j�jd�� �j� d S )Nrh c sT ��F � j �jd�� �j� �� � j�jd�� | r<| �W d Q R X W d Q R X d S r? )r@ r7 r= rF rR r� r r rS � s z+BaseSemaphoreTests.test_with.<locals>._withFr )r� r@ r7 r= rT rU )r rS r r� r rV � s
z BaseSemaphoreTests.test_withN)
r# r$ r% r& r1 r� r: rQ rA rH r� r� rV r r r r r� ] s
%
r� c @ � e Zd ZdZdd� ZdS )�SemaphoreTestsz)
Tests for unbounded semaphores.
c C s. | j d�}|j� |j� |j� |j� d S �NrE )r� r= r7 r� r r r rp � s
z&SemaphoreTests.test_release_unacquiredN�r# r$ r% r& rp r r r r r� � � r� c @ r� )�BoundedSemaphoreTestsz'
Tests for bounded semaphores.
c C s8 | j � }| jt|j� |j� |j� | jt|j� d S r )r� rT r_ r= r7 r� r r r rp � s
z-BoundedSemaphoreTests.test_release_unacquiredNr� r r r r r� � r� r� c @ s� e Zd ZdZdZdZdd� Zdd� Zdd � Zd
d � Z d"d
d�Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!S )#� BarrierTestsz$
Tests for Barrier objects.
rI g @c C s | j | j| jd�| _d S )NrX )� barriertyperO �defaultTimeout�barrierr r r r r) � r" zBarrierTests.setUpc C s | j j� d S r )r� �abortr r r r r* r" zBarrierTests.tearDownc C s" t || jd �}|� |j� d S r� )r
rO r rk r r r � run_threads s zBarrierTests.run_threadsc C s� | j j}| j|| j� xtt|�D ]h}|d jd� | jt|d �|| � | j j� |d jd� | jt|d �|d | � | j j� q W | j| j jd� | j | j j
� d S )Nr TrE ) r� ZpartiesrM rO r r r r} � n_waitingrF �broken)r r^ r Zmr r r r � multipass s
zBarrierTests.multipassrE c s& g g g�� ��fdd�}�j |� dS )z;
Test that a barrier is passed in lockstep
c s �j �� � d S r )r� r ��passesr^ r r r r r" z$BarrierTests.test_barrier.<locals>.fN�r� )r r� r r r� r � test_barrier s zBarrierTests.test_barrierc C s
| j d�S )zC
Test that a barrier works for 10 consecutive runs
r� )r� r r r r �test_barrier_10 s z BarrierTests.test_barrier_10c s: g � � �fdd�}�j |� �jt� �tt�j��� dS )z9
test the return value from barrier.wait
c s �j j� } � j| � d S r )r� r} r )r� �r^ r r r r ) s
z(BarrierTests.test_wait_return.<locals>.fN)r� rM Zsumr rO rG r r� r �test_wait_return$ s
z BarrierTests.test_wait_returnc s< g ��fdd�}�j �j|�� � ��fdd�}�j|� dS )z,
Test the 'action' callback
c s � j d� d S r )r r )r^ r r �action5 r" z(BarrierTests.test_action.<locals>.actionc s � j � �jt��d� d S r� )r} rM r r �r� r^ r r r r 8 r2 z#BarrierTests.test_action.<locals>.fN�r� rO r� )r r� r r r� r � test_action0 s
zBarrierTests.test_actionc sZ g � g �� ��fdd�}�j |� �jt� �d� �jt���jd � �j�jj� dS )zK
Test that an abort will put the barrier in a broken state
c sv y4�j j� } | �jd kr t��j j� � jd� W n< tjk
rT �jd� Y n tk
rp �j j� Y nX d S �Nrh T)r� r} rO ro r r �BrokenBarrierErrorr� �r �r r� r r r r D s
z"BarrierTests.test_abort.<locals>.fr rE N)r� rM r rO r@ r� r� rG r r� r �
test_abort> s
zBarrierTests.test_abortc sd g � g �g �� ���fdd�}�j |� �jt� �d� �jt���jd � �jt���j� dS )zL
Test that a 'reset' on a barrier frees the waiting threads
c s� �j j� } | �jd krFx �j j�jd k r8tjd� qW �j j� n:y�j j� � jd� W n tj k
r~ �jd� Y nX �j j� �jd� d S )Nrh rE g����MbP?T)
r� r} rO r� r r �resetr r r� r� �r r� �results3r r r r ] s
z"BarrierTests.test_reset.<locals>.fr rE N)r� rM r rO rG r r� r �
test_resetV s
zBarrierTests.test_resetc sr g �g �g ��j �j�� � ����fdd�}�j|� �jt��d� �jt���jd � �jt���j� dS )zF
Test that a barrier can be reset after being broken.
c s� y4�j j� } | �jd kr t��j j� �jd� W n< tjk
rT �jd� Y n tk
rp �j j� Y nX � j� �jd kr��j j� � j� �j j� �jd� d S r� ) r� r} rO ro r r r� r� r� r� �Zbarrier2r r� r� r r r r | s
z,BarrierTests.test_abort_and_reset.<locals>.fr rE N)r� rO r� rM r rG r r� r �test_abort_and_resett s
z!BarrierTests.test_abort_and_resetc s � fdd�}� j |� dS )z$
Test wait(timeout)
c s: � j j� } | � jd kr"tjd� � jtj� j jd� d S )Nrh r� rZ )r� r} rO r r rT r r� r� r r r r � s
z$BarrierTests.test_timeout.<locals>.fNr� rG r r r r` � s zBarrierTests.test_timeoutc s, �j �jdd�� � �fdd�}�j|� dS )z4
Test the barrier's default timeout
g333333�?rX c s4 � j � } | �jd kr tjd� �jtj� j � d S )Nrh r� )r} rO r r rT r r� r� �r� r r r r � s
z,BarrierTests.test_default_timeout.<locals>.fNr� rG r r� r �test_default_timeout� s z!BarrierTests.test_default_timeoutc C s | j d�}|j� |j� d S r� )r� r} )r rP r r r �test_single_thread� s
z BarrierTests.test_single_threadN)rE )r# r$ r% r& rO r� r) r* r� r� r� r� r� r� r� r� r� r` r� r� r r r r r� � s"
"r� )r& r� r Z_threadr r r Zunittestra Ztestr r Zobjectr
ZTestCaser' r- rf rn ru r� r� r� r� r� r r r r Z<module> s* 1 1C^ 0~