a äze<ã@sZddlmZddlZddlZddlZddlZddlZddlmZddl Z ddl Z ddlZddlm Z ddlmZe d¡Zdd„ZdKd d „ZdLdd„Zejd d„ƒZdd„Zifdd„ZGdd„deddƒƒZejdd„ƒZGdd„deddƒƒZGdd„deddƒƒZddœd d!„Zd"d#„Zd$d%„Zd&d'„Z Gd(d)„d)ej!ƒZ"Gd*d+„d+ej!ƒZ#Gd,d-„d-ej!ƒZ$Gd.d/„d/e"ƒZ%Gd0d1„d1e"ƒZ&Gd2d3„d3e"ƒZ'Gd4d5„d5e"ƒZ(Gd6d7„d7e"ƒZ)Gd8d9„d9e"ƒZ*Gd:d;„d;e"ƒZ+Gdd?„d?e"ƒZ-Gd@dA„dAe"ƒZ.GdBdC„dCe"ƒZ/GdDdE„dEedEdFƒƒZ0e 1dG¡GdHdI„dIe"ƒƒZ2e3dJkrVe 4¡dS)Mé)Ú namedtupleN)Údedent)Úsupport)Ú script_helperZ_xxsubinterpreterscCs:t ¡\}}| dd¡}td|›d|›dƒ}|t|ƒfS)NÚ z z- import contextlib with open(zU, 'w') as spipe: with contextlib.redirect_stdout(spipe): z )ÚosÚpipeÚreplacerÚopen)ÚscriptÚrÚwZindentedÚwrapped©rú2/usr/lib/python3.9/test/test__xxsubinterpreters.pyÚ_captured_scriptsþü rcCsJt|ƒ\}}|&t |||¡| ¡WdƒS1s<0YdS©N)rÚinterpretersÚ run_stringÚread)ÚinterpZrequestÚsharedrZrpiperrrÚ_run_output"srcCsL|durtj}t ¡}||}t |¡sHt ¡|kr.run©Útargetr Údone) rrÚ threadingÚThreadÚstartr r ÚwriteÚjoin)rr r"ÚtZspiperr!rÚ_running7s(r,cKst|||ƒdSr)Ú_run_interp)ÚidÚsourcerrrrÚ run_interpVsr0cCsFt|ƒ}t ¡}||kr4t ¡|kr(t‚t||ƒnt |||¡dSr)rrÚget_mainÚget_currentrÚexecr)r.r/rZ_mainnsÚmainrrrr-Zsr-cs*eZdZedd„ƒZd‡fdd„ Z‡ZS)ÚInterpretercCs(t||ƒr|St|tƒr ||ƒSt‚dSr)Ú isinstanceÚstrÚNotImplementedError)ÚclsÚrawrrrÚfrom_rawhs zInterpreter.from_rawNcs¢t ¡}||kr6|sd}n|dkr0td |¡ƒ‚|}nX|durp|sHd}n|dkrXtdƒ‚t|tjƒsŽt |¡}n|r||dkr†d}|}nt ¡}tƒ |||¡}|S)Nr4z)name mismatch (expected "main", got "{}")rz!name mismatch (unexpected "main")) rr1Ú ValueErrorÚformatr6Ú InterpreterIDÚcreateÚsuperÚ__new__)r9Únamer.r4Úself©Ú __class__rrrAqs,ÿzInterpreter.__new__)NN)Ú__name__Ú __module__Ú__qualname__Úclassmethodr;rAÚ __classcell__rrrDrr5fs r5zname idccs$z dVWntjyYn0dSr)rÚChannelClosedErrorrrrrÚexpect_channel_closedŒs rLcs6eZdZd ‡fdd„ Zdd„Zdd„Zdd „Z‡ZS)Ú ChannelActionNcs&|sd}|sd}tƒ ||||¡}|S)NÚbothr4©r@rA)r9ÚactionÚendrrCrDrrrA˜szChannelAction.__new__cOsb|jdkr |jdvrJt|jƒ‚n*|jdvr@|jdvrJt|jƒ‚n t|jƒ‚|jdvr^t|jƒ‚dS)NÚuse)ÚsameÚoppositeÚsendÚrecv©Úcloseúforce-close)rNrSrTrUrV)r4rSÚotherÚextra)rPrQr<r)rCÚargsÚkwargsrrrÚ__init__ s zChannelAction.__init__cCs2|jdkr|S|jdkr(|dkr$dSdS|jSdS)NrSrTrUrV©rQ©rCrQrrrÚresolve_end¬s zChannelAction.resolve_endcCst|jdkr|S|jdkr(|dur$t‚|S|jdkrB|dur>t‚|S|jdkrp|jdkrZ|S|rl|jdkrl|St‚dS)NrSrZr[r4)rrrB)rCrrZr[rrrÚresolve_interp´s zChannelAction.resolve_interp)NN)rFrGrHrAr^rarbrJrrrDrrM–srMzaction end interpcsBeZdZdddœ‡fdd„Zdd„Zdd „Zd dœdd „Z‡ZS)ÚChannelStaterF©Úclosedcstƒ |||¡}|SrrO)r9ÚpendingrerCrDrrrAËszChannelState.__new__cCst|ƒ|jd|jdS©Nérd©Útyperfre©rCrrrÚincrÏszChannelState.incrcCst|ƒ|jd|jdSrgrirkrrrÚdecrÒszChannelState.decrT©ÚforcecCs2|jr|r|jdkr|St|ƒ|r&dn|jddS)NrTrd)rerfrj)rCrorrrrXÕszChannelState.close)r)rFrGrHrArlrmrXrJrrrDrrcÉsrczpending closedT©Ú hideclosedcCsr|jr(|dkr"|dkr"|jr"d}q,d}nd}zt||||ƒ}Wn&tjyd|sX|sX‚| ¡}Yn 0|rnd‚|S)NrRrVFT.)rerfÚ_run_actionrrKrX)ÚcidrPrQÚstaterqZ expectfailÚresultrrrÚ run_actionÜsrvcCs|dkr‚|dkr$t |d¡| ¡S|dkrx|jsdzt |¡WntjyX|YS0tdƒ‚q€t |¡| ¡Snt|ƒ‚n~|dkr¸i}|dvržd||<tj |fi|¤Ž| ¡S|d krød di}|dvrÚd||<tj |fi|¤Ž|j ddSt|ƒ‚dS)NrRrUóspamrVzexpected ChannelEmptyErrorrX©rVrUTrYrorn)rÚchannel_sendrlrfÚchannel_recvÚChannelEmptyErrorÚ Exceptionrmr<Ú channel_closerX)rsrPrQrtr]rrrrrñs8 ÿrrc Cs>t ¡D]0}|dkrqzt |¡Wqty6Yq0qdS)Nr)rÚlist_allÚdestroyr©r.rrrÚclean_up_interpreterssrc Cs6t ¡D](}zt |¡Wqtjy.Yq0qdSr)rÚchannel_list_allÚchannel_destroyÚChannelNotFoundError©rsrrrÚclean_up_channelss r†c@seZdZdd„ZdS)ÚTestBasecCstƒtƒdSr©rr†rkrrrÚtearDown)szTestBase.tearDownN)rFrGrHr‰rrrrr‡'sr‡c@seZdZdd„Zdd„ZdS)ÚIsShareableTestsc CsPgd¢}|D]>}| |¡ | t |¡¡Wdƒq1s@0YqdS)N)NrwÚspamé iöÿÿÿ)ÚsubTestÚ assertTruerÚis_shareable)rCZ shareablesÚobjrrrÚtest_default_shareables3s ÿz(IsShareableTests.test_default_shareablesc Cs’Gdd„dƒ}Gdd„dtƒ}ddtdtttƒtƒd||d ƒ|d ƒg}|D]B}| t|ƒ¡ | t |¡¡WdƒqJ1s‚0YqJdS)Nc@seZdZdd„Zdd„ZdS)z3IsShareableTests.test_not_shareable..CheesecSs ||_dSr©rB)rCrBrrrr^Dsz.Cheese.__init__cSs|jSrr’rkrrrÚ__str__Fsz;IsShareableTests.test_not_shareable..Cheese.__str__N)rFrGrHr^r“rrrrÚCheeseCsr”c@seZdZdZdS)z5IsShareableTests.test_not_shareable..SubByteszA subclass of a shareable type.N)rFrGrHÚ__doc__rrrrÚSubBytesIsr–TF.gY@ZWensleydalerw) ÚbytesÚNotImplementedrjÚobjectr|rÚreprÚassertFalserr)rCr”r–Znot_shareablesrrrrÚtest_not_shareableBs(ñÿz#IsShareableTests.test_not_shareableN)rFrGrHr‘rœrrrrrŠ1srŠcs`eZdZ‡fdd„Z‡fdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dd„Z dd„Z‡ZS)ÚShareableTypeTestscstƒ ¡t ¡|_dSr)r@ÚsetUprÚchannel_creatersrkrDrrržes zShareableTypeTests.setUpcst |j¡tƒ ¡dSr)rrƒrsr@r‰rkrDrrr‰iszShareableTypeTests.tearDownc Csr|D]h}| |¡Jt |j|¡t |j¡}| ||¡| t|ƒt|ƒ¡Wdƒq1sb0YqdSr)rrryrsrzÚassertEqualÚassertIsrj)rCÚvaluesrÚgotrrrÚ_assert_valuesmsz!ShareableTypeTests._assert_valuesc Cs^dD]T}| |¡6t |j|¡t |j¡}| ||¡Wdƒq1sN0YqdS)Nr)rrryrsrzr¡)rCrr£rrrÚtest_singletonsxs z"ShareableTypeTests.test_singletonscCs| dd|jg¡dS)Nrwi')r¤rsrkrrrÚ test_typess ýzShareableTypeTests.test_typescCs| dd„tddƒDƒ¡dS)Ncss|]}|jddddVqdS)éÚlittleT)ÚsignedN)Úto_bytes)Ú.0ÚirrrÚ ‰sÿz0ShareableTypeTests.test_bytes..éÿÿÿÿé)r¤ÚrangerkrrrÚ test_bytesˆs ÿzShareableTypeTests.test_bytescCs| gd¢¡dS)N)zhello worlduä½ å¥½ä¸–ç•ŒÚ)r¤rkrrrÚ test_strsŒszShareableTypeTests.test_strscCs*| t tddƒtjtjdg¡¡dS)Nr®r¯rh)r¤Ú itertoolsÚchainr°ÚsysÚmaxsizerkrrrÚtest_intsÿzShareableTypeTests.test_intc CsŒtjdtjdddg}|D]f}| |¡H| t¡t |j|¡Wdƒn1s^0YWdƒq 1s|0Yq dS)Nrhr§éè)r¶r·rÚassertRaisesÚ OverflowErrorrryrs)rCZintsr¬rrrÚtest_non_shareable_int“s ýz)ShareableTypeTests.test_non_shareable_int) rFrGrHržr‰r¤r¥r¦r±r³r¸r¼rJrrrDrrcs rc@s$eZdZdd„Zdd„Zdd„ZdS)ÚListAllTestscCs"t ¡}t ¡}| ||g¡dSr)rr1r~r )rCr4ÚidsrrrÚtest_initial¤szListAllTests.test_initialcCs6t ¡}t ¡}t ¡}t ¡}| ||||g¡dSr)rr1r?r~r ©rCr4ÚfirstÚsecondr¾rrrÚtest_after_creating©s z ListAllTests.test_after_creatingcCs>t ¡}t ¡}t ¡}t |¡t ¡}| |||g¡dSr)rr1r?rr~r rÀrrrÚtest_after_destroying°s z"ListAllTests.test_after_destroyingN)rFrGrHr¿rÃrÄrrrrr½¢sr½c@seZdZdd„Zdd„ZdS)ÚGetCurrentTestscCs.t ¡}t ¡}| ||¡| |tj¡dSr)rr1r2r ÚassertIsInstancer>)rCr4ÚcurrrrÚ test_main»szGetCurrentTests.test_maincCsRt ¡}t ¡}t|tdƒƒ}t| ¡ƒ}t ¡\}}| ||¡| ||¡dS)NzÉ import _xxsubinterpreters as _interpreters cur = _interpreters.get_current() print(cur) assert isinstance(cur, _interpreters.InterpreterID) ) rr1r?rrÚintÚstripr~r ZassertNotEqual)rCr4rÚoutrÇÚ_ÚexpectedrrrÚtest_subinterpreterÁsz#GetCurrentTests.test_subinterpreterN)rFrGrHrÈrÎrrrrrÅ¹srÅc@seZdZdd„Zdd„ZdS)ÚGetMainTestscCs0t ¡\}t ¡}| ||¡| |tj¡dSr)rr~r1r rÆr>)rCrÍr4rrrÚtest_from_mainÒs zGetMainTests.test_from_maincCs<t ¡\}t ¡}t|tdƒƒ}t| ¡ƒ}| ||¡dS)NzÉ import _xxsubinterpreters as _interpreters main = _interpreters.get_main() print(main) assert isinstance(main, _interpreters.InterpreterID) )rr~r?rrrÉrÊr )rCrÍrrËr4rrrÚtest_from_subinterpreterØs z%GetMainTests.test_from_subinterpreterN)rFrGrHrÐrÑrrrrrÏÐsrÏc@s<eZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd S)ÚIsRunningTestscCst ¡}| t |¡¡dSr)rr1rŽr)rCr4rrrrÈçszIsRunningTests.test_maincCsdt ¡}| t |¡¡t|ƒ | t |¡¡Wdƒn1sF0Y| t |¡¡dSr)rr?r›rr,rŽ©rCrrrrrÎës .z"IsRunningTests.test_subinterpretercCs2t ¡}t|td|›dƒƒ}| | ¡d¡dS)Nz` import _xxsubinterpreters as _interpreters if _interpreters.is_running(zZ): print(True) else: print(False) ÚTrue)rr?rrr rÊ)rCrrËrrrrÑós þz'IsRunningTests.test_from_subinterpretercCsJt ¡}t |¡| t¡t |¡Wdƒn1s<0YdSr)rr?rrºrrrÓrrrÚtest_already_destroyedþs z%IsRunningTests.test_already_destroyedcCs8| t¡t d¡Wdƒn1s*0YdS©Ni@B)rºrrrrkrrrÚtest_does_not_existsz"IsRunningTests.test_does_not_existcCs8| t¡t d¡Wdƒn1s*0YdS©Nr®)rºr<rrrkrrrÚtest_bad_idszIsRunningTests.test_bad_idN) rFrGrHrÈrÎrÑrÕr×rÙrrrrrÒåsrÒc@sDeZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dS)ÚInterpreterIDTestscCs"tjddd}| t|ƒd¡dS)NrŒTrn)rr>r rÉ©rCr.rrrÚ test_with_intsz InterpreterIDTests.test_with_intcCs4Gdd„dtƒ}tj|ƒdd}| t|ƒd¡dS)Nc@seZdZdd„ZdS)z.InterpreterIDTests.test_coerce_id..IntcSsdS©NrŒrrkrrrÚ __index__sz8InterpreterIDTests.test_coerce_id..Int.__index__N©rFrGrHrÞrrrrÚIntsràTrnrŒ)r7rr>r rÉ)rCràr.rrrÚtest_coerce_idsz!InterpreterIDTests.test_coerce_idcCsf| ttjtƒ¡| ttjd¡| ttjd¡| ttjd¡| ttjd¡| ttjd¡dS©Ng$@Ú10s10r®l)rºÚ TypeErrorrr>r™r<r»rkrrrrÙszInterpreterIDTests.test_bad_idcCsHt ¡}| t¡"t t|ƒd¡Wdƒn1s:0YdS©Nrh)rrŸrºrr>rÉrÛrrrr×$sz&InterpreterIDTests.test_does_not_existcCs"tjddd}| t|ƒd¡dS©NrŒTrnrã)rr>r r7rÛrrrÚtest_str)szInterpreterIDTests.test_strcCs"tjddd}| t|ƒd¡dS)NrŒTrnzInterpreterID(10))rr>r ršrÛrrrÚ test_repr-szInterpreterIDTests.test_reprcCs(t ¡}t t|ƒ¡}t ¡}| ||k¡| ||k¡| |t|ƒk¡| t|ƒ|k¡| |tt|ƒƒk¡| tt|ƒƒ|k¡| |tt|ƒƒdk¡| |tt|ƒƒk¡| |ddk¡| |tdƒk¡| |dk¡| ||k¡| ||k¡| ||k¡| ||k¡dS©Nçš™™™™™¹?r§r¹Úinfr‹)rr?r>rÉrŽÚfloatr›r7©rCÚid1Úid2Úid3rrrÚ test_equality1s$z InterpreterIDTests.test_equalityN) rFrGrHrÜrárÙr×rçrèrñrrrrrÚ srÚc@sNeZdZdd„Ze d¡dd„ƒZdd„Zdd „Zd d„Z dd „Z dd„ZdS)ÚCreateTestscCs*t ¡}| |tj¡| |t ¡¡dSr)rr?rÆr>ÚassertInr~rÛrrrÚtest_in_mainJszCreateTests.test_in_mainz*enable this test when working on pystate.ccCsDtƒ}tdƒD] }t ¡}t |¡| |¡q| t|ƒd¡dS)Néd)Úsetr°rr?rÚaddr Úlen)rCÚseenrÌr.rrrÚtest_unique_idPs zCreateTests.test_unique_idcsnt ¡‰d‰‡‡fdd„}tj|d}ˆ| ¡Wdƒn1sH0Y| ¡| ˆt ¡¡dS)Ncst ¡‰ˆ ¡ˆ ¡dSr)rr?ÚacquireÚreleaser©r.ÚlockrrÚf]sz%CreateTests.test_in_thread..fr#)r&ÚLockr'r(r*rórr~©rCrÿr+rrýrÚtest_in_threadZs&zCreateTests.test_in_threadcCsJt ¡\}t ¡}t|tdƒƒ}t| ¡ƒ}| tt ¡ƒ|||h¡dS)NzÁ import _xxsubinterpreters as _interpreters id = _interpreters.create() print(id) assert isinstance(id, _interpreters.InterpreterID) ) rr~r?rrrÉrÊr rö)rCr4rîrËrïrrrÚtest_in_subinterpreteris z"CreateTests.test_in_subinterpretercs^t ¡\}t ¡‰d‰‡‡fdd„}tj|d}| ¡| ¡| tt ¡ƒ|ˆˆh¡dS)Ncstˆtdƒƒ}t| ¡ƒ‰dS)Nz’ import _xxsubinterpreters as _interpreters id = _interpreters.create() print(id) )rrrÉrÊ)rË©rîrïrrrÿzsz6CreateTests.test_in_threaded_subinterpreter..fr#) rr~r?r&r'r(r*r rö)rCr4rÿr+rrrÚtest_in_threaded_subinterpretervs z+CreateTests.test_in_threaded_subinterpretercCsjtt ¡ƒ}g}tdƒD]}t ¡}| |¡q|D]}t |¡q4t ¡}| tt ¡ƒ||hB¡dS©Né)rörr~r°r?Úappendrr ©rCÚbeforer¾rÌr.rrrÚtest_after_destroy_all‰sz"CreateTests.test_after_destroy_allcCs`tt ¡ƒ}t ¡}t ¡}t ¡}t |¡t |¡t ¡}| tt ¡ƒ|||hB¡dSr)rörr~r?rr )rCr rîrïrðr.rrrÚtest_after_destroy_some—s z#CreateTests.test_after_destroy_someN)rFrGrHrôÚunittestÚskiprúrrrrrrrrrròHs ròc@s\eZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dd„Z dd„Zdd„ZdS)ÚDestroyTestscCsft ¡}t ¡}t ¡}| |t ¡¡t |¡| |t ¡¡| |t ¡¡| |t ¡¡dSr)rr?rór~rÚassertNotInrírrrÚtest_one§s zDestroyTests.test_onecCsvtt ¡ƒ}tƒ}tdƒD]}t ¡}| |¡q| tt ¡ƒ||B¡|D]}t |¡qN| tt ¡ƒ|¡dSr)rörr~r°r?r÷r rr rrrÚtest_all±szDestroyTests.test_allcslt ¡\‰ˆ t¡t ˆ¡Wdƒn1s40Y‡‡fdd„}tj|d}| ¡| ¡dS)Ncs8ˆ t¡t ˆ¡Wdƒn1s*0YdSr©rºrrrr©r4rCrrrÿÁsz!DestroyTests.test_main..fr#) rr~rºrrr&r'r(r*rrrrrÈ¼s (zDestroyTests.test_maincCsJt ¡}t |¡| t¡t |¡Wdƒn1s<0YdSr)rr?rrºrrÛrrrrÕÉs z#DestroyTests.test_already_destroyedcCs8| t¡t d¡Wdƒn1s*0YdSrÖrrkrrrr×Ïsz DestroyTests.test_does_not_existcCs8| t¡t d¡Wdƒn1s*0YdSrØ)rºr<rrrkrrrrÙÓszDestroyTests.test_bad_idcCsJt ¡\}t ¡}td|›dƒ}t ||¡| tt ¡ƒ||h¡dS)Nzo import _xxsubinterpreters as _interpreters try: _interpreters.destroy(zD) except RuntimeError: pass ©rr~r?rrr rö)rCr4r.rrrrÚtest_from_current×s ý zDestroyTests.test_from_currentcCsRt ¡\}t ¡}t ¡}td|›dƒ}t ||¡| tt ¡ƒ||h¡dS)NzZ import _xxsubinterpreters as _interpreters _interpreters.destroy(ú) r)rCr4rîrïrrrrÚtest_from_siblingås þ zDestroyTests.test_from_siblingcs4t ¡‰‡fdd„}tj|d}| ¡| ¡dS)Ncst ˆ¡dSr)rrrr€rrrÿósz.DestroyTests.test_from_other_thread..fr#)rr?r&r'r(r*rrr€rÚtest_from_other_threadñs z#DestroyTests.test_from_other_threadc Csªt ¡\}t ¡}t|ƒ||jt |¡d|›dd|jtd|›ddt |¡Wdƒn1sn0Y| t |¡¡Wdƒn1sœ0YdS)NzInterp z& should be running before destruction.)Úmsgz%Should not be able to destroy interp z while it's still running.) rr~r?r,rŽrrºrr)rCr4rrrrÚtest_still_runningús ÿ ÿ(zDestroyTests.test_still_runningN) rFrGrHrrrÈrÕr×rÙrrrrrrrrr¥s rcseZdZedƒZdZ‡fdd„Z‡fdd„Zdd„Zd d „Z dd„Z e e ed ƒd¡dd„ƒZdd„Zdd„Zdd„Zdd„Zdd„Zdd„Zejd5dd„ƒZd d!„Zd"d#„Zd$d%„Zd&d'„Zd(d)„Zd*d+„Zd,d-„Zd.d/„Z d0d1„Z!e "d2¡d3d4„ƒZ#‡Z$S)6ÚRunStringTestszJ with open('{}', 'w') as out: out.write('{}') r‹cstƒ ¡t ¡|_d|_dSr)r@ržrr?r.Ú_fsrkrDrrržs zRunStringTests.setUpcs"|jdur|j ¡tƒ ¡dSr)rrXr@r‰rkrDrrr‰s zRunStringTests.tearDowncCsVtdƒ\}}|&t |j|¡| ¡}Wdƒn1s<0Y| |d¡dS)Núprint("it worked!", end="")ú it worked!)rrrr.rr )rCrÚfilerËrrrÚtest_successs &zRunStringTests.test_successcsrtdƒ\‰}|B‡‡fdd„}tj|d}| ¡| ¡| ¡}Wdƒn1sX0Yˆ |d¡dS)Nrcst ˆjˆ¡dSr)rrr.r©rrCrrrÿ$sz(RunStringTests.test_in_thread..fr#r)rr&r'r(r*rr )rCr rÿr+rËrr"rr!s&zRunStringTests.test_in_threadcCs`tjdd}tdƒ\}}|$t ||¡| ¡}Wdƒn1sF0Y| |d¡dS)NF)ÚisolatedzÂ import threading def f(): print('it worked!', end='') t = threading.Thread(target=f) t.start() t.join() r)rr?rrrr )rCZ subinterprr rËrrrÚtest_create_thread.s &z!RunStringTests.test_create_threadÚforkztest needs os.fork()cCsddl}| d¡j}| d¡| ¡d}td|j›d|›dƒ}t |j|¡| d¡| ¡}| ||¡Wdƒn1s‚0YdS)Nrzw+r²zspam spam spam spam spamz’ import os try: os.fork() except RuntimeError: with open('z3', 'w') as out: out.write('z') )ÚtempfileÚNamedTemporaryFiler)ÚflushrrBrrr.Úseekrr )rCr&r rÍrZcontentrrrÚ test_fork?s ûú zRunStringTests.test_forkc Csft|jƒH| t¡t |jd¡Wdƒn1s:0YWdƒn1sX0YdS)Nú print("spam"))r,r.rºrrrrkrrrÚtest_already_runningUsz#RunStringTests.test_already_runningcCsTd}|t ¡vr|d7}q| t¡t |d¡Wdƒn1sF0YdS)Nrrhr+)rr~rºrrrÛrrrr×Zs z"RunStringTests.test_does_not_existcCs:| t¡t dd¡Wdƒn1s,0YdS)Nr®r+)rºr<rrrkrrrÚ test_error_idaszRunStringTests.test_error_idcCs:| t¡t dd¡Wdƒn1s,0YdS)Nr‹r+)rºrärrrkrrrrÙeszRunStringTests.test_bad_idcCs<| t¡t |jd¡Wdƒn1s.0YdSrÝ©rºrärrr.rkrrrÚtest_bad_scriptiszRunStringTests.test_bad_scriptcCs<| t¡t |jd¡Wdƒn1s.0YdS)Ns print("spam")r.rkrrrÚtest_bytes_for_scriptmsz$RunStringTests.test_bytes_for_scriptNccsz| tj¡}dVWdƒn1s(0Y|dur\| t|jƒ d¡dt|ƒ¡n| t|jƒd ||¡¡dS)Nú:rz{}: {})rºrÚRunFailedErrorr r7Ú exceptionÚsplitr=)rCÚexctyperZcaughtrrrÚassert_run_failedqs$ÿ ÿz RunStringTests.assert_run_failedcCs<| t¡t |jd¡Wdƒn1s.0YdS)Nzprint("spam")r6ÚSyntaxErrorrrr.rkrrrÚtest_invalid_syntax|sz"RunStringTests.test_invalid_syntaxcCs>| td¡t |jd¡Wdƒn1s00YdS)Nr‹zraise Exception("spam"))r6r|rrr.rkrrrÚtest_failureszRunStringTests.test_failurecCs>| td¡t |jd¡Wdƒn1s00YdS)NÚ42zraise SystemExit(42))r6Ú SystemExitrrr.rkrrrÚtest_SystemExit…szRunStringTests.test_SystemExitcCs~| t¡"t |jtdƒ¡Wdƒn1s20Y| td¡"t |jtdƒ¡Wdƒn1sp0YdS)NzG import sys sys.exit() r:zI import sys sys.exit(42) )r6r;rrr.rrkrrrÚ test_sys_exit‰s0zRunStringTests.test_sys_exitcCs®t ¡\}}ddddœ}td|›dƒ}t |j||¡t|dƒ}t |¡}Wdƒn1sb0Y| |dd¡| |d d ¡| |dd¡| |d ¡dS)Nóhams-1)r‹ÚeggsÚcheddarzÇ eggs = int(eggs) spam = 42 result = spam + eggs ns = dict(vars()) del ns['__builtins__'] import pickle with open(úC, 'wb') as chan: pickle.dump(ns, chan) Úrbr‹é*r?r®rué)r@)rrrrrr.r ÚpickleÚloadr ZassertIsNone©rCrr rrÚchanÚnsrrrÚtest_with_shared–sýø (zRunStringTests.test_with_sharedcCsÌt |jtdƒ¡ddi}tdƒ}t |j||¡t ¡\}}td|›dƒ}t |j|¡t|dƒ}t |¡}Wdƒn1s†0Y| |ddd ¡| |d dd¡| |dd¡dS)Nzj spam = 'eggs' ns1 = dict(vars()) del ns1['__builtins__'] r‹r>zL ns2 = dict(vars()) del ns2['__builtins__'] zr ns = dict(vars()) del ns['__builtins__'] import pickle with open(rArBÚns1r?Úns2) rrr.rrrr rErFr )rCrrrr rHrIrrrÚtest_shared_overwrites²sü (z%RunStringTests.test_shared_overwritescCs|t ¡\}}ddi}td|›dƒ}t |j||¡t|dƒ}t |¡}Wdƒn1s^0Y| |dd¡dS)NrFsnot __main__z‰ spam = 42 ns = dict(vars()) del ns['__builtins__'] import pickle with open(rArB) rrrrrr.r rErFr rGrrrÚ#test_shared_overwrites_default_varsÐsú (z2RunStringTests.test_shared_overwrites_default_varscCsèt ¡\}}t |jtd|›dƒ¡t|dƒ}t |¡}Wdƒn1sP0Yt ¡\}}t |jtd|›dƒ¡t|dƒ}t |¡}Wdƒn1sª0Y| d|¡| d|¡| d|¡| d|¡dS)Nz‹ spam = True ns = dict(vars()) del ns['__builtins__'] import pickle with open(zd, 'wb') as chan: pickle.dump(ns, chan) del ns, pickle, chan rBzŒ eggs = False ns = dict(vars()) del ns['__builtins__'] import pickle with open(rAr‹r?)rrrrr.rr rErFrór)rCrr rHrKrLrrrÚtest_main_reusedãs ú (ú (zRunStringTests.test_main_reusedc Cst ¡\}}td|›dƒ}t |j|¡t|dƒ}t |¡}Wdƒn1sT0Y| d¡| d¡| |didddddœ¡dS) NzŸ spam = 42 ns = dict(vars()) ns['__builtins__'] = str(ns['__builtins__']) import pickle with open(rArBÚ__builtins__Ú __loader__Ú__main__rC)rFÚ__annotations__r•Ú__package__Ú__spec__r‹)rrrrrr.r rErFÚpopr )rCrr rrHrIrrrÚ test_execution_namespace_is_mains"ú ( úz/RunStringTests.test_execution_namespace_is_mainzblocking foreverc Cs€tdƒ}t ¡P}t |d|¡}t |¡}| ¡}Wdƒn1sH0YWdƒn1sf0Y| |d¡dS)Na¾ from textwrap import dedent import threading import _xxsubinterpreters as _interpreters id = _interpreters.create() def f(): _interpreters.run_string(id, dedent(''' import time # Give plenty of time for the main interpreter to finish. time.sleep(1_000_000) ''')) t = threading.Thread(target=f) t.start() rr)rrZtemp_dirrZmake_scriptZspawn_pythonÚwaitr )rCrÚdirnameÚfilenameÚprocÚretcoderrrÚtest_still_running_at_exit s Dz)RunStringTests.test_still_running_at_exit)N)%rFrGrHrZSCRIPTZFILENAMEržr‰r!rr$r Z skipUnlessÚhasattrrr*r,r×r-rÙr/r0Ú contextlibÚcontextmanagerr6r8r9r<r=rJrMrNrOrWrr]rJrrrDrrs8 !rc@sTeZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dd„Z dd„ZdS)ÚChannelIDTestscCs0tjddd}| t|ƒd¡| |jd¡dS)NrŒTrnrN)rÚ_channel_idr rÉrQ©rCrsrrrÚtest_default_kwargs>sz"ChannelIDTests.test_default_kwargscCs tjdddd}| |jd¡tjddddd}| |jd¡tjdddd}| |jd¡tjddddd }| |jd¡tjddddd}| |jd ¡dS)NrŒT©rUrorUF©rUrVro©rVrorV)rVrUrorN)rrbr rQrcrrrÚtest_with_kwargsDszChannelIDTests.test_with_kwargscCs4Gdd„dtƒ}tj|ƒdd}| t|ƒd¡dS)Nc@seZdZdd„ZdS)z*ChannelIDTests.test_coerce_id..IntcSsdSrÝrrkrrrrÞVsz4ChannelIDTests.test_coerce_id..Int.__index__NrßrrrrràUsràTrnrŒ)r7rrbr rÉ)rCràrsrrrráTszChannelIDTests.test_coerce_idcCsf| ttjtƒ¡| ttjd¡| ttjd¡| ttjd¡| ttjd¡| ttjd¡dSrâ)rºrärrbr™r<r»rkrrrrÙ\szChannelIDTests.test_bad_idcCs>| t¡ tjddddWdƒn1s00YdS)NrŒF©rUrV)rºr<rrbrkrrrÚtest_bad_kwargsdszChannelIDTests.test_bad_kwargscCsJt ¡}| tj¡"t t|ƒd¡Wdƒn1s<0YdSrå)rrŸrºr„rbrÉrcrrrr×hsz"ChannelIDTests.test_does_not_existcCs"tjddd}| t|ƒd¡dSræ)rrbr r7rcrrrrçmszChannelIDTests.test_strcCs„tjddd}| t|ƒd¡tjdddd}| t|ƒd¡tjdddd}| t|ƒd¡tjddddd }| t|ƒd¡dS) NrŒTrnz ChannelID(10)rezChannelID(10, send=True)rgzChannelID(10, recv=True)rf)rrbr ršrcrrrrèqszChannelIDTests.test_reprcCs(t ¡}t t|ƒ¡}t ¡}| ||k¡| ||k¡| |t|ƒk¡| t|ƒ|k¡| |tt|ƒƒk¡| tt|ƒƒ|k¡| |tt|ƒƒdk¡| |tt|ƒƒk¡| |ddk¡| |tdƒk¡| |dk¡| ||k¡| ||k¡| ||k¡| ||k¡dSré)rrŸrbrÉrŽrìr›r7)rCÚcid1Úcid2Zcid3rrrrñ~s$zChannelIDTests.test_equalityN)rFrGrHrdrhrárÙrjr×rçrèrñrrrrra<s rac@s>eZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dd„Z dd„Zdd„Zdd„Z dd„Zdd„Zdd„Zdd„Zdd „Zd!d"„Zd#d$„Zd%d&„Zd'd(„Ze d)¡d*d+„ƒZd,d-„Zd.d/„Zd0d1„Zd2d3„Zd4d5„Zd6d7„Zd8d9„Z d:d;„Z!dd?„Z#d@dA„Z$dBdC„Z%dDdE„Z&dFdG„Z'dHdI„Z(dJdK„Z)dLS)MÚChannelTestscCst ¡}| |tj¡dSr)rrŸrÆZ ChannelIDrcrrrÚtest_create_cid—szChannelTests.test_create_cidcCsrt ¡}t ¡}t ¡}t ¡}t ¡}| |t|ƒd¡| |t|ƒd¡| t|ƒt|ƒ|||h¡dSrå)rr‚rŸr rÉrö)rCr rîrïrðZafterrrrÚtest_sequential_ids›sz ChannelTests.test_sequential_idscCs\t ¡}t|tdƒƒ}t| ¡ƒ}t ¡}t|tdƒƒ}t| ¡ƒ}| |t|ƒd¡dS)NzŒ import _xxsubinterpreters as _interpreters cid = _interpreters.channel_create() print(cid) rh)rr?rrrÉrÊr )rCrîrËrkrïrlrrrÚtest_ids_global¦szChannelTests.test_ids_globalcCs@t ¡}tj|dd}tj|dd}| |g¡| |g¡dS)z=Test listing interpreters for a channel with no associations.T©rUFN)rrŸÚchannel_list_interpretersr )rCrsÚsend_interpsÚrecv_interpsrrrÚ#test_channel_list_interpreters_none¹s z0ChannelTests.test_channel_list_interpreters_nonecCs¬t ¡}t ¡}t |d¡tj|dd}tj|dd}| ||g¡| |g¡t ¡}t|td|›dƒƒtj|dd}tj|dd}| ||g¡| ||g¡dS)z(Test basic listing channel interpreters.rUTrqFúe import _xxsubinterpreters as _interpreters obj = _interpreters.channel_recv(rN) rr1rŸryrrr r?rr)rCÚinterp0rsrsrtÚinterp1rrrÚ$test_channel_list_interpreters_basicÂsþz1ChannelTests.test_channel_list_interpreters_basiccCs¾t ¡}t ¡}t ¡}t ¡}t ¡}t |d¡t|td|›dƒƒt|td|›dƒƒt|td|›dƒƒtj|dd}tj|dd}| t |ƒ||h¡| t |ƒ||h¡d S) z?Test listing interpreters for a channel with many associations.rUú_ import _xxsubinterpreters as _interpreters _interpreters.channel_send(z, "send") rvrTrqFN) rr1r?rŸryrrrrr rö)rCrwrxÚinterp2Úinterp3rsrsrtrrrÚ'test_channel_list_interpreters_multipleØs&þþþz4ChannelTests.test_channel_list_interpreters_multiplecCs¶t ¡}t ¡}t ¡}t |d¡t|td|›dƒƒtj|dd}tj|dd}| ||g¡| ||g¡t |¡tj|dd}tj|dd}| ||g¡| |g¡dS)z?Test listing channel interpreters with a destroyed interpreter.rUrvrTrqFN) rr1r?rŸryrrrrr r©rCrwrxrsrsrtrrrÚ(test_channel_list_interpreters_destroyedòs þ z5ChannelTests.test_channel_list_interpreters_destroyedcCs>t ¡}t ¡}t ¡}t ¡}t |d¡t|td|›dƒƒt |d¡t|td|›dƒƒtj|dd}tj|dd}| t |ƒd¡| t |ƒd¡tj |ddtj|dd}tj|dd}| t |ƒd ¡| t |ƒd¡t|td |›dƒƒtj|dd}tj|dd}| t |ƒd ¡| ||g¡dS)z:Test listing channel interpreters with a released channel.ÚdatarvrTrqFrhr§rúb import _xxsubinterpreters as _interpreters _interpreters.channel_release(N)rr1r?rŸryrrrrr røÚchannel_release)rCrwrxr{rsrsrtrrrÚ'test_channel_list_interpreters_released s8þþþz4ChannelTests.test_channel_list_interpreters_releasedcCsæt ¡}t ¡}t ¡}t |d¡tj|dd}tj|dd}| t|ƒd¡| t|ƒd¡tj|dd| tj ¡tj|ddWdƒn1sž0Y| tj ¡tj|ddWdƒn1sØ0YdS) z8Test listing channel interpreters with a closed channel.rUTrqFrhrrnN)rr1r?rŸryrrr rør}rºrKr~rrrÚ%test_channel_list_interpreters_closed4s,z2ChannelTests.test_channel_list_interpreters_closedcCsXt ¡}t ¡}t ¡}t |d¡tj|dd}tj|dd}| t|ƒd¡| t|ƒd¡tj|dd| tj ¡tj|ddWdƒn1sž0Ytj|dd}| t|ƒd¡t|td|›d ƒƒ| tj ¡tj|ddWdƒn1s0Y| tj ¡tj|ddWdƒn1sJ0YdS) zCTest listing channel interpreters with a channel's send end closed.rUTrqFrhrNú` import _xxsubinterpreters as _interpreters _interpreters.channel_close(ú, force=True) ) rr1r?rŸryrrr rør}rºrKrrr~rrrÚ.test_channel_list_interpreters_closed_send_endJs(,þ.z;ChannelTests.test_channel_list_interpreters_closed_send_endcCs>t ¡}d}t ||¡t |¡}| ||¡| ||¡dS©Nrw)rrŸryrzr ZassertIsNot)rCrsZorigrrrrÚtest_send_recv_mainns z ChannelTests.test_send_recv_maincCst ¡}t|tdƒƒ}dS)Na6 import _xxsubinterpreters as _interpreters cid = _interpreters.channel_create() orig = b'spam' _interpreters.channel_send(cid, orig) obj = _interpreters.channel_recv(cid) assert obj is not orig assert obj == orig )rr?rr)rCrîrËrrrÚtest_send_recv_same_interpreterwsz,ChannelTests.test_send_recv_same_interpretercCs@t ¡}t ¡}t|td|›dƒƒ}t |¡}| |d¡dS)Nrzú, b'spam') rw)rrŸr?rrrzr )rCrsrîrËrrrrÚ%test_send_recv_different_interpretersƒsþ z2ChannelTests.test_send_recv_different_interpreterscsVt ¡‰‡fdd„}tj|d}| ¡t ˆd¡| ¡t ˆ¡}| |d¡dS)NcsDzt ˆ¡}Wq4Wqtjy0t d¡Yq0qt ˆ|¡dS)Nrê)rrzr{rrry)rr…rrrÿ‘s z8ChannelTests.test_send_recv_different_threads..fr#rw) rrŸr&r'r(ryr*rzr ©rCrÿr+rrr…rÚ test_send_recv_different_threadsŽs z-ChannelTests.test_send_recv_different_threadscsft ¡‰t ¡‰d‰‡‡‡fdd„}tj|d}| ¡t ˆd¡| ¡t ˆ¡}| |d¡dS)Ncs tˆtdˆ›dˆ›dƒƒ‰dS)NzÆ import time import _xxsubinterpreters as _interpreters while True: try: obj = _interpreters.channel_recv(zÖ) break except _interpreters.ChannelEmptyError: time.sleep(0.1) assert(obj == b'spam') _interpreters.channel_send(z, b'eggs') )rrr©rsrîrËrrrÿ§s û özIChannelTests.test_send_recv_different_interpreters_and_threads..fr#rwóeggs) rrŸr?r&r'r(ryr*rzr rrrrÚ1test_send_recv_different_interpreters_and_threads¢s z>ChannelTests.test_send_recv_different_interpreters_and_threadscCs<| tj¡t dd¡Wdƒn1s.0YdS)NrŒrw)rºrr„ryrkrrrÚtest_send_not_found¾sz ChannelTests.test_send_not_foundcCs:| tj¡t d¡Wdƒn1s,0YdSrÝ)rºrr„rzrkrrrÚtest_recv_not_foundÂsz ChannelTests.test_recv_not_foundcCsBt ¡}| tj¡t |¡Wdƒn1s40YdSr)rrŸrºr{rzrcrrrÚtest_recv_emptyÆszChannelTests.test_recv_emptyc CsÐtƒ}t ¡}t ||¡}t |d¡t |d¡t |d¡t |d¡t ||¡}t ||¡}t |¡}t ||¡}t ||¡}| ||¡| |d¡| |d¡| |d¡| |d¡| ||¡dS)Nrhrwr)r™rrŸrzryr¡r ) rCÚdefaultrsZobj1Úobj2Zobj3Zobj4Zobj5Zobj6rrrÚtest_recv_defaultËs$ zChannelTests.test_recv_defaultcCsRt ¡}t ¡}t|tdƒt|jdƒ}t |¡}| |d¡| | ¡d¡dS)Nz” import _xxsubinterpreters as _interpreters print(cid.end) _interpreters.channel_send(cid, b'spam') r…rwrU) rrŸr?rrÚdictrUrzr rÊ©rCrsrrËrrrrÚtest_run_string_arg_unresolvedàs û z+ChannelTests.test_run_string_arg_unresolvedz(disabled until high-level channels existcCs`t ¡}tj|dd}t ¡}t|tdƒt|jdƒ}t |¡}| |d¡| | ¡d¡dS)NT)Ú_resolvezœ import _xxsubinterpreters as _interpreters print(chan.id.end) _interpreters.channel_send(chan.id, b'spam') )rHrwrU)rrŸrbr?rrr˜rUrzr rÊr™rrrÚtest_run_string_arg_resolvedòs û z)ChannelTests.test_run_string_arg_resolvedcCsšt ¡}t |d¡t |¡t |¡| tj¡t |d¡Wdƒn1sV0Y| tj¡t |¡Wdƒn1sŒ0YdS©Nrwr©rrŸryrzr}rºrKrcrrrÚtest_close_single_users *z#ChannelTests.test_close_single_usercCst ¡}t ¡}t ¡}t |td|›dƒ¡t |td|›dƒ¡t |¡| tj¡(}t |td|›dƒ¡Wdƒn1sŒ0Y| dt |j ƒ¡| tj¡(}t |td|›dƒ¡Wdƒn1sâ0Y| dt |j ƒ¡dS)Nrzr‹z_ import _xxsubinterpreters as _interpreters _interpreters.channel_recv(rz, _interpreters.channel_send(z, b'spam') rK)rrŸr?rrr}rºr2rór7r3)rCrsrîrïÚcmrrrÚtest_close_multiple_userss( þ þ ÿ* ÿ*z&ChannelTests.test_close_multiple_userscCsbt ¡}t |d¡t |¡t |¡| tj¡t |¡Wdƒn1sT0YdSrˆržrcrrrÚtest_close_multiple_times(s z&ChannelTests.test_close_multiple_timesc Csägd¢}|D]Ò\}}| ||f¡¬t ¡}t |d¡t |¡tj|||d| tj¡t |d¡Wdƒn1s€0Y| tj¡t |¡Wdƒn1s¶0YWdƒq1sÔ0YqdS)N))FF©TF)FT)TTrwrir)rrrŸryrzr}rºrK)rCZtestsrUrVrsrrrÚtest_close_empty1s *zChannelTests.test_close_emptycCspt ¡}t |d¡t |d¡| tj¡t |¡Wdƒn1sL0Yt |¡t |d¡dS)Nrwr>r©rrŸryrºZChannelNotEmptyErrorr}rzrcrrrÚ%test_close_defaults_with_unused_itemsDs( z2ChannelTests.test_close_defaults_with_unused_itemscCs–t ¡}t |d¡t |d¡| tj¡tj|ddWdƒn1sP0Yt |¡t |d¡t |¡t |¡tj|dddS)Nrwr>T©rVrr¥rcrrrÚ*test_close_recv_with_unused_items_unforcedNs, z7ChannelTests.test_close_recv_with_unused_items_unforcedcCs´t ¡}t |d¡t |d¡tj|dd| tj¡t |d¡Wdƒn1s\0Yt |¡t |¡| tj¡t |¡Wdƒn1s¦0YdS)Nrwr>Trqr©rrŸryr}rºrKrzrcrrrÚ*test_close_send_with_unused_items_unforced[s* z7ChannelTests.test_close_send_with_unused_items_unforcedcCs˜t ¡}t |d¡t |d¡| tj¡ tj|dddWdƒn1sR0Yt |¡t |d¡t |¡t |¡tj|dddS)Nrwr>Trxrr§r¥rcrrrÚ*test_close_both_with_unused_items_unforcedhs. z7ChannelTests.test_close_both_with_unused_items_unforcedcCs¢t ¡}t |d¡t |d¡tj|ddd| tj¡t |d¡Wdƒn1s^0Y| tj¡t |¡Wdƒn1s”0YdS)Nrwr>Trgrr©rcrrrÚ(test_close_recv_with_unused_items_forcedus*z5ChannelTests.test_close_recv_with_unused_items_forcedcCs¢t ¡}t |d¡t |d¡tj|ddd| tj¡t |d¡Wdƒn1s^0Y| tj¡t |¡Wdƒn1s”0YdS)Nrwr>Trerr©rcrrrÚ(test_close_send_with_unused_items_forced€s*z5ChannelTests.test_close_send_with_unused_items_forcedcCs¤t ¡}t |d¡t |d¡tj|dddd| tj¡t |d¡Wdƒn1s`0Y| tj¡t |¡Wdƒn1s–0YdS)Nrwr>Trfrr©rcrrrÚ(test_close_both_with_unused_items_forced‹s*z5ChannelTests.test_close_both_with_unused_items_forcedcCs„t ¡}t |¡| tj¡t |d¡Wdƒn1s@0Y| tj¡t |¡Wdƒn1sv0YdSrˆ)rrŸr}rºrKryrzrcrrrÚtest_close_never_used–s *z"ChannelTests.test_close_never_usedcCs¤t ¡}t |d¡t ¡}t |td|›dƒ¡| tj¡t |¡Wdƒn1s`0Y| tj¡t |¡Wdƒn1s–0YdS)Nrwr…r†) rrŸryr?rrrºrKrzr}©rCrsrrrrÚ!test_close_by_unassociated_interpŸs þ(z.ChannelTests.test_close_by_unassociated_interpcCs¶t ¡}t |d¡t |d¡t |d¡t |¡tj|dd| tj¡t |d¡Wdƒn1sr0Y| tj¡t |¡Wdƒn1s¨0YdS)NrwTrnrržrcrrrÚ-test_close_used_multiple_times_by_single_user¬s *z:ChannelTests.test_close_used_multiple_times_by_single_usercCsŠt ¡}| tj¡tjdddWdƒn1s80Yt |¡| tj¡tj|ddWdƒn1s|0YdS)Nr¹Trq)rrŸrºr„rrr}rKrcrrrÚ.test_channel_list_interpreters_invalid_channel¹s, z;ChannelTests.test_channel_list_interpreters_invalid_channelcCs@t ¡}| t¡t |¡Wdƒn1s20YdSr)rrŸrºrärrrcrrrÚ+test_channel_list_interpreters_invalid_argsÄsz8ChannelTests.test_channel_list_interpreters_invalid_argsN)*rFrGrHrnrorpruryr}rrƒr„r‡r‰rŠrŒrŽr‘r’r“r”r—ršr rrœrŸr¡r¢r¤r¦r¨rªr«r¬rr®r¯r±r²r³r´rrrrrm•sL +$ rmc@s`eZdZdZdd„Zdd„Zdd„Zdd „Zd d„Zdd „Z dd„Z dd„Zdd„Zdd„Z dS)ÚChannelReleaseTestsa - main / interp / other - run in: current thread / new thread / other thread / different threads - end / opposite - force / no force - used / not used (associated / not associated) - empty / emptied / never emptied / partly emptied - closed / not closed - released / not released - creator (interp) / other - associated interpreter not running - associated interpreter destroyed cCs t ¡}t |d¡t |¡tj|ddd| tj¡t |d¡Wdƒn1s\0Y| tj¡t |¡Wdƒn1s’0YdS©NrwTrir©rrŸryrzr‚rºrKrcrrrÚtest_single_userös *z$ChannelReleaseTests.test_single_usercCsxt ¡}t ¡}t ¡}t |td|›dƒ¡t|td|›d|›dƒƒ}t |td|›dƒ¡| | ¡d¡dS) Nrzr‹rvz,) _interpreters.channel_release(z+) print(repr(obj)) z+ _interpreters.channel_release(rzb'spam')rrŸr?rrrr rÊ)rCrsrîrïrËrrrÚtest_multiple_userss þþý ÿz'ChannelReleaseTests.test_multiple_userscCsšt ¡}t |d¡t |¡t |¡| tj¡t |d¡Wdƒn1sV0Y| tj¡t |¡Wdƒn1sŒ0YdSrr·rcrrrÚtest_no_kwargss *z"ChannelReleaseTests.test_no_kwargscCsnt ¡}t |d¡t |¡tj|ddd| tj¡ tj|dddWdƒn1s`0YdS)NrwTrir·rcrrrÚtest_multiple_times s z'ChannelReleaseTests.test_multiple_timescCsjt ¡}t |d¡t |d¡tj|ddd| tj¡t |¡Wdƒn1s\0YdS)Nrwr>Tri)rrŸryr‚rºrKrzrcrrrÚtest_with_unused_items)sz*ChannelReleaseTests.test_with_unused_itemscCs„t ¡}t |¡| tj¡t |d¡Wdƒn1s@0Y| tj¡t |¡Wdƒn1sv0YdSrˆ)rrŸr‚rºrKryrzrcrrrÚtest_never_used2s *z#ChannelReleaseTests.test_never_usedcCst ¡}t |d¡t ¡}t |td|›dƒ¡t |¡}t |¡| tj ¡t |d¡Wdƒn1sv0Y| |d¡dS)Nrwrrr)rrŸryr?rrrzr‚rºrKr )rCrsrrrrrÚtest_by_unassociated_interp;s þ *z/ChannelReleaseTests.test_by_unassociated_interpc Csht ¡}t ¡}t |td|›d|›dƒ¡| tj¡t |¡Wdƒn1sZ0YdS)Nze import _xxsubinterpreters as _interpreters obj = _interpreters.channel_send(z5, b'spam') _interpreters.channel_release(r)rrŸr?rrrºrKrzr°rrrÚtest_close_if_unassociatedJs þýz.ChannelReleaseTests.test_close_if_unassociatedcCsRt ¡}t |d¡t |¡t |d¡tj|ddt |¡}| |d¡dS)NrwTrq)rrŸryrzr‚r )rCrsrrrrÚtest_partiallyWs z"ChannelReleaseTests.test_partiallycCs¸t ¡}t |d¡t |d¡t |d¡t |¡tj|ddd| tj¡t |d¡Wdƒn1st0Y| tj¡t |¡Wdƒn1sª0YdSr¶r·rcrrrÚ'test_used_multiple_times_by_single_userbs *z;ChannelReleaseTests.test_used_multiple_times_by_single_userN)rFrGrHr•r¸r¹rºr»r¼r½r¾r¿rÀrÁrrrrrµËs' rµcszeZdZdZ‡fdd„Zedd„ƒZedd„ƒZdd „Zddd„Z d d„Z dd„Zdd„Zdd„Z dd„Zdd„Z‡ZS)ÚChannelCloseFixtureFcsx|jri}n4t |¡}t |¡}t |¡}|j||j||j|i}|sHd}tƒ ||||||¡}tƒ|_tƒ|_ ||_ |S)NrS)ÚQUICKr5r;rBr@rAröÚ_preppedrcÚ_stateÚ_known)r9rQrrZr[ÚcreatorZknownrCrDrrrAws ýzChannelCloseFixture.__new__cCs|jSr©rÅrkrrrrtŒszChannelCloseFixture.statecCs>z|jWSty8| |j¡}| |¡|_|jYS0dSr)Ú_cidÚAttributeErrorÚ_get_interpreterrÇÚ_new_channel)rCrÇrrrrsszChannelCloseFixture.cidcCs| |¡}| |¡|Sr)rËÚ_prep_interpreterrÓrrrÚget_interpreter™s z#ChannelCloseFixture.get_interpreterNcCs2|dur|j}|dkr&|jjdkr&dSt|jjƒS)NrVrUF)rQrtreÚboolr`rrrÚexpect_closed_erroržs z'ChannelCloseFixture.expect_closed_errorcCs| |¡dSr)rÍrÓrrrÚprep_interpreter¥sz$ChannelCloseFixture.prep_interpretercCs ||_dSrrÈ)rCrPrurrrÚ record_action¨sz!ChannelCloseFixture.record_actioncCstƒtƒdSrrˆrkrrrÚclean_up«szChannelCloseFixture.clean_upcCs@|jdkrt ¡St ¡}t|jd|›dƒt |¡|_|jS)Nr4a import _xxsubinterpreters cid = _xxsubinterpreters.channel_create() # We purposefully send back an int to avoid tying the # channel to the other interpreter. _xxsubinterpreters.channel_send(zC, int(cid)) del _xxsubinterpreters )rBrrŸr0r.rzrÉ)rCrÇZchrrrrÌ±s û z ChannelCloseFixture._new_channelcCsj|dvr|jS|dkr|jS|dkr*|jS|}z|j|}Wn$ty`t|ƒ}|j|<Yn0|SdS)N)rSrrZr[)rrZr[rÆÚKeyErrorr5)rCrrBrrrrËÁsz$ChannelCloseFixture._get_interpretercCsF|j|jvrdS|j |j¡|jdkr,dSt|jd|j›dƒdS)Nr4a import _xxsubinterpreters as interpreters import test.test__xxsubinterpreters as helpers ChannelState = helpers.ChannelState try: cid except NameError: cid = interpreters._channel_id(r)r.rÄr÷rBr0rsrÓrrrrÍÐs ùz%ChannelCloseFixture._prep_interpreter)N)rFrGrHrÃrAÚpropertyrtrsrÎrÐrÑrÒrÓrÌrËrÍrJrrrDrrÂps rÂzend interp other extra creatorz%these tests take several hours to runc@sŠeZdZdZdd„Zdd„Zdd„Zdd „Zd d„Zdd œdd„Z dd„Z dd„Zd"dd„Zdd„Z d#dd„Zdd„Zdd„Zd d!„ZdS)$ÚExhaustiveChannelTestsaÈ - main / interp / other - run in: current thread / new thread / other thread / different threads - end / opposite - force / no force - used / not used (associated / not associated) - empty / emptied / never emptied / partly emptied - closed / not closed - released / not released - creator (interp) / other - associated interpreter not running - associated interpreter destroyed - close after unbound ccs‚gV| dd¡D]"}|V| ¡D]}||Vq$q| dd¡D]"}|V| ¡D]}||VqTqB| dd¡D]z}|V| dd¡D]*}||}|V| ¡D]}||Vq¢qˆ| dd¡D]*}||}|V| ¡D]}||VqÚqÀqr| dd¡D]‚}|V| dd¡D].}||}|V| ¡D]}||Vq*q| dd¡D].}||}|V| ¡D]}||VqfqLqúdS)NrSrZr[)Ú_iter_close_action_setsÚ_iter_post_close_action_setsÚ_iter_use_action_sets)rCZcloseactionsZpostactionsZ useactionsÚactionsrrrÚiter_action_setssBz'ExhaustiveChannelTests.iter_action_setsccs||f}tdd|ƒgVtdd|ƒgVtdd|ƒtdd|ƒgVtdd|ƒgVtdd|ƒgVtdd|ƒtdd|ƒgV|D]<}|D]2}|D](}tdd|ƒtdd|ƒtdd|ƒgVqqˆq€|D]P}|D]F}|D]<}|D]2}tdd|ƒtdd|ƒtdd|ƒtdd|ƒgVqÚqÒqÊqÂdS)NrRrVrU©rM)rCrxr{Úinterpsr|Zinterp4rrrrÙ9s> ÿ ÿ þ ÿ ÿ þ ý üz,ExhaustiveChannelTests._iter_use_action_setsc csŒd}||f}dD]4}|rdnd}|D]}|D]}t|||ƒgVq,q$qdD]<} dD]2} |D](}|D]}t| d|ƒt| d|ƒgVqbqZqRqJdS)Nrxr£rYrXrWrVrUrÜ) rCrxr{ZendsrÝroÚoprrQZrecvopZsendoprVrUrrrr×js ÿ þz.ExhaustiveChannelTests._iter_close_action_setsccs.dD]$}tdd|ƒgVtdd|ƒgVqdS)N)rSr[rZrRrVrUrÜrÓrrrrØ}s ÿ ÿz3ExhaustiveChannelTests._iter_post_close_action_setscCs|D]}| ||¡qdSr)rv)rCÚfixrÚrPrrrÚrun_actions†sz"ExhaustiveChannelTests.run_actionsTrpcCsà| |j¡}| |j|j|j¡}| |¡|jdkrZt|j |j ||j|d}| ||¡n‚t ¡}t|jd|j ›dt|j ƒ›dt|ƒ›dt|jƒ›d|›d|›d|›dƒtt t |¡d ¡tt |¡ƒd }| ||¡dS)Nr4rpzB result = helpers.run_action( z, z!, hideclosed=zB, ) interpreters.channel_send(zR, result.pending.to_bytes(1, 'little')) interpreters.channel_send(z2, b'X' if result.closed else b'') r¨)rfre)rarQrbrrZr[rÑrBrvrsrPrtrÒrrŸr0r.ršrcrÉÚ from_bytesrzrÏ)rCrßrPrqrQrrurÉrrrrvŠsB ûþýüûúø ÷ þz!ExhaustiveChannelTests.run_actionc csBgd¢}|D]0\}}}dD] }dD]}t|||||ƒVq"qqdS)N))r4rr[)rr4r[)rxr{r[)rxr{r4)rSrZrÇri)rÂ)rCrrrZr[rÇrQrrrÚ iter_fixturesªs z$ExhaustiveChannelTests.iter_fixturescCst|rdnd}t||jdƒ}| ¡s4|j||ddn<| tj¡ |j||ddWdƒn1sf0YdS)NrYrXrSFrp)rMrQrÐrvrºrrK)rCrßrorÞrXrrrÚ_close·szExhaustiveChannelTests._closeNcCs.|dus|jdkrú| tj¡t |j¡Wdƒn1s@0Y| tj¡t |jd¡Wdƒn1sz0Y| tj¡t |j¡Wdƒn1s²0Y| tj¡ tj|jddWdƒn1sî0Yn0t|j dƒt|j dƒt|j dƒt|j dƒdS) Nr4rwTrnzz with helpers.expect_channel_closed(): interpreters.channel_recv(cid) zƒ with helpers.expect_channel_closed(): interpreters.channel_send(cid, b'spam') z{ with helpers.expect_channel_closed(): interpreters.channel_close(cid) z‡ with helpers.expect_channel_closed(): interpreters.channel_close(cid, force=True) ) rBrºrrKrzrsryr}r0r.)rCrßrrrrÚ_assert_closed_in_interpÀs*,*0z/ExhaustiveChannelTests._assert_closed_in_interpcCs|| |jj¡t|jjƒD]}t |j¡q| |¡dD]&}| |¡}|j dkrTq:| ||¡q:| d¡}| ||¡dS)N)rSrZr4Zfresh)rŽrtrer°rfrrzrsrärÎrB)rCrßrÌrrrrÚ_assert_closedÜs z%ExhaustiveChannelTests._assert_closedFc csÄd}| ¡D]¬}tƒ| ¡D]Œ}|d7}|dkr:dS|rl|dddkrTtƒt||d t|ƒ¡ƒn2|dddkrˆtdddtd ddtj ¡|||fVq|rtd ƒqtƒdS)Nrrhr¹éz({} actions)ú r²r_Ú.z---)rÛÚprintrâr=rør¶Ústdoutr()rCÚverboser¬rÚrßrrrÚ_iter_close_testsìs$ z(ExhaustiveChannelTests._iter_close_testscCsdt_| ¡D] \}}}qdS)NT)rÂrÃrì©rCr¬rßrÚrrrÚ_skim_close_tests sz(ExhaustiveChannelTests._skim_close_testsc Cs„| ¡D]v\}}}| d |||¡¡@| |j¡| ||¡|j|dd| |¡Wdƒn1sl0Y| ¡qdS)Nú {} {} {}Frn© rìrr=rÑrràrãrårÓrírrrÚ test_close s(z!ExhaustiveChannelTests.test_closec Cs„| ¡D]v\}}}| d |||¡¡@| |j¡| ||¡|j|dd| |¡Wdƒn1sl0Y| ¡qdS)NrïTrnrðrírrrÚtest_force_close s(z'ExhaustiveChannelTests.test_force_close)N)F)rFrGrHr•rÛrÙr×rØràrvrârãrärårìrîrñròrrrrrÖás(-1 rÖrR)N)N)5Úcollectionsrr_r´rrEr¶Útextwraprr&rr ÚtestrZtest.supportrÚ import_modulerrrr r`r,r0r-r5rLrMrcrvrrrr†ZTestCaser‡rŠrr½rÅrÏrÒrÚròrrrarmrµrÂrrÖrFr4rrrrÚst & 3$ 2?(;]b7Y:&ÿq@