U
|
¸ý°ds ã @ sô d dl mZ d dl mZ d dl mZ d dlZd dlZd dlZd dlZd dlm Z m
|
Z
|
d dl m Z ddl m Z dd lmZ G d
|
d d eZd d Zdd ZG dd de ZG dd de ZG dd de ZG dd de Zedkrðd dlZe ¡ dS )é )Úabsolute_import)Údivision)Úprint_functionN)ÚABCMetaÚabstractmethod)Úgreenleté )ÚTestCase)Úfails_leakcheckc @ s e Zd ZdS )Ú SomeErrorN©Ú__name__Ú
|
__module__Ú __qualname__© r r úSd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\greenlet/tests/test_greenlet.pyr s r c C s< zt ¡ j ¡ W n | t ¡ d ¡ Y nX td S ©Nr )r Ú
|
getcurrentÚparentÚswitchÚappendÚsysÚexc_infor ©Úseenr r r Úfmain s r c C s" dd }t || d}| |¡ d S )Nc S s | d S ©Nr )Úexcr r r Úcrasher% s z send_exception.<locals>.crasher©r ©r r )Úgr r Úg1r r r Úsend_exception" s r# c @ sb e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dd Z
|
dd Z dd Z dd Z dd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd1d2 Zd3d4 Z e dUd6d7Z e d8d9 Z d:d; Z e d<d= Z!d>d? Z"d@dA Z#dBdC Z$dDdE Z%dFdG Z&dHdI Z'dJdK Z(dLdM Z)dNdO Z*dPdQ Z+dRdS Z,dTS )VÚ TestGreenletc s^ g fdd}t |} d¡ | ¡ d¡ | ¡ d¡ | ttd¡ d S )Nc s& d¡ t ¡ j ¡ d¡ d S )Nr é ©r r r r r r ©Úlstr r Úf0 s
|
z'TestGreenlet._do_simple_test.<locals>.fr é é é )r r r Ú assertEqualÚlistÚrange)Úselfr) r! r r' r Ú_do_simple_test- s
|
|
|
z TestGreenlet._do_simple_testc C s | ¡ d S r )r1 ©r0 r r r Ú test_simple< s zTestGreenlet.test_simplec C s: t }| t¡}| ¡ W 5 Q R X | dt|j¡ d S ©NÚrun)r Ú assertRaisesÚAttributeErrorr ÚassertInÚstrÚ exception©r0 r! r r r r Ú(test_switch_no_run_raises_AttributeError? s z5TestGreenlet.test_switch_no_run_raises_AttributeErrorc C s< t }| t¡}| t¡ W 5 Q R X | dt|j¡ d S r4 )r r6 r7 Úthrowr r8 r9 r: r; r r r Ú'test_throw_no_run_raises_AttributeErrorF s z4TestGreenlet.test_throw_no_run_raises_AttributeErrorc C s* t d d}| |¡ | |jt ¡ ¡ d S )Nr )r ÚassertIsNotNoneÚassertIsr r ©r0 r! r r r Útest_parent_equals_NoneM s
|
|
z$TestGreenlet.test_parent_equals_Nonec C s$ t d d}| |¡ | |j¡ d S )N)r5 )r r? Ú assertIsNoner5 rA r r r Útest_run_equals_NoneR s
|
|
z!TestGreenlet.test_run_equals_Nonec s g fdd}t |}t |}| ¡ | t d¡ | ¡ | t d¡ | ¡ | t d¡ | |jd¡ | ¡ | t d¡ | |jd¡ d S )Nc s* d¡ t ¡ j ¡ ddg¡ d S )Nr )r r r r r Úextendr r' r r r) Z s
|
z)TestGreenlet.test_two_children.<locals>.fr r* r+ Té )r r r- ÚlenÚdead)r0 r) r! Úhr r' r Útest_two_childrenW s z TestGreenlet.test_two_childrenc sh g fdd fdd}t |}| t |¡d¡ | ¡ | dddg¡ | t |¡d¡ d S ) Nc s d¡ t ¡ j ¡ d S )NÚbr& r r' r r r) n s
|
z3TestGreenlet.test_two_recursive_children.<locals>.fc s( d¡ t } | ¡ d¡ d S )NÚaÚc)r r r ©r! ©r) r( r r r! r s
|
z3TestGreenlet.test_two_recursive_children.<locals>.gr* rL rK rM )r r- r Ú getrefcountr rA r rO r Útest_two_recursive_childrenk s z(TestGreenlet.test_two_recursive_childrenc sf g fdd fddt dD }|D ] }| ¡ q,|D ]}| d¡ q> tt|¡ d S )Nc s ¡ d¡ d S ©NT)r1 r r )r0 Úsuccessr r r) s z$TestGreenlet.test_threads.<locals>.fc s g | ]}t j d qS )©Útarget)Ú threadingÚThread)Ú.0Úi©r) r r Ú
|
<listcomp>
s z-TestGreenlet.test_threads.<locals>.<listcomp>é
|
)r/ ÚstartÚjoinr- rG )r0 ZthsÚthr )r) r0 rS r Ú test_threads s
|
zTestGreenlet.test_threadsc C s g }t t}t t}| |¡ | |¡ ||_| |g ¡ | t|j¡ | |tg¡ | ¡ }| |d¡ | |tg¡ | d¡}| |d¡ | |tg¡ d S )Nr é )r r r r r- r6 r )r0 r r" Úg2Úvaluer r r Útest_exception s
|
|
|
zTestGreenlet.test_exceptionc C s8 g }t t}| |¡ | tt|t¡ | |tg¡ d S r )r r r r6 ÚKeyErrorr# r- )r0 r r" r r r Útest_send_exception¨ s
|
|
z TestGreenlet.test_send_exceptionc C sp g }t t}t t}| |¡ | |¡ | |g ¡ ~t ¡ | |t jg¡ ~t ¡ | |t jt jg¡ d S r )r r r r- ÚgcÚcollectÚ GreenletExit)r0 r r" rb r r r Ú test_dealloc¯ s
|
|
zTestGreenlet.test_deallocc C s dd }t |}| ¡ tj}zddlm} W n tk
|
rN ddlm} Y nX | }t_z~W 5 |t_X | ¡ }| d|¡ | d|¡ | d|¡ d S )Nc S s2 zt ¡ j ¡ W n t jk
|
r, tY nX d S r )r r r r ri r r r r r r5 ¾ s zHTestGreenlet.test_dealloc_catches_GreenletExit_throws_other.<locals>.runr )ÚStringIOÚ ExceptionZignoredr )
|
r r r ÚstderrÚ cStringIOrk Ú ImportErrorÚioÚgetvaluer8 )r0 r5 r! Z oldstderrrk rm Úvr r r Ú.test_dealloc_catches_GreenletExit_throws_other½ s z;TestGreenlet.test_dealloc_catches_GreenletExit_throws_otherc sê g g t ¡ t ¡ t ¡ t ¡ fdd}t j|d}| ¡ d¡ | g ¡ | td¡ d d
= t ¡ | g ¡ ¡ d¡ z| t j g¡ W 5 ¡ |
|
d¡ d d
= d d
= X d S )Nc sZ t t} | ¡ | ¡ ~ t ¡ ¡ d¡ t ¡ d¡ t d S )Nr% )r r r r rg rh ÚsetÚwait)r" ©Z/bg_glet_created_running_and_no_longer_ref_in_bgZbg_should_be_clearZfg_ref_releasedZok_to_exit_bg_threadr Zsomerefr r r) ä s
|
|
|
|
z1TestGreenlet.test_dealloc_other_thread.<locals>.frT r\ r r% ) rV ÚEventrW r] ru r- rG rg rh rt r^ r ri )r0 r) Útr rv r Útest_dealloc_other_threadÛ s.
|
|
|
|
|
z&TestGreenlet.test_dealloc_other_threadc sf fdd}t |}| ¡ } ||jk¡ |¡ | ¡ } |¡ |d¡ |jd ¡ d S )Nc s, t d¡} | jd ¡ t ¡ j | ¡ dS )Nr úmeaning of life)r Ú _getframer- Úf_backr r r r rZ r2 r r Úf1 s
|
z#TestGreenlet.test_frame.<locals>.f1rz )r r Ú
|
assertTrueÚgr_frameÚ assertFalser- )r0 r} r! ÚframeZfrom_gr r2 r Ú
|
test_frame s
|
|
zTestGreenlet.test_framec C sL dd }t j|dd}t j|dd}| ¡ | ¡ | d¡ | d¡ d S )Nc s t fdd}| ¡ d S )Nc s
|
t ¡S r )ÚtimeÚsleepr ©Úxr r Ú<lambda> ó z>TestGreenlet.test_thread_bug.<locals>.runner.<locals>.<lambda>r )r r! r r
r Úrunner s z,TestGreenlet.test_thread_bug.<locals>.runner)gÉ?©rU Úargs)g333333Ó?r\ )rV rW r] r^ )r0 r Út1Út2r r r Útest_thread_bug s
|
z TestGreenlet.test_thread_bugc s. fdd}t |jddd} |d¡ d S )Nc s | d¡ |d¡ dS )Nr+ r* é* )r- ©rL rK r2 r r r5 # s z,TestGreenlet.test_switch_kwargs.<locals>.runr+ r* r r ©r r r- )r0 r5 r r r2 r Útest_switch_kwargs" s z TestGreenlet.test_switch_kwargsc C sR dd }t |}| ddi| d¡¡ | dddif| ¡ ¡ | d| ¡ ¡ d S )Nc S s2 t ¡ jj| d t ¡ jjddd | | d fS )Nr
r* r% ©r r r r r
r r r r5 + s z6TestGreenlet.test_switch_kwargs_to_parent.<locals>.runr r% )r* )r% é )r r- r )r0 r5 r! r r r Ú test_switch_kwargs_to_parent* s
|
z)TestGreenlet.test_switch_kwargs_to_parentc s i t ¡ t ¡ fdd}t j|d}| ¡ d¡ | tj¡ d ¡ W 5 Q R X ¡ |
|
d¡ ¡ d S )Nc s& t dd d< ¡ d¡ d S )Nc S s d S r r r r r r r : r zITestGreenlet.test_switch_to_another_thread.<locals>.run.<locals>.<lambda>r! r\ ©r rt ru r ©Z created_eventÚdataÚ
|
done_eventr r r5 9 s z7TestGreenlet.test_switch_to_another_thread.<locals>.runrT r\ r! ) rV rw rW r] ru r6 r Úerrorr rt r^ Úclear)r0 r5 Úthreadr r r Ú test_switch_to_another_thread4 s
|
|
z*TestGreenlet.test_switch_to_another_threadc s* fdd}fdd t | ¡ d S )Nc sB z t dW n0 t ¡ } t ¡ | t ¡ ¡ Y nX d S )NZfun)Ú
|
ValueErrorr r r r r- )r ©rI r0 r r r) H s z&TestGreenlet.test_exc_state.<locals>.fc s t ¡ d¡ d S )N)NNN)r- r r r r2 r r rI P s z&TestGreenlet.test_exc_state.<locals>.hr )r0 r) r r r Útest_exc_stateG s zTestGreenlet.test_exc_statec C s dd }dd }dd }t |}| |ji ¡ | ¡ | |jd¡ | |jddi¡ |j|_| |jddi¡ | t||¡ | t||d¡ d S ) Nc S s dt ¡ _d S ©Nr )r r Útestr r r r r) V s z*TestGreenlet.test_instance_dict.<locals>.fc S s | ` d S r ©Ú__dict__rN r r r ÚdeldictX s z0TestGreenlet.test_instance_dict.<locals>.deldictc S s
|
|| _ d S r r£ )r! rc r r r ÚsetdictZ s z0TestGreenlet.test_instance_dict.<locals>.setdictr r¢ )r r- r¤ r r¢ r6 Ú TypeError)r0 r) r¥ r¦ r! r r r Útest_instance_dictU s z TestGreenlet.test_instance_dictc s2 g fdd}t |}| ¡ | dg¡ d S )Nc s tt ¡ d¡ d S r4 )r Úhasattrr r r ©Zhas_runr r Úfunch s ÿz;TestGreenlet.test_running_greenlet_has_no_run.<locals>.funcFr )r0 r« r! r rª r Ú test_running_greenlet_has_no_runf s
|
z-TestGreenlet.test_running_greenlet_has_no_runc C s0 dd l }| t|j t ¡ | t|jt ¡ d S r )Úcopyr6 r§ r Údeepcopy)r0 r r r r Ú test_deepcopyq s zTestGreenlet.test_deepcopyc s t dd t ¡ g fdd}t | d}| ¡ ~| ¡ | d ¡ | d j ¡ d d
= d d d S )Nc S s d S r r r r r r r w r z;TestGreenlet.test_parent_restored_on_kill.<locals>.<lambda>c sN z ¡ W n< tjk
|
rH t ¡ j¡ t ¡ ¡ ¡ Y nX d S r )r r ri r r r r ©ZhubÚmainÚresultr r Úworkerz s z9TestGreenlet.test_parent_restored_on_kill.<locals>.workerr r r )r r r r~ r@ r )r0 r³ r! r r° r Ú test_parent_restored_on_killv s
|
|
z)TestGreenlet.test_parent_restored_on_killc C s8 t }t dd |d}| t¡ | ¡ W 5 Q R X d S )Nc S s d S r r r r r r r r z9TestGreenlet.test_parent_return_failure.<locals>.<lambda>r )r r6 r7 r )r0 r" rb r r r Útest_parent_return_failure s z'TestGreenlet.test_parent_return_failurec C s2 G dd dt }|dd }| t|jt ¡ d S )Nc @ s e Zd Zdd ZdS )z>TestGreenlet.test_throw_exception_not_lost.<locals>.mygreenletc S s$ z
|
t W n Y nX t | |¡S r )rl r Ú__getattribute__©r0 Únamer r r r¶ s
|
|
zOTestGreenlet.test_throw_exception_not_lost.<locals>.mygreenlet.__getattribute__N©r r r r¶ r r r r Ú
|
mygreenlet s rº c S s d S r r r r r r r ¢ r z<TestGreenlet.test_throw_exception_not_lost.<locals>.<lambda>)r r6 r r= )r0 rº r! r r r Ú test_throw_exception_not_lost s z*TestGreenlet.test_throw_exception_not_lostFc s g dd fdd}t j|d}| ¡ | d¡ ~rH| ¡ | tj¡} d t ¡ W 5 Q R X s|
|
t |j dd g¡ n| t |j d¡ t d jd
|
rÐ| t¡ d j ¡ W 5 Q R X sæ d jj ¡ n| d j¡ ~d d d
= d | _d S ) Nc S s t ¡ j ¡ d S r r r r r r r³ ¨ s zGTestGreenlet._do_test_throw_to_dead_thread_doesnt_crash.<locals>.workerc s2 t } | ¡ | ¡ r.| ¡ t ¡ d S r )r r r r rN ©r² Úwait_for_cleanupr³ r r Úcreator« s
|
zHTestGreenlet._do_test_throw_to_dead_thread_doesnt_crash.<locals>.creatorrT r\ r úBcannot switch to a different thread (which happens to have exited)ú#cannot switch to a different threadr T)rV rW r] r^ Úwait_for_pending_cleanupsr6 r r r= r r8 r9 r: r- r© r Ú RuntimeErrorr Úf_localsrC Úexpect_greenlet_leak)r0 r½ r¾ rx r r r¼ r Ú*_do_test_throw_to_dead_thread_doesnt_crash¥ s@
|
þÿþ
|
z7TestGreenlet._do_test_throw_to_dead_thread_doesnt_crashc C s | ¡ d S r ©rÅ r2 r r r Ú&test_throw_to_dead_thread_doesnt_crashÞ s z3TestGreenlet.test_throw_to_dead_thread_doesnt_crashc C s | d¡ d S rR rÆ r2 r r r Ú+test_throw_to_dead_thread_doesnt_crash_waitâ s z8TestGreenlet.test_throw_to_dead_thread_doesnt_crash_waitc C s2 G dd dt }| }| | d¡d¡ d| _d S )Nc @ s$ e Zd Zdd Zdd Zdd ZdS )z7TestGreenlet.test_recursive_startup.<locals>.convolutedc S s t | ¡ d| _d S r )r Ú__init__Úcountr2 r r r rÉ è s
|
z@TestGreenlet.test_recursive_startup.<locals>.convoluted.__init__c S s. |dkr"| j dkr"d| _ | d¡ t | |¡S )Nr5 r r é+ )rÊ r r r¶ r· r r r r¶ ë s
|
zHTestGreenlet.test_recursive_startup.<locals>.convoluted.__getattribute__c S s | j |¡ q d S r ©r r ©r0 rc r r r r5 ð s z;TestGreenlet.test_recursive_startup.<locals>.convoluted.runN)r r r rÉ r¶ r5 r r r r Ú
|
convolutedç s rÎ r rË T)r r- r rÄ )r0 rÎ r! r r r Útest_recursive_startupå s z#TestGreenlet.test_recursive_startupc sº t ¡ ¡ t ¡ ¡ G fdddt}dd } fdd}t ¡ }t|g | d _ d ¡ t j|d}| ¡
|
¡ ¡ | t ¡ |¡ | d ¡ d S )
|
Nc s e Zd Z fddZdS )z;TestGreenlet.test_threaded_updatecurrent.<locals>.finalizedc s ¡ ¡ d S r ©ÚreleaseÚacquirer2 ©Úlock1Úlock2r r Ú__del__ s zCTestGreenlet.test_threaded_updatecurrent.<locals>.finalized.__del__N©r r r rÖ r rÓ r r Ú finalized s rØ c S s t ¡ j ¡ d S r r r r r r Ú deallocator
|
s z=TestGreenlet.test_threaded_updatecurrent.<locals>.deallocatorc s: ¡ t ¡ d= ¡ ¡ t ¡ ¡ d S r ©rÒ r r rÑ r ©r! rÔ rÕ r r Úfthread s z9TestGreenlet.test_threaded_updatecurrent.<locals>.fthreadr rT r\ ) rV ÚLockrÒ Úobjectr r Zbombr rW r] rÑ r- r^ )r0 rØ rÙ rÜ r± rx r rÛ r Útest_threaded_updatecurrentû s"
|
|
z(TestGreenlet.test_threaded_updatecurrentc sb g fdddd t gd ¡ t d ¡ }| ¡ | |d¡ d S )Nc
|
sJ t ¡ j ¡ } d= t ¡ j _zt ¡ j | ¡ W 5 t ¡ ¡ X d S r )r r r r r )rc ©Ú initiatorr r³ r r r³ , s z>TestGreenlet.test_dealloc_switch_args_not_lost.<locals>.workerc S s dS r¡ r r r r r rá 9 s zATestGreenlet.test_dealloc_switch_args_not_lost.<locals>.initiatorr r )r r r~ r- rÍ r rà r Ú!test_dealloc_switch_args_not_lost* s
|
|
z.TestGreenlet.test_dealloc_switch_args_not_lostc sh t jd dkrdd nt G dd dt}| tdd fd d
|
}t|}| | ¡ ¡ d S ) Nr r* c S s | || d S r r )r« rL Úkr r r Ú_applyU s z0TestGreenlet.test_tuple_subclass.<locals>._applyc @ s e Zd Zdd ZdS )z1TestGreenlet.test_tuple_subclass.<locals>.mytuplec S s t ¡ ¡ t | ¡S r )r r r ÚtupleÚ__len__r2 r r r ræ [ s z9TestGreenlet.test_tuple_subclass.<locals>.mytuple.__len__N)r r r ræ r r r r ÚmytupleZ s rç r )rL c s t ¡ jj d S r r r ©rä r Úkwargsr r Ú switchapply` s z5TestGreenlet.test_tuple_subclass.<locals>.switchapply)r Ú version_infoÚapplyrå Údictr r- r )r0 rç rê r! r rè r Útest_tuple_subclassD s
|
|
z TestGreenlet.test_tuple_subclassc C sP t dtfdtdd i}G dd d|}G dd d|}| | t|¡ d S ) NÚAbstractSubclassr5 c S s d S r r r2 r r r r i r z7TestGreenlet.test_abstract_subclasses.<locals>.<lambda>c @ s e Zd ZdS )z:TestGreenlet.test_abstract_subclasses.<locals>.BadSubclassNr r r r r Ú BadSubclassk s rð c @ s e Zd Zdd ZdS )z;TestGreenlet.test_abstract_subclasses.<locals>.GoodSubclassc S s d S r r r2 r r r r5 o s z?TestGreenlet.test_abstract_subclasses.<locals>.GoodSubclass.runN)r r r r5 r r r r Ú GoodSubclassn s rñ )r r r r6 r§ )r0 rï rð rñ r r r Útest_abstract_subclassese s ýz%TestGreenlet.test_abstract_subclassesc sN t ¡ s d S t ¡ d dk r$d S fdd}tdD ]}| r: qJq:d S )Nr é2 c s t ¡ ¡ t ¡ ¡ dgfdd} t j| d}| ¡ G fdddt G fdddt}g }td }t ¡ }| }|D ]<}d }d
|
r¶| d ¡ dS t }d
|
rÈ qò|
|
|¡ qt ¡ d
|
rî| d ¡ dS |j|¡ |D ]} |j|¡ qd S ) NFc s ¡ t ¡ ¡ d S r rÚ r rÓ r r Úanother_thread s zWTestGreenlet.test_implicit_parent_with_threads.<locals>.attempt.<locals>.another_threadrT c s e Zd Z fddZdS )zTTestGreenlet.test_implicit_parent_with_threads.<locals>.attempt.<locals>.gc_callbackc s ¡ ¡ dd< d S )NTr rÐ r2 ©rÔ rÕ Úrecycledr r rÖ s z\TestGreenlet.test_implicit_parent_with_threads.<locals>.attempt.<locals>.gc_callback.__del__Nr× r rõ r r Ú gc_callback s r÷ c s e Zd Z fddZdS )zPTestGreenlet.test_implicit_parent_with_threads.<locals>.attempt.<locals>.garbagec s | | _ | _d S r )ÚcycleÚcallbackr2 ©r÷ r r rÉ s zYTestGreenlet.test_implicit_parent_with_threads.<locals>.attempt.<locals>.garbage.__init__N)r r r rÉ r rú r r Úgarbage s rû r* r r\ T)rV rÝ rÒ rW r] rÞ r/ r r r^ r rg rh r- r ) rô rx rû Úlr Úcurrentr! Ú_Úlast©ÚNr0 )r÷ rÔ rÕ rö r Úattempt{ s>
|
|
z?TestGreenlet.test_implicit_parent_with_threads.<locals>.attemptr, )rg Ú isenabledZ get_thresholdr/ )r0 r rþ r r r Ú!test_implicit_parent_with_threadsu s - z.TestGreenlet.test_implicit_parent_with_threadsc s| ddl m ddl m G dd dt }t |¡}g _ fdd}tdD ]}|| ¡ qP` t |¡|¡ d S ) Nr ©r )ri c @ s e Zd ZdS )zTTestGreenlet.test_issue_245_reference_counting_subclass_no_threads.<locals>.GreenletNr r r r r ÚGreenletµ s r c s8 z j ¡ W n" k
|
r2 j ¡ Y nX d S r )r r Úgletsr r ©ri r r0 r r Ú greenlet_main¾ s zYTestGreenlet.test_issue_245_reference_counting_subclass_no_threads.<locals>.greenlet_mainr\ ) r r ri r rP r r/ r r- )r0 r Ú initial_refsr rþ r r r Ú5test_issue_245_reference_counting_subclass_no_threads¬ s
|
zBTestGreenlet.test_issue_245_reference_counting_subclass_no_threadsc
|
sè ddl m} ddl m} ddlm G dd dt g | fdd fd d
|
}t ¡}g }t|d D ]*}| }|||fd }| |¡ | ¡ qx|D ]} |
|
d ¡ q¨d d
= ¡ | ¡ | t ¡|¡ d S )Nr )rW )rw r c @ s e Zd ZdS )zSTestGreenlet.test_issue_245_reference_counting_subclass_threads.<locals>.MyGreenletNr r r r r Ú
|
MyGreenletÒ s r c s j ¡ d S r rÌ r r r r r Ø s zVTestGreenlet.test_issue_245_reference_counting_subclass_threads.<locals>.greenlet_mainc s8 } |¡ | ¡ ~| ¡ d¡ d S )Nr\ )r r rt ru )Zgreenlet_running_eventZmine©r r r r Z ref_clearedr r Ú thread_mainÛ s
|
|
zTTestGreenlet.test_issue_245_reference_counting_subclass_threads.<locals>.thread_mainé- r r\ )rV rW rw r r r rP r/ r r] ru rt rÁ r- )
|
r0 rW rw r r
|
Zthread_ready_eventsrþ Úeventr r r r r Ú2test_issue_245_reference_counting_subclass_threadsË s.
|
ÿ
|
|
|
z?TestGreenlet.test_issue_245_reference_counting_subclass_threadsc C sD dd }t |}dd }t ||}| t¡ | ¡ W 5 Q R X d S )Nc S s dS )Né r r r r r Úno_args s z\TestGreenlet.test_falling_off_end_switches_to_unstarted_parent_raises_error.<locals>.no_argsc S s dS r¡ r r r r r Úleaf s zYTestGreenlet.test_falling_off_end_switches_to_unstarted_parent_raises_error.<locals>.leaf)r r6 r§ r )r0 r Úparent_never_startedr Úchildr r r Ú>test_falling_off_end_switches_to_unstarted_parent_raises_error s
|
zKTestGreenlet.test_falling_off_end_switches_to_unstarted_parent_raises_errorc C s: dd }t |}dd }t ||}| ¡ }| |d¡ d S )Nc S s | dfS ©Né r r
r r r Úone_arg s zUTestGreenlet.test_falling_off_end_switches_to_unstarted_parent_works.<locals>.one_argc S s dS r¡ r r r r r r # s zRTestGreenlet.test_falling_off_end_switches_to_unstarted_parent_works.<locals>.leaf)r r r )r0 r r r r r² r r r Ú7test_falling_off_end_switches_to_unstarted_parent_works s
|
zDTestGreenlet.test_falling_off_end_switches_to_unstarted_parent_worksc s G dd dt }| }g t fdd|}| t¡ | ¡ W 5 Q R X | dg¡ | t¡ | ¡ W 5 Q R X | dg¡ d S )Nc @ s e Zd Zdd ZdS )zXTestGreenlet.test_switch_to_dead_greenlet_with_unstarted_perverse_parent.<locals>.Parentc S s |dkr t d S r4 )r r· r r r r¶ - s ziTestGreenlet.test_switch_to_dead_greenlet_with_unstarted_perverse_parent.<locals>.Parent.__getattribute__Nr¹ r r r r ÚParent, s r c s
|
d¡S r¡ ©r r r r r r 4 r zZTestGreenlet.test_switch_to_dead_greenlet_with_unstarted_perverse_parent.<locals>.<lambda>r )r r6 r r r- )r0 r r r r r r Ú;test_switch_to_dead_greenlet_with_unstarted_perverse_parent+ s zHTestGreenlet.test_switch_to_dead_greenlet_with_unstarted_perverse_parentc sf g t fdd}t fdd}| ¡ | dg¡ ||_| ¡ }| |¡ | ddg¡ d S )Nc s
|
d¡S r r r r r r r B r zDTestGreenlet.test_switch_to_dead_greenlet_reparent.<locals>.<lambda>c s
|
d¡S r¡ r r r r r r C r r r )r r r- r rC )r0 r r r² r r r Ú%test_switch_to_dead_greenlet_reparent@ s
|
z2TestGreenlet.test_switch_to_dead_greenlet_reparentN)F)-r r r r1 r3 r< r> rB rD rJ rQ r` rd rf rj rs ry r r r r r r r¨ r¬ r¯ r´ rµ r» r
|
rÅ rÇ rÈ rÏ rß râ rî rò r r r r r r r r r r r r$ + sX ,
|
8
|
|
/!7 Cr$ c @ s\ e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dd Z
|
dd Z dd Z dS )ÚTestGreenletSetParentErrorsc s¢ i t ¡ t ¡ fdd}dd }t j|d}| ¡ d¡ t|}| ¡ | t¡}d |_ W 5 Q R X
|
¡ | d¡ | t |jd¡ d S ) Nc s& t dd d< ¡ d¡ d S )Nc S s d S r r r r r r r V r zQTestGreenletSetParentErrors.test_threaded_reparent.<locals>.run.<locals>.<lambda>r! r\ r r r r r r5 U s z?TestGreenletSetParentErrors.test_threaded_reparent.<locals>.runc S s t ¡ j ¡ d S r r r r r r ÚblankZ s zATestGreenletSetParentErrors.test_threaded_reparent.<locals>.blankrT r\ r! z&parent cannot be on a different thread)rV rw rW r] ru r r r6 r r rt r^ r- r9 r: )r0 r5 r! r r! r r r r Útest_threaded_reparentP s
|
|
z2TestGreenletSetParentErrors.test_threaded_reparentc s g fdd}t j|d}| ¡ | d¡ | j| jd d G fdddt}|d d
|
}| tj¡}| ¡ W 5 Q R X |
|
t |j d ¡ d d
= d S ) Nc s" t dd } | ¡ | ¡ d S )Nc S s d S r r r r r r r l r zYTestGreenletSetParentErrors.test_unexpected_reparenting.<locals>.worker.<locals>.<lambda>)r r r rN ©Úanotherr r r³ k s
|
zGTestGreenletSetParentErrors.test_unexpected_reparenting.<locals>.workerrT r\ r )Zinitial_main_greenletsc s e Zd Z fddZdS )zKTestGreenletSetParentErrors.test_unexpected_reparenting.<locals>.convolutedc s |dkr d | _ t | |¡S ©Nr5 r ©r r r¶ r· r# r r r¶ s
|
z\TestGreenletSetParentErrors.test_unexpected_reparenting.<locals>.convoluted.__getattribute__Nr¹ r r# r r rÎ s rÎ c S s d S r r r r r r r r zITestGreenletSetParentErrors.test_unexpected_reparenting.<locals>.<lambda>r¿ ) rV rW r] r^ rÁ Zmain_greenlets_before_testr r6 r r r- r9 r: )r0 r³ rx rÎ r! r r r# r Útest_unexpected_reparentingi s
|
ÿz7TestGreenletSetParentErrors.test_unexpected_reparentingc s¼ g t ¡ t ¡ fdd}G fdddt}t j|d}| ¡ d¡ zB|dd }| tj ¡}|
|
¡ W 5 Q R X | t |j d ¡ W 5 ¡ | d¡ d d
= X d S )
|
Nc s4 t dd } | ¡ | ¡ ¡ d¡ d S )Nc S s d S r r r r r r r r zhTestGreenletSetParentErrors.test_unexpected_reparenting_thread_running.<locals>.worker.<locals>.<lambda>r\ )r r r rt ru rN ©r$ Zkeep_main_aliveZswitched_to_greenletr r r³ s
|
|
zVTestGreenletSetParentErrors.test_unexpected_reparenting_thread_running.<locals>.workerc s e Zd Z fddZdS )zZTestGreenletSetParentErrors.test_unexpected_reparenting_thread_running.<locals>.convolutedc s |dkr d | _ t | |¡S r% r& r· r# r r r¶ s
|
zkTestGreenletSetParentErrors.test_unexpected_reparenting_thread_running.<locals>.convoluted.__getattribute__Nr¹ r r# r r rÎ s rÎ rT r\ c S s d S r r r r r r r © r zXTestGreenletSetParentErrors.test_unexpected_reparenting_thread_running.<locals>.<lambda>rÀ )rV rw r rW r] ru rt r^ r6 r r r- r9 r: )r0 r³ rÎ rx r! r r r( r Ú*test_unexpected_reparenting_thread_running s
|
|
zFTestGreenletSetParentErrors.test_unexpected_reparenting_thread_runningc C sN t dd }| |jt ¡ ¡ | t¡
|
}|`W 5 Q R X | t|jd¡ d S )Nc S s d S r r r r r r r µ r zGTestGreenletSetParentErrors.test_cannot_delete_parent.<locals>.<lambda>úcan't delete attribute) r r@ r r r6 r7 r- r9 r: )r0 r³ r r r r Útest_cannot_delete_parent´ s
|
z5TestGreenletSetParentErrors.test_cannot_delete_parentc C s4 | t¡}t ¡ `W 5 Q R X | t|jd¡ d S )Nr* ©r6 r7 r r r r- r9 r: ©r0 r r r r Ú!test_cannot_delete_parent_of_main¼ s z=TestGreenletSetParentErrors.test_cannot_delete_parent_of_mainc C s | t ¡ j¡ d S r )rC r r r r2 r r r Ú!test_main_greenlet_parent_is_none s z=TestGreenletSetParentErrors.test_main_greenlet_parent_is_nonec sT dd } fdd}t |} |¡ || | ¡ |¡ || | ¡ d S )Nc S s t ¡ j ¡ d S r r r r r r ÚbgÇ s zCTestGreenletSetParentErrors.test_set_parent_wrong_types.<locals>.bgc
|
sN d d dfD ]<} t¡ }|| _W 5 Q R X t|jdt|j ¡ q d S )Nr Z42z4GreenletChecker: Expected any type of greenlet, not )r6 r§ r r- r9 r: Útyper )ÚgletÚpr r2 r r ÚcheckË s þzFTestGreenletSetParentErrors.test_set_parent_wrong_types.<locals>.check)r r r r~ )r0 r0 r4 r! r r2 r Útest_set_parent_wrong_typesÆ s
|
|
|
z7TestGreenletSetParentErrors.test_set_parent_wrong_typesc C s> t dd }| t¡ }||_W 5 Q R X | t|jd¡ d S )Nc S s d S r r r r r r r ã r z@TestGreenletSetParentErrors.test_trivial_cycle.<locals>.<lambda>úcyclic parent chain)r r6 r r r- r9 r: )r0 r2 r r r r Útest_trivial_cycleâ s z.TestGreenletSetParentErrors.test_trivial_cyclec C s: | t¡}t ¡ t ¡ _W 5 Q R X | t|jd¡ d S )Nz(cannot set the parent of a main greenletr, r- r r r Útest_trivial_cycle_mainè s z3TestGreenletSetParentErrors.test_trivial_cycle_mainc C sb t dd }t dd }t dd }||_||_| t¡ }||_W 5 Q R X | t|jd¡ d S )Nc S s d S r r r r r r r ï r z?TestGreenletSetParentErrors.test_deeper_cycle.<locals>.<lambda>c S s d S r r r r r r r ð r c S s d S r r r r r r r ñ r r6 )r r r6 r r- r9 r: )r0 r" rb Zg3r r r r Útest_deeper_cycleî s z-TestGreenletSetParentErrors.test_deeper_cycleN) r r r r" r' r) r+ r. r/ r5 r7 r8 r9 r r r r r O s )" r c @ sD e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dS )ÚTestReprc C s | | |¡||f¡ d S r )r~ Úendswith)r0 ÚgotÚsuffixr r r ÚassertEndsWithü s zTestRepr.assertEndsWithc C s t t ¡ }| |d¡ d S )Nú current active started main>)Úreprr r r> ©r0 Úrr r r Útest_main_while_runningÿ s z TestRepr.test_main_while_runningc s4 t ¡ fdd}t |}| ¡ }| |d¡ d S )Nc s t S r )r@ r ©r± r r r5 s z-TestRepr.test_main_in_background.<locals>.runú suspended active started main>)r r r r> )r0 r5 r! rB r rD r Útest_main_in_background s
|
z TestRepr.test_main_in_backgroundc C s t t }| |d¡ d S )Nz pending>)r@ r r> rA r r r Ú test_initial s
|
zTestRepr.test_initialc s t ¡ G fdddtj}| }| ¡ | d¡ | |jd¡ | |jd¡ t dD ]}t
|
d¡ qZt dD ](}| |j j¡ t|j }| |d¡ qrd S ) Nc s$ e Zd Zd ZZdZ fddZdS )z/TestRepr.test_main_from_other_thread.<locals>.TNc s$ t | _t ¡ | _t | j| _d S r )r@ Ú original_mainr r Ú main_gletr r2 rD r r r5 s
|
|
z3TestRepr.test_main_from_other_thread.<locals>.T.run)r r r rH r rI r5 r rD r r ÚT s rJ r\ rE r? r% gü©ñÒMbP?z (thread exited) dead>)r r rV rW r] r^ r> rH r r/ r r r~ rI rH r@ )r0 rJ rx rþ rB r rD r Útest_main_from_other_thread s
|
|
z$TestRepr.test_main_from_other_threadc C sX t dd }| ¡ | t|d¡ | dt|¡ | dt|¡ | dt|¡ d S )Nc S s d S r r r r r r r 4 r z$TestRepr.test_dead.<locals>.<lambda>z dead>Z suspendedÚstartedÚactive)r r r> r@ Z assertNotInrA r r r Ú test_dead3 s zTestRepr.test_deadc C sX t dd }t dd }t ¡ }|||fD ](}| d|f t¡ | d|f t¡ q*d S )Nc S s d S r r r r r r r ? r z>TestRepr.test_formatting_produces_native_str.<locals>.<lambda>c S s d S r r r r r r r @ r z%sz%r)r r ÚassertIsInstancer9 )r0 Zg_deadZ g_not_startedZg_curr! r r r Ú#test_formatting_produces_native_str; s þþz,TestRepr.test_formatting_produces_native_strN)
|
r r r r> rC rF rG rK rN rP r r r r r: ú s #r: c @ s$ e Zd Zdd Zdd Zdd ZdS )ÚTestMainGreenletc C s4 dt t ¡ ksttt ¡ }dt |ks0t|S )Nr± )r@ r r ÚAssertionErrorr1 )r0 rx r r r Ú_check_current_is_mainS s z'TestMainGreenlet._check_current_is_mainc C s$ | ¡ }td|fi }| |¡ d S )NÚsubclass)rS r1 r? )r0 Z main_typerT r r r Ú)test_main_greenlet_type_can_be_subclassed[ s z:TestMainGreenlet.test_main_greenlet_type_can_be_subclassedc C s | ¡ | t ¡ t¡ d S r )rS rO r r r2 r r r Ú test_main_greenlet_is_greenlet` s z/TestMainGreenlet.test_main_greenlet_is_greenletN)r r r rS rU rV r r r r rQ O s rQ Ú__main__)Ú
|
__future__r r r rg r r rV Úabcr r r Ú r Z leakcheckr
|
rl r r r# r$ r r: rQ r Zunittestr± r r r r Ú<module> s6 * ,U
|
