python (3.12.0)
Browse
Usage
Versions
͑e > d dl mZ d dlZd dlZd dlmZ d dlZd dlZd dlZd dl m
Z
d dl m Z m
Z
mZ e
j d Zd Zi fdZ G d d
ed
d Zej( d Z G d
d edd Z G d d edd ZdddZd Zd Z G d dej6 Z G d de Z G d d e Z G d d e Z G d d! ed!d" Z ejB d# G d$ d%e Z"e#d&k( r ejH yy)' )
namedtupleN)dedent)
import_helper) interpreters _run_outputclean_up_interpreters_xxinterpchannelsc t | || y N) _run_interp)idsourceshareds O/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test__xxinterpchannels.py
run_interpr " s FF# c t | }t j }|| k( r*t j |k7 rt t || y t j | || y r )r r get_main get_current RuntimeErrorexec
run_string)r
r r _mainnsmains r r r & sS
F^F "D rz # # % - VW FF3r c 0 e Zd Zed Zd fd Z xZS ) Interpreterc Z t || r|S t |t r | | S t r )
isinstancestrNotImplementedError)clsraws r from_rawzInterpreter.from_raw4 s* c3 J
S
!s8O% %r c x t j }||k( r'|sd}n |dk7 rt dj | |}ng|E|sd}n|dk( r t d t |t j
s6t j
| }n |r|dk( rd}|}nt j }t | ! | || }|S )Nr z)name mismatch (expected "main", got "{}")interpz!name mismatch (unexpected "main")) r r
ValueErrorformatr
InterpreterIDcreatesuper__new__)r! namer
r self __class__s r r+ zInterpreter.__new__= s $$&
: ?FFtLN NB
^ !DEE b,"<"<=!//3 DB $$&BwsD"- r NN)__name__
__module__ __qualname__ classmethodr# r+
__classcell__r. s @r r r 2 s & & r r zname idc # T K d J d # t j $ r Y y w xY ww)Nzchannel not closed)channelsChannelClosedError r r expect_channel_closedr: X s2 +
+** & &
s ( (%(%(c 2 e Zd Zd fd Zd Zd Zd Z xZS )
ChannelActionc < |sd}|sd}t | | ||| }|S )Nbothr r* r+ )r! actionendr% r- r. s r r+ zChannelAction.__new__d s, CFwsFC8 r c : | j dk( r#| j dvr[t | j | j dv r#| j dvr*t | j t | j | j dvrt | j y )Nuse)sameoppositesendrecvclose force-close)r> rD rE rF rG )r rD otherextra)r@ rA r& r% )r- argskwargss r __init__zChannelAction.__init__l s ;;% xx CC **
[[ 4
4xx KK ** T[[) ) ;; @ @ T[[) ) Ar c l | j dk( r|S | j dk( r |dk( rdS dS | j S )NrD rE rF rG rA r- rA s r resolve_endzChannelAction.resolve_endx s9 88v J
XX
# F]6 6 688Or 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 y )NrD rK rL r )r% r r, )r- r% rK rL s r resolve_interpz ChannelAction.resolve_interp s ;;& M
[[G
#}""L
[[G
#}""L
[[F
"{{f$
5::/ ""
#r r/ )r0 r1 r2 r+ rO rS rU r4 r5 s @r r< r< b s
* #r r< zaction end interpc > e Zd Zd dd fd Zd Zd ZdddZ xZS )
ChannelStateFclosedc * t | | || }|S r r? )r! pendingrY r- r. s r r+ zChannelState.__new__ s wsGV4 r c V t | | j dz | j S N rX typer[ rY r- s r incrzChannelState.incr " tDz$,,*4;;??r c V t | | j dz
| j S r] r_ ra s r decrzChannelState.decr rc r Tforcec | j r|r| j dk( r| S t | |rdd S | j d S )Nr TrX )rY r[ r` )r- rg s r rI zChannelState.close s? ;;DLLA - tDzu!tDD$,,tDDr )r )r0 r1 r2 r+ rb re rI r4 r5 s @r rW rW s, % @@ " E Er rW zpending closedT
hideclosedc |j r |dk( r|dk( r|j rd}nd}nd} t | ||| }|rd|S # t j $ r |s|s |j }Y |S w xY w)NrC rG FT.)rY r[ _run_actionr7 r8 rI )cidr@ rA staterj
expectfailresults r
run_actionrq s || U?sf} J J
S&#u5 I M & & * M s A (A,+A,c R |dk( r|dk( r&t j | d |j S |dk( rR|j s! t j | t d t j | |j S t | |dk( r1i }|dv rd||< t j | fi | |j S |d k( r5d
di}|dv rd||< t j | fi | |j d S t | # t j $ r |cY S w xY w) NrC rF spamrG zexpected ChannelEmptyErrorrI rG rF TrJ rg rf )
r7 rF rb r[ rG ExceptionChannelEmptyErrorre r& rI )rm r@ rA rn rN s r rl rl s'
&= MM#w '::<
F]==B MM#& $$@AA
c" zz|# S/ ! 7 " " F3Ks%f%{{} = T " " F3Ks%f%{{{&& 1 11 ! L!s D D&%D&c t j D ] } t j | y # t j $ r Y 1w xY wr )r7 list_alldestroyChannelNotFoundErrorrm s r clean_up_channelsr| sG " S ! ,, s 1AAc e Zd Zd Zy)TestBasec , t t y r )r| r ra s r tearDownzTestBase.tearDown s r N)r0 r1 r2 r r9 r r r~ r~ s r r~ c H e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z y ) ChannelIDTestsc t j dd }| j t | d | j |j d y )N
Trf r> )r7 _channel_id assertEqualintrA r- rm s r test_default_kwargsz"ChannelIDTests.test_default_kwargs s? ""2T"2 S2& &)r c t j ddd }| j |j d t j dddd }| j |j d t j ddd }| j |j d t j dddd }| j |j d t j dddd }| j |j d
y ) Nr TrF rg rF FrF rG rg rG rg rG )rG rF rg r> )r7 r r rA r s r test_with_kwargsz ChannelIDTests.test_with_kwargs s ""2D"= &)""2DuD"I &)""2D"= &)""2DuD"I &)""2Dt4"H &)r c G d dt }t j | d }| j t | d y )Nc e Zd Zd Zy)*ChannelIDTests.test_coerce_id.<locals>.Intc yNr r9 ra s r __index__z4ChannelIDTests.test_coerce_id.<locals>.Int.__index__
s r N)r0 r1 r2 r r9 r r Intr s
r r Trf r )r r7 r r r )r- r rm s r test_coerce_idz ChannelIDTests.test_coerce_id s; # ""35"5 S2&r c | j t t j t | j t t j d | j t t j d | j t t j d | j t
t j d | j t t j d y )Ng $@10s 10l ) assertRaises TypeErrorr7 r objectr&
OverflowErrorra s r test_bad_idzChannelIDTests.test_bad_id s )X%9%968D )X%9%94@ )X%9%94@ )X%9%95A *h&:&:B? -)=)=uEr c | j t 5 t j ddd d d d y # 1 sw Y y xY w)Nr FrF rG )r r& r7 r ra s r test_bad_kwargsz ChannelIDTests.test_bad_kwargs s:
z
* = %e < = = =s 8Ac t j }| j t j 5 t j t | dz d d d y # 1 sw Y y xY wNr^ )r7 r) r rz r r r s r test_does_not_existz"ChannelIDTests.test_does_not_exist sM oo
x < <
= / SA . / / /s "A A(c h t j dd }| j t | d y )Nr Trf r )r7 r r r r s r test_strzChannelIDTests.test_str$ s+ ""2T"2 S4(r c t j dd }| j t | d t j ddd }| j t | d t j ddd }| j t | d t j dddd }| j t | d y )
Nr Trf z
ChannelID(10)r zChannelID(10, send=True)r zChannelID(10, recv=True)r )r7 r r reprr s r test_reprzChannelIDTests.test_repr( s ""2T"2 cO4""2D"= c$>?""2D"= c$>?""2Dt4"H cO4r c t j }t j t | }t j }| j ||k( | j ||k( | j |t | k( | j t | |k( | j |t t | k( | j t t | |k( | j
|t t | dz k( | j
|t t | k( | j
|ddz k( | j
|t d k( | j
|dk( | j
||k( | j
||k7 | j
||k7 | j ||k7 y )N皙? infspam)r7 r) r r
assertTruefloat assertFalser )r- cid1cid2cid3s r
test_equalityz ChannelIDTests.test_equality5 sm ##CI. % % D )* D T)* c$i 001 c$i(D01 s4y!1C!778 SY /0 D ) u -. ( & & & %r c t j }t j }t j || t j | }| j || | j t
| t
| y r )r7 r) rF rG r assertIsr` )r- chanobjgots r test_shareablez ChannelIDTests.test_shareableK s\ oo
dC mmD! c"
d3ic+r N)
r0 r1 r2 r r r r r r r r r r r9 r r r r s5 * * 'F=/
) 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 Zd Zd Z ej4 d d 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' Z*d( Z+y))* ChannelTestsc l t j }| j |t j y r )r7 r) assertIsInstance ChannelIDr s r test_create_cidz ChannelTests.test_create_cidZ s$ oo c8#5#56r c t j }t j }t j }t j }t j }| j |t | dz | j |t | dz | j t | t | z
|||h y r )r7 rx r) r r set)r- beforeid1id2id3afters r test_sequential_idsz ChannelTests.test_sequential_ids^ s ""$oo oo oo !!# c#hl+ c#hl+ Uc&k1Cc?Cr c H t j }t |t d }t |j }t j }t |t d }t |j }| j
|t | dz y )Nz{
import _xxinterpchannels as _channels
cid = _channels.create()
print(cid)
r^ )r r) r r r stripr )r- r outr r r s r test_ids_globalz ChannelTests.test_ids_globali s !!##v '
399; !!##v '
399; s4y1}-r c t j }t j |d }t j |d }| j |g | j |g y)z=Test listing interpreters for a channel with no associations.TrF FN)r7 r) list_interpretersr )r- rm send_interps recv_interpss r #test_channel_list_interpreters_nonez0ChannelTests.test_channel_list_interpreters_none| sZ oo 11#D1A 11#E1B r* r*r c ( t j }t j }t j |d t j |d }t j |d }| j
||g | j
|g t j }t |t d| d t j |d }t j |d }| j
||g | j
||g y)z(Test basic listing channel interpreters.rF Tr FT
import _xxinterpchannels as _channels
obj = _channels.recv()
N) r r r7 r) rF r r r r )r- interp0rm r r interp1s r $test_channel_list_interpreters_basicz1ChannelTests.test_channel_list_interpreters_basic s '')oo
c6" 11#D1A 11#E1B y1 r* %%'GV )""% '
%
11#D1A 11#E1B y1 y1r c ^ t j }t j }t j }t j }t j }t j |d t |t
d| d t |t
d| d t |t
d| d t j |d }t j |d }| j t | ||h | j t | ||h y )
z?Test listing interpreters for a channel with many associations.rF N
import _xxinterpchannels as _channels
_channels.send(z, "send")
r r Tr FN)
r r r) r7 rF r r r r r )r- r r interp2interp3rm r r s r 'test_channel_list_interpreters_multiplez4ChannelTests.test_channel_list_interpreters_multiple s' '') %%' %%' %%'oo
c6"GV ) 5 !
% GV )""% '
% GV )""% '
% 11#D1A 11#E1B \*Wg,>? \*Wg,>?r c R t j }t j }t j }t j |d t |t
d| d t j |d }t j |d }| j ||g | j ||g t j | t j |d }t j |d }| j ||g | j |g y)z?Test listing channel interpreters with a destroyed interpreter.rF r r Tr FN)
r r r) r7 rF r r r r ry r- r r rm r r s r (test_channel_list_interpreters_destroyedz5ChannelTests.test_channel_list_interpreters_destroyed s '') %%'oo
c6"GV )""% '
%
11#D1A 11#E1B y1 y1 W% 11#D1A 11#E1B y1 r*r c t j }t j }t j }t j }t j |d t |t
d| d t j |d t |t
d| d t j |d }t j |d }| j t | d | j t | d t j |d t j |d }t j |d }| j t | d | j t | d t |t
d
| d t j |d }t j |d }| j t | d | j ||g y ) z:Test listing channel interpreters with a released channel.datar r Tr Fr^ r r Q
import _xxinterpchannels as _channels
_channels.release(N) r r r) r7 rF r r r r lenrelease)r- r r r rm r r s r 'test_channel_list_interpreters_releasedz4ChannelTests.test_channel_list_interpreters_released s '') %%' %%'oo
c6"GV )""% '
%
c6"GV )""% '
%
11#D1A 11#E1B \*A. \*A. 4( 11#D1A 11#E1B \*A. \*A. GV ) "e $
%
11#D1A 11#E1B \*A. y1r c t j }t j }t j }t j |d t j |d }t j |d }| j
t | d | j
t | d t j |d | j t j 5 t j |d ddd | j t j 5 t j |d ddd y# 1 sw Y IxY w# 1 sw Y yxY w) z8Test listing channel interpreters with a closed channel.rF Tr Fr^ r rf N) r r r) r7 rF r r r rI r r8 r s r %test_channel_list_interpreters_closedz2ChannelTests.test_channel_list_interpreters_closed s '') %%'oo
c6" 11#D1A 11#E1B \*A. \*A. s$'
x : :
; 7 & &s & 6 7
x : :
; 8 & &s & 7 8 8 7 7 8 8s -E
,E
EE"c t j }t j }t j }t j |d t j |d }t j |d }| j
t | d | j
t | d t j |d | j t j 5 t j |d ddd t j |d }| j
t | d t |t d| d y# 1 sw Y UxY w)
zCTest listing channel interpreters with a channel's send end closed.rF Tr Fr^ r NO
import _xxinterpchannels as _channels
_channels.close(, force=True)
)
r r r) r7 rF r r r rI r r8 r r r s r .test_channel_list_interpreters_closed_send_endz;ChannelTests.test_channel_list_interpreters_closed_send_end
s4 '') %%'oo
c6" 11#D1A 11#E1B \*A. \*A. s&
x : :
; 7 & &s & 6 7 11#E1B \*A. GV ) E "
% 7 7s -EE"c t j }d}t j || t j | }| j || | j || y Nrs )r7 r) rF rG r assertIsNot)r- rm origr s r test_send_recv_mainz ChannelTests.test_send_recv_main2 sO oo
c4 mmC d# d#r c V t j }t |t d }y )Na
import _xxinterpchannels as _channels
cid = _channels.create()
orig = b'spam'
_channels.send(cid, orig)
obj = _channels.recv(cid)
assert obj is not orig
assert obj == orig
)r r) r r )r- r r s r test_send_recv_same_interpreterz,ChannelTests.test_send_recv_same_interpreter; s( !!##v ' r c t j }t j }t |t d| d }t j | }| j
|d y )Nr , b'spam')
rs )r7 r) r r r rG r )r- rm r r r s r %test_send_recv_different_interpretersz2ChannelTests.test_send_recv_different_interpretersG sc oo !!##v + 5 !
' mmC g&r c t j fd}t j | }|j t j d |j
t j }| j |d y )Nc t j } t j | y # t j $ r t j d Y nw xY w])Nr )r7 rG rv timesleeprF )r rm s r fz8ChannelTests.test_send_recv_different_threads.<locals>.fU sS $"--,C
MM#s # 11 $JJsO$ s 1 (A A targetrs ) r7 r) threadingThreadstartrF joinrG r )r- r tr rm s @r test_send_recv_different_threadsz-ChannelTests.test_send_recv_different_threadsR sd oo $
A &
c7# mmC g&r c R t j t j d fd}t j | }|j t j
d |j t j }| j |d y )Nc
> t t d d d y )Nz
import time
import _xxinterpchannels as _channels
while True:
try:
obj = _channels.recv(z)
break
except _channels.ChannelEmptyError:
time.sleep(0.1)
assert(obj == b'spam')
_channels.send(z, b'eggs')
)r r )rm r r s r r zIChannelTests.test_send_recv_different_interpreters_and_threads.<locals>.fk s8 c6 /.
/2U 3
!$u % + $ Cr r rs eggs)
r7 r) r r r r rF r rG r )r- r r r rm r r s @@@r 1test_send_recv_different_interpreters_and_threadsz>ChannelTests.test_send_recv_different_interpreters_and_threadsf sw oo !!#
A &
c7# mmC g&r c | j t j 5 t j dd d d d y # 1 sw Y y xY w)Nr rs )r r7 rz rF ra s r test_send_not_foundz ChannelTests.test_send_not_found s9
x < <
= ' MM"g & ' ' 's A A c | j t j 5 t j d d d d y # 1 sw Y y xY wr )r r7 rz rG ra s r test_recv_not_foundz ChannelTests.test_recv_not_found s7
x < <
= MM" s ?Ac t j }| j t j 5 t j | d d d y # 1 sw Y y xY wr )r7 r) r rv rG r s r test_recv_emptyz ChannelTests.test_recv_empty sC oo
x 9 9
: MM# s AA c t }t j }t j || }t j |d t j |d t j |d t j |d t j || }t j || }t j | }t j || }t j || }| j || | j |d | j
|d | j
|d | j
|d | j || y )Nr^ rs r )r r7 r) rG rF r r ) r- defaultrm obj1obj2obj3obj4obj5obj6s r test_recv_defaultz ChannelTests.test_recv_default s (oo }}S'*
c4
c1
c7#
c7#}}S'*}}S'*}}S!}}S'*}}S'*
dG$
dD! q! w' w'
dG$r c | j d 5 t j }t j }t j |t d| d t j | | j t d| d 5 t j | d d d ~d d d | j d 5 t j }t j }t j |t d| d t j |d t j | t j | | j t d| d 5 t j | d d d ~d d d y # 1 sw Y xY w# 1 sw Y xY w# 1 sw Y +xY w# 1 sw Y y xY w) NrY zV
import _xxinterpchannels as _channels
_channels.send(, b'spam')
zchannel z
is closedz
still openr z is empty) subTestr7 r) r r r ry assertRaisesRegexr rG rF )r- r r% r s r "test_recv_sending_interp_destroyedz/ChannelTests.test_recv_sending_interp_destroyed s
\\(
# ??$D!((*F # #FF 8 $v &4 -
('' *24&
(CE
$
d#
$ \\,
' ??$D!((*F # #FF 8 $v &4 -
MM$ ( ( MM$ '' *24& (BD
$
d#
$
$
$ 0
$
$ sI A;F
F# F B&F7+F+ F7F F F(+F4 0F77G c P t j }g d}|D ]} }| j | 5 t j || t j | }| j || | j
t | t | d d d y # 1 sw Y xY w)N)Nr rs * )r7 r) r rF rG r r r` )r- rm objectsr r s r test_allowed_typesz ChannelTests.test_allowed_types s oo
4C c"
4
c3' mmC( c*
d3ic3
4
4 4
4
4s A"B B% c 6 t j }t j }t |t d t |j }t j | }| j |d | j |j d y )Nz
import _xxinterpchannels as _channels
print(cid.end)
_channels.send(cid, b'spam')
r{ rs rF )
r7 r) r r r dictrF rG r r r- rm r% r r s r test_run_string_arg_unresolvedz+ChannelTests.test_run_string_arg_unresolved sx oo $$&&& * #
SXX mmC g& f-r z(disabled until high-level channels existc d t j }t j |d }t j }t |t d t
|j }t j | }| j |d | j |j d y )NT)_resolvez
import _xxinterpchannels as _channels
print(chan.id.end)
_channels.send(chan.id, b'spam')
)r rs rF ) r7 r) r r r r r# rF rG r r r$ s r test_run_string_arg_resolvedz)ChannelTests.test_run_string_arg_resolved s oo ""3"6 $$&&& * #
chh ! mmC g& f-r c t j }t j |d t j | t j | | j t j 5 t j |d d d d | j t j 5 t j | d d d y # 1 sw Y GxY w# 1 sw Y y xY wNrs r r7 r) rF rG rI r r8 r s r test_close_single_userz#ChannelTests.test_close_single_user s oo
c7#
cs
x : :
; ( MM#w ' (
x : :
; MM# ( ( 4C2C C C&c " t j }t j }t j }t j |t d| d t j |t d| d t j | | j
t j 5 }t j |t d| d d d d | j dt j | j
t j 5 }t j |t d| d d d d | j dt |j y # 1 sw Y xY w# 1 sw Y ;xY w)Nr r zN
import _xxinterpchannels as _channels
_channels.recv(r z
_channels.send(r r8 ) r7 r) r r r rI r RunFailedErrorassertInr exception)r- rm r r cms r test_close_multiple_usersz&ChannelTests.test_close_multiple_users sp oo !!#!!# V 1 5 !
- & V 1 5 !
- & s
| : :
; r # #C 5 #u %1 *
*C ,=>
| : :
; r # #C 5 #u %1 *
*C ,=>
s 7$E9'$F9FFc > t j }t j |d t j | t j | | j t j 5 t j | d d d y # 1 sw Y y xY wr r+ r s r test_close_multiple_timesz&ChannelTests.test_close_multiple_times si oo
c7#
cs
x : :
; NN3 s 4BB c F g d}|D ] \ }}| j ||f 5 t j }t j |d t j | t j ||| | j
t j 5 t j |d d d d | j
t j 5 t j | d d d d d d y # 1 sw Y QxY w# 1 sw Y xY w# 1 sw Y xY w)N))FFTF)FT)TTrs r r )r r7 r) rF rG rI r r8 )r- testsrF rG rm s r test_close_emptyz ChannelTests.test_close_empty& s
'JD$ tTl+
' oo'
c7+
c"sD9&&x'B'BC 0 MM#w/0&&x'B'BC ' MM#&'
'
'
'0 0' '
'
's< A7DC>.'DD
+D>D D
D DD c l t j }t j |d t j |d | j t j 5 t j | d d d t j
| t j |d y # 1 sw Y 5xY w)Nrs hamr r7 r) rF r ChannelNotEmptyErrorrI rG r s r %test_close_defaults_with_unused_itemsz2ChannelTests.test_close_defaults_with_unused_items9 sy oo
c7#
c6"
x < <
= NN3
c
c7# s B**B3c t j }t j |d t j |d | j t j 5 t j |d d d d t j
| t j |d t j
| t j
| t j |d y # 1 sw Y vxY w)Nrs r; TrG r r< r s r *test_close_recv_with_unused_items_unforcedz7ChannelTests.test_close_recv_with_unused_items_unforcedC s oo
c7#
c6"
x < <
= + NN3TN * +
c
c7#
c
cs&
+ +s C--C6c , t j }t j |d t j |d t j |d | j t j
5 t j |d d d d t j
| t j
| | j t j
5 t j
| d d d y # 1 sw Y qxY w# 1 sw Y y xY w)Nrs r; Tr r r7 r) rF rI r r8 rG r s r *test_close_send_with_unused_items_unforcedz7ChannelTests.test_close_send_with_unused_items_unforcedP s oo
c7#
c6"s&
x : :
; ( MM#w ' (
c
c
x : :
; MM# ( ( s 7C> D
>D
Dc t j }t j |d t j |d | j t j 5 t j |dd d d d t j
| t j |d t j
| t j
| t j |d y # 1 sw Y vxY w)Nrs r; Trt r r@ r< r s r *test_close_both_with_unused_items_unforcedz7ChannelTests.test_close_both_with_unused_items_unforced] s oo
c7#
c6"
x < <
= 6 NN3TN 5 6
c
c7#
c
cs&
6 6s C..C7c t j }t j |d t j |d t j |dd | j t j
5 t j |d d d d | j t j
5 t j
| d d d y # 1 sw Y GxY w# 1 sw Y y xY w)Nrs r; Tr r rC r s r (test_close_recv_with_unused_items_forcedz5ChannelTests.test_close_recv_with_unused_items_forcedj oo
c7#
c6"sT2
x : :
; ( MM#w ' (
x : :
; MM# ( ( 8C6C!C !C*c t j }t j |d t j |d t j |dd | j t j
5 t j |d d d d | j t j
5 t j
| d d d y # 1 sw Y GxY w# 1 sw Y y xY w)Nrs r; Tr r rC r s r (test_close_send_with_unused_items_forcedz5ChannelTests.test_close_send_with_unused_items_forcedu rI rJ c t j }t j |d t j |d t j |ddd | j t j
5 t j |d d d d | j t j
5 t j
| d d d y # 1 sw Y GxY w# 1 sw Y y xY w)Nrs r; Tr r rC r s r (test_close_both_with_unused_items_forcedz5ChannelTests.test_close_both_with_unused_items_forced s oo
c7#
c6"sD=
x : :
; ( MM#w ' (
x : :
; MM# ( ( s 9C7C"C "C+c | t j }t j | | j t j 5 t j |d d d d | j t j 5 t j
| d d d y # 1 sw Y GxY w# 1 sw Y y xY wr )r7 r) rI r r8 rF rG r s r test_close_never_usedz"ChannelTests.test_close_never_used s oo s
x : :
; ( MM#w ' (
x : :
; MM# ( ( B&B2&B/2B;c t j }t j |d t j }t j |t d| d | j
t j 5 t j | d d d | j
t j 5 t j | d d d y # 1 sw Y GxY w# 1 sw Y y xY w)Nrs r r )
r7 r) rF r r r r r8 rG rI r- rm r% s r !test_close_by_unassociated_interpz.ChannelTests.test_close_by_unassociated_interp s oo
c7# $$& 4 E "
0 )
x : :
; MM#
x : :
; NN3 s C >C) C&)C2c . t j }t j |d t j |d t j |d t j | t j |d | j t j 5 t j |d d d d | j t j 5 t j | d d d y # 1 sw Y GxY w# 1 sw Y y xY w)Nrs Trf r r+ r s r -test_close_used_multiple_times_by_single_userz:ChannelTests.test_close_used_multiple_times_by_single_user s oo
c7#
c7#
c7#
cs$'
x : :
; ( MM#w ' (
x : :
; MM# ( ( s "C? D ?D Dc t j }| j t j 5 t j dd d d d t j | | j t j 5 t j |d d d d y # 1 sw Y ^xY w# 1 sw Y y xY w)Nr Tr )r7 r) r rz r rI r8 r s r .test_channel_list_interpreters_invalid_channelz;ChannelTests.test_channel_list_interpreters_invalid_channel s oo
x < <
= 8 & &t$ & 7 8 s
x : :
; 7 & &s & 6 7 7 8 8
7 7s B)B5)B25B>c t j }| j t 5 t j | d d d y # 1 sw Y y xY wr )r7 r) r r r r s r +test_channel_list_interpreters_invalid_argsz8ChannelTests.test_channel_list_interpreters_invalid_args s? oo
y
) , & &s + , , ,s A AN),r0 r1 r2 r r r r r r r r r r r r r r r r r
r r r r! r% unittestskipr( r, r3 r5 r9 r> rA rD rF rH rL rN rP rT rV rX rZ r9 r r r r X s 7 D.&+2,@4+.)2V8,!8J$
''('8'
%* <4&
.$ X]]=>. ?.$ ?0 '&$ ' ' 7,r r c P e Zd ZdZ d Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
y )
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
c t j }t j |d t j | t j |dd | j t j 5 t j |d d d d | j t j 5 t j | d d d y # 1 sw Y GxY w# 1 sw Y y xY wNrs Tr r r7 r) rF rG r r r8 r s r test_single_userz$ChannelReleaseTests.test_single_user s oo
c7#
c4d3
x : :
; ( MM#w ' (
x : :
; MM# ( ( s 7C5C C C)c
t j }t j }t j }t j |t d| d t |t d| d| d }t j |t d| d | j
|j d y ) Nr r r z )
_channels.release(z+)
print(repr(obj))
z
_channels.release(r zb'spam')r7 r) r r r r r r )r- rm r r r s r test_multiple_usersz'ChannelReleaseTests.test_multiple_users s oo !!#!!# V 1 5 !
- & #v +""% ' "e $
' V 1 "e $
- &
i0r c t j }t j |d t j | t j | | j t j 5 t j |d d d d | j t j 5 t j | d d d y # 1 sw Y GxY w# 1 sw Y y xY wr* ra r s r test_no_kwargsz"ChannelReleaseTests.test_no_kwargs
s oo
c7#
c
x : :
; ( MM#w ' (
x : :
; MM# ( ( r- c J t j }t j |d t j | t j |dd | j t j 5 t j |dd d d d y # 1 sw Y y xY w)Nrs Tr ra r s r test_multiple_timesz'ChannelReleaseTests.test_multiple_times s{ oo
c7#
c4d3
x : :
; 8 St$ 7 8 8 8s 7BB"c F t j }t j |d t j |d t j |dd | j t j
5 t j
| d d d y # 1 sw Y y xY w)Nrs r; Tr )r7 r) rF r r r8 rG r s r test_with_unused_itemsz*ChannelReleaseTests.test_with_unused_items st oo
c7#
c6"4d3
x : :
; MM# s 8BB c | t j }t j | | j t j 5 t j |d d d d | j t j 5 t j
| d d d y # 1 sw Y GxY w# 1 sw Y y xY wr )r7 r) r r r8 rF rG r s r test_never_usedz#ChannelReleaseTests.test_never_used' s oo
x : :
; ( MM#w ' (
x : :
; MM# ( ( rQ c t j }t j |d t j }t j |t d| d t j
| }t j | | j t j 5 t j |d d d d | j |d y # 1 sw Y xY w)Nrs r r r ) r7 r) rF r r r rG r r r8 r )r- rm r% r s r test_by_unassociated_interpz/ChannelReleaseTests.test_by_unassociated_interp0 s oo
c7# $$& 4 "e $
0 ) mmC
x : :
; ( MM#w ' ( g& ( (s +C C&c
2 t j }t j }t j |t d| d| d | j t j 5 t j | d d d y # 1 sw Y y xY w)NzT
import _xxinterpchannels as _channels
obj = _channels.send(z), b'spam')
_channels.release(r )r7 r) r r r r r8 rG rS s r test_close_if_unassociatedz.ChannelReleaseTests.test_close_if_unassociated? s oo $$& 4""% ' "e $
0 )
x : :
; MM# s .B
Bc * t j }t j |d t j | t j |d t j |d t j | }| j |d y )Nrs Tr )r7 r) rF rG r r )r- rm r s r test_partiallyz"ChannelReleaseTests.test_partiallyL sg oo
c4
c
c7#4(mmC g&r c 0 t j }t j |d t j |d t j |d t j | t j |dd | j t j 5 t j |d d d d | j t j 5 t j | d d d y # 1 sw Y GxY w# 1 sw Y y xY wr` ra r s r 'test_used_multiple_times_by_single_userz;ChannelReleaseTests.test_used_multiple_times_by_single_userW s oo
c7#
c7#
c7#
c4d3
x : :
; ( MM#w ' (
x : :
; MM# ( ( s #D !D D DN)r0 r1 r2 __doc__rb rd rf rh rj rl rn rp rr rt r9 r r r^ r^ sC " 1( 8
' ' r r^ c t e Zd ZdZ fdZed Zed Zd Zd
dZ d Z
d Z d Z d
Z
d Zd Z xZS )ChannelCloseFixtureFc v |dv sJ | j ri }net j | }t j | }t j | }|j ||j ||j |i}|sd}t | | ||||| }t
|_ t |_ ||_
|S )Nr rD ) QUICKr r# r, r* r+ r _preppedrW _state_known) r! rA r% rK rL creatorknownr- r. s r r+ zChannelCloseFixture.__new__l s &&& 99E ))&1F ((/E ((/E V
E
EE
GwsCwG
"n r c | j S r r{ ra s r rn zChannelCloseFixture.state s {{r c | j S # t $ r@ | j | j }| j | | _ | j cY S w xY wr )_cidAttributeError_get_interpreterr} _new_channel)r- r} s r rm zChannelCloseFixture.cid sP 99 ++DLL9G ))'2DI99 s AAAc J | j | }| j | |S r )r _prep_interpreterr- r% s r get_interpreterz#ChannelCloseFixture.get_interpreter s% &&v. v&
r c | | j }|dk( r| j j dk( ryt | j j S )NrG rF F)rA rn rY boolrR s r expect_closed_errorz'ChannelCloseFixture.expect_closed_error s@ ;((C &=TZZ . .& 8DJJ%%&&r c & | j | y r )r r s r prep_interpreterz$ChannelCloseFixture.prep_interpreter s v&r c || _ y r r )r- r@ rp s r
record_actionz!ChannelCloseFixture.record_action s r c , t t y r )r r| ra s r clean_upz ChannelCloseFixture.clean_up s r c |j dk( rt j S t j }t |j d| d t j | | _ | j S )Nr z
import _xxsubinterpreters
cid = _xxsubchannels.create()
# We purposefully send back an int to avoid tying the
# channel to the other interpreter.
_xxsubchannels.send(zC, int(cid))
del _xxsubinterpreters
)r, r7 r) r r
rG r )r- r} chs r r z ChannelCloseFixture._new_channel sg <<6 !??$ $ "B wzz (%
&(D ) $
!
b)DIyyr c |dv r | j S |dk( r | j S |dk( r | j S |} | j | }|S # t $ r t | x}| j |< Y |S w xY w)N)rD r% rK rL )r% rK rL r| KeyErrorr )r- r% r, s r r z$ChannelCloseFixture._get_interpreter s ' ';;
w
::
w
:: D
? T* M
?-8->>T*M
?s A #A.-A.c |j | j v ry | j j |j |j dk( ry t |j d| j
d y )Nr a
import _xxinterpchannels as channels
import test.test__xxinterpchannels as helpers
ChannelState = helpers.ChannelState
try:
cid
except NameError:
cid = channels._channel_id(r )r
rz addr, r rm r s r r z%ChannelCloseFixture._prep_interpreter sb 99
%
&))$ ;;& 699 #, -1HH: 6
r r )r0 r1 r2 ry r+ propertyrn rm r r r r r r r r r4 r5 s @r rw rw e s_
E*
''
r rw z end interp other extra creatorz%these tests take several hours to runc r e Zd ZdZ d Zd Zd Zd Zd Zddd Z d
Z
d Z dd
Z d Z
ddZd Zd Zd Zy )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
c # < K g | j dd D ]" }| | j D ] }||z $ | j dd D ]" }| | j D ] }||z $ | j dd D ]~ }| | j dd D ]' }||z }| | j D ] }||z ) | j dd D ]' }||z }| | j D ] }||z ) | j dd D ]~ }| | j dd D ]' }||z }| | j D ] }||z ) | j dd D ]' }||z }| | j D ] }||z ) y w)NrD rK rL )_iter_close_action_sets _iter_post_close_action_sets_iter_use_action_sets)r- closeactions postactions
useactionsactionss r iter_action_setsz'ExhaustiveChannelTests.iter_action_sets s ! 8 8 I 1L # @ @ B
1 "[00
1 1 ! 8 8' J 1L # @ @ B
1 "[00
1 1 44VWE 0J $ < <VW M
0 $|3
#'#D#D#F 0K!K//0
0
!% < <Wg N
0 $|3
#'#D#D#F 0K!K//0
0 0 44WgF 0J $ < <VW M
0 $|3
#'#D#D#F 0K!K//0
0
!% < <Wg N
0 $|3
#'#D#D#F 0K!K//0
0 0s FF c # K ||f}t dd| g t dd| g t dd| t dd| g t dd| g t dd| g t dd| t dd| g |D ]8 }|D ]1 }|D ]* }t dd| t dd| t dd| g , 3 : |D ]K }|D ]D }|D ]= }|D ]6 }t dd| t dd| t dd| t dd| g 8 ? F M y w)NrC rG rF r< )r- r r interpsr interp4s r r z,ExhaustiveChannelTests._iter_use_action_sets. s G$
% 1
% 1
% 1 % 1
% 1
% 1
% 1 % 1 G"
& G%eVW=%eVW=%eVW=
G"
& G#* )% A )% A )% A )% A
s D D
c
# K d}||f}dD ]& }|rdnd}|D ] }|D ] }t ||| g ( dD ]3 } dD ], }
|D ]% } |D ] } t | d| t |
d| g ' . 5 y w)Nrt r7 rJ rI rH rG rF r )
r- r r endsr rg opr% rA recvopsendoprG rF s
r r z.ExhaustiveChannelTests._iter_close_action_sets_ s G$" E"' WB!
C%b#v6
/ F2
# D ' )&&$ ? )&&$ ?
s A+A-c # Z K dD ]" }t dd| g t dd| g $ y w)N)rD rL rK rC rG rF r r s r r z3ExhaustiveChannelTests._iter_post_close_action_setsr sC 0 F eVV4
eVV4
s )+c 6 |D ] }| j || y r )rq )r- fixr r@ s r run_actionsz"ExhaustiveChannelTests.run_actions{ s )F OOC ( )r Tri c |j |j }|j |j |j |j
}|j
| |j dk( rAt |j |j ||j | }|j || y t j }t |j d|j dt# |j dt# | dt# |j d| d| d| d t% t& j) t j+ | d t- t j+ |
}|j || y ) Nr ri zB
result = helpers.run_action(
z,
z!,
hideclosed=z6,
)
channels.send(zF, result.pending.to_bytes(1, 'little'))
channels.send(z2, b'X' if result.closed else b'')
little)r[ rY )rS rA rU r% rK rL r r, rq rm r@ rn r r7 r) r r
r rW r
from_bytesrG r )r- r r@ rj rA r% rp r s r rq z!ExhaustiveChannelTests.run_action sR )&&szz399ciiH V$ ;;&
% F
ff -??$D vyy 'WWI &--() *#YK #))_% & *| , #f % #f %
#
"x}}T':HEHMM$ /0F
ff -r c
# h K g d}|D ]% \ }}}dD ] }dD ] }t ||||| ' y w)N))r r% rL )r% r rL )r r rL )r r r )rD rK r} r )rw )r- r r% rK rL r} rA s r
iter_fixturesz$ExhaustiveChannelTests.iter_fixtures s\
%1 R FE57
R+ RC-c65%QQR
R Rs 02c |rdnd}t ||j d }|j s| j ||d y | j t
j 5 | j ||d d d d y # 1 sw Y y xY w)NrJ rI rD Fri )r< rA r rq r r7 r8 )r- r rg r rI s r _closez ExhaustiveChannelTests._close sv #] b#''62&&( OOC5O 9""8#>#>?
>Uu=
>
>
>s "B B Nc | ||j dk( r | j t j 5 t j |j
d d d | j t j 5 t j
|j
d d d d | j t j 5 t j |j
d d d | j t j 5 t j |j
d d d d y t |j d t |j d t |j d t |j d y # 1 sw Y <xY w# 1 sw Y xY w# 1 sw Y xY w# 1 sw Y y xY w) Nr rs Trf zn
with helpers.expect_channel_closed():
channels.recv(cid)
zw
with helpers.expect_channel_closed():
channels.send(cid, b'spam')
zo
with helpers.expect_channel_closed():
channels.close(cid)
z{
with helpers.expect_channel_closed():
channels.close(cid, force=True)
)
r, r r7 r8 rG rm rF rI r r
)r- r r% s r _assert_closed_in_interpz/ExhaustiveChannelTests._assert_closed_in_interp sU >V[[F 2""8#>#>?
'
cgg&
'""8#>#>?
0
cggw/
0""8#>#>?
(sww'
(""8#>#>?
4swwd3
4
4
vyy #
vyy #
vyy #
vyy #
+
'
'
0
0
(
(
4
4s/ F 9!F F&"F2 FF#&F/2F;c | j |j j t |j j D ]! }t
j
|j # | j | dD ]5 }|j | }|j dk( r$| j || 7 |j d }| j || y )N)rD rK r fresh) r rn rY ranger[ r7 rG rm r r r, )r- r _r% s r _assert_closedz%ExhaustiveChannelTests._assert_closed s (()syy(() #A MM#'' " # %%c*' 7F((0F{{f$ ) )#v 6 7 $$W- %%c62r c # K d}| j D ] }t | j D ] }|dz
}|dkD r y |r;|dz
dz dk( r
t t ||dj t | nC|dz
dz dk( r
t dd t d d t
j j |||f |st d
t y w) Nr r^ r z ({} actions) rQ .z---)r printr r' r sysstdoutflush)r- verboseir r s r _iter_close_testsz(ExhaustiveChannelTests._iter_close_tests s
,,. G G))+
&Qt8A{a' !S."7"7G "EFA{a' cr*#2&
(8(8(:go%
& e ! " s C C&C&c L dt _ | j D ] \ }}} y )NT)rw ry r r- r r r s r _skim_close_testsz(ExhaustiveChannelTests._skim_close_tests s, $(! # 5 5 7 OAsG r c f | j D ] \ }}}| j dj ||| 5 |j |j | j || | j
|d | j | d d d |j y # 1 sw Y xY w)N {} {} {}Frf r r r' r r% r r r r r s r
test_closez!ExhaustiveChannelTests.test_close s # 5 5 7 OAsG k 0 0C AB
)$$SZZ0 g. Cu -##C(
)
LLN
)
) AB''B0 c f | j D ] \ }}}| j dj ||| 5 |j |j | j || | j
|d | j | d d d |j y # 1 sw Y xY w)Nr Trf r r s r test_force_closez'ExhaustiveChannelTests.test_force_close s # 5 5 7 OAsG k 0 0C AB
)$$SZZ0 g. Ct ,##C(
)
LLN
)
)r r )F)r0 r1 r2 ru r r r r r rq r r r r r r r r r9 r r r r s` +0Z/ b &) 59 .@ R>83 ,
r r __main__)% collectionsr
contextlibr textwrapr r r r[ test.supportr test.test__xxsubinterpretersr r r
import_moduler7 r r r contextmanagerr: r< rW rq rl r| TestCaser~ r r r^ rw r\ r r0 r r9 r r <module>r sX "
& '= & &': ; $ -/ 4!*]I6 !L + +/#J0CD /#fE:n.>? E& 7; *!!H x `,X `,Je ,8 e ,Pb ( b Jn*%:%EG nb 67{X { 8{| zHMMO r