ÿØÿà JFIF 

  
 
  ÿÛ „ 
 !.%+&8&+/1555$;@;4?.451
4,$,44444444444414444444444444444444444444444444444444ÿÀ  á á
" 

ÿÄ   



           
 ÿÄ ? 
    
 !1AQaq"2‘¡±ÁðBRbrÑá#‚’¢²3S CñÿÄ 
 

             
ÿÄ ! 
 
 
       
!1QAa‘2ÿÚ 
  ? 5˜Z¯V¦cø)›t/? z¨±>Õ5€¶‹Á¤·¼z¼Ü¬+ñ®v¤¨_ˆR­BFn©—˜ý®ç̝P8gýt·ÉSTŦˆìät?þé¼íìN/Þa)ì–í6ô…
Ï¿øÃj´¿KÇü]ÿ ªô¹-eKànëÕHTx}ýSÜ›ÿ ”7Ø×&µ<¦  ¥ÑO¶[Ù¯ä¨ÞÃÿ PZ-¬;#õ|•
oaÿ ©CìÞz3˜öː/¤­ñTûIØ}š^   mÓ%ªxˆ¥ÉŸu=Z+ISe¿45™¼u;ú&WØ÷€æßQ™®{|
íx*TC“#ZŠìZ§²‹ 6pv…³¿¡äª*áZÐ%ÒOáˆo"x«OHk
w±æ+¬V(kMúŸ5Vö«$ ÁrÏbàb57/luR ¸ÑÛj Òµì`Ðœq­û žICÀ
Ê•©4€Âcà¨Ï€O´<èÐ:›ù(Ë^L8þ‘ÍÌ#¸Ð_Ì©ÙK(Öz 4¬û+¸;ü’V’84‘¬ÃŽ:[â‡ÔÌáõp¢~§ªlæ£ö{®G>J¼"°‡7¯ÆÉèßû ‹É‹§ÁòÃýâßî
^ƾÙõ‹×óH#«LP½ïX=xÑÍ$|W?•~•îëÔ©ª‹
{ÝT…Kÿ ”hûâá)J*ö˜–ÔU;iÇ€/ ÆþjóZ\ýwØ=Ìm
ºèËL9 ýè
Æð/¨’¥öo=nË.%Îì   ŽÕ¯È|{Oj²ƒE6e/ßdÄõ²Ìâ1O®ò×TsəԸhOMýíMˆ¿¼H˜l²,7Â¥#MF/Úf°Ö½± ¸–dr‹NýÊ íjqx{œÉ ä-È    ¦
øÄër¨q°ð
†nцýÑÄÆ’mä…n<0È™;ÁÝá¯ÁZƒ7FÀmì­ É&9ˆîéi¶ùN§Y•ÃZãAâ?•‡©‰ , ó¾IŸŠc1 4â&y­&pŠ­6;M À 0¹qç»p.á …ŸÅáK@<u %Ü6ÓtIÌpÓr»söfeÁ0O…­´Kƒ&ñ™\©<+,~)‹
ºHÐ*×µ&†ž‘Æ÷ÚŸ
1ßjC5Oh´‡›

Ø×ë æâ“Þà

ÒT]§n{ºöB³ ¦ ̹Â8Êï¦MÉ<„¨s¹¶ì7Ì”æR$Ncà! /éþäRM÷Gƒ¿É$
¦oà>%6·y6ƒ‰3?”úºŽ‰éX5ªPT §µ!=Mž«Ú½‹ÅgÂSâÉaþÓoö–¯ÁÔìR>5éÿ üs¶ÆUcÌ  kÇR
]ÿ ù¬¼«VŽ;Â|‡~¢¦”ÏÅ°æ
{L™Õ°Óv¹ò¸írŽ¡×¢CÃ!íVÕ {¶»sŒNPg/
"uÕbkm²“$ďå¿é¹§°½æz¯6 †s¿!s–wÚÝ“™Œ°.ûj>·+™Òa…©Œ&rÝÎtÛë긪Ît’LAVp%c Úý[ÄzJ¾ÇàXXç@˜ó<êL]·T˜¾¥1Ó©V‡g´æ½¦Ý@¹óø!_@´ÞâSÁ —S3™•& ]@JHÚý©ZŽ €×æÔr»Áf!‡yÞ4Mv*èÓã_{‘åóUuљØ«Oïé*®EvÑ
Œ÷‡U \"㪒ÍK+À 4“M¡ï:0¥5í!'<@î´”>Ç»&Z–ïCCV˜Ì5Šo&îhè.žû
|ÓK©h$s6KìŒëã)¹hI¦GïOåóI;ììü#É$Š0…Ææ¥TØ.5­¾gn´ “ÂÖ\:hœ89G)J@„}œ:’Ò{/Š"¦_Æ×7Æ3VÇŠÊa]ÚŒÙ€Ä–=®uÁßâACZƒ§§£Qnâ:«,×{tyø¬iÛcœÜÄ€H½ÄÍCk´÷šß
.W'b¤Íåh]÷€=,Žv×cÚEÚHXJX¶îo¨FÒtèöŸ>ªª6[J®Fµ£sGÁeqõfe\íjÒÐïÄÐGˆe1Ø‹.Ø”‘Ëuø
Y­ˆÜŽG|zùªüMpDnQWÄ”%JŠ™)â*p@Örš«ÕT2Ð%ˆG#ª„
·¤!°ŸOTÂT¸aÚ%4&h™LµšØüÐ.F¿²ÐÞ_Ç‚¾ÅÃaÜ÷09Æ 
q€öy˜v‡85õN÷]¬äѼóS{°_MŽ¬úÔ#°Ç¸0åÞè2ëôPcvÆw9®ií1Ä8F™˜à‰´+‰Ik1òÝ7“Ñ×ÒsÝ\x‚h`ÞÑ`ó"|µEcý£n˜h`}GÞ  !±ù²Ápü²
ß6
0ïi󜵩SÈÇ7˜-ÕURO˜¦´f$ªž-Í6(œ}<„ éc øs]ŽŽ„*—¾
ìdŽ„)méª\¿êÎIg¾ØÞ~I#C/¼¼´EÁÈŽi8“©õådô·>euä ƒ'Ê×लR1ÉJE1ÐAát`t;ÇР%Ý<‡¥„ÍÆ`×Oyó)õiI€ñQaŸ4Ûù\áàaÃÔ¹HÃu¹*k€¦<„eS‡&õÏ
B!ŽhüÞ`yj}mªf×\¿
Ç~æ­9‡û\՞Ǖg²1Žû5V7 !àöšm°
c`ܬøÇìµÒ'P"?…´Ö,"§^•õŽ¨sÔ)6˜sæéÍR¼
ò|Sl”‹7 nPW

Gòú÷½§O¯‡„l¡kSÞŒr½PÊ@æ¢pŽ-mÿ #Ÿ˜Àº¶Áä¦;ïÔæ$1££`“Õ>„—·ž)ß
ð
³ñ#Ï Ô$¶œ‰ÊE‹À;÷º
¯«P:Ñ”8–IÊtpÞ3ª“>ê“þës4ò2OÏÕ­±zô†Õ§‰.÷ä¸;¿˜“'œ›žª}«Œ{ª±Ì 9ÔóÞÕ‡0
$íWV3Üì¬
—@kÝ4@¿r¼±½¬™›?øØæ´'Áé®CË3-g$˜ö‡×auÚi´Žp/êÛæF›Ú2v‹ã¿¿,nB1̨ƃqÞa5͝@&Æû“él÷ \C²½UÍc ¯k×¢U
ÖéQå™—-r    wô ÞÏ<Ò=&=ÿ Ôê Òêˈt,i—;LîÜ á¸*ÚÃ1$êL•LÍ <É)ýÐà’
;F™{ƒ™˜€&'}‚ãÄK`¡ÞT@I;®žZóè‚s’7®°›+§O­Åq©é»²9<Ô
J ¼9O’HL»Ùïì¸rk¼Ž_ý‘TŸu[²ßÚŒ·ü÷B%¯E ŸÔX5êO´Ç•€’I0 É<mÆÈJoúáõóQâØòÙaÙt:  ·=|Ôaz]a1cÉŸ1
4˜à3΍}GFøí7/B«vεŕL=Ðr1ÕšnwH›óÞ¢ºö{)´4€æZç^ÿ yÑ:_([¿ipqQÊ^âÆe;»½“¦º|¢ÀTçèrú1”óTÃ’u¦CG¤ ¡
Š­7ë

·i“¿z»n
ö¼±ù^ö<‹çu7¸ÈlvZðÛAUXje•
dLÞH ÚosÇr`È™‡pÊeÇ4@x7´)ö†Ótœ~i‘Ï[x@äUÃæ­m·e´x
°t¸·²5'žªža   =ÖÌåzϘ'-´ˆpž3§ò‡k  Ý'‰ýÑï¦3ºdè“{eiÔõNkîšECEΠ¥ÃT9ãqÃâŸîɐ8z \?€    >JX` 
ñ¹õ%;µŸD‘«´€àwÒ™UûئžÖö\×®×´8 ½‡ºÐÆÓ§?Àkmœ=;d5*@-ì0F Rªýš[Ü6âö̃ڸr*KA9· u*µæ£?U¸Âêí†8@¦X4 e-ò„0s{ HâUpU?¼mñRa°®a%Ð'tÉ×’\¾ÊÉ]t›h>·(Ë@R¼¡Ãt h}’O÷au<+nT…Ö…MӐ??Óe95 q>í/;&JSû °¯ÊéÞøƒ*Ã2½Ài&:nôUl=¾¿5eˆ3”ñc|Ú2V”>„»&eE;«ÚäC
p¢Ûúy 9š[ŒÌx¼擼A&DåÒ¯ˆ¤ÀÌ;"˜ÏQä¸åhÊ}Ûq«Û0WžÒ|»€ø®öCm5•\ÇÀ§Pe3£]0ÃàLDÉ‰1øªxjgwT‚÷¿LΨK‹›ùs—xˆÜ±µ
kæ¸f‰‰ÜGk/LÛØ6d9ò¶ùA{ƒA3š/¬D¬khÓk‰`˜"㯒r¿±Óã jx‡°e}<Ñø\3y:'À•/h½Í€Ç4~g ?Û(¼]v‘ªlKÎâ~?O‚W%{Ì:“'©úNq¾›úo(X’¥¯ˆ
nFê{Ç€ü?º'ë
ø‹ì
Þ09ŒÌç9Æ —ËC`j@ÓÄ(+a‹un¸#ÂꟋ{K`‘ÑÍÍ'à´»/Û,KW;Þ4²þð ï Nm|~fGÏ(…³Ã)«1ö­Õ
¥‡¨©ƒÃ™ü-s=à=U66Ï«Ýc蓦W¹íž®›nÔ%êÇìŒ<#Ü×84ån®Ð ÒåOC`  ñânÑs‡¢ç 1õ%Îhì½Ã½® e:ݼUZo
™`  
ÅZŸŒÊ«ê1ÏÄo$q¹Þ€©ˆhÐÉä¯ñ[!…Ú˜àJ:x2$Íß&PåT£6ç—
‡Í*4Ýšçjÿ ‰É nófÐ ó(L5C•åÆ\rMÒ@ò
}y-W}™üýVù—ú¢=Ù”c®‘< M ž
´Phr¦©TD ‘ù.$´÷O‡‘V2Æò.=IUŒ=ž‡â¬i™aþÓåÙ?òUø'ØÖ•.~* šTŒ!•-×áºTâ®ä#õü'´ eýlYÅÓeÕKÂrT"CÚ@u!Óxƒ{š3€}1¿(r}%«nËamjÑ%ÑNEò
v  ˜à  σöK³,*º.àzù¨™Ó ÚçâU¦*¿ 9{%Ö¹ njûdaXöb)  kÛƱûÓ\°M7ˆÂ=û›ç¿Ã‚­V»Cg–8ÙêE-j)k$º`Ã-ùEýeBÆÇ]c¡°ñty&Òd0nõ'¡W+ƒ*|–ø<K\%¦cÏÄ#N,Úú‘¤òÒÛõ ’¶§‰Ì
ú•dçb31Ð\7‡ëÚw82
‰KÝkÚñ'¢Ž…[&¼ÌAÔzHàP *اoßreÁY¥Ñ¾ãE|&QbKg]ã„þê*b;R³Öi‹  ±î$£ÈTm¶k÷ˆ
¦»Ù¹i¦¨6 h%Á'Ú
J   \F±â+‹b/Å9ñå5Àë­nˆRv«¯#„&î„$º’@:‘Ôrø+,àq‘秬*Úg´>µFa\GQªEAÔp5\Ǽ·¼Ç8·õ -â§Ú[
‡
uZeÖ 3}×d'+¹:ð+K†Û®s!Ï$úe€<Û”x)1»a­¡LC]¸µík…ÚàA»AYº{†ªS[¦5HÒ7ù
--,ísòDØ€èk   ÞÀîÜò@â(  ËNˆë›4ô½•/¦o‡€Û7
ê•ÆêòðÜy
'Án½µ á˜ݦ  ndeo…[ì¶Ê,¥R³Ä=À±—–ß;£™´ñSâ*g§”ïaið‘Jå~™ÓÞß³Õ¢»8x埒²52>AÊb&-÷\7´éÄù€T˜,w;3{ï˜k…à¹ÄqÀ«œ{
€\
ˆ¾[´¨јr &Úé„Ívˆ±8†¿]|¬ņ4I×pÞS1ÈÖz‰#Ìv‡G!YNògñ:màTz¢Ý1ô©^O=~ë|5Bã™ç•¼µõ•bÆ@úÕS¬ÈŒ#¬zünrŸ
û”
Z²•ï›èðV"ÁHÚý©wÝ €7¼Ìu1hÑa3Éä û f$o¿É ™Ú›ÝçnpÒ3äÌ3†Í§,Äï]$‰/pê†«À¼
¸e9­Æê_C]žƒ·ý·frÁN«,E=›Çq
-‰öŒ:aÏ¿±í&£Í:-}
84‘ÿ eƒQÑeëSsuiA
³g㟥ú£?ÿ ʼn*”“÷aühe:ÊWa@ÒÞk±eØ]
F Ô—r.åä˜@ö¥ªZoÐýYL·¥S²G/‡ñ
<~*ZÆ´è>JlòàÛƽÿ 窘ìGN¢:I®KšJp/`íIÁÀõ#Ä-€ö­šµŒoF4|ÆQØÆ@Ì|£Ô…¢À{9˜è½Üó›€ôYÒÎYsið;ís¤€à²ˆ‚4qÉVŒI$  ‰"°   æµ8cXGjœˏ¡Aâý•ËÜ¢ûïe·çLx']á"oÅÎê3¯Ç—¹”ó0nå‚âg{Œñ>
S´˜îè°g238‚ãköÝfÚd´6Ò€;ò÷±¢™¼›º¢Æ'¥Ðx'e¬ç
]bÈÆV¢ó‹kýBO
ðÊâ$Ÿ!×T
3Mýמ
žìٍàÌü‘8÷€àæØ8æ©6‰©L´«…oãpð„~Çk‰!ñ;‹”ÛžÍ àž±z Ÿôû øŸÝužÏ;ÿ #|u6™Þ¬ÚˆÐõA4¶â|ôl|Ê2ŽÇ¤ÝÅÇY.<#Aí.k§hóF‚”Y;
M½Ö4hŸ4&›­¿tès´%FìL¥£Ãk‰ÇT¤haÁ¤ÚxfÉ`ÑìË›>i 3t‚:,–+^÷´–{Û–Nxi"x‘Ûg
î¨>¥Õ܁ùZH,2Û“:8xÊ¢Çí9.É-Ìâã-=çjwµS˜dütžçwýGòú®®ûº_ˆýx$–¡ãøO
EÚÛÏ÷R„×w+3£Á£öUMyR²¹âŒ°š›¸Ñãò9§Ó_Dl+Ùßc›úšGÅÌc†Ž!Ko=¶.‘Îÿ c²(2®V mª.ÿ ¹B›¹å ù„öŸSV>™ü¯$y:G¢Z×àøúdî¹û­·ýÇ´:•c LÍõi_‹ö+ÎæGÊè>OŠ•äž´§Þ{X}¨1ÚTc›»Qþ•êô°t¿OP?eæ~É{5]•ÙR£r5†nZ\ã@
&îJõ ¾àC°þV>fé¥/ü5ñÊIº_é5;e­h<@
Ä&æÃëE%;X,ÒãÆÞ`Oò¦kŸm#˜!ÀyÄ¢|
óLšò¥Ä`
¶R=|ÈCâh5ò3DˆïF†ðÒ#ÅìÛœ?¸yhBãœí
ZxßÎÄhºRK„`Þödvײ™ÀÈÑÒgŒuYw³%†ƒÓzõ ÖÏp‚dH®¦A´ù§»ÓÇMæ~)ˆð‡û:ù&Ä •vGD´À 
n
Ý
‡¼Ö8Fö   óáà£~Ë¥x`oK|Ä?fxiØü%pìR>éò+Û±éÎ>núlFŤ'tq8LZÏvÃ?„¡ß±È⽆¯³íü@x|PöUäèØã¡ð‚ŒAìÏ"vÍwóŸÍ{ ý0.z    È•Ö{,N¡£¡ŸKÕÙž>Ýœþ ÍÀ<n^Àïe€Þgn¹”ÜiQê
9Ú±‡„è]ËA¿‚MJìiÓxŒn-ÄS6!ÓæÑû*jÎWøìšÇ뙦gj~+?\,Ö7ÁÕÊ”G™q6TF)óCç<ÓšÂUé†gW=àà“hóR³ÊQì<!÷ÇpR1¯u„De,è­vvâDß~žHå‰ú£Kìní¢ÐçÅÄÅ¥Ü÷
±ÃìÇžûƒz\þÞ¨-•‹
€

¸+¶n¿^
?†[ÖWóÒX¸,0Ø:l?‰Âý«ÿ ·Dc+fÔ[ƒ›ûªšx«kæž1KI…<#'nž¶\±íÎ8¤ìK@’@J¥v)º[Ž±Æå´¼
½Ý¡ç¯ÐO¥ø®è•Óȱ߿wša©“œt‡4îyªœ&+1ÏØ:‚æƒ=/ꎔ`hm
“=©‹]°g}ì€DgUƒ8¤qCˆãáÅ,‡Ô¬ñ10HÑDÂbáÂÿ Œ»v·:uòB6»áp‰>°<×EA!Å‚D™IúOÍ
¡>ôG}Â`ÍßkÜL™Ž  Þð™
{IøF²
¹òQ3&!ÃÂÞz.d&Ï-sH¸,Ôõ˜ŽP€
77ˆÝ¼ÊëÜw   =cÕ
Ú,ØÐ5ÎYÐ)ì´öœgŒ[¤
ßv㙑8心>h]§µháYš£²ºÑ.{Ï7Sð•?´~×SÃKýJÛ˜
™Íäiúu<µX¶1õ^kâçIÑ£sZ4h>j*ÔšD:4­¿_ ÷¸
Õxæÿ ¸?Mù _•­ÊÐ ä ÷ý ÑwL
œ­ïnTkÛUÍN©ë:¦fV ¶ÜÔÜMªÅâA½–¿R×TXš-%iTÊT•‡Ù‚JôϐZxWÑè‰f‰òG º
×Õû2aZ7OU3[“×AT–ÞŒ…-‘¤”Ì 
ì&(ˆ¿­•ƒkï’:ðY¦W‘Å)“†‘˜³Åtcø˜ñTÂwÚÇ4
|üLÇªí–v-
qˆèU
qPE.†â‘˜µ Æ,ÐÅs]8¾„oúÑ i>ÜxxÈó)ƒ ´æÁâØ$À‰vžŸf$Ž|ãw;ÀÁIJ»b`
{¦Ó¤Ú$©YÀ‘n@Óïž«9J¼êG   m¤
ܯ¹ÌW4€ÐÒÅÛ‡#褕Ÿn-?í|с¥÷Ú¹¬'´ÞÜ9ÓK`hê£SÄSà?7—Wí_´…óB›»:=Ãïq`<8ñÓŒÑlú2d¬ê³£hÖ[l|$vÝro~'R®‰§°ñmY ͧäP
|PUª¹·:3Œ[Û{Xÿ ºâ@‚W–Äé u‚ ¯´*=íή.pûÒdt @
G‰¬ s¸    ëÉücr ÞæѨÊ@>¤¢Ö±.Þ'¯°ÌME[YéïĵÂCå½
Ué©Áû'Ê9%eÔðNU”ë‘ÌsD3/®+UI˜9h.WC”
빓$#:pz:YÓ ¿xž* ³$Í +$kñAŠ‹†¢
Uê>¸)_š¬÷©ßAÂÔb9ÇU ¯¾
á•9¯ÏÏ÷O÷¼¼Fähal1‰3Ì[Ïr•´UCksNÐ]R‘¸¥H+§Šé†c©vÖÞ0iÓ76s†î!§=ß
¼~Ô'°Ãmäoäš³ªøi1úÉ)³yV8CLÄØÁ‘WYïi€H6ÖÑiámø^ÈY´°Ñ7¥Û*—Ñ©L«Qƒï—Ùrÿ ›£Ð*š¸ˆL©ˆ$ˆ ÷¾D§9È®«qbqC)–ˆïv´çñsÑVT­Ø, <àïºÀO«Jý·õ 
àfPìð  .wFšir´þ’2_Y
*Æ€x\«
ì€9š@ Ž|F⇥ˆkZ@hÖÄ0t¿-<“‹qµ¾*ZL¤Ú)&BJpÓF5=$„at*Zš$’ÑtdûÝRI1    2Ž‰$€$I$#‰SÞ’H
ë¬ï;Á$¡t$’`<(ñÇt)$‡Ð.Êf¢X’Kt=Éé$‚ˆªè¢oÝëòI%Rgcª÷ŠyI%¡‰ÿ !ñ)´õ $¤ Ô’IIGÿÙa

�3�gp��@sdd
lm
Z

e
�d�

e
��
ddlmZ
ddlmZ
ddlZddl	Z	ddl
Z
ddlmZ
ddl
Z
ddlZddlZddlZddlZddlZddlZddlmZ
ddlmZ
dd	lmZmZmZmZmZmZmZ
dd
l m!Z!
ddl"Z#ddl$Z#ddl#Z%e
j&ddd��
re�'d
�
�
eddfdd�
Z(e(ed�
Z)e(ed�
Z*e(ed�
Z+e(ed�
Z,e(ee-�d�Z.e(edd�Z/da0dd�Z1dd�Z2dd�Z3dd�Z4dd�Z5dd �Z6dkd!d"�
Z7Gd#d$�d$e8�Z9Gd%d&�d&�Z:d'd(�Z;Gd)d*�d*ej<�Z=Gd+d,�d,�Z>Gd-d.�d.e>�Z?Gd/d0�d0e>�Z@Gd1d2�d2e>�ZAGd3d4�d4e>�ZBe=f
e?e@eBeAffd5d6�
ZCGd7d8�d8e>�ZDGd9d:�d:e>�ZEeCeD�

eCeE�

Gd;d<�d<�ZFGd=d>�d>e?eFe=�ZGGd?d@�d@eF�ZHeCeHe@eBeAfdA�
GdBdC�dC�ZIGdDdE�dEe?eIe=�ZJeCeIe@eBeAfdA�
GdFdG�dG�ZKeCeK�

GdHdI�dI�ZLGdJdK�dKe?eLe=�ZMGdLdM�dMeL�ZNeCeNe@eBeAfdA�
dldNdO�
ZOdPdQ�ZPdRdS�ZQdTdU�ZRdVdW�ZSGdXdY�dYe8�ZTGdZd[�d[e8�ZUGd\d]�d]e8�ZVGd^d_�d_e8�ZWGd`da�dae8�ZXGdbdc�dce8�ZYGddde�de�ZZeCeZe@eBeAfdA�
Gdfdg�dge=�Z[dhdi�Z\e]djk�re�^�
dS)m�)
�support�_multiprocessing)
�hashlib_helper)
�assert_python_okN)
�QueueHandler�
�
PicklingError)
�futures)�PENDING�RUNNING�	CANCELLED�CANCELLED_AND_NOTIFIED�FINISHED�Future�BrokenExecutor)
�BrokenProcessPoolT)�addressZmemoryz test too slow on ASAN/MSAN buildcCst�}||_
|
|_||_|S�
N)r�_state�
_exception�_result)�state�	exception�result�
f�r�;/opt/python39/lib/python3.9/test/test_concurrent_futures.py�
create_future)s





r�
r�rr�*�rr�
uninitializedcCs||
Srr)�
x�
yrrr�mul;s
r%cOs||
fSrr)�args�kwargsrrr�capture>s
r(c

Cst�
|�

td
�
�
dS)Nzthis is an exception)�time�sleep�	Exception)
�
trrr�sleep_and_raiseAs


r-cCs t�
|�

t|
�

tj��
dSr)r)r*�print�sys�stdout�flush)r,�msgrrr�sleep_and_printEs



r3c


Cs|adSr�
�INITIALIZER_STATUS)
r#rrr�initJsr6c
CstSrr4rrrr�get_init_statusNs
r7c
CsF|du
r0t�
d
�
}
|
�t|�
�

|
�d�

d|
_t�d�

td�
�
dS)N�concurrent.futures�CRITICALF皙�����?zerror in initializer)	�logging�	getLogger�
addHandlerr�setLevel�	propagater)r*�
ValueError)�	log_queue�loggerrrr�	init_failQs









rCc@seZ
dZd
d�ZdS)�MyObjectc


CsdSrr�
�selfrrr�	my_method\s
zMyObject.my_methodN)�__name__�
__module__�__qualname__rGrrrrrD[s
rDc@seZ
dZd
d�Zdd�ZdS)�
EventfulGCObjcCs|
��|_
dSr)�Event�event)rF�mgrrrr�__init__as
zEventfulGCObj.__init__c

Cs|j�
�
dSr)rM�setrErrr�__del__ds
zEventfulGCObj.__del__N)rHrIrJrOrQrrrrrK`s
rKc


Cst�Sr)
rD)
�
_rrr�make_dummy_objecths
rSc@seZ
dZd
d�Zdd�ZdS)�BaseTestCasec

Cst�
�|_dSr)r�threading_setup�_thread_keyrErrr�setUpms
zBaseTestCase.setUpc

Cst�
�
tj|j�
dSr)r�
reap_children�threading_cleanuprVrErrr�tearDownps

zBaseTestCase.tearDownN)rHrIrJrWrZrrrrrTls
rTcs8eZ
dZd
ZiZ�f
dd�Z�f
dd�Zdd�Z�ZS)�
ExecutorMixin�c

s^t��
�
t��|_t|d
�r@|jf|j|��d�|j	�
�
|_
n|jfd|ji
|j	�
�
|_
dS)N�ctx��max_workers�
mp_contextr_)�superrWr)�	monotonic�t1�hasattr�
executor_type�worker_count�get_context�executor_kwargs�executorrE�
�	__class__rrrWys







��

��zExecutorMixin.setUpc
sT|jj
d
d�

d|_t��|j}
tjr8td|
dd�
|�|
dd�
t	��
�
dS)NT�
�waitz%.2fs�
 )
�endi,
z+synchronization issue: test lasted too long)ri�shutdownr)rbrcr�verboser.Z
assertLessrarZ)rFZdtrjrrrZ�s




zExecutorMixin.tearDownc

Cst�
|j�
Sr)�mprgr]rErrrrg�s
zExecutorMixin.get_context)	rHrIrJrfrhrWrZrg�
__classcell__rrrjrr[us


r[c
@seZ
dZejZd
S)�ThreadPoolMixinN)rHrIrJr	�ThreadPoolExecutorrerrrrrt�s
rtcs&eZ
dZejZd
Z�f
dd�Z�ZS)�ProcessPoolForkMixin�forkc

stj
d
kr|�d�

t���S�N�win32zrequire unix system�r/�platformZskipTestrargrErjrrrg�s




z ProcessPoolForkMixin.get_context�	rHrIrJr	�ProcessPoolExecutorrer]rgrsrrrjrrv�s

rvc
@seZ
dZejZd
ZdS)�ProcessPoolSpawnMixin�spawnN)rHrIrJr	r}rer]rrrrr~�s

r~cs&eZ
dZejZd
Z�f
dd�Z�ZS)�ProcessPoolForkserverMixin�
forkserverc

stj
d
kr|�d�

t���SrxrzrErjrrrg�s




z&ProcessPoolForkserverMixin.get_contextr|rrrjrr��s

r�cCsPd
d�}|D]>}d||j�
||j�
f}t
||f
|f
|
i�}|t�|<qdS)Nc

Ss4|�d
�
r|dd�S|�d�
r,|dd�S|SdS)N)ZMixinZTests�����ZTest�����)
�endswith)
�namerrr�strip_mixin�s






z*create_executor_tests.<locals>.strip_mixinz%s%sTest)rH�type�globals)Zmixin�bases�executor_mixinsr�Zexer��clsrrr�create_executor_tests�s

�
r�cs(eZ
dZd
Z�f
dd�Zdd�Z�ZS)�InitializerMixin�c

s d
at
tdd�|_t���
dS)Nr")
�initialized��initializer�initargs)r5�dictr6rhrarWrErjrrrW�s


�zInitializerMixin.setUpc
s6�f
d
d�t�j
�
D�
}
|
D]}��|��d�
qdS)Nc
sg|]}
�j�
t�
�qSr)ri�submitr7��.0rRrErr�
<listcomp>�s
�z5InitializerMixin.test_initializer.<locals>.<listcomp>r�)�rangerf�assertEqualr)rFr	rrrEr�test_initializer�s



�
z!InitializerMixin.test_initializer)rHrIrJrfrWr�rsrrrjrr��s
r�cs6eZ
dZd
Z�f
dd�Zdd�Zejdd��
Z�Z	S)�FailingInitializerMixinr�c

sZt|d
�r4|�
�|_|j��|_tt|jf
d�|_nd|_d|_ttd�
|_t��	�
dS)Nr]r�)
r�)
rdrgr`�QueuerAr�rCrhrarWrErjrrrW�s





�



zFailingInitializerMixin.setUpc
	Cs�|�d
�
��
z|j
�t�
}
Wnty.


Yn40|�t�
�
|
��
Wd�
n1sX0


Y
t��}|j
j	s�t��|dkr�|�
d�

t�d�

qj|�t�
�
|j
�t�

Wd�
n1s�0


Y
Wd�
n1s�0


Y
dS)Nz ValueError: error in initializerr\zexecutor not broken after 5 s.g{�G�z�?)�_assert_loggedrir�r7r�assertRaisesrr)rb�_broken�failr*)rF�futurercrrrr��s




&





z(FailingInitializerMixin.test_initializerc#s�|jdu
rFdV
g}z|�
|j�����

qWq~tjyB


Yq~0n8|�d
d��}dV
Wd�
n1sn0


Y
|j}|�t	�f
dd�|D�
�
|�
dS)Nr8r9c
3s|]}
�|
vV
qdSrr)r��line�
r2rr�	<genexpr>

�z9FailingInitializerMixin._assert_logged.<locals>.<genexpr>)
rA�append�
get_nowait�
getMessage�queue�EmptyZ
assertLogs�output�
assertTrue�any)rFr2r��cmrr�rr��s






$


�z&FailingInitializerMixin._assert_logged)
rHrIrJrfrWr��
contextlib�contextmanagerr�rsrrrjrr��s


r�c@s<eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
S)�ExecutorShutdownTestc

Cs$|j�
�
|�t|jjtd
d�
dS)Nr�r\)rirpr��RuntimeErrorr��powrErrr�test_run_after_shutdown
s





�z,ExecutorShutdownTest.test_run_after_shutdownc
CsDtd
dj
|jjt|dd�d��\}
}}|�|�

|�|��d�
dS)N�-caKif 1:
            from concurrent.futures import {executor_type}
            from time import sleep
            from test.test_concurrent_futures import sleep_and_print
            if __name__ == "__main__":
                context = '{context}'
                if context == "":
                    t = {executor_type}(5)
                else:
                    from multiprocessing import get_context
                    context = get_context(context)
                    t = {executor_type}(5, mp_context=context)
                t.submit(sleep_and_print, 1.0, "apple")
            r]��re�context�apple)r�formatrerH�getattr�assertFalser��strip�rF�rc�out�errrrr�test_interpreter_shutdown
s


�

z.ExecutorShutdownTest.test_interpreter_shutdownc
CsJtd
dj
|jjt|dd�d��\}
}}|�d|���
|�|��d�
dS)Nr�a�if 1:
            import atexit
            @atexit.register
            def run_last():
                try:
                    t.submit(id, None)
                except RuntimeError:
                    print("runtime-error")
                    raise
            from concurrent.futures import {executor_type}
            if __name__ == "__main__":
                context = '{context}'
                if not context:
                    t = {executor_type}(5)
                else:
                    from multiprocessing import get_context
                    context = get_context(context)
                    t = {executor_type}(5, mp_context=context)
                    t.submit(id, 42).result()
            r]r�r�z)RuntimeError: cannot schedule new futuress
runtime-error)	rr�rerHr��assertIn�decoder�r�r�rrr�&test_submit_after_interpreter_shutdown2
s

�
z;ExecutorShutdownTest.test_submit_after_interpreter_shutdownc
s6�f
d
d�td�
D�
}
�j
��
|
D]}|��
q$dS)Nc
sg|]}
�j�
tjd��qS�
r:�rir�r)r*r�rErrr�O
r�z=ExecutorShutdownTest.test_hang_issue12364.<locals>.<listcomp>�2)r�rirpr)rF�fsrrrEr�test_hang_issue12364N
s




z)ExecutorShutdownTest.test_hang_issue12364c
s��f
d
d�td�
D�
}
�j
jdd�

dd�|
D�
}��t|�
d�
dd�|
D�
}|D],}�j|��d	|j��d
�
��|�	��

qT��t|�
d�
dS)Nc
sg|]}
�j�
tjd��qSr�r�r�rErrr�V
r�z<ExecutorShutdownTest.test_cancel_futures.<locals>.<listcomp>r�T)
�cancel_futuresc
Ssg|]}
|
��r|
�qSr�
�	cancelled�r��futrrrr�[
r��c
Ssg|]}
|
��s|
�qSrr�r�rrrr�a
r�zfut._state=r�r
)
r�rirpZ
assertGreater�lenr��doner�assertIsNoner)rFr�r�Zothersr�rrEr�test_cancel_futuresT
s




z(ExecutorShutdownTest.test_cancel_futuresc
CsZ|jt
jkrt�d
�
�
tddj|jjt|dd�d��\}
}}|�	|�

|�
|��d�
dS)z�shutdown(wait=False) doesn't hang at exit with running futures.

        See https://github.com/python/cpython/issues/83386.
        z9Hangs, see https://github.com/python/cpython/issues/83386r�a�
if True:
            from concurrent.futures import {executor_type}
            from test.test_concurrent_futures import sleep_and_print
            if __name__ == "__main__":
                if {context!r}: multiprocessing.set_start_method({context!r})
                t = {executor_type}(max_workers=3)
                t.submit(sleep_and_print, 1.0, "apple")
                t.shutdown(wait=False)
            r]Nr�r�)rer	r}�unittest�SkipTestrr�rHr�r�r�r�r�rrr�test_hang_gh83386k
s

�

�


z&ExecutorShutdownTest.test_hang_gh83386N)	rHrIrJr�r�r�r�r�r�rrrrr�
s
r�c@sDeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dS)�ThreadPoolShutdownTestc
Cs|d
d�}
t�
d�
}td�
D]}|j�|
|�
q|�t|jj�
d�
td�
D]}|��
qJ|j�	�
|jjD]}|�
�
qjdS)Nc

Ss|��
dSr�
�acquire�
�lockrrr�acquire_lock�
s
zCThreadPoolShutdownTest.test_threads_terminate.<locals>.acquire_lockr
�)�	threading�	Semaphorer�rir�r�r��_threads�releaserp�join)rFr��sem�
ir,rrr�test_threads_terminate�
s











z-ThreadPoolShutdownTest.test_threads_terminatec

Csjtj
d
d�
�6}
|
}|�t|
�ttdd
���
gd�
�
Wd�
n1sH0


Y
|jD]}|��
qXdS)Nr\�
r_r��
r\�r�r��
r
r�r�r�r�)	r	rur��list�map�absr�r�r�)rF�
erir,rrr�test_context_manager_shutdown�
s



�"

z4ThreadPoolShutdownTest.test_context_manager_shutdownc
Cs<tj
d
d�
}
|
�ttdd
��}|
j}~
|D]}|��
q*dS)Nr\r�r�)r	rur�r�r�r�r��rFri�res�threadsr,rrr�test_del_shutdown�
s





z(ThreadPoolShutdownTest.test_del_shutdownc
CsFtj
d
d�
}
|
�ttdd
��}|
j}|
jdd�

|D]}|��
q4dS)Nr\r�r�Frl)r	rur�r�r�r�rpr�r�rrr�test_shutdown_no_wait�
s





z,ThreadPoolShutdownTest.test_shutdown_no_waitc
CsTtj
d
dd�}
|
�ttdd
��
|
j}~
t��
|D]}|�|j	d�
|�
�
q4dS)Nr\ZSpecialPool)r_Zthread_name_prefixr�z^SpecialPool_[0-4]$�r	rur�r�r�r�r�
gc_collect�assertRegexr�r��rFrir�r,rrr�test_thread_names_assigned�
s

�




z1ThreadPoolShutdownTest.test_thread_names_assignedc
CsRtj
d
d�
}
|
�ttdd
��
|
j}~
t��
|D]}|�|j	d�
|�
�
q2dS)Nr\r�r�zThreadPoolExecutor-\d+_[0-4]$r�r�rrr�test_thread_names_default�
s





z0ThreadPoolShutdownTest.test_thread_names_defaultc
Cs:td
dj
|jjd�
�\}
}}|�|�

|�|��d�
dS)Nr�a[
if True:
            from concurrent.futures import ThreadPoolExecutor
            from test.test_concurrent_futures import sleep_and_print
            if __name__ == "__main__":
                t = ThreadPoolExecutor()
                t.submit(sleep_and_print, .1, "apple")
                t.shutdown(wait=False, cancel_futures=True)
            )
rer�)rr�rerHr�r�r�r�rrr�test_cancel_futures_wait_false�
s
�


z5ThreadPoolShutdownTest.test_cancel_futures_wait_falseN)
rHrIrJr�r�r�r�r�r�r�rrrrr��
s
	

r�c@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
�ProcessPoolShutdownTestc
Cs�d
d�}
|��}|j
dd�
dkr(|j}nd}|�d�
}td�
D]}|j�|
|�
q>|�t|jj	�
|�
td�
D]}|�
�
qn|jj	}|j��
|��D]}|�
�
q�dS)Nc

Ss|��
dSrr�r�rrrr��
s
zFProcessPoolShutdownTest.test_processes_terminate.<locals>.acquire_lockF�
�
allow_nonerwr�r
)rg�get_start_methodrfr�r�rir�r�r��
_processesr�rp�valuesr�)rFr�r`Zexpected_num_processesr�rR�	processes�
prrr�test_processes_terminate�
s












z0ProcessPoolShutdownTest.test_processes_terminatec

Csttj
d
|��d��8}
|
j}|�t|
�ttdd
���
gd�
�
Wd�
n1sP0


Y
|�	�D]}|�
�
qbdS)Nr\r^r�r�)r	r}rgr
r�r�r�r�r�r

r�)rFr�r
r
rrrr��
s

�



�"
z5ProcessPoolShutdownTest.test_context_manager_shutdownc
Csptj
d
|��d�}
|
�ttdd
��}|
j}|
j}|
j}|
j}~
t	�
�
|��
|��D]}|��
qV|�
�
dS)Nr\r^r�)r	r}rgr�r�r��_executor_manager_threadr
�_call_queuerr�r�r

�join_thread)rFrir��executor_manager_threadr
�
call_queuer
rrrr�s

�









z)ProcessPoolShutdownTest.test_del_shutdownc
Csltj
d
|��d�}
|
�ttdd
��}|
j}|
j}|
j}|
j	dd�

|�
�
|��D]}|�
�
qR|��
dS)Nr\r^r�Frl)
r	r}rgr�r�r�r
r
r
rpr�r

r
)rFrir�r
r	
r
r
rrrr�s
�







z-ProcessPoolShutdownTest.test_shutdown_no_waitN)rHrIrJr
r�r�r�rrrrr��
s

r�)
r�c@sLeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dS)�	WaitTestsc
CsH|j�
tjd
�}
tj|
|
gtjd�\}}|�|
h
|�
|�t�|�
dS�N��?�
�return_when)	rir�r)r*r	rm�
ALL_COMPLETEDr�rP)rFr�r��not_donerrr�
test_203696s


�

zWaitTests.test_20369c
Csd|j�
td
d�}
|j�
tjd�}tjt|
|gtjd�\}}|�	t
|
g
�
|�
|�	t
t|g�
|�
dS)N�r�r
r

)rir�r%r)r*r	rm�CANCELLED_FUTURE�FIRST_COMPLETEDr�rP)rF�future1�future2r�r
rrr�test_first_completed?s



�

zWaitTests.test_first_completedc
CsT|j�
tjd
�}
tjtt|
gtjd�\}}|�	t
ttg�
|�
|�	t
|
g
�
|�
dSr
)rir�r)r*r	rm�CANCELLED_AND_NOTIFIED_FUTURE�SUCCESSFUL_FUTUREr
r�rP�rFr
�finished�pendingrrr�+test_first_completed_some_already_completedJs


�



�z5WaitTests.test_first_completed_some_already_completedc
Csr|j�
td
d�}
|j�
td�}|j�
tjd�}tj|
||gtjd�\}}|�	t
|
|g�
|�
|�	t
|g
�
|�
dS)Nr�r
r
r�r

)rir�r%r-r)r*r	rm�FIRST_EXCEPTIONr�rP)rFr
r
Zfuture3r
r
rrr�test_first_exceptionVs




�

zWaitTests.test_first_exceptionc
Csl|j�
td
d�}
|j�
tjd�}tjttt	|
|gtj
d�\}}|�ttt	|
g�
|�
|�tt|g�
|�
dS)Nr
r
r
r

)
rir��divmodr)r*r	rmr
r
r
r
r�rP�rFr
r
r
r
rrr�*test_first_exception_some_already_completebs"





��


��z4WaitTests.test_first_exception_some_already_completec
CsP|j�
tjd
�}
tjt|
gtjd�\}}|�t	tg
�
|�
|�t	|
g
�
|�
dS)Nr�r

)
rir�r)r*r	rm�EXCEPTION_FUTUREr
r�rPr
rrr�'test_first_exception_one_already_failedrs


�

z1WaitTests.test_first_exception_one_already_failedc
Csj|j�
td
d�}
|j�
td
d�}tjttt|
|gtj	d�\}}|�
tttt|
|g�
|�
|�
t�|�
dS)Nr�r
r
r

)rir�r 
r%r	rmr
r
r#
r
r�rPr!
rrr�test_all_completed|s(






��




��zWaitTests.test_all_completedc
Csn|j�
td
d�}
|j�
tjd
�}tjttt	|
|gdtj
d�\}}|�tttt	|
g�
|�
|�t|g
�
|�
dS)N��r\)�timeoutr
)
rir�r%r)r*r	rmr
r#
r
r
r�rPr!
rrr�test_timeout�s&





�
�



��zWaitTests.test_timeoutN)rHrIrJr
r
r
r
r"
r$
r%
r)
rrrrr

5s
	
r

c@seZ
dZd
d�ZdS)�ThreadPoolWaitTestsc
	svt�
���f
d
d��
t��}
t�d�

z>�
�fdd�td�
D�
}���
tj|tj	d�
Wt�|
�

nt�|
�

0dS)Ncs���
dSrrlr)
rMrr�future_func�s
z@ThreadPoolWaitTests.test_pending_calls_race.<locals>.future_funcg�����ư>c
sh|]}
�
j�
��
�qSr)rir�)r�r�)r+
rFrr�	<setcomp>�r�z>ThreadPoolWaitTests.test_pending_calls_race.<locals>.<setcomp>�dr

)
r�rLr/�getswitchinterval�setswitchintervalr�rPr	rmr
)rFZoldswitchintervalr�r)rMr+
rFr�test_pending_calls_race�s






z+ThreadPoolWaitTests.test_pending_calls_raceN)rHrIrJr0
rrrrr*
�sr*
c@s4eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�ZdS)�AsCompletedTestsc
CsV|j�
td
d�}
|j�
tdd�}tt�ttt|
|g�
�
}|�	tttt|
|g�
|�
dS)Nr�r
r'
r&
)
rir�r%rPr	�as_completedr
r#
r
r�)rFr
r
�	completedrrr�test_no_timeout�s$





��



���z AsCompletedTests.test_no_timeoutc
Csp|j�
tjd
�}
t�}z*tjttt	|
gdd�D]}|�
|�

q.WntjyT


Yn0|�tttt	g�
|�
dS)Nr�r
�
r(
)
rir�r)r*rPr	r2
r
r#
r
�add�TimeoutErrorr�)rFr
Zcompleted_futuresr�rrr�test_zero_timeout�s(







��




��z"AsCompletedTests.test_zero_timeoutc
Cs@|j�
tjd
�}
dd�t�t�|
d��
D�
}|�t	|�
d�
dS)Nr�c
Ssg|]}
|
�qSrr)r�rrrrr��s
z;AsCompletedTests.test_duplicate_futures.<locals>.<listcomp>r�r�)
rir�r)r*r	r2
�	itertools�repeatr�r�)rFr
r3
rrr�test_duplicate_futures�s


�z'AsCompletedTests.test_duplicate_futuresc
Cs�d
d�td�
D�
}
|
�
ttd�
�

|
�
ttdd��

|�tj�
�N
tj|
dd�D].}|
�	|�

t
�|�
}~t�
�
|�|��

qPWd�
n1s�0


Y
|
d�d	�

t�|
�
D]@}|
�	|�

t
�|�
}~t�
�
|�|��

|
r�|
d�d	�

q�dS)
Nc
Ssg|]
}
t��qSr)
rr�rrrr��r�zGAsCompletedTests.test_free_reference_yielded_future.<locals>.<listcomp>�rr r!r
r5
�test)r�r�rr
rr�r	r7
r2
�remove�weakref�refrr�r��
set_result)rF�futures_listr��wrrrr�"test_free_reference_yielded_future�s&









,









z3AsCompletedTests.test_free_reference_yielded_futurec
Cs`tt
ttg}
|�tj�
�"}ttj|
d
d��

Wd�
n1s@0


Y
|�	t
|j�
d�
dS)Nr
r5
z2 (of 4) futures unfinished)r
�PENDING_FUTURE�RUNNING_FUTUREr
r�r	r7
r�r2
r��strr)rFrB
r�rrr�"test_correct_timeout_exception_msgs

�
0z3AsCompletedTests.test_correct_timeout_exception_msgN)rHrIrJr4
r8
r;
rD
rH
rrrrr1
�s

r1
c@sZeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Ze	j
d
d��
Zdd�Zdd�Z
dS)�ExecutorTestc
Cs$|j�
td
d�}
|�d|
���
dS)Nr�r<
�
)rir�r�r�r�rFr�rrr�test_submits

zExecutorTest.test_submitc
Cs�|jj
td
dd�}
|�d|
���
|jj
tdd
dd�}
|�|
��dd
dd�f�
|�t�
� 
|jj
tdd	�
Wd�
n1s�0


Y
|�t�
�
|jj
dd
�

Wd�
n1s�0


Y
dS)Nr�r<
)
r$�r�r�)rF�fn)
r�)rN
�arg)
rO
)rir�r%r�rr(r��	TypeErrorrK
rrr�test_submit_keywords





.

z ExecutorTest.test_submit_keywordc

	Csx|�t
|j�ttd
�
td
�
��
t
tttd
�
td
�
��
�
|�t
|jjttd
�
td
�
dd��
t
tttd
�
td
�
��
�
dS)N�
r��
�	chunksize)r�r�rir�r�r�rErrr�test_map s


�

�zExecutorTest.test_mapc
CsJ|j�
tgd
�
gd�
�}
|�|
��d�
|�|
��d�
|�t|
j�
dS)N)r�r�r�r�)r�r�r
r\)r
r�)rir�r 
r��__next__r��ZeroDivisionError)rFr�rrr�test_map_exception)s



zExecutorTest.test_map_exceptionc
Csdg}
z,|jj
tjgd
�
dd�D]}|
�|�

qWntjyD


Yn0|�d�

|�ddg|
�
dS)N)r
r
r&
r\r5
zexpected TimeoutError)	rir�r)r*r�r	r7
r�r�)rF�resultsr�rrr�test_map_timeout/s





�



zExecutorTest.test_map_timeoutc

Cs(|j�
td
g
|jd�
|j��
dS)Nr�r�)rir�rG
rfrprErrr�test_shutdown_race_issue12456=s
z*ExecutorTest.test_shutdown_race_issue12456c
sPt�}
t
���t�|
�f
d
d��}|j�|
j�

~
�jt	j
d�
}|�|d�
dS)Nc

s���Sr)
rP)
�obj�
Zmy_object_collectedrr�<lambda>Kr�z7ExecutorTest.test_no_stale_references.<locals>.<lambda>r5
z-Stale reference not collected within timeout.)rDr�rLr?
r@
rir�rGrmr�
SHORT_TIMEOUTr�)rFZ	my_objectZmy_object_callbackZ	collectedrr]
r�test_no_stale_referencesDs


�


�z%ExecutorTest.test_no_stale_referencesc
	CsFd
D]<}
|�t
d��
|j|
d�

Wd�
q1s60


Y
qdS)N)r
�����z"max_workers must be greater than 0r�)�assertRaisesRegexr@re)rFZnumberrrr�test_max_workers_negativeTs



�z&ExecutorTest.test_max_workers_negativec
Cs<|j�
ttd
�
�D]$}
t�|
�
}~
t��
|�|��

qdS)NrR
)	rir�rSr�r?
r@
rr�r�)rFr\
rC
rrr�test_free_reference[s





z ExecutorTest.test_free_referenceN)rHrIrJrL
rQ
rU
rX
rZ
r[
rZcpython_onlyr`
rc
rd
rrrrrI
s
	

rI
c@sFeZ
dZd
d�Zdd�Zdd�Zdd�Ze�e	e
d	�d
�dd��
Zd
S)�ThreadPoolExecutorTestc
sDg��f
d
d�}
|j�
|
td�
�
|jjdd�

|��td�
�
dS)zTests verifying issue 11777.c

s��|�

dSr)
r�)
�
n�
r
rr�record_finishedis
zRThreadPoolExecutorTest.test_map_submits_without_iteration.<locals>.record_finishedrR
TrlN)rir�r�rpZassertCountEqual)rFrh
rrg
r�"test_map_submits_without_iterationfs



z9ThreadPoolExecutorTest.test_map_submits_without_iterationc
Cs0|��}
t
d
t��pdd�}|�|
j|�
dS)N� r�r�)re�min�os�	cpu_countr��_max_workers)rFriZexpectedrrr�test_default_workersps


z+ThreadPoolExecutorTest.test_default_workersc
Cs||�d
�
}
dd�}t
�d�
}td|
j�
D]}|
�||�
q*|�t|
j�
|
j�
td|
j�
D]}|�	�
q^|
j
dd�

dS)Nr�c

Ss|��
dSrr�r�rrrr�ws
z<ThreadPoolExecutorTest.test_saturation.<locals>.acquire_lockr
�Trl)rer�r�r�rn
r�r�r�r�r�rp)rFrir�r�r�rrr�test_saturationus










z&ThreadPoolExecutorTest.test_saturationc
Cs`|��}
|
�
td
d���
|
�
tdd���
|
�
tdd���
|�t|
j�
d�
|
jdd	�

dS)
Nr
r�r&
r'
r��r�Trl)rer�r%rr�r�r�rp�rFrirrr�test_idle_thread_reuse�s





z-ThreadPoolExecutorTest.test_idle_thread_reuse�register_at_forkzneed os.register_at_forkc

s��f
d
d��t�
d�
�h}
|
��|
�
td�
D]B}tjdt�d�
d��}|�t�

Wd�
q,1sd0


Y
q,Wd�
n1s�0


Y
dS)Nc

s|��|�
dSr�
r�)
�poolrv
rrr��s
zEThreadPoolExecutorTest.test_hang_global_shutdown_lock.<locals>.submitr�r�rw)
r`)r	rur�r�r}rrrg�tuple)rFrw
rR�workersrrv
r�test_hang_global_shutdown_lock�s


z5ThreadPoolExecutorTest.test_hang_global_shutdown_lockN)rHrIrJri
ro
rq
rt
r��
skipUnlessrdrl
rz
rrrrre
es



re
c@steZ
dZe�ejd
kd�dd��
Zdd�Zdd�Z	e
d	d
��
Zdd�Ze
�d
�
dd��
Zdd�Zdd�Zdd�ZdS)�ProcessPoolExecutorTestryzWindows-only process limitc

Cs<|�t
d
��
tjdd�

Wd�
n1s.0


Y
dS)Nzmax_workers must be <= 61�>r�)rb
r@r	r}rErrr�test_max_workers_too_large�s
�z2ProcessPoolExecutorTest.test_max_workers_too_largec
Cs`|j�
tjd
�g
}
tt|jj���
�
}|��
|
D]}|�	t
|j�
q2|�	t
|jj
tdd�
dS)Nr�r�r<
)
rir�r)r*�next�iterr
r

�	terminater�rrr�)rFr	r
r�rrr�test_killed_child�s


z)ProcessPoolExecutorTest.test_killed_childc
	s��f
d
d�}
tt
ttd�
td�
��
}��t�jj
ttd�
td�
dd��
|�
��t�jj
ttd�
td�
dd��
|�
��t�jj
ttd�
td�
dd��
|�
��t|
�
dS)Ncs$t�j
jttd
�
td
�
dd��

dS)N�(ra
rS
)r�rir�r�r�rrErr�bad_map�s
z;ProcessPoolExecutorTest.test_map_chunksize.<locals>.bad_mapr�
r&
rS
r�)r�r�r�r�r�rir�r@)rFr�
r@
rrEr�test_map_chunksize�s



�

�

�z*ProcessPoolExecutorTest.test_map_chunksizec

Cstd
�
�
dS)N�{)
r��
r�rrr�_test_traceback�sz'ProcessPoolExecutorTest._test_tracebackc
	Cs�|j�
|j�
}
|�t�
�}|
��
Wd�
n1s60


Y
|j}|�t|�
t	�
|�
|jd
�
|j}|�t|�
t
jj�
|�d|j�
t���:}z|�
Wn t	y�


tjt���
Yn0Wd�
n1s�0


Y
|�d|���
dS)N)
r�
z&raise RuntimeError(123) # some comment)rir�r�
r�r+rrZassertIsr�r�r�r&�	__cause__r	�process�_RemoteTracebackr��tbr�captured_stderrr/�
excepthook�exc_info�getvalue)rFr�r��exc�cause�f1rrr�test_traceback�s"

&









2

�z&ProcessPoolExecutorTest.test_traceback�md5c
Cs^|���
�}
t|
�
}|j�t|�}|��
|�|jj	d
d�
�

d}t
��
|
��
|
�
�
dS)Nr�r5
)rg�ManagerrKrir��idrr�rMrmrr�rpr�)rFrNr\
r�rrr�test_ressources_gced_in_workers�s




z7ProcessPoolExecutorTest.test_ressources_gced_in_workersc
Csj|j}
|�
�}|�d
�
}d|
j}t|�
D]}|
�|j�

q*|�t|
j	�
|
j�
t|�
D]}|�
�
qXdS)Nr
rp
)rirgr�rn
r�r�r�r�r�r
r�)rFrir`r�Z	job_countrRrrrrq
�s










z'ProcessPoolExecutorTest.test_saturationc
Csp|j}
|�
�jd
d�
dkr$t�d�
�
|
�tdd���
|
�tdd���
|
�td	d
���
|�t	|
j
�
d�
dS)NFr�rw�(Incompatible with the fork start method.r
r�r&
r'
r�rr
r�)rirgr�r�r�r�r%rr�r�r
rs
rrr�test_idle_process_reuse_one�s






z3ProcessPoolExecutorTest.test_idle_process_reuse_onec
Cs�|j}
|�
�jd
d�
dkr$t�d�
�
|
�tdd���
|
�tdd�
|
�tdd	���
|
�td
d�
|
�tdd
���
|
�tdd�
|�t	|
j
�
d�
|
��
dS)NFr�rwr�
�r'
�!����r�r�r
�	r�)rirgr�r�r�r�r%rZassertLessEqualr�r
rprs
rrr� test_idle_process_reuse_multiple�s










z8ProcessPoolExecutorTest.test_idle_process_reuse_multipleN)rHrIrJr�r{
r/r{r~
r�
r�
�classmethodr�
r�
rZrequires_hashdigestr�
rq
r�
r�
rrrrr|
�s






r|
c
Cs*|rt�
|�

d
dl}
|
��
|
��
dS)zInduces a segfault.r
N)r)r*�faulthandler�disableZ_sigsegv)�delayr�
rrr�_crashs





r�
cCst�
d
�

dS)z#Induces a sys exit with exitcode 1.r�N)r/�exitrrrr�_exitsr�
c


Cs
|��
d
S)z-Function that raises an Exception in process.Nr)
�Errrrr�_raise_error!sr�
c
Csd
dl}
|
�
�t_|��
dS)z@Function that raises an Exception in process and ignores stderr.r
N)�io�StringIOr/�stderr)r�
r�
rrr�_raise_error_ignore_stderr&s


r�
c


Cs|�S)
z(Function that returns a instance of cls.rr�
rrr�_return_instance-sr�
c@seZ
dZd
Zdd�ZdS)�
CrashAtPicklez5Bad object that triggers a segfault at pickling time.c


Cs
t�
dSr�
r�
rErrr�
__reduce__4s
zCrashAtPickle.__reduce__N�rHrIrJ�__doc__r�
rrrrr�
2s

r�
c@seZ
dZd
Zdd�ZdS)�CrashAtUnpicklez7Bad object that triggers a segfault at unpickling time.c

Cstd
fS�Nrr�
rErrrr�
:s
zCrashAtUnpickle.__reduce__Nr�
rrrrr�
8s

r�
c@seZ
dZd
Zdd�ZdS)�ExitAtPicklez9Bad object that triggers a process exit at pickling time.c


Cs
t�
dSr�
r�
rErrrr�
@s
zExitAtPickle.__reduce__Nr�
rrrrr�
>s

r�
c@seZ
dZd
Zdd�ZdS)�ExitAtUnpicklez;Bad object that triggers a process exit at unpickling time.c

Cstd
fSr�
r�
rErrrr�
Fs
zExitAtUnpickle.__reduce__Nr�
rrrrr�
Ds

r�
c@seZ
dZd
Zdd�ZdS)�
ErrorAtPicklez3Bad object that triggers an error at pickling time.c
Csd
dlm
}

|
d�
�
dS)Nr
rzError in pickle)�pickler)rFrrrrr�
Ls

zErrorAtPickle.__reduce__Nr�
rrrrr�
Js

r�
c@seZ
dZd
Zdd�ZdS)�ErrorAtUnpicklez5Bad object that triggers an error at unpickling time.c
Csd
dlm
}

t|
f
fS)Nr
)
�UnpicklingError)r�
r�
r�
)rFr�
rrrr�
Ss

zErrorAtUnpickle.__reduce__Nr�
rrrrr�
Qs

r�
c@s�eZ
dZejZd
d�Zdd�
dd�Zdd�Zd	d
�Z	dd�Z
d
d�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#S)$�ExecutorDeadlockTestcCs�d
dl}d
dl
m}
|dd�
�.}|j|d�

|�d
�

|��}Wd�
n1sR0


Y
|
j��D]}|��
qf|
j	dd�

t
d|��tjd�
|�
d	|���

dS)
Nr
)
�
TemporaryFilezw+)
�mode)
�fileTrlz
Traceback:
 zExecutor deadlock:

)r�
�tempfiler�
Zdump_traceback�seek�readr
r

r�
rpr.r/�
__stderr__r�)rFrir�
r�
rr�
r
rrr�_fail_on_deadlock[s





&




z&ExecutorDeadlockTest._fail_on_deadlockF�
�
ignore_stderrc
	Gs�|jj
d
d�

|jd|��d�}|j|g
|�
R�}|r@t��}nt��}z`|�	|
�
�B
|�
|j
|jd�

Wd�
n1s~0


Y
Wd�
n1s�0


Y
Wntj
y�


|�|�

Yn0|j
d
d�

dS)NTrlr�r^r5
)rirprergr�rr�
r��nullcontextr�r�TIMEOUTr	r7
r�
)rF�error�funcr�
r&rir�r�rrr�_check_crashns
�




N

z!ExecutorDeadlockTest._check_crashc

Cs|�t
tt��
dSr)r�
rr�
r�
rErrr�test_error_at_task_pickle�sz.ExecutorDeadlockTest.test_error_at_task_picklec

Cs|�t
tt��
dSr)r�
rr�
r�
rErrr�test_exit_at_task_unpickle�sz/ExecutorDeadlockTest.test_exit_at_task_unpicklec

Cs|�t
tt��
dSr)r�
rr�
r�
rErrr�test_error_at_task_unpickle�sz0ExecutorDeadlockTest.test_error_at_task_unpicklec

Cs|�t
tt��
dSr)r�
rr�
r�
rErrr�test_crash_at_task_unpickle�sz0ExecutorDeadlockTest.test_crash_at_task_unpicklec

Cs|�t
t�
dSr)r�
rr�
rErrr�%test_crash_during_func_exec_on_worker�sz:ExecutorDeadlockTest.test_crash_during_func_exec_on_workerc

Cs|�t
t�
dSr)r�
�
SystemExitr�
rErrr�$test_exit_during_func_exec_on_worker�sz9ExecutorDeadlockTest.test_exit_during_func_exec_on_workerc

Cs|�t
tt
�
dSr)r�
r�r�
rErrr�%test_error_during_func_exec_on_worker�sz:ExecutorDeadlockTest.test_error_during_func_exec_on_workerc

Cs|�t
tt�
dSr)r�
rr�
r�
rErrr�)test_crash_during_result_pickle_on_worker�sz>ExecutorDeadlockTest.test_crash_during_result_pickle_on_workerc

Cs|�t
tt�
dSr)r�
r�
r�
r�
rErrr�(test_exit_during_result_pickle_on_worker�sz=ExecutorDeadlockTest.test_exit_during_result_pickle_on_workerc

Cs|�t
tt�
dSr)r�
rr�
r�
rErrr�)test_error_during_result_pickle_on_worker�sz>ExecutorDeadlockTest.test_error_during_result_pickle_on_workerc

Cs|jt
ttd
d�
dS)NTr�
)r�
rr�
r�
rErrr�3test_error_during_result_unpickle_in_result_handler�s

�zHExecutorDeadlockTest.test_error_during_result_unpickle_in_result_handlerc

Cs|�t
tt�
dSr)r�
rr�
r�
rErrr�2test_exit_during_result_unpickle_in_result_handler�szGExecutorDeadlockTest.test_exit_during_result_unpickle_in_result_handlerc
	Cs�|jj
d
d�

|jd|��d��b}
|
|_|
jtdd�}|
j
d
d�

|�t�
�
|��
Wd�
n1sj0


Y
Wd�
n1s�0


Y
dS)NTrlr�r^r:)
r�
)	rirprergr�r�
r�rr)rFrirrrr�test_shutdown_deadlock�s

�





z+ExecutorDeadlockTest.test_shutdown_deadlockc
	Cs�|jj
d
d�

|jd|��d��x}
|
|_|
�td���
|
j}|
�tt��}|
j
dd�

|�	t
�
�
|��
Wd�
n1s�0


Y
Wd�
n1s�0


Y
|��
dS)NTrlr�r^r F)rirprergr�r�
rr
r�
r�rr�)rFriZexecutor_managerrrrr�test_shutdown_deadlock_pickle�s

�





Dz2ExecutorDeadlockTest.test_shutdown_deadlock_pickleN)rHrIrJrr_
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
rrrrr�
Xs"
r�
c@s�eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)S)*�FutureTestsc
s:d��f
d
d�}
t�}|�
|
�

|�d�

|�d��
dS)Nc

s|���dSr�
r�
Zcallback_future�
Zcallback_resultrrrN
�sz6FutureTests.test_done_callback_with_result.<locals>.fnr\)r�add_done_callbackrA
r��rFrN
rrr�
r�test_done_callback_with_result�s






z*FutureTests.test_done_callback_with_resultc
s@d��f
d
d�}
t�}|�
|
�

|�td�
�

|�d�j�
dS)Nc

s|���dSr�
rr�
�
Zcallback_exceptionrrrN
�sz9FutureTests.test_done_callback_with_exception.<locals>.fnr=
�
r=
)rr�
�
set_exceptionr+r�r&r�
rr�
r�!test_done_callback_with_exception�s





z-FutureTests.test_done_callback_with_exceptionc
s<d��f
d
d�}
t�}|�
|
�

|�|���

|���

dS)Nc

s|���dSrr�r�
�
Z
was_cancelledrrrN
sz6FutureTests.test_done_callback_with_cancel.<locals>.fn)rr�
r��cancelr�
rr�
r�test_done_callback_with_cancel
s





z*FutureTests.test_done_callback_with_cancelc
s�t�
��x}
d
�
d
��
f
dd�}�f
dd�}t�}|�|�

|�|�

|�d�

|��
�

|���

|�d|
���
Wd�
n1s�0


Y
dS)NFc

sd
�td�
�
dS)NT�doh!�
r+r�
)
�raising_was_calledrr�
raising_fns
z9FutureTests.test_done_callback_raises.<locals>.raising_fnc


sd
�dS)NTrr�
)
�
fn_was_calledrrrN
sz1FutureTests.test_done_callback_raises.<locals>.fnr\zException: doh!)rr�
rr�
rA
r�r�r�
)rFr�
r�
rN
rr)r�
r�
r�test_done_callback_raisess














z%FutureTests.test_done_callback_raisesc
s:d��f
d
d�}
t�}|�
d�

|�|
�

|�d��
dS)Nc

s|���dSrr�
r�
r�
rrrN
$sz=FutureTests.test_done_callback_already_successful.<locals>.fnr\)rrA
r�
r�r�
rr�
r�%test_done_callback_already_successful"s






z1FutureTests.test_done_callback_already_successfulc
s@d��f
d
d�}
t�}|�
td�
�

|�|
�

|�d�j�
dS)Nc

s|���dSrr�
r�
r�
rrrN
/sz9FutureTests.test_done_callback_already_failed.<locals>.fnr=
r�
)rr�
r+r�
r�r&r�
rr�
r�!test_done_callback_already_failed-s





z-FutureTests.test_done_callback_already_failedc
s<d��f
d
d�}
t�}|�
|���

|�|
�

|�
��

dS)Nc

s|���dSrr�r�
r�
rrrN
:sz<FutureTests.test_done_callback_already_cancelled.<locals>.fn)rr�r�
r�
r�
rr�
r�$test_done_callback_already_cancelled8s





z0FutureTests.test_done_callback_already_cancelledc
Csnt�
��R}
d
d�}t�}|�d�

|�|�

|�d|
���
|�d|
���
Wd�
n1s`0


Y
dS)Nc

Sstd
�
�
dS)Nr�
r�
r�
rrrr�
Es
zKFutureTests.test_done_callback_raises_already_succeeded.<locals>.raising_fnr\zexception calling callback forr�
)rr�
rrA
r�
r�r�
)rFr�
r�
rrrr�+test_done_callback_raises_already_succeededCs






z7FutureTests.test_done_callback_raises_already_succeededc

Csd|�t
t�
d
�
|�t
t�
d�
|�t
t�
d�
|�t
t�
d�
|�t
t�
d�
|�t
t�
d�
dS)Nz%<Future at 0x[0-9a-f]+ state=pending>z%<Future at 0x[0-9a-f]+ state=running>z'<Future at 0x[0-9a-f]+ state=cancelled>z5<Future at 0x[0-9a-f]+ state=finished raised OSError>z3<Future at 0x[0-9a-f]+ state=finished returned int>)r��reprrE
rF
r
r
r#
r
rErrr�	test_reprSs(


�

�

�

�

�

�zFutureTests.test_reprc
Cs�tt
d
�
}
ttd
�
}ttd
�
}ttd
�
}ttt�d�}ttdd�}|�|
���

|�	|
j
t�
|�|���

|�	|j
t�
|�|���

|�	|j
t�
|�|���

|�	|j
t�
|�|���

|�	|j
t�
|�|���

|�	|j
t�
dS)Nrrr\r!)rr
rrr
r�OSErrorr�r�
r�rr�)rFr�
�f2Zf3Zf4Zf5Zf6rrr�test_cancelds$















zFutureTests.test_cancelc

CsX|�t
���

|�t���

|�t���

|�t���

|�t���

|�t���

dSr)	r�rE
r�rF
r�r
r
r#
r
rErrr�test_cancelled~s





zFutureTests.test_cancelledc

CsX|�t
���

|�t���

|�t���

|�t���

|�t���

|�t���

dSr)	r�rE
r�rF
r�r
r
r#
r
rErrr�	test_done�s





zFutureTests.test_donec

CsX|�t
���

|�t���

|�t���

|�t���

|�t���

|�t���

dSr)	r�rE
�runningr�rF
r
r
r#
r
rErrr�test_running�s





zFutureTests.test_runningc

Csz|jt
jtjd
d�
|jt
jtjd
d�
|jt
jtjd
d�
|jt
jtjd
d�
|jt	t
jd
d�
|�tjd
d�
d�
dS)Nr
r5
r )
r�r	r7
rE
rrF
�CancelledErrorr
r
r�
r#
r�r
rErrr�test_result_with_timeout�s

�
�
�
�
z$FutureTests.test_result_with_timeoutc
sJ�f
d
d�}
tt
d�
�tj|
d�
}|��
|��jdd�
d�
|��
dS)Ncst�
d
�

��d�

dS)Nr�r )r)r*rA
r�
r�
rr�notification�s

z:FutureTests.test_result_with_success.<locals>.notificationr�
�targetr\r5
r )rr
r��Thread�startr�rr��rFrr,rrr�test_result_with_success�s



z$FutureTests.test_result_with_successc
sL�f
d
d�}
tt
d�
�tj|
d�
}|��
|jtj�jt	j
d�
|��
dS)Ncst�
d
�

���
dS�Nr�)r)r*r�
rrrrr�s

z9FutureTests.test_result_with_cancel.<locals>.notificationrrr5
)rr
r�rrr�r	rrrr_
r�rrrr�test_result_with_cancel�s



�z#FutureTests.test_result_with_cancelc

Cs�|jt
jtjd
d�
|jt
jtjd
d�
|jt
jtjd
d�
|jt
jtjd
d�
|�	t
tjd
d�
t��

|�
tjd
d�
d�
dS)Nr
r5
)r�r	r7
rE
rrF
rr
r
r��
isinstancer#
r�
r�r
rErrr�test_exception_with_timeout�s 

�
�
�
�
�z'FutureTests.test_exception_with_timeoutc
sP�f
d
d�}
tt
d�
�tj|
d�
}|��
|�t�jtj	d�
t
��

|��
dS)NcsLt�
d
�

�j�(
t�_t��_�j��
Wd�
n1s>0


Y
dSr
)r)r*�
_conditionrrr�
r�
notify_allrrrrr�s





z=FutureTests.test_exception_with_success.<locals>.notificationrrr5
)rr
r�rrr�rrrr_
r�
r�rrrr�test_exception_with_success�s




z'FutureTests.test_exception_with_successc
Csntt
d
�
}
|
�d�

|�tjd��
|
�d�

Wd�
n1sB0


Y
|�|
���

|�|
�	�d�
dS)Nrr�z=FINISHED: <Future at 0x[0-9a-f]+ state=finished returned int>r�)
rr
rA
rb
r	�InvalidStateErrorr�r�r�r)rFrrrr�test_multiple_set_result�s





�(
z$FutureTests.test_multiple_set_resultc
Cshtt
d
�
}
t�}|
�|�

|�tjd��
|
�t��

Wd�
n1sJ0


Y
|�|
�	�|�
dS)NrzBFINISHED: <Future at 0x[0-9a-f]+ state=finished raised ValueError>)
rr
r@r�
rb
r	rr+r�r)rFrr�rrr�test_multiple_set_exception�s






�*z'FutureTests.test_multiple_set_exceptionN)rHrIrJr�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r
r	rr
rrrrrrrr�
�s(

r�
c
Cs.t�
tjj�

t��}tj
tjg
|�
R�
dSr)r�ZaddModuleCleanup�multiprocessing�util�_cleanup_testsrrUrY)
�thread_inforrr�setUpModule�s


r�__main__)
N)
N)_r=
r�
import_moduleZ*skip_if_broken_multiprocessing_synchronizeZtest.supportrZtest.support.script_helperrr�r9
r;Zlogging.handlersrrl
r�r/r�r)r�r?
r�
r�
concurrentr	�concurrent.futures._baser
rrr
rrrZconcurrent.futures.processrZmultiprocessing.processrZmultiprocessing.utilrrZcheck_sanitizerr�rrE
rF
r
r
r�
r#
r
r5r%r(r-r3r6r7rC�objectrDrKrSZTestCaserTr[rtrvr~r�r�r�r�r�r�r�r

r*
r1
rI
re
r|
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
r�
rrH�mainrrrr�<module>
s�













$













	!





��
8
m^O


��m


��RV4u


��
	



��