python (3.11.7)
Browse
Usage
Versions
e_; d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl Z d dl
Z
d dl Z d dl m
Z
d dlmZ d dlmZ ej d Zd ZdAd ZdAd
Zej d Zd Zi fd
Z G d d edd Zej d Z G d d edd Z G d d edd Z dddZ d Z d Z d Z! G d d e j" Z# G d d!e j" Z$ G d" d#e j" Z% G d$ d%e# Z& G d& d'e# Z' G d( d)e# Z( G d* d+e# Z) G d, d-e# Z* G d. d/e# Z+ G d0 d1e# Z, G d2 d3e# Z- G d4 d5e# Z. G d6 d7e# Z/ G d8 d9e# Z0 G d: d; ed;d< Z1 e j2 d= G d> d?e# Z3e4d@k r e j5 dS dS )B )
namedtupleN)dedent)support)
import_helper)
script_helper_xxsubinterpretersc t j \ }}| dd }t d| d| d }|t |d fS )N
z
z-
import contextlib
with open(zg, 'w', encoding="utf-8") as spipe:
with contextlib.redirect_stdout(spipe):
z
utf-8encoding)ospipereplacer open)scriptrwindentedwrappeds P/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test__xxsubinterpreters.py_captured_scriptr st
799DAq~~d$899H
G DW--- -- c t | \ }}|5 t | || | cd d d S # 1 swxY w Y d S N)r interpreters
run_stringread)interprequestsharedr rpipes r _run_outputr# # s $W--MFE 777zz|| s 0AAAc | t j }t j |d D ] }t | r d S t d )NF)errorzinterp is not running)r
SHORT_TIMEOUTsleeping_retryr
is_running RuntimeError)r timeout_s r _wait_for_interp_to_runr, * sc '
#G5
9
9
9 4 4 " "6 * * EE 2333r c # d K t j \ } fd}t j | }| t d V t
|dd 5 }| d d d d n # 1 swxY w Y | d S )Nc ` t t d d d S )Nz7
# wait for "signal"
with open(zG, encoding="utf-8") as rpipe:
rpipe.read()
)r r r )r r s r runz_running.<locals>.run: sJ 00 0 0 ) ) r targetr r r done) r r threadingThreadstartr, r writejoin)r r r/ tspiper s ` @r _runningr: 7 s
799DAq $$$AGGIIIF### EEE
aw ' ' ' 5
F FFHHHHHs /BBBc ( t | || d S r ) _run_interp)idsourcer! s r
run_interpr? V s FF#####r c t | }t }|| k r6t |k rt t || d S t | || d S r )r r get_main get_currentr) execr )r= r> r! _mainnsmains r r< r< Z sx
F^^F " "D rzz # # % % - - VW FF33333r c 6 e Zd Zed Zd fd Z xZS ) Interpreterc t t || r|S t |t r | | S t r )
isinstancestrNotImplementedError)clsraws r from_rawzInterpreter.from_rawh s> c3 &J
S
!
! &3s88O% %r Nc t }||k r0|sd}n(|dk r"t d | |}nw|O|sd}n|dk rt d t |t j st | }n&|r|dk rd}|}nt }t | || }|S )NrE z)name mismatch (expected "main", got "{}")r z!name mismatch (unexpected "main")) r rA
ValueErrorformatrI
InterpreterIDcreatesuper__new__)rL namer= rE self __class__s r rU zInterpreter.__new__q s $$&&
::
N ?FFtLLN N NBB
^
F !DEEE b,"<==
4!//33 ' DBB $$&&BwwsD"-- r NN)__name__
__module__ __qualname__ classmethodrN rU
__classcell__rX s @r rG rG f sV & & [& r rG zname idc # @ K d V d S # t j $ r Y d S w xY wr )r ChannelClosedError r r expect_channel_closedrc s= +
*
s
c 2 e Zd Zd fd Zd Zd Zd Z xZS )
ChannelActionNc ` |sd}|sd}t | ||| }|S )NbothrE rT rU )rL actionendr rW rX s r rU zChannelAction.__new__ s= C FwwsFC88 r c | j dk r | j dvrt | j n;| j dv r | j dvrt | j nt | j | j dvrt | j d S )Nuse)sameoppositesendrecvclose force-close)rg rm rn ro rp )rE rm otherextra)ri rj rP r )rW argskwargss r __init__zChannelAction.__init__ s ;% x CCC *** D
[ 4
4
4x KKK *** L T[)) ) ; @ @ @ T[)) ) A @r c T | j dk r|S | j dk r
|dk rdndS | j S )Nrm rn ro rp rj rW rj s r resolve_endzChannelAction.resolve_end s: 8v J
X
#
# F]]66 68Or c | j dk r|S | j dk r |t |S | j dk r |t |S | j dk r#|j dk r|S |r
|j dk r|S t d S )Nrm rt ru rE )r r) rV )rW r rt ru s r resolve_interpz ChannelAction.resolve_interp s ;& M
[G
#
#}""L
[G
#
#}""L
[F
"
"{f$$
#5:// ""
#
"r rY )rZ r[ r\ rU rx r| r~ r^ r_ s @r re re sj
*
*
* # # # # # # #r re zaction end interpc > e Zd Zd
dd fd Zd Zd Zddd Z xZS ) ChannelStater Fclosedc N t | || }|S r rh )rL pendingr rW rX s r rU zChannelState.__new__ s! wwsGV44 r c P t | | j dz | j S N r typer r rW s r incrzChannelState.incr & tDzz$,*4;????r c P t | | j dz
| j S r r r s r decrzChannelState.decr r r Tforcec t | j r|r | j dk r| S t | |rdn| j d S )Nr Tr )r r r )rW r s r rr zChannelState.close sK ;
DLA - - tDzzu6!!$,tDDDDr )r )rZ r[ r\ rU r r rr r^ r_ s @r r r s % @ @ @@ @ @ " E E E E E E E E Er r zpending closedT
hideclosedc |j r|dk r|dk r
|j rd}nd}nd} t | ||| }|rdn.# t j $ r |s|s | }Y nw xY w|S )Nrl rp FT.)r r _run_actionr ra rr )cidri rj stater
expectfailresults r
run_actionr s | U??sf}} } JJ JJ
S&#u55 I * * Ms ; (A&%A&c |dk r|dk r/t | d | S |dk rv|j sA t | t d # t j $ r |cY S w xY wt | | S t | |dk r1i }|dv rd||< t j | fi | |
S |d k r5d
di}|dv rd||< t j | fi | |
d S t | ) Nrl ro spamrp zexpected ChannelEmptyErrorrr rp ro Trs r r ) r channel_sendr r channel_recv ExceptionChannelEmptyErrorr rP
channel_closerr )r ri rj r rw s r r r s
&== % %c7 3 3 3::<<
F]]=
$B --c222 $$@AAA $5 ! ! ! LLL!
))#... zz||# S// ! 7 " " " F3K"311&111{{}} = T " " " F3K"311&111{{{&&& s
A3 3BBc t D ]4} | dk r t | %# t $ r Y 1w xY wd S )Nr )r list_alldestroyr) r= s r clean_up_interpretersr so ##%%
77 $ $ $ $ D s ?
A A c t D ]2} t | # t j $ r Y /w xY wd S r )r channel_list_allchannel_destroyChannelNotFoundErrorr s r clean_up_channelsr sf ,,.. ( ( - - - -0 D s 8A
A
c e Zd Zd ZdS )TestBasec > t t d S r r r r s r tearDownzTestBase.tearDown) r N)rZ r[ r\ r rb r r r r ' s# r r c e Zd Zd Zd ZdS )IsShareableTestsc g d}|D ]\}| | 5 | t | d d d n # 1 swxY w Y ]d S )N)Nr spam
i)subTest
assertTruer is_shareable)rW
shareablesobjs r test_default_shareablesz(IsShareableTests.test_default_shareables3 s
4 4C c""
4
4 --c224 4 4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4 4 4s .AA A c G d d } G d dt }ddt dt t t t d| |d |d
g }|D ]i}| t
| 5 | t | d d d n # 1 swxY w Y jd S ) Nc e Zd Zd Zd ZdS )3IsShareableTests.test_not_shareable.<locals>.Cheesec || _ d S r rV )rW rV s r rx z<IsShareableTests.test_not_shareable.<locals>.Cheese.__init__D s
r c | j S r r r s r __str__z;IsShareableTests.test_not_shareable.<locals>.Cheese.__str__F s
y r N)rZ r[ r\ rx r rb r r Cheeser C s2
!
!
!
!
!
!
!
!r r c e Zd ZdS )5IsShareableTests.test_not_shareable.<locals>.SubBytesN)rZ r[ r\ rb r r SubBytesr I s 1 1r r TF.g Y@ Wensleydaler )
bytesNotImplementedr objectr r repr assertFalser r )rW r r not_shareablesr s r test_not_shareablez#IsShareableTests.test_not_shareableB sO ! ! ! ! ! ! ! ! 2 2 2 2 2u 2 2 2
}%%!! " " 4 4C d3ii((
4
4 --c224 4 4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4 4 4s .CC C N)rZ r[ r\ r r rb r r r r 1 s2
4
4
4 4 4 4 4 4r r c R e Zd Z fdZ fdZd Zd Zd Zd Zd Z d Z
d Z xZ S )
ShareableTypeTestsc t t | _ d S r )rT setUpr channel_creater rW rX s r r zShareableTypeTests.setUpe s+
..00r c t | j t d S r )r r r rT r r s r r zShareableTypeTests.tearDowni s5 $$TX...
r c t |D ]}| | 5 t | j | t | j }| || | t | t | d d d n # 1 swxY w Y d S r )r r r r r assertEqualassertIsr )rW valuesr gots r _assert_valuesz!ShareableTypeTests._assert_valuesm s 4 4C c""
4
4 ))$(C888"//99 c***
d3iic333
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4 4 4s BB,,B0 3B0 c dD ]}| | 5 t | j | t | j }| || d d d n # 1 swxY w Y d S )Nr )r r r r r r )rW r r s r test_singletonsz"ShareableTypeTests.test_singletonsx s ( (C c""
(
( ))$(C888"//99
c3'''
(
(
(
(
(
(
(
(
(
(
(
(
(
(
( ( (s AA<<B B c @ | dd| j g d S )Nr i' )r r r s r
test_typesz ShareableTypeTests.test_types s4 H r c ` | d t dd D d S )Nc 3 F K | ] }| d dd V dS ) littleT)signedN)to_bytes).0is r <genexpr>z0ShareableTypeTests.test_bytes.<locals>.<genexpr> sH 5 5 ! JJq(4J @ @ 5 5 5 5 5 5r )r ranger s r
test_bytesz ShareableTypeTests.test_bytes sH 5 5%*2s^^ 5 5 5 5 5 5 5 5r c 4 | g d d S )N)z hello worldu 你好世界 )r r s r test_strsz ShareableTypeTests.test_strs s# ? ? ?@@@@@r c | t j t dd t j t j dz
g d S )Nr r r )r itertoolschainr sysmaxsizer s r test_intzShareableTypeTests.test_int sV IOE"cNN-0[3;,:J,K M M N N N N Nr c T t j dz t j dz
ddz g}|D ]}| | 5 | t 5 t
| j | d d d n # 1 swxY w Y d d d n # 1 swxY w Y d S )Nr r )r r r assertRaises
OverflowErrorr r r )rW intsr s r test_non_shareable_intz)ShareableTypeTests.test_non_shareable_int s' K!O
[L1
tG
; ;A a
;
;&&}55 ; ; --dh:::; ; ; ; ; ; ; ; ; ; ; ; ; ; ;
;
;
;
;
;
;
;
;
;
;
;
;
;
;
; ; ;s5 B !B9 B B B B
B B #B )
rZ r[ r\ r r r r r r r r r r^ r_ s @r r r c s 1 1 1 1 1 4 4 4( ( ( 5 5 5A A AN N N ; ; ; ; ; ; ;r r c e Zd Zd Zd Zd ZdS ) ListAllTestsc t }t }| ||g d S r )r rA r r )rW rE idss r test_initialzListAllTests.test_initial sB $$&&##%% tf%%%%%r c t }t }t }t }| ||||g d S r )r rA rS r r rW rE firstsecondr s r test_after_creatingz ListAllTests.test_after_creating si $$&& ##%% $$&&##%% tUF 344444r c 2 t }t }t }t | t }| |||g d S r )r rA rS r r r r s r test_after_destroyingz"ListAllTests.test_after_destroying sz $$&& ##%% $$&& U#####%% tVn-----r N)rZ r[ r\ r r r
rb r r r r sA & & &
5 5 5. . . . .r r c e Zd Zd Zd ZdS )GetCurrentTestsc t }t }| || | |t j d S r )r rA rB r assertIsInstancerR )rW rE curs r test_mainzGetCurrentTests.test_main sY $$&&&&(( d### c<#=>>>>>r c v t }t }t |t d }t | }t \ }}| || | || d S )Nz
import _xxsubinterpreters as _interpreters
cur = _interpreters.get_current()
print(cur)
assert isinstance(cur, _interpreters.InterpreterID)
)
r rA rS r# r intstripr r assertNotEqual)rW rE r outr r+ expecteds r test_subinterpreterz#GetCurrentTests.test_subinterpreter s $$&& $$&&&& * # # #))++ "++-- 8 h''' C&&&&&r N)rZ r[ r\ r r rb r r r r s2 ? ? ? ' ' ' ' 'r r c e Zd Zd Zd ZdS ) GetMainTestsc t \ }t }| || | |t j d S r )r r rA r r rR )rW r rE s r test_from_mainzGetMainTests.test_from_main s[ !**,,
$$&& x((( dL$>?????r c t \ }t }t |t d }t | }| || d S )Nz
import _xxsubinterpreters as _interpreters
main = _interpreters.get_main()
print(main)
assert isinstance(main, _interpreters.InterpreterID)
)r r rS r# r r r r )rW r r r rE s r test_from_subinterpreterz%GetMainTests.test_from_subinterpreter s{ !**,,
$$&&&& * # # 399;; x(((((r N)rZ r[ r\ r r rb r r r r s5 @ @ @
)
)
)
)
)r r c ^ e Zd Zd Z ej d d Zd Zd Zd Z d Z
dS ) IsRunningTestsc t }| t | d S r )r rA r r( )rW rE s r r zIsRunningTests.test_main s9 $$&& //5566666r zFails on FreeBSDc t }| t | t | 5 | t | d d d n # 1 swxY w Y | t | d S r )r rS r r( r: r rW r s r r z"IsRunningTests.test_subinterpreter s $$&& 0088999
f
= = OOL 3 3F ; ; < < < = = = = = = = = = = = = = = = 008899999s .BBBc t }t |t d| d }| | d d S )Nz`
import _xxsubinterpreters as _interpreters
if _interpreters.is_running(zZ):
print(True)
else:
print(False)
True)r rS r# r r r )rW r r s r r z'IsRunningTests.test_from_subinterpreter sm $$&&&& *)/* * * # #
f-----r c t }t | | t 5 t | d d d d S # 1 swxY w Y d S r )r rS r r r) r( r" s r test_already_destroyedz%IsRunningTests.test_already_destroyed s $$&& V$$$
|
,
, , , # #F + + + , , , , , , , , , , , , , , , , , , A66A:=A:c | t 5 t d d d d d S # 1 swxY w Y d S Ni@B )r r) r r( r s r test_does_not_existz"IsRunningTests.test_does_not_exist s
|
,
, / / # #I . . . / / / / / / / / / / / / / / / / / / AA
Ac | t 5 t d d d d d S # 1 swxY w Y d S Nr )r rP r r( r s r test_bad_idzIsRunningTests.test_bad_id s
z
*
* ( ( # #B ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (r+ N) rZ r[ r\ r unittestskipr r r& r* r. rb r r r r s 7 7 7 X]%&&: : '&: . . ., , , / / /( ( ( ( (r r c 8 e Zd Zd Zd Zd Zd Zd Zd Zd Z dS ) InterpreterIDTestsc t dd }| t | d d S )Nr Tr )r rR r r rW r= s r
test_with_intz InterpreterIDTests.test_with_int s<
'
'$
'
7
7 R"%%%%%r c G d dt }t | d }| t | d d S )Nc e Zd Zd ZdS ).InterpreterIDTests.test_coerce_id.<locals>.Intc dS Nr rb r s r __index__z8InterpreterIDTests.test_coerce_id.<locals>.Int.__index__ rr NrZ r[ r\ r; rb r r Intr8 #
r r> Tr r )rJ r rR r r )rW r> r= s r test_coerce_idz!InterpreterIDTests.test_coerce_id sn #
'
'T
'
:
: R"%%%%%r c | t t j t | t t j d | t t j d | t t j d | t
t j d | t t j d d S Ng $@10s 10r l )r TypeErrorr rR r rP r r s r r. z InterpreterIDTests.test_bad_id s )\%?JJJ )\%?FFF )\%?FFF )\%?GGG *l&@"EEE - )CUKKKKKr c t }| t 5 t t | dz d d d d S # 1 swxY w Y d S Nr )r r r r) rR r r4 s r r* z&InterpreterIDTests.test_does_not_exist% s
(
(
*
*
|
,
, 4 4 & &s2ww{ 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s +A,,A03A0c t dd }| t | d d S Nr Tr rC )r rR r rJ r4 s r test_strzInterpreterIDTests.test_str* s<
'
'$
'
7
7 R$'''''r c t dd }| t | d d S )Nr Tr zInterpreterID(10))r rR r r r4 s r test_reprz InterpreterIDTests.test_repr. s=
'
'$
'
7
7 b#677777r c t }t t | }t }| ||k | ||k | |t | k | t | |k | |t t | k | t t | |k | |t t | dz k | |t t | k | |ddz k | |t d k | |dk | ||k | ||k | ||k | ||k d S N皙?r r infr )r rS rR r r floatr rJ rW id1id2id3s r
test_equalityz InterpreterIDTests.test_equality2 s !!##((S22!!## s
### s
### s3xx((( CC((( uSXX./// c#hh3./// c#hh# 55666 CHH
-... 4 ((( e ,--- ''' $$$ $$$ $$$ s
#####r N)
rZ r[ r\ r5 r@ r. r* rI rK rU rb r r r2 r2 s & & &
& & &L L L4 4 4
( ( (8 8 8$ $ $ $ $r r2 c d e Zd Zd Z ej d d Zd Zd Zd Z d Z
d Z d S )
CreateTestsc t }| |t j | |t d S r )r rS r rR assertInr r4 s r test_in_mainzCreateTests.test_in_mainK sR
"
" b,"<===
b,//1122222r z*enable this test when working on pystate.cc t }t d D ]J}t }t | | | K| t | d d S )Nd )setr r rS r addr len)rW seenr+ r= s r test_unique_idzCreateTests.test_unique_idQ sx uus A $$&&B $ $ $ HHRLLLL TC(((((r c H t j d fd}t j | }5 | d d d n # 1 swxY w Y | | t d S )Nc t d S r )r rS acquirerelease)r= locks r fz%CreateTests.test_in_thread.<locals>.f^ s2 $$&&B LLNNN LLNNNNNr r0 )r3 Lockr4 r5 r7 rY r r )rW rg r8 r= rf s @@r test_in_threadzCreateTests.test_in_thread[ s ~
A & & &
GGIII
b,//1122222s AA Ac d t \ }t }t |t d }t | }| t t |||h d S )Nz
import _xxsubinterpreters as _interpreters
id = _interpreters.create()
print(id)
assert isinstance(id, _interpreters.InterpreterID)
) r r rS r# r r r r r] )rW rE rR r rS s r test_in_subinterpreterz"CreateTests.test_in_subinterpreterj s %%''!!###v ' #))++ \ 2 2 4 455c37GHHHHHr c v t \ }t d fd}t j | }| | | t t |h d S )Nc t t d } t | d S )Nz
import _xxsubinterpreters as _interpreters
id = _interpreters.create()
print(id)
)r# r r r )r rR rS s r rg z6CreateTests.test_in_threaded_subinterpreter.<locals>.f{ s@ c6 + $ $ C
ciikk""CCCr r0 ) r r rS r3 r4 r5 r7 r r] )rW rE rg r8 rR rS s @@r test_in_threaded_subinterpreterz+CreateTests.test_in_threaded_subinterpreterw s %%''!!## # # # # # #
A & & & \ 2 2 4 455c37GHHHHHr c t t }g }t d D ]0}t }| | 1|D ] }t | t }| t t ||hz d S N )r] r r r rS appendr r rW beforer r+ r= s r test_after_destroy_allz"CreateTests.test_after_destroy_all s \**,,--q A $$&&B JJrNNNN % %B $ $ $ $
"
" \ 2 2 4 455v}EEEEEr c t t }t }t }t }t | t | t }| t t |||hz d S r )r] r r rS r r )rW rt rR rS rT r= s r test_after_destroy_somez#CreateTests.test_after_destroy_some s \**,,--!!##!!##!!## S!!! S!!!
"
" \ 2 2 4 455vS 7IJJJJJr N) rZ r[ r\ rZ r/ r0 ra ri rk rn ru rw rb r r rW rW I s 3 3 3 X]?@@) ) A@)
3
3
3 I I II I I& F F F K K K K Kr rW c J e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d S ) DestroyTestsc 8 t }t }t }| |t t | | |t | |t | |t d S r )r rS rY r r assertNotInrQ s r test_onezDestroyTests.test_one s !!##!!##!!##
c<0022333 S!!! l 3 3 5 5666
c<0022333
c<002233333r c t t }t }t d D ]0}t }| | 1| t t ||z |D ] }t | | t t | d S rp )r] r r r rS r^ r r rs s r test_allzDestroyTests.test_all s \**,,--eeq A $$&&B GGBKKKK \ 2 2 4 455v|DDD % %B $ $ $ $ \ 2 2 4 455v>>>>>r c ^ t \ t 5 t d d d n # 1 swxY w Y fd}t j | }| | d S )Nc t 5 t d d d d S # 1 swxY w Y d S r r r) r r )rE rW s r rg z!DestroyTests.test_main.<locals>.f s ""<00
+
+ $$T***
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+s AA Ar0 ) r r r r) r r3 r4 r5 r7 )rW rg r8 rE s ` @r r zDestroyTests.test_main s %%''
|
,
, ' ' & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' + + + + + +
A & & & s A A#&A#c t }t | | t 5 t | d d d d S # 1 swxY w Y d S r )r rS r r r) r4 s r r& z#DestroyTests.test_already_destroyed s
"
" R
|
,
, % % $ $ $ % % % % % % % % % % % % % % % % % %r' c | t 5 t d d d d d S # 1 swxY w Y d S r) r r s r r* z DestroyTests.test_does_not_exist s
|
,
, , , + + + , , , , , , , , , , , , , , , , , ,r+ c | t 5 t d d d d d S # 1 swxY w Y d S r- )r rP r r r s r r. zDestroyTests.test_bad_id s
z
*
* % % $ $ $ % % % % % % % % % % % % % % % % % %r+ c B t \ }t }t d| d }t || | t
t ||h d S )Nzo
import _xxsubinterpreters as _interpreters
try:
_interpreters.destroy(zD)
except RuntimeError:
pass
r r rS r r r r] )rW rE r= r s r test_from_currentz DestroyTests.test_from_current s %%''
"
" (* F+++ \ 2 2 4 455bzBBBBBr c t t \ }t }t }t d| d }t || | t
t ||h d S )NzZ
import _xxsubinterpreters as _interpreters
_interpreters.destroy()
r )rW rE rR rS r s r test_from_siblingz DestroyTests.test_from_sibling s %%''!!##!!## #& V,,, \ 2 2 4 455c{CCCCCr c t fd}t j | }| | d S )Nc < t d S r )r r r s r rg z.DestroyTests.test_from_other_thread.<locals>.f s $ $ $ $ $r r0 )r rS r3 r4 r5 r7 )rW rg r8 r= s @r test_from_other_threadz#DestroyTests.test_from_other_thread s`
"
" % % % % %
A & & & r c " t \ }t }t | 5 | t | d| d | t d| d 5 t | d d d n # 1 swxY w Y | t | d d d d S # 1 swxY w Y d S )NzInterp z& should be running before destruction.)msgz%Should not be able to destroy interp z while it's still running.) r r rS r: r r( r r) r )rW rE r s r test_still_runningz DestroyTests.test_still_running s %%'' $$&&
f
= = OOL 3 3F ; ; X& X X X
Z
Z
Z ""<'qv'q'q'q # s s
-
- $$V,,,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
OOL 3 3F ; ; < < < = = = = = = = = = = = = = = = = = =s7 ADB?3 D?C DC 0DD DN)
rZ r[ r\ r| r~ r r& r* r. r r r r rb r r ry ry s 4 4 4 ? ? ? % % % , , ,% % % C C C
D
D
D
=
=
=
=
=r ry c e Zd Z fdZd Zd Zd Z ej d Z d Z
d Z d Z d Z
d
Zd Zej dd
Zd Zd Zd Zd Zd Zd Zd Zd Zd Z e j d d Z xZ S )RunStringTestsc t t | _ d S r )rT r r rS r= r s r r zRunStringTests.setUp
s+
%%''r c t d \ }}|5 t | j | | }d d d n # 1 swxY w Y | |d d S )Nprint("it worked!", end="")
it worked!)r r r r= r r )rW r filer s r test_successzRunStringTests.test_success s '(EFF
# #DGV 4 4 4))++C
l+++++s 5AA Ac < t d \ }|5 fd}t j | }| | | }d d d n # 1 swxY w Y |d d S )Nr c H t j d S r )r r r= )r rW s r rg z(RunStringTests.test_in_thread.<locals>.f s! ''88888r r0 r )r r3 r4 r5 r7 r r )rW r rg r8 r r s ` @r ri z RunStringTests.test_in_thread s '(EFF
9
9
9
9
9
9 ***A
GGIII
FFHHH))++C
l+++++s AA;;A?A?c t d }t d \ }}|5 t || | }d d d n # 1 swxY w Y | |d d S )NF)isolatedz
import threading
def f():
print('it worked!', end='')
t = threading.Thread(target=f)
t.start()
t.join()
r )r rS r r r r )rW subinterpr r r s r test_create_threadz!RunStringTests.test_create_thread# s '''77 ' ) # #Iv 6 6 6))++C
l+++++s 0A,,A03A0c dd l }| dd 5 }| d | d}t d|j d| d }t | j | | d |
}| || d d d d S # 1 swxY w Y d S )
Nr zw+r r r zspam spam spam spam spamz
import os
try:
os.fork()
except RuntimeError:
with open('zE', 'w', encoding='utf-8') as out:
out.write('z')
) tempfileNamedTemporaryFiler6 flushr rV r r r= seekr r )rW r r r r contents r test_forkzRunStringTests.test_fork4 s+
(
(
(
@
@ 0D JJrNNN JJLLL1H
!% %-
F
# #DGV 4 4 4 IIaLLLiikkG Wh / / /# 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s B&CCCc t | j 5 | t 5 t | j d d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S )N
print("spam"))r: r= r r) r r r s r test_already_runningz#RunStringTests.test_already_runningJ s
dg
B B""<00
B
B '' AAA
B
B
B
B
B
B
B
B
B
B
B
B
B
B
B B B B B B B B B B B B B B B B B B Bs4 A5!A A5 A! !A5$A! %A55A9<A9c d}|t v r |dz
}|t v | t 5 t |d d d d d S # 1 swxY w Y d S )Nr r r )r r r r) r r4 s r r* z"RunStringTests.test_does_not_existO s
L))++++ !GB L))++++
|
,
, 9 9 # #B 8 8 8 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9s BBBc | t 5 t dd d d d d S # 1 swxY w Y d S )Nr r )r rP r r r s r
test_error_idz RunStringTests.test_error_idV s
z
*
* 9 9 # #B 8 8 8 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 AA Ac | t 5 t dd d d d d S # 1 swxY w Y d S )Nr r )r rD r r r s r r. zRunStringTests.test_bad_idZ s
y
)
) = = # #FO < < < = = = = = = = = = = = = = = = = = =r c | t 5 t | j d d d d d S # 1 swxY w Y d S r: r rD r r r= r s r test_bad_scriptz RunStringTests.test_bad_script^ s
y
)
) 1 1 # #DGR 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 !A A
A
c | t 5 t | j d d d d d S # 1 swxY w Y d S )Ns
print("spam")r r s r test_bytes_for_scriptz$RunStringTests.test_bytes_for_scriptb s
y
)
) ? ? # #DG-= > > > ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?r Nc # K | t j 5 }d V d d d n # 1 swxY w Y |P| t |j d d t | d S | t |j d || d S )N:r z{}: {})r r RunFailedErrorr rJ exceptionsplitrQ )rW exctyper caughts r assert_run_failedz RunStringTests.assert_run_failedf s
| :
;
; v EEE ; S!1 2 2 8 8 = =a @ \\
+
+
+
+
+
S!1 2 2 %__Wc : :
<
<
<
<
<s 377c | t 5 t | j d d d d d S # 1 swxY w Y d S )Nz print("spam")r SyntaxErrorr r r= r s r test_invalid_syntaxz"RunStringTests.test_invalid_syntaxq s
#
#K
0
0 = = # #DG^ < < < = = = = = = = = = = = = = = = = = =r c | t d 5 t | j d d d d d S # 1 swxY w Y d S )Nr zraise Exception("spam"))r r r r r= r s r test_failurezRunStringTests.test_failurev s
#
#Iv
6
6 H H # #DG-F G G G H H H H H H H H H H H H H H H H H H !A
AAc | t d 5 t | j d d d d d S # 1 swxY w Y d S )N42zraise SystemExit(42))r
SystemExitr r r= r s r test_SystemExitz RunStringTests.test_SystemExitz s
#
#J
5
5 E E # #DG-C D D D E E E E E E E E E E E E E E E E E Er c | t 5 t | j t d d d d n # 1 swxY w Y | t d 5 t | j t d d d d d S # 1 swxY w Y d S )NzG
import sys
sys.exit()
r zI
import sys
sys.exit(42)
)r r r r r= r r s r
test_sys_exitz RunStringTests.test_sys_exit~ sA
#
#J
/
/ # #DGV 5 . .
#
#J
5
5 # #DGV 5 . .
s# .AA A;.B66B:=B:c t j \ }}ddd d}t d| d }t | j || t
|d 5 }t j | }d d d n # 1 swxY w Y | |d d | |d d
| |d d |
|d
d S )N hams -1)r eggscheddarz
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 r ) r ) r r r r r r= r pickleloadr assertIsNonerW r r r! r channss r test_with_sharedz RunStringTests.test_with_shared sK wyy1
888
!T]] #dT""B # # # # # # # # # # # # # # #
FR((( FR((( H r*** "Y-(((((s !BB Bc t | j t d ddi}t d }t | j || t j \ }}t d| d }t | j | t
|d 5 }t j | }d d d n # 1 swxY w Y | |d d d | |d
d d | |d d d S ) 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(r r ns1r ns2)
r r r= r r r r r r r )rW r! r r r r r s r test_shared_overwritesz%RunStringTests.test_shared_overwrites s 1 * * &!
888wyy1 000
!T]] #dT""B # # # # # # # # # # # # # # #
E6*F333 E6*F333 FV,,,,,s ;C C #C c R t j \ }}ddi}t d| d }t | j || t
|d 5 }t j | }d d d n # 1 swxY w Y | |d d d S )NrZ s not __main__z
spam = 42
ns = dict(vars())
del ns['__builtins__']
import pickle
with open(r r )
r r r r r r= r r r r r s r #test_shared_overwrites_default_varsz2RunStringTests.test_shared_overwrites_default_vars s wyy1 o.
888
!T]] #dT""B # # # # # # # # # # # # # # #
J 99999s B BBc t j \ }}t | j t d| d t
|d 5 }t j | }d d d n # 1 swxY w Y t j \ }}t | j t d| d t
|d 5 }t j | }d d d n # 1 swxY w Y | d| |
d| | d| | d| d S )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
r z
eggs = False
ns = dict(vars())
del ns['__builtins__']
import pickle
with open(r r r ) r r r r r= r r r r rY r{ )rW r r r r r s r test_main_reusedz RunStringTests.test_main_reused s wyy1 1
1 1 1 * * !T]] $d+d##C $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ wyy1 1
1 1 1 * * !T]] $d+d##C $ $ $ $ $ $ $ $ $ $ $ $ $ $ $
fc""" %%%
fc"""
fc"""""s$ A99A= A=C<<D D c
t j \ }}t d| d }t | j | t
|d 5 }t j | }d d d n # 1 swxY w Y | d | d |
|di d d d dd d S ) Nz
spam = 42
ns = dict(vars())
ns['__builtins__'] = str(ns['__builtins__'])
import pickle
with open(r r __builtins__
__loader____main__r )rZ __annotations____doc__ __package____spec__r ) r r r r r r= r r r popr )rW r r r r r s r test_execution_namespace_is_mainz/RunStringTests.test_execution_namespace_is_main s( wyy1
000
!T]] #dT""B # # # # # # # # # # # # # # # ~
| " !
s A;;A?A?zblocking foreverc R t d }t j 5 }t j |d| }t j | 5 }| }d d d n # 1 swxY w Y d d d n # 1 swxY w Y | |d d S )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()
r r )r r temp_dirr make_script spawn_pythonwaitr )rW r dirnamefilenameprocretcodes r test_still_running_at_exitz)RunStringTests.test_still_running_at_exit s
&7$0(FKKH +H55
& ))++
&
&
&
&
&
&
&
&
&
&
&
&
&
&
& & & & & & & & & & & & & & & &
!$$$$$s5 +BA/# B/A3 3B6A3 7BB
B
r ) rZ r[ r\ r r ri r r
requires_forkr r r* r r. r r
contextlibcontextmanagerr r r r r r r r r r r/ r0 r r^ r_ s @r r r s ( ( ( ( (, , , , , ,, , ," W 0 0 0*B B B
9 9 99 9 9= = =1 1 1? ? ? < < < <= = =
H H HE E E ) ) )8 - - -<: : :& # # #B 8 X]%&&% % '&% % % % %r r c D e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) ChannelIDTestsc t dd }| t | d | |j d d S )Nr Tr rg )r _channel_idr r rj rW r s r test_default_kwargsz"ChannelIDTests.test_default_kwargs3 sT &&r&66 S2&&& &)))))r c < t ddd }| |j d t dddd }| |j d t ddd }| |j d t dddd }| |j d t dddd }| |j d
d S ) Nr Tro r ro Fro rp r rp r rp )rp ro r rg )r r r rj r s r test_with_kwargsz ChannelIDTests.test_with_kwargs9 s &&rD&AA &)))&&r5&MM &)))&&rD&AA &)))&&r5&MM &)))&&r4t&LL &)))))r c G d dt }t | d }| t | d d S )Nc e Zd Zd ZdS )*ChannelIDTests.test_coerce_id.<locals>.Intc dS r: rb r s r r; z4ChannelIDTests.test_coerce_id.<locals>.Int.__index__K r< r Nr= rb r r r> r J r? r r> Tr r )rJ r r r r )rW r> r s r r@ z ChannelIDTests.test_coerce_idI sn # &&ssuuD&99 S2&&&&&r c | t t j t | t t j d | t t j d | t t j d | t
t j d | t t j d d S rB )r rD r r r rP r r s r r. zChannelIDTests.test_bad_idQ s )\%=vxxHHH )\%=tDDD )\%=tDDD )\%=uEEE *l&>CCC - )A5IIIIIr c | t 5 t ddd d d d d S # 1 swxY w Y d S )Nr Fro rp )r rP r r r s r test_bad_kwargsz ChannelIDTests.test_bad_kwargsY s
z
*
* A A $ $Re% $ @ @ @ A A A A A A A A A A A A A A A A A As AA
A
c t }| t j 5 t t | dz d d d d S # 1 swxY w Y d S rF )r r r r r r r s r r* z"ChannelIDTests.test_does_not_exist] s ))++
| @
A
A 3 3 $ $SXX\ 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s +A11A58A5c t dd }| t | d d S rH )r r r rJ r s r rI zChannelIDTests.test_strb s< &&r&66 S4(((((r c t dd }| t | d t ddd }| t | d t ddd }| t | d t dddd }| t | d d S )
Nr Tr z
ChannelID(10)r zChannelID(10, send=True)r zChannelID(10, recv=True)r )r r r r r s r rK zChannelIDTests.test_reprf s &&r&66 cO444&&rD&AA c$>???&&rD&AA c$>???&&r4t&LL cO44444r c t }t t | }t }| ||k | ||k | |t | k | t | |k | |t t | k | t t | |k | |t t | dz k | |t t | k | |ddz k | |t d k | |dk | ||k | ||k | ||k | ||k d S rM )r r r r r rP r rJ )rW cid1cid2cid3s r rU z ChannelIDTests.test_equalitys s **,,''D 22**,, %%% %%% D )*** D T)*** c$ii 0 00111 c$ii((D0111 s4yy!1!1C!77888 SYY /000 D ))) u -... ((( &&& &&& &&& %%%%%r N) rZ r[ r\ r r r@ r. r r* rI rK rU rb r r r r 1 s * * * * * * ' ' 'J J JA A A3 3 3
) ) ) 5 5 5& & & & &r r c e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zd Zd Zd Z ej d d Zd Zd Zd Z d Z d Z d Z d Z d Z!d Z"d Z#d! Z$d" Z%d# Z&d$ Z'd% Z(d& Z)d'S )( ChannelTestsc x t }| |t j d S r )r r r ChannelIDr s r test_create_cidz ChannelTests.test_create_cid s2 ))++ c<#9:::::r c t }t }t }t }t }| |t | dz | |t | dz | t | t | z
|||h d S rF )r r r r r r] )rW rt rR rS rT afters r test_sequential_idsz ChannelTests.test_sequential_ids s ..00))++))++))++ --// c#hhl+++ c#hhl+++ Uc&kk1Cc?CCCCCr c t }t |t d }t | }t }t |t d }t | }| |t | dz d S )Nz
import _xxsubinterpreters as _interpreters
cid = _interpreters.channel_create()
print(cid)
r )r rS r# r r r r )rW rR r r
rS r s r test_ids_globalz ChannelTests.test_ids_global s !!###v '
399;; !!###v '
399;; s4yy1}-----r c t }t |d }t |d }| |g | |g d S )NTro F)r r channel_list_interpretersr )rW r send_interps recv_interpss r #test_channel_list_interpreters_nonez0ChannelTests.test_channel_list_interpreters_none sx K))++#==c=MM #==c=NN r*** r*****r c t }t }t |d t |d }t |d }| ||g | |g t }t |t d| d t |d }t |d }| ||g | ||g d S )Nro Tr Fe
import _xxsubinterpreters as _interpreters
obj = _interpreters.channel_recv(r ) r rA r r r r rS r# r )rW interp0r r r interp1s r $test_channel_list_interpreters_basicz1ChannelTests.test_channel_list_interpreters_basic sK 6 ''))))++!!#v...#==c=MM #==c=NN y111 r*** %%''GV %.1% % %
$==c=MM #==c=NN y111 y11111r c t }t }t }t }t }t |d t |t
d| d t |t
d| d t |t
d| d t |d }t |d }| t | ||h | t | ||h d S ) Nro _
import _xxsubinterpreters as _interpreters
_interpreters.channel_send(z, "send")
r! r Tr F)
r rA rS r r r# r r r r] )rW r" r# interp2interp3r r r s r 'test_channel_list_interpreters_multiplez4ChannelTests.test_channel_list_interpreters_multiple s M '')) %%'' %%'' %%''))++!!#v...GV %(+% % % GV %.1% % % GV %.1% % % $==c=MM #==c=NN \**Wg,>??? \**Wg,>?????r c t }t }t }t |d t |t
d| d t |d }t |d }| ||g | ||g t | t |d }t |d }| ||g | |g d S )Nro r! r Tr F)
r rA rS r r r# r r r r rW r" r# r r r s r (test_channel_list_interpreters_destroyedz5ChannelTests.test_channel_list_interpreters_destroyed s_ M '')) %%''))++!!#v...GV %.1% % %
$==c=MM #==c=NN y111 y111 W%%%#==c=MM #==c=NN y111 r*****r c t }t }t }t }t |d t |t
d| d t |d t |t
d| d t |d }t |d }| t | d | t | d t
|d t |d }t |d }| t | d | t | d t |t
d
| d t |d }t |d }| t | d | ||g d S ) Ndatar! r Tr Fr r r b
import _xxsubinterpreters as _interpreters
_interpreters.channel_release() r rA rS r r r# r r r r_ channel_release)rW r" r# r' r r r s r 'test_channel_list_interpreters_releasedz4ChannelTests.test_channel_list_interpreters_released s H '')) %%'' %%''))++!!#v...GV %.1% % % !!#v...GV %.1% % %
$==c=MM #==c=NN \**A... \**A... $$St$444#==c=MM #==c=NN \**A... \**A... GV %+.% % %
$==c=MM #==c=NN \**A... y11111r c V t }t }t }t |d t |d }t |d }| t | d | t | d t |d | t j
5 t |d d d d n # 1 swxY w Y | t j
5 t |d d d d d S # 1 swxY w Y d S )Nro Tr Fr r r ) r rA rS r r r r r_ r r ra r+ s r %test_channel_list_interpreters_closedz2ChannelTests.test_channel_list_interpreters_closed) s F '')) %%''))++!!#v... $==c=MM #==c=NN \**A... \**A... ""3d"333
| >
?
? C C 2 23T 2 B B B C C C C C C C C C C C C C C C
| >
?
? D D 2 23U 2 C C C D D D D D D D D D D D D D D D D D Ds$ ! E
EE4 F F"%F"c t }t }t }t |d t |d }t |d }| t | d | t | d t |d | t j
5 t |d d d d n # 1 swxY w Y t |d }| t | d t |t d| d | t j
5 t |d d d d n # 1 swxY w Y | t j
5 t |d d d d d S # 1 swxY w Y d S ) Nro Tr Fr r `
import _xxsubinterpreters as _interpreters
_interpreters.channel_close(, force=True)
)
r rA rS r r r r r_ r r ra r# r r+ s r .test_channel_list_interpreters_closed_send_endz;ChannelTests.test_channel_list_interpreters_closed_send_end? s Q '')) %%''))++!!#v... $==c=MM #==c=NN \**A... \**A... ""3T"222
| >
?
? C C 2 23T 2 B B B C C C C C C C C C C C C C C C $==c=NN \**A... GV %),% % %
| >
?
? C C 2 23T 2 B B B C C C C C C C C C C C C C C C
| >
?
? D D 2 23U 2 C C C D D D D D D D D D D D D D D D D D Ds6 ! E
EE G==HH' IIIc t }d}t || t | }| || | || d S Nr )r r r r r assertIsNot)rW r origr s r test_send_recv_mainz ChannelTests.test_send_recv_mainc ss ))++!!#t,,,'',, d### d#####r c r t }t |t d }d S )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
)r rS r# r )rW rR r s r test_send_recv_same_interpreterz,ChannelTests.test_send_recv_same_interpreterl s9 !!###v ' r c t }t }t |t d| d }t | }| |d d S )Nr& , b'spam')
r )r r rS r# r r r )rW r rR r r s r %test_send_recv_different_interpretersz2ChannelTests.test_send_recv_different_interpretersx s ))++!!###v '(+' ' ' '',, g&&&&&r c T t fd}t j | }| t d | t }| |d d S )Nc t } n*# t j $ r t j d Y nw xY wFt | d S )NTrN )r r r timesleepr )r r s r rg z8ChannelTests.test_send_recv_different_threads.<locals>.f su
$$&33C88C#5 $ $ $JsOOOOO$
$
% %c3 / / / / /s #AAr0 r ) r r r3 r4 r5 r r7 r r )rW rg r8 r r s @r test_send_recv_different_threadsz-ChannelTests.test_send_recv_different_threads s ))++ 0 0 0 0 0
A & & & !!#w/// '',, g&&&&&r c t t d fd}t j | }| t d | t }| |d d S )Nc
P t t d d d d S )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')
)r# r )r rR r s r rg zIChannelTests.test_send_recv_different_interpreters_and_threads.<locals>.f sL c6 +
;> + + -0 + + + $ $ CCCr r0 r eggs)
r r rS r3 r4 r5 r r7 r r )rW rg r8 r r rR r s @@@r 1test_send_recv_different_interpreters_and_threadsz>ChannelTests.test_send_recv_different_interpreters_and_threads s ))++!!##
A & & & !!#w/// '',, g&&&&&r c | t j 5 t dd d d d d S # 1 swxY w Y d S )Nr r )r r r r r s r test_send_not_foundz ChannelTests.test_send_not_found s
| @
A
A 3 3 % %b' 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s A A
A
c | t j 5 t d d d d d S # 1 swxY w Y d S r: )r r r r r s r test_recv_not_foundz ChannelTests.test_recv_not_found s
| @
A
A * * % %b ) ) ) * * * * * * * * * * * * * * * * * *s AA A c t }| t j 5 t | d d d d S # 1 swxY w Y d S r )r r r r r r s r test_recv_emptyz ChannelTests.test_recv_empty s ))++
| =
>
> + + % %c * * * + + + + + + + + + + + + + + + + + +s A!!A%(A%c v t }t }t || }t |d t |d t |d t |d t || }t || }t | }t || }t || }| || | |d | |d | |d | |d | || d S )Nr r rI )r r r r r r r ) rW defaultr obj1obj2obj3obj4obj5obj6s r test_recv_defaultz ChannelTests.test_recv_default st (())++((g66!!#t,,,!!#q)))!!#w///!!#w///((g66((g66((--((g66((g66
dG$$$
dD!!! q!!! w''' w'''
dG$$$$$r c | t }t }t |t d t |j }t | }| |d | | d d S )Nz
import _xxsubinterpreters as _interpreters
print(cid.end)
_interpreters.channel_send(cid, b'spam')
r r ro )
r r rS r# r dictro r r r rW r r r r s r test_run_string_arg_unresolvedz+ChannelTests.test_run_string_arg_unresolved s ))++ $$&&&& * # #
SX '',, g&&& f-----r z(disabled until high-level channels existc t }t |d }t }t |t d t
|j }t | }| |d | |
d d S )NT)_resolvez
import _xxsubinterpreters as _interpreters
print(chan.id.end)
_interpreters.channel_send(chan.id, b'spam')
)r r ro ) r r r rS r# r r[ ro r r r r\ s r test_run_string_arg_resolvedz)ChannelTests.test_run_string_arg_resolved s ))++&&sT&:: $$&&&& * # #
ch ! ! '',, g&&& f-----r c t }t |d t | t | | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S Nr rI r r r r r r ra r s r test_close_single_userz#ChannelTests.test_close_single_user sb ))++!!#w///!!#&&&""3'''
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +$ B00B47B4DD Dc t }t }t }t |t d| d t |t d| d t | | t j 5 }t |t d| d d d d n # 1 swxY w Y | dt |j
| t j 5 }t |t d| d d d d n # 1 swxY w Y | dt |j
d S )Nr& r@ z_
import _xxsubinterpreters as _interpreters
_interpreters.channel_recv(r z,
_interpreters.channel_send(z, b'spam')
ra ) r r rS r r r r r rY rJ r )rW r rR rS cms r test_close_multiple_usersz&ChannelTests.test_close_multiple_users s[ ))++!!##!!## V -(+- - - & & V -(+- - - & & ""3'''
| :
;
; r # #C 1,/1 1 1 * *
*C ,=,=>>>
| :
;
; r # #C 1,/1 1 1 * *
*C ,=,=>>>>>s$ -DD D(-F!!F%(F%c z t }t |d t | t | | t j 5 t | d d d d S # 1 swxY w Y d S r9 rc r s r test_close_multiple_timesz&ChannelTests.test_close_multiple_times s ))++!!#w///!!#&&&""3'''
| >
?
? , , & &s + + + , , , , , , , , , , , , , , , , , ,s B00B47B4c g d}|D ]C\ }}| ||f 5 t }t |d t | t ||| | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d n # 1 swxY w Y d d d n # 1 swxY w Y Ed S )N))FFTF)FT)TTr r rI )r r r r r r r ra )rW testsro rp r s r test_close_emptyz ChannelTests.test_close_empty& s
3
3JD$ tTl++
3
3"1133 ))#w777 ))#... **3T*EEE&&|'FGG < < --c7;;;< < < < < < < < < < < < < < <&&|'FGG 3 3 --c2223 3 3 3 3 3 3 3 3 3 3 3 3 3 3
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3sZ B D?/ C D?C D? C "D?D( D?(D, ,D?/D, 0D??E E c t }t |d t |d | t j 5 t | d d d n # 1 swxY w Y t | t |d d S )Nr r rI r r r r ChannelNotEmptyErrorr r r s r %test_close_defaults_with_unused_itemsz2ChannelTests.test_close_defaults_with_unused_items9 s ))++!!#w///!!#v...
| @
A
A , , & &s + + + , , , , , , , , , , , , , , ,!!#&&&!!#w/////s /BB Bc T t }t |d t |d | t j 5 t |d d d d n # 1 swxY w Y t | t |d t | t | t |d d S )Nr r Trp rI rp r s r *test_close_recv_with_unused_items_unforcedz7ChannelTests.test_close_recv_with_unused_items_unforcedC s5 ))++!!#w///!!#v...
| @
A
A 7 7 & &s & 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7!!#&&&!!#w///!!#&&&!!#&&&""3T"22222s / BB B c t }t |d t |d t |d | t j 5 t |d d d d n # 1 swxY w Y t | t | | t j 5 t | d d d d S # 1 swxY w Y d S )Nr r Tr rI r r r r r ra r r s r *test_close_send_with_unused_items_unforcedz7ChannelTests.test_close_send_with_unused_items_unforcedP s ))++!!#w///!!#v...""3T"222
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4!!#&&&!!#&&&
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +s$ B33B7:B7D99D= D=c V t }t |d t |d | t j 5 t |dd d d d n # 1 swxY w Y t | t |d t | t | t |d d S )Nr r Tr rI rt rp r s r *test_close_both_with_unused_items_unforcedz7ChannelTests.test_close_both_with_unused_items_unforced] sH ))++!!#w///!!#v...
| @
A
A B B & &sD & A A A B B B B B B B B B B B B B B B!!#&&&!!#w///!!#&&&!!#&&&""3T"22222s / BB B c & t }t |d t |d t |dd | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S )Nr r Tr rI rw r s r (test_close_recv_with_unused_items_forcedz5ChannelTests.test_close_recv_with_unused_items_forcedj k ))++!!#w///!!#v...""3T">>>
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +$ B44B8;B8 DD
D
c & t }t |d t |d t |dd | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S )Nr r Tr rI rw r s r (test_close_send_with_unused_items_forcedz5ChannelTests.test_close_send_with_unused_items_forcedu r} r~ c ( t }t |d t |d t |ddd | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S )Nr r Tr rI rw r s r (test_close_both_with_unused_items_forcedz5ChannelTests.test_close_both_with_unused_items_forced sm ))++!!#w///!!#v...""3TD"III
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +s$
B55B9<B9 DD D c t }t | | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S r9 )r r r r ra r r r s r test_close_never_usedz"ChannelTests.test_close_never_used s8 ))++""3'''
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +$ A;;A?A?%C
CCc > t }t |d t }t |t d| d | t j 5 t | d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S )Nr r5 r6 )
r r r rS r r r ra r r rW r r s r !test_close_by_unassociated_interpz.ChannelTests.test_close_by_unassociated_interp s ))++!!#w/// $$&& 0),0 0 0 ) )
| >
?
? + + % %c * * * + + + + + + + + + + + + + + +
| >
?
? , , & &s + + + , , , , , , , , , , , , , , , , , ,s$ C CC*DDDc t }t |d t |d t |d t | t |d | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S )Nr Tr rI rc r s r -test_close_used_multiple_times_by_single_userz:ChannelTests.test_close_used_multiple_times_by_single_user s ))++!!#w///!!#w///!!#w///!!#&&&""3d"333
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +s$ C((C,/C,D::D>D>c t }| t j 5 t dd d d d n # 1 swxY w Y t | | t j 5 t |d d d d d S # 1 swxY w Y d S )Nr Tr )r r r r r r ra r s r .test_channel_list_interpreters_invalid_channelz;ChannelTests.test_channel_list_interpreters_invalid_channel sg ))++
| @
A
A D D 2 24d 2 C C C D D D D D D D D D D D D D D D ""3'''
| >
?
? C C 2 23T 2 B B B C C C C C C C C C C C C C C C C C Cs# A""A&)A&& CCCc t }| t 5 t | d d d d S # 1 swxY w Y d S r )r r r rD r r s r +test_channel_list_interpreters_invalid_argsz8ChannelTests.test_channel_list_interpreters_invalid_args s ))++
y
)
) 8 8 2 23 7 7 7 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8s A A #A N)*rZ r[ r\ r r r r r$ r) r, r1 r3 r7 r< r> rA rF rJ rL rN rP rY r] r/ r0 r` rd rh rj rn rr ru rx rz r| r r r r r r r rb r r r r sj ; ; ; D D D. . .&+ + +2 2 2,@ @ @4+ + +.)2 )2 )2VD D D, D D DH$ $ $
' ' '' ' '(' ' '83 3 3* * *+ + +
% % %*
.
.
.$ X]=>>. . ?>.$ + + +? ? ?0, , ,3 3 3&0 0 0 3 3 3 + + + 3 3 3 + + + + + + + + ++ + + , , , + + + C C C8 8 8 8 8r r c P e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d S ) ChannelReleaseTestsc $ t }t |d t | t |dd | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S Nr Tr rI r r r r r0 r ra r s r test_single_userz$ChannelReleaseTests.test_single_user si ))++!!#w///!!#&&&$$St$$???
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +s$ B33B7:B7 DD D c
t }t }t }t |t d| d t |t d| d| d }t |t d| d | | d d S ) Nr& r@ r! z,)
_interpreters.channel_release(z+)
print(repr(obj))
z+
_interpreters.channel_release(r zb'spam')r r rS r r r# r r )rW r rR rS r s r test_multiple_usersz'ChannelReleaseTests.test_multiple_users s ))++!!##!!## V -(+- - - & & #v '.1' ' ,/' ' ' V -+.- - - & &
i00000r c t }t |d t | t | | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S rb r r s r test_no_kwargsz"ChannelReleaseTests.test_no_kwargs
sb ))++!!#w///!!#&&&$$S)))
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +re c t }t |d t | t |dd | t j 5 t |dd d d d d S # 1 swxY w Y d S )Nr Tr r r s r test_multiple_timesz'ChannelReleaseTests.test_multiple_times s ))++!!#w///!!#&&&$$St$$???
| >
?
? D D ( (4d ( C C C D D D D D D D D D D D D D D D D D Ds B66B:=B:c t }t |d t |d t |dd | t j 5 t | d d d d S # 1 swxY w Y d S )Nr r Tr )r r r r0 r ra r r s r test_with_unused_itemsz*ChannelReleaseTests.test_with_unused_items s ))++!!#w///!!#v...$$St$$???
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +s B44B8;B8c t }t | | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S r9 )r r r0 r ra r r r s r test_never_usedz#ChannelReleaseTests.test_never_used' s8 ))++$$S)))
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +r c 0 t }t |d t }t |t d| d t | }t | | t j 5 t |d d d d n # 1 swxY w Y |
|d d S )Nr r/ r rI ) r r r rS r r r r0 r ra r )rW r r r s r test_by_unassociated_interpz/ChannelReleaseTests.test_by_unassociated_interp0 s> ))++!!#w/// $$&& 0+.0 0 0 ) ) '',,$$S)))
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 g&&&&&s
C55C9<C9c
l t }t }t |t d| d| d | t j 5 t | d d d d S # 1 swxY w Y d S )Nze
import _xxsubinterpreters as _interpreters
obj = _interpreters.channel_send(z5, b'spam')
_interpreters.channel_release(r )r r rS r r r ra r r s r test_close_if_unassociatedz.ChannelReleaseTests.test_close_if_unassociated? s ))++ $$&& 0.10 0 ,/0 0 0 ) )
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +s B))B-0B-c p t }t |d t | t |d t |d t | }| |d d S )Nr Tr )r r r r r0 r )rW r r s r test_partiallyz"ChannelReleaseTests.test_partiallyL s ))++!!#t,,,!!#&&&!!#w///$$St$444'',, g&&&&&r c t }t |d t |d t |d t | t |dd | t j 5 t |d d d d n # 1 swxY w Y | t j 5 t | d d d d S # 1 swxY w Y d S r r r s r 'test_used_multiple_times_by_single_userz;ChannelReleaseTests.test_used_multiple_times_by_single_userW s ))++!!#w///!!#w///!!#w///!!#&&&$$St$$???
| >
?
? 4 4 % %c7 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
| >
?
? + + % %c * * * + + + + + + + + + + + + + + + + + +s$ C))C-0C-D;;D?D?N)
rZ r[ r\ r r r r r r r r r r rb r r r r s " + + +1 1 1( + + +D D D+ + ++ + +
'
'
' + + + ' ' ' + + + + +r r c e Zd ZdZ fdZed Zed Zd ZddZ d Z
d Z d
Z d Z
d Zd
Z xZS )ChannelCloseFixtureFc | j ri }net | }t | }t | }|j ||j ||j |i}|sd}t | ||||| }t
|_ t |_ ||_
|S )Nrm ) QUICKrG rN rV rT rU r] _preppedr _state_known) rL rj r rt ru creatorknownrW rX s r rU zChannelCloseFixture.__new__l s 9
EE ))&11F ((//E ((//E V
E
EE
GwwsCwGG
"nn r c | j S r r r s r r zChannelCloseFixture.state s
{r c | j S # t $ r> | | j }| | | _ | j cY S w xY wr )_cidAttributeError_get_interpreterr _new_channel)rW r s r r zChannelCloseFixture.cid sb 9 ++DL99G ))'22DI9 s AAAc Z | | }| | |S r )r _prep_interpreterr" s r get_interpreterz#ChannelCloseFixture.get_interpreter s. &&v.. v&&&
r Nc v || j }|dk r| j j dk rdS t | j j S )Nrp ro F)rj r r boolr{ s r expect_closed_errorz'ChannelCloseFixture.expect_closed_error s> ;(C &==TZ .& 8 85DJ%&&&r c 0 | | d S r )r r" s r prep_interpreterz$ChannelCloseFixture.prep_interpreter s v&&&&&r c || _ d S r r )rW ri r s r
record_actionz!ChannelCloseFixture.record_action s
r c > t t d S r r r s r clean_upz ChannelCloseFixture.clean_up r r c |j dk rt S t }t |j d| d t | | _ | j S )NrE a
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
)rV r r r? r= r r )rW r chs r r z ChannelCloseFixture._new_channel s <6 ! ! ..00 0 ,,..B wz $
24 $ $ $
%11"55DIyr c |dv r| j S |dk r| j S |dk r| j S |} | j | }n)# t $ r t | x}| j |< Y nw xY w|S )N)rm r rt ru )r rt ru r KeyErrorrG )rW r rV s r r z$ChannelCloseFixture._get_interpreter s ' ' ';
w
:
w
: D
? T*
?
?
?-8->->>T***
?Ms
7 #A A c |j | j v rd S | j |j |j dk rd S t |j d| j d d S )NrE a
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^ rV r? r r" s r r z%ChannelCloseFixture._prep_interpreter s{ 9
% % F
&)$$$ ;& F69 15 r r )rZ r[ r\ r rU propertyr r r r r r r r r r r^ r_ s @r r r e s
E * X X
' ' ' '' ' '
r r z end interp other extra creatorz%these tests take several hours to runc r e Zd Z d Zd Zd Zd Zd ZdddZd Z d
Z
dd Z d
Z ddZ
d Zd Zd Zd S )ExhaustiveChannelTestsc # r K g V | dd D ]$}|V | D ] }||z V
%| dd D ]$}|V | D ] }||z V
%| dd D ]}|V | dd D ])}||z }|V | D ] }||z V
*| dd D ])}||z }|V | D ] }||z V
*| dd D ]}|V | dd D ])}||z }|V | D ] }||z V
*| dd D ])}||z }|V | D ] }||z V
*d S )Nrm rt ru )_iter_close_action_sets _iter_post_close_action_sets_iter_use_action_sets)rW closeactions postactions
useactionsactionss r iter_action_setsz'ExhaustiveChannelTests.iter_action_sets s ! 8 8 I I 1 1L # @ @ B B
1
1 "[00000
1 8 8' J J 1 1L # @ @ B B
1
1 "[00000
1 44VWEE 0 0J $ < <VW M M
0
0 $|3
#'#D#D#F#F 0 0K!K/////0 $ < <Wg N N
0
0 $|3
#'#D#D#F#F 0 0K!K/////0
0
44WgFF 0 0J $ < <VW M M
0
0 $|3
#'#D#D#F#F 0 0K!K/////0 $ < <Wg N N
0
0 $|3
#'#D#D#F#F 0 0K!K/////0
0 0 0r c # x K ||f}t dd| gV t dd| gV t dd| t dd| gV t dd| gV t dd| gV t dd| t dd| gV |D ]@}|D ];}|D ]6}t dd| t dd| t dd| gV 7<A|D ]U}|D ]P}|D ]K}|D ]F}t dd| t dd| t dd| t dd| gV GLQVd S )Nrl rp ro re )rW r# r' interpsr( interp4s r r z,ExhaustiveChannelTests._iter_use_action_sets. s7 G$
% 1 1
% 1 1
% 1 1 % 1 1
% 1 1
% 1 1
% 1 1 % 1 1 G"
& G%eVW==%eVW==%eVW==
G"
& G#* )% A A )% A A )% A A )% A A
r c
# K d}||f}dD ]&}|rdnd}|D ]}|D ]}t ||| gV 'dD ]5} dD ]0}
|D ]+} |D ]&} t | d| t |
d| gV ',16d S )Nr rl rs rr rq rp ro r )
rW r# r' endsr r opr rj recvopsendoprp ro s
r r z.ExhaustiveChannelTests._iter_close_action_sets_ s G$" E"'4 WB!
C%b#v66
/ F2
# D ' )&&$ ? ? )&&$ ? ?
r c # d K dD ]*}t dd| gV t dd| gV +d S )N)rm ru rt rl rp ro r r" s r r z3ExhaustiveChannelTests._iter_post_close_action_setsr sl 0 F eVV44
eVV44
r c < |D ]}| || d S r )r )rW fixr ri s r run_actionsz"ExhaustiveChannelTests.run_actions{ s2 ) )F OOC ( ( ( ( ) )r Tr c * | |j }| |j |j |j }| | |j dk r;t |j |j
||j | }| || d S t }t |j d|j dt# |j
dt# | dt# |j d| d| d| d t% t& t | d t- t |
}| || d S ) NrE r zB
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 )r r )r| rj r~ r rt ru r rV r r ri r r r r r? r= r r r
from_bytesr r )rW r ri r rj r r r s r r z!ExhaustiveChannelTests.run_action s ))&&sz39ciHH V$$$ ;&
% F
ff - - - - - ..00D vy
#W
#
# &-((
#
# #YY
#
#
#)__
#
# !+
#
# ,0
#
# ,0
#
#
#
"|'@'@'F'FQQL 5 5d ; ;<< F
ff - - - - -r c
# b K g d}|D ]%\ }}}dD ] }dD ]}t ||||| V &d S )N))rE r ru )r rE ru )r# r' ru )r# r' rE )rm rt r r )r )rW r r rt ru r rj s r
iter_fixturesz$ExhaustiveChannelTests.iter_fixtures s
%1 R R FE57
R
R+ R RC-c65%QQQQQQR
R R Rr c : |rdnd}t ||j d }| s| ||d d S | t
j 5 | ||d d d d d S # 1 swxY w Y d S )Nrs rr rm Fr )re rj r r r r ra )rW r r r rr s r _closez ExhaustiveChannelTests._close s #
0]] b#'622&&(( > OOC5O 9 9 9 9 9""<#BCC
>
>Uu===
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>s *BBBNc | |j dk r^| t j 5 t |j d d d n # 1 swxY w Y | t j 5 t |j d d d d n # 1 swxY w Y | t j 5 t |j d d d n # 1 swxY w Y | t j 5 t |j d d d d d S # 1 swxY w Y d S t |j d t |j d t |j d t |j d d S ) NrE r Tr zz
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)
)
rV r r ra r r r r r? r= )rW r r s r _assert_closed_in_interpz/ExhaustiveChannelTests._assert_closed_in_interp s >V[F 2 2""<#BCC
3
3 ))#'222
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3""<#BCC
<
< ))#'7;;;
<
<
<
<
<
<
<
<
<
<
<
<
<
<
<""<#BCC
4
4 **37333
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4""<#BCC
@
@ **37$*???
@
@
@
@
@
@
@
@
@
@
@
@
@
@
@
@
@
@
vy #
vy #
vy #
vy #
sG AA !A !B11B58B5 DD D 1"E E$'E$c | |j j t |j j D ]!}t
|j "| | dD ]9}| | }|j
dk r#| || :| d }| || d S )N)rm rt rE fresh) r r r r r r r r r r rV )rW r r+ r s r _assert_closedz%ExhaustiveChannelTests._assert_closed s ()))sy()) / /A % %cg . . . . %%c***' 7 7F((00F{f$$ ) )#v 6 6 6 6$$W-- %%c622222r Fc # $ K d}| D ]}t | D ]}|dz
}|dk r d S |rL|dz
dz dk rt t ||d t | nL|dz
dz dk rt dd t d d t
j |||fV |rt d
t d S ) Nr r r z ({} actions) r rz .z---)r printr rQ r_ r stdoutr )rW verboser r r s r _iter_close_testsz(ExhaustiveChannelTests._iter_close_tests s4
,,.. G GGG))++
&
&Qt88FFF ;A{a'' !S."7"7G "E"EFFFFA{a'' cr****#2&&&&
(8(8(:(:(:go%%%%
e
r c T dt _ | D ]\ }}}d S )NT)r r r rW r r r s r _skim_close_testsz(ExhaustiveChannelTests._skim_close_tests s9 $(! # 5 5 7 7 OAsG r c | D ]\ }}}| d ||| 5 | |j | || | |d | | d d d n # 1 swxY w Y | d S )N {} {} {}Fr r r rQ r r r r r r r s r
test_closez!ExhaustiveChannelTests.test_close s
# 5 5 7 7 OAsG k 0 0C A ABB
)
)$$SZ000 g... Cu ---##C(((
)
)
)
)
)
)
)
)
)
)
)
)
)
)
)
LLNNNN A B..B2 5B2 c | D ]\ }}}| d ||| 5 | |j | || | |d | | d d d n # 1 swxY w Y | d S )Nr Tr r r s r test_force_closez'ExhaustiveChannelTests.test_force_close s
# 5 5 7 7 OAsG k 0 0C A ABB
)
)$$SZ000 g... Ct ,,,##C(((
)
)
)
)
)
)
)
)
)
)
)
)
)
)
)
LLNNNN r r )F)rZ r[ r\ r r r r r r r r r r r r r r rb r r r r s +0 +0 +0Z/ / / b & ) ) ) 59 . . . . .@ R R R> > > 83 3 3 ,
r r r r )6 collectionsr r r r r r textwrapr r3 rD r/ testr test.supportr r
import_moduler r r# r, r r: r? r< rG rc re r r r r r TestCaser r r r r r r r2 rW ry r r r r r r0 r rZ rE rb r r <module>r s " " " " " "
& & & & & & & & & & & & +}*+?@@ . . .
4
4
4
4
<$ $ $ -/ 4 4 4 4! ! ! ! !**]I66 ! ! !L + + +/# /# /# /# /#JJ0CDD /# /# /#fE E E E E::n.>?? E E E& 7; *!! !! !!H x /4 /4 /4 /4 /4x( /4 /4 /4d9; 9; 9; 9; 9;* 9; 9; 9;~. . . . .8 . . ..' ' ' ' 'h ' ' '.) ) ) ) )8 ) ) )*&( &( &( &( &(X &( &( &(R8$ 8$ 8$ 8$ 8$ 8$ 8$ 8$vZK ZK ZK ZK ZK( ZK ZK ZKz_= _= _= _= _=8 _= _= _=Dc% c% c% c% c%X c% c% c%R V& V& V& V& V&X V& V& V&rs8 s8 s8 s8 s88 s8 s8 s8lb+ b+ b+ b+ b+( b+ b+ b+Jn n n n n**%:%EG G n n nb 677{ { { { {X { { 87{| zHMOOOOO r