ÿØÿà JFIF 

  
 
  ÿÛ „ 	 ( %"1!%)+...383,7(-.+




-+++--++++---+-+-----+---------------+---+-++7-----ÿÀ  ß â
" 

ÿÄ   

           
 ÿÄ H 
     
 !1AQaq"‘¡2B±ÁÑð#R“Ò Tbr‚²á3csƒ’ÂñDS¢³$CÿÄ 
 


            
ÿÄ %

 
       
!1AQa"23‘ÿÚ 
  ? ôÿ ¨pŸªáÿ —åYõõ\?àÒü©ŠÄï¨pŸªáÿ —åYõõ\?àÓü©ŠÄá 0Ÿªáÿ Ÿå[úƒ	ú®ði~TÁb
qÐ8OÕpÿ ƒOò¤Oè`–RÂáœá™êi€ßÉ< FtŸI“öÌ8úDf´°å}“¾œ6
öFá°y¥jñÇh†ˆ¢ã/ÃÐ:ªcÈ
"Y¡ðÑl>ÿ ”ÏËte:qž\oäŠe÷󲍷˜HT4&ÿ ÓÐü6ö®¿øþßèô	Ÿ•7Ñi’•j|“ñì>b…þS?*Óôÿ ÓÐü*h¥£ír¶ü UãSç‚Ÿ[AÐaè[ûª•õ&õj?†Éö+EzP—WeÒírJFt	‘BŒ†Ï‡%#tE Øz ¥OÛ«!1›üä±Í™%º<!vB™'èÔ6´Ña¿«e`Àà0U[-ÂБ4)M÷YK*³hï÷%ÎÎkÇ«m‘-íWŽLsã?nÂ~«†üö®þ¡ÂlÃaÿ ‰ÿ l©°Õ¥ åÜá¿r ºL[Çâ°(Çè'Vãôl8´ÏRÀvLvPõ:…ÙNçF™÷ë>Íãö]°î(–:@<‹ŒÊö×òÆt¦ãº+‡¦%ÌÁ²h´OƒJŒtMÜ>ÀÜÊw3
Y´•牋4ǍýʏTì>œú=Íwhyë,¾Ôò×õ¿ßÊa»«þˆѪQ|%6ž™A	õ%:øj<>É—ÿ Å_ˆCbõ¥š±ý¯Ýƒï…¶|RëócÍf溪“t.СøTÿ *Ä¿-{†çàczůŽ_–^XþŒ±miB[X±d 1,é”zEù»&
î9gœf™9Ð'.;—™i}!ôšåîqêÛ٤ёý£½ÆA–àôe"A$˝Úsäÿ 
÷Û	#°xŸëí(l
	 »ý3—¥5m!
rt`†0~'j2(]S¦¦kv,ÚÇl¦øJA£Šƒ
J3E8ÙiŽ:cÉžúeZ°€¯\®kÖ(79«Ž:¯X”¾³Š&¡* ….‰Ž(ÜíŸ2¥ª‡×Hi²TF¤ò[¨íÈRëÉ䢍mgÑ.Ÿ<öäS0í„ǹÁU´f#Vß;Õ–…P@3ío<ä-±»Ž.L|kªÀê›fÂ6@»eu‚|ÓaÞÆŸ…¨ááå>åŠ?cKü6ùTÍÆ”†sĤÚ;H2RÚ†õ\Ö·Ÿn'¾ ñ#ºI¤Å´%çÁ­‚â7›‹qT3Iï¨Ö
Ú5I7Ë!ÅOóŸ¶øÝñØôת¦$Tcö‘[«Ö³šÒ';Aþ ¸èíg
A2Z
"i¸vdÄ÷.iõ®§)¿]¤À†–‡É&ä{V¶iŽ”.Ó×Õÿ û?h¬Mt–íª[ÿ Ñÿ ÌV(í}=ibÔ¡›¥¢±b
 Lô¥‡piη_Z<‡z§èŒ)iÖwiÇ 2hÙ3·=’d÷8éŽ1¦¸c¤µ€7›7Ø	ð\á)}	¹fËí›pAÃL%âc2 í§æQz¿;T8sæ°qø)QFMð‰XŒÂ±
N¢aF¨…8¯!U		Z©RÊ ÖPVÄÀÍin™Ì-GˆªÅËŠ›•zË}º±ŽÍFò¹}Uw×#ä5B¤{î}Ð<ÙD
é©¤&‡ïDbàÁôMÁ."
¤‡ú*õ'VŽ|¼´Úgllº¼klz[Æüï÷Aób‡Eÿ dÑ»Xx9ÃÜ£ÁT/`¼¸vI±Ýµ·Ë‚“G³þ*Ÿû´r|*}<¨îºœ @¦mÄ’M¹”.œ«Y–|6ÏU¤jç¥ÕÞqO
˜kDÆÁ¨5ÿ š;Њ¦¦€GÙk \
	–Þ=â¼=SͧµªS°ÚÍpÜãQűÀõ¬?ÃÁ1Ñ•õZà?hóœ€
L¦l{Y*K˜Ù›zc˜–ˆâø+¾	­-Ök¥%ùEÜA'}ˆ><ÊIè“bpÍ/qÞâvoX€w,\úªò6Z[XdÒæ­@Ö—€$òJí#é>'°Ú
ôª˜<)4ryÙ£|óAÅn5žêŸyÒäMÝ2{"}‰–¤l÷ûWX\l¾Á¸góÉOÔ /óñB¤f¸çñ[.P˜ZsÊË*ßT܈§QN¢’¡¨§V¼(Üù*eÕ“”5T¨‹Âê¥FŒã½Dü[8'Ò¥a…Ú¶k7a
*•›¼'Ò·\8¨ª\@\õ¢¦íq+DÙrmÎ…_ªæ»ŠÓœ¡¯’Ré9MÅ×D™lælffc+ŒÑ,ý™ÿ ¯þǤ=Å’Á7µ÷ÚÛ/“Ü
€ñýã¼àí¾ÕÑ+ƒ,uµMâÀÄbm:ÒÎPæ{˜Gz[ƒ¯«® KHà`ßØŠéí¯P8Aq.C‰ à€kòpj´kN¶qô€…Õ,ÜNŠª-­{Zö’æû44‰sŽè‰îVíRœÕm"
6?³D9¡ÇTíÅꋇ`4«¸ÝÁô ï’ýorqКÇZ«x4Žâéþuïf¹µö[P ,Q£éaX±`PÉÍZ ¸äYúgüAx
’6Lê‚xÝÓ*äQ
Ï’¨hÍ
=²,6ï#rÃ<¯–£»ƒ‹,–ê•€ aÛsñ'%Æ"®ÛüìBᝠHÚ3ß°©$“XnœÖ’î2ËTeûìxîß
¦å¿çÉ
ðK§þ{‘t‚Ϋ¬jéîZ[”š7L¥4VÚCE×]m¤Øy”ä4-dz£œ§¸x.*ã
ÊÊ b÷•h:©‡¦s`BTÁRû¾g⻩‹jø sF¢àJøFl‘È•Xᓁà~*j¯ +(ÚÕ6-£¯÷GŠØy‚<Ç’.F‹Hœw(+)ÜÜâÈzÄäT§FߘãÏ;DmVœ3Àu@mÚüXÝü•3B¨òÌÁÛ<·ÃÜz,Ì@õÅ·d2]ü8s÷IôÞ¯^Ç9¢u„~ëAŸï4«M?
K]­ÅàPl@s_ p:°¬ZR”´›JC[CS.h‹ƒïËœ«Æ]–÷ó‚wR×k7X‰k›‘´ù¦=¡«‰¨¨Â')—71ó’c‡Ðúµ
`é.{§p¹ój\Ž{1h{o±Ý=áUÊïGÖŒõ–-BÄm+AZX¶¡
ïHðæ¥JmÙ;…ä¡Ÿˆ¦ ° äšiÉg«$üMk5¤L“’çÊvïâï	,=f“"íἊ5ô¬x6{ɏžID0e¸vçmi'︧ºð9$ò¹÷*£’9ÿ ²TÔ…×>JV¥}Œ}$p[bÔ®*[jzS*8
”·T›Í–ñUîƒwo$áè=LT™ç—~ô·¤ÈÚ$榍q‰„+´kFm)ž‹©i–ËqÞŠ‰à¶ü( ‚•§ •°ò·‡#5ª•µÊ﯅¡X¨šÁ*F#TXJÊ
ušJVÍ&=iÄs1‚3•'fý§5Ñ<=[íÞ­
PÚ;ѱÌ_~Ä££8rÞ
²w;’hDT°>ÈG¬8Á²ÚzŽ®ò®qZcqJêäÞ-ö[ܘbň±çb“Š¶31²n×iƒðÕ;1¶þÉ
ªX‰,ßqÏ$>•î íZ¥Z 1{ç൵+ƒÕµ¥°T$§K]á»Ûï*·¤tMI’ÂZbŽÕiÒ˜}bÓ0£ª5›¨[5Ž^ÝœWøÂÝh°
¢OWun£¤5 a2Z.G2³YL]jåtì”
ä	ÁÓ‘%"©<ÔúÊ°sº UZvä‡ÄiÆÒM .÷V·™ø#kèýií<NçŽôª¦„lË»{ƒ®<
[¦Y‹éƒ}j•*‚±€I‡e&gbéšp9å^!®€ö?ù^àTzo@Q¨Aêœ& [”…üÔ}пF’Hq‚©´{“ëH·?.½%úå»É Á´9¿¼Ò‰Á¼Ì¥Ús¼zW¶aÃhwÖ…ÑÏ$mò´ë:×Ñγ|”x§
µ0Âз$·aÆn µ†šÇ³£‰Ì®ž
õ@kŽ«gtí䢩ÒP×5¤?µÿ m´Ì^ ‡8¸Á8‹”žÆWÑ ¡™„,Ì“»à‹ÃéV¸®á›ÐÇŽBÀ®Ã…Z”ØÛë8;é|Ñ5)7aÕ&2Ù¸÷©ö—Ð;‡¬7"¿"7M·d
ñœÒÌf5”ê ;"Ãp5¯¬3‹ùJÚÝG›½&¯<{òñKÎÖ“3:¦ÀòGPÅS¨;
à‘Ün´öpð±W)z'¬öÀÖ#Xf2& æ
Œ‹é¾"‹\!Ñ9…
0±2A›*ØMÄ $X
끫ØXÖ,X¥ ô'ËnFÍãlqJXçuaJ4¦„ëµ7ê;h"Zã¾Áä£,vÛ‹’N©E(Öu÷)…ÁaÜÇÔkˆ$‘1kmG¨øtÛ>Ì–ª)µT[)BˆõÑ
xB¾B€ÖT¨.¥~ð@VĶr#¸ü*åZNDŽH;âi 
],©£öØpù(šºãö¼T.uCê•4@ÿ GÕÛ)Cx›®0ø#:ÏðFÒbR\(€€Ä
®fã4Þ‰Fä¯HXƒÅ,†öEÑÔÜ]Öv²?tLÃvBY£ú6Êu5ÅAQ³1‘’¬x–HŒÐ‡ ^	¸KwJôÖŽ5×CÚ¨vÜ«/B0$×k°=ðbÇ(Ï)w±A†Á†	11Í=èQšµ626ŒÜ/`G«µ<}—-Ö7KEHÈÉðóȤmݱû±·ø«Snmá=“ä«šmݱŸ¡¶~ó·“äUóJæúòB|E LêŽy´jDÔ$G¢þÐñ7óR8ýÒ…Ç›	WVe#·Ÿ	p·Fx~•ݤF÷0Èÿ K¯æS<6’¡WШ
;´ÿ ¥Êø\Òuî†åÝ–VNœkÒ7oòX¨Á­Ø÷FÎÑä±g÷ÿ M~Çî=p,X´
ÝÌÚÅ‹
’ÃjÖ.ØöÏñ
qïQ¤ÓZE†° =6·]܈ s¸>v•Ž^Ý\wq9r‰Î\¸¡kURÒ$­*‹Nq?Þª*!sŠÆ:TU_u±T+øX¡
®¹¡,ÄâÃBTsÜ$Ø›4m椴zÜK]’’›Pƒ@€#â˜`é¹=I‡fiV•Ôî“nRm+µFPOhÍ0B£
€+¬5c
v•:P'ÒyÎ ‰V~‚Ó†ÖuókDoh$å\*ö%Ю=£«…aȼ½÷Û.-½VŒŠ¼'lyî±1¬3ó#ÞE¿ÔS¤gV£m›<HqÚ,sVºóÆß¼Hïô…¹…Méi‡Ò" µùEîØÏj|ÓøVOuœ"f’aÞÞëx…˜ÌO`dHHš×4K*H$‡5×
ÚÄ
Â×CUÅAŠŒsr»2°ÄÁiÚ±Çéõe•¶_SÕÆÃ3ˆ•-3´‘¸¡‡cgDîÚ¦ÃcX}'êûJè½9ñìÓ­ä±	×ÓûçÁmO”üVÞ¸÷¥ I~“ÒôhhûýÑwxlïZ¹G¡4ž=”)º£ò
®vÆŽ%UqÝ4qž©­hûÎí‡š§é1R±cÜèðà y' °ôy¦£q§Ýï¬;šÖõ„Sÿ ›  z('S†$Ï}*evÚ¾Kýº8ý
¨å	jÛ]´-‚6«¶ÖK+8ÊiS45jrœèËQDüDØ]R”˜SPÃ
xJÕl>
=§\û"—WU¤ÚǼÿ ÂnÁ
GŒÃ
‚õN	D³õNÚíŒÕ;HôyÄÈ©P¹Ä{:?R‘Ô¨âF÷ø£bÅó® JS|‚R÷ivýáâ€Æé¡è³´IئÑT!§˜•Øª‚¬â@q€wnïCWÄ@JU€ê¯m6]Ï:£âx
'+ÒðXvÓ¦Úm=–´7œ $ì“B£~p%ÕŸUþ« N@¼üï~w˜ñø5®—'Ôe»¤5ã//€ž~‰Tþ›Å7•#¤×Íö
pÄ$ùeåì*«ÓŠEØWEÈsßg¦ûvžSsLpºÊW–âµEWöˬH;™!CYõZÃÄf æ#1W.
\uWâ\,\Çfj’<qTbên›Î[vxx£ë 'ö¨1›˜ÀM¼Pÿ H)ƒêêŒA7s,|F“꺸k³9Ìö*ç®;Ö!Ö$Eiž•¹ÒÚ†ýóéÝû¾ÕS®ó$’NÝäŸz¤5r¦ãÄÃD÷Üø!°ø‡Ô&@m™Ì^Ãä­d	q5Lnÿ N;.6½·N|#ä"1Nƒx“ã<3('&ñß
t  ~ªu”1Tb㫨9ê–›–bìd$ߣ=#ÕãÒmU¯eí$EFù5ýYô櫨æ왍Ǘ±ssM]·á¿
0ÕåJRÓªîiƒ+O58ÖñªŠÒx"	\µâá¨i’¤i
—Ö
”
M+M¤ë9‚‰A¦°Qõ¾ßøK~¼Ã‘g…Ö´~÷Ï[3GUœÒ½#…kàÔ®Ò”‰³·dWV‰IP‰Ú8u¹”E
ÖqLj¾êÕCBš{A^Âß;–¨`¯¬ìö
˼	×tìø.tƐm*n¨y4o&Àx¥n¦×î‡aupáÛj8¿m›è¶ã!o½;ß0y^ý×^EÑ¿ÒjzŒ­)vÚÑnÄL
…^ªô× ‡—‚3k	Îý­hï]içå–îÏ*÷ñþ»Ô
CÒjøjÍznˆ´
¹#b'Fô‹
‰v¥'’à'T´ƒHýÍ%M‰ ƒ&ÆÇŒï1 ‘	–Þ
‰i¬s žR-Ÿ kŠ¬á¬7:þ 0ŒÅÒÕ/aÙ¬ÃÝ#Úøœ
©aiVc‰. ¹¦ãµ”
›Yg¦›ÆÎýº°f³7ƒhá·¸­}&D9¡ÂsÉÙÞèŠõØàC™¨ñbFC|´Ü(ŸƒÚÒ-%»'a	Ì¿)ËÇn¿úÿ ÞŽX…4ÊÅH^ôΑí@ù¹Eh¶“L8Çjù
¼ÎåVªóR©Ï5uÃ
V4lZß®=€xÖŸ–ÑÈ
÷”¨°¾__yM1tÉ?uÆþIkÄgæ@þ[¢†°XÃJ£j·:nkÅ¢u‘}âGzö­/IµèŠ¬¼48q¦F°ŽR¼=ûì{´¯RýicS
ÕÛ íNtÍÙï£,w4rêì®»~x(©Uñ§#Ñ&œÕ¤>ÎåÍÓ9’Ö{9eV­[Öjâ²ãu]˜å2›qÑšÕJç0€sÄ|Êëè0튔bÁ>“{×_F`Ø©ºê:µä,v¤ðfc1±"«ÔÍän1#=·
Âøv~H<Q-Ìk7Æ;•L´©ÙC°.7
¯hKL@ävÊâž$´4¸ð‚¦­R–ÂZ7ÕÃj±·¿rÓrªJ_PÕ.#g¤gÀ)©`ª<KžèÝ'ä©èÒ3rwû€Ø¦ÒƒLf¤
,¿I½{Ƕ8‘$KÝU/Oi>½ÐßA¾¿Ü€Óš]Õ; I¾÷ç‚Qi†î¹9ywÔKG˜áñ zQY—§ÃÕZ07§X‚Áh;ÁM)iÌCH-¯T‘ë|A0{Ò½LÚ–TâÖkÜ’dÀ“rmm»”جPF³ÖcbE§T€ÒxKºû’Ó®7±²(\4ŽÃ¸Uu@j™yĵ;³µ!Á¢b.W¤=mõ´êµKk
¸K^ÜÛ#p*Ü14qkZç5ïë†°5Ï%ÍÛ<Õ¤×Ô¥ê†C	Õ´¼ú$ƒÖ“”]Ù¬qÞÚ[4©ý!ûÏ—Áb쳐XµA¬â~`›Çr¸8ìùÝ䫦<>ä÷«?xs´ÇÑ	/á;¹øüÊÈÙà{"@Žïzâ¬[âß‚ U_<ÇŸ½4èN˜ú61®qŠu ¦þF£»äJ_ˆÙÎ~ ÞAã–Ý„Ï—rŠD;xTž‘ô`É«…suãO`?³à™ô
Lý#Íc5öoæØ‚y´´÷«ZR§<&JÇ+éâô´€i!Àˆ0æAoàðLèÖ-2ŸõW.’t^–(KÁmHµV@xÜÇy®Ñø­â^:Ú3w· 7½¹°ñ¸â¹®:',«Mœ—n­Á+Ãbš
LÈ‘ÄnRÓÅœ%¦²‰¨ùQ:¤f‚ "PÕtô¸…cæl…&˜Ú˜Ôkv‹ž+vŠ,=¢v­6—X
y*¥t£«<™:“aï<QÝ&Ó]i4音äzçáíHÚÕxcòãæäÝÔm퐡 `Â)C×ehÀdHP6ÅMEöZ®Í¨	é¾Tr뢘6*¶;´sÙì]ÊŽŽÛíÉwRÈ´up* Ã	‚m´:Û{·”MUë©õ̤êÔo7:ŽÕ
qÏ'E ˆk^uãT€$Ú$Æ{•ŸBP°al¾Ž©ŒÃ^}äA
,º­$Ü]ºÚ.í:‹¤ÜöXnno7X€¥BÂà ±1ã>Œºîϲ=¦6rO]XI¿Œ÷¤zÚ­›¶ 6÷”w\dü~v®ˆÌk«^m<ÿ ¢‰Õ\)ùºŽ;… lîÙÅEŠ®cѾ@vnMÏ,¼“
ñ•ŽBxðÃzãÇç%3ˆ"}Ù•Åî>
BÉú;Ò]V+P˜F_´ßé>
Øše|ï‡ÄOmFæÇ ãqÞ$/xÐx­z`ï9"œÜij‚!7.\Td…9M‡•iŽ‹¾‘50ÞŽn¥ß4ÉôO¹*í^QêËÜÇÌ8=Ž
§s‰'ÂëÙ«á%Pú[O
†ÅP¯VsŽ°.‰,kc¶ ¬A9n˜XÎ-ÞšN["¹QÕ‰ƒMýÁߺXJæÍaLj¾×Ãmã¾ãÚ uñÒþåQô¦¥
/ÄUx:‚ÍÜ’ Đ©ØÝ3V¨‰ÕnÐ6ó*óúK­«…c ¯U òhsý­jóÔj#,ímŒRµ«lbïUTŒÑ8†Ä0œÏr`ð¡¬É	Ї
ë"À²

™	6¥ f¶¢ÚoܱԷ-<Àî)†a¶ž'Ú»¨TXqØæ¶÷Y
ÄHy˜9ÈIW­YÀuMFë
ºÏ’AqÌ4·/Ú
†ô'i$øä­=Ä
Ý|öK×40è|È6p‘0§)o¥ctî§H+CA-“ xØ|ÐXŠç
l8íºð3Ø:³¤¬KX¯UÿÙ
3

�^d���
@s dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dl	Z	ddl
mZ
ddl
mZ
ddl
m
Z

ddl
mZ
ddl
mZ
dd	l
mZ
dd
l
mZ
ddl
mZ
ddl
mZ
dd
l
mZ
ddlmZ
ddlmZ
dddddgZejdkr�ed�
�
dd�Zy
ejZWnek
�
r,


dd�ZYnXGdd�dej�Z e!ed��
rVdd�Z"nd
dl#Z#d d�Z"Gd!d"�d"ej$�Z%Gd#d$�d$ej&ej'�Z(e!ed%��
r�ej)Z*nd
dl#Z#d&d'�Z*Gd(d)�d)ej+�Z,Gd*d�d�Z-Gd+d,�d,e-�Z.Gd-d�de.�Z/Gd.d�de.�Z0Gd/d0�d0ej1�Z2e Z3e2Z4dS)1z2Selector event loop for Unix with signal handling.�N�
)
�base_events)
�base_subprocess)
�compat)
�	constants)
�
coroutines)
�events)
�futures)
�selector_events)
�	selectors)
�
transports)
�	coroutine)
�logger�SelectorEventLoop�AbstractChildWatcher�SafeChildWatcher�FastChildWatcher�DefaultEventLoopPolicyZwin32z+Signals are not really supported on Windowsc
Csd
S)zDummy signal handler.N�)�signum�framerr�)/usr/lib/python3.6/asyncio/unix_events.py�_sighandler_noop%src


Cs|S)
Nr)
�pathrrr�<lambda>.srcs�eZ
dZd
Zd"�f
dd�	Zdd�Z�f
dd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zd#dd�
Zd$dd�
Z
ed%dd�
�
Zdd�Zedddd�dd��
Zed&dddd�d d!��
Z�ZS)'�_UnixSelectorEventLoopzdUnix event loop.

    Adds signal handling and UNIX Domain Socket support to SelectorEventLoop.
    Ncst�j
|
�

i|_dS)
N)�super�__init__�_signal_handlers)�self�selector)
�	__class__rrr7s

z_UnixSelectorEventLoop.__init__c


Cstj
�S)
N)�socketZ
socketpair)
rrrr�_socketpair;s
z"_UnixSelectorEventLoop._socketpairc
s^t�j
�
tj�s2xFt|j�
D]}
|j|
�

qWn(|jrZtjd
|�d�t	|d�
|jj
�
dS)NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removal)
�source)r�close�sys�
is_finalizing�listr�remove_signal_handler�warnings�warn�ResourceWarning�clear)r�sig)
r!rrr%>s







z_UnixSelectorEventLoop.closecCs"x|
D]}|sq|j|�

qWdS)
N)
�_handle_signal)r�datarrrr�_process_self_dataLs



z)_UnixSelectorEventLoop._process_self_datac+GsH
tj
|�
stj|�
rtd
�
�
|j|
�

|j�
ytj|jj	��

Wn2t
tfk
rt
}
ztt
|�
�
�
WYdd}~XnXtj|||�}||j|
<ytj|
t�
tj|
d�
Wn�tk
�
rB
}
zz|j|
=|j�
sytjd�

Wn4t
tfk
�
r
}
ztjd|�
WYdd}~XnX|jtjk�
r0tdj|
�
�
�
n�WYdd}~XnXdS)z�Add a handler for a signal.  UNIX only.

        Raise ValueError if the signal number is invalid or uncatchable.
        Raise RuntimeError if there is a problem setting up the handler.
        z3coroutines cannot be used with add_signal_handler()NFrzset_wakeup_fd(-1) failed: %szsig {} cannot be caught�����)rZiscoroutineZiscoroutinefunction�	TypeError�
_check_signalZ
_check_closed�signal�
set_wakeup_fdZ_csock�fileno�
ValueError�OSError�RuntimeError�strrZHandlerr�siginterruptr�info�errno�EINVAL�format)rr.�callback�args�exc�handleZnexcrrr�add_signal_handlerSs0


















z)_UnixSelectorEventLoop.add_signal_handlercCs8|jj
|
�
}|d
krd
S|jr*|j|
�

n
|j|�

d
S)z2Internal helper that is the actual signal handler.N)r�getZ
_cancelledr)Z_add_callback_signalsafe)rr.rDrrrr/�s



z%_UnixSelectorEventLoop._handle_signalc&Cs�|j|
�

y|j
|
=Wntk
r*


d
SX|
tjkr>tj}ntj}ytj|
|�
Wn@tk
r�
}
z$|jtj	kr�t
dj|
�
�
�
n�WYdd}~XnX|j
s�ytjd�

Wn2t
tfk
r�
}
ztjd|�
WYdd}~XnXdS)zwRemove a handler for a signal.  UNIX only.

        Return True if a signal handler was removed, False if not.
        Fzsig {} cannot be caughtNrzset_wakeup_fd(-1) failed: %sTr2)r4r�KeyErrorr5�SIGINT�default_int_handler�SIG_DFLr9r>r?r:r@r6r8rr=)rr.ZhandlerrCrrrr)�s(














z,_UnixSelectorEventLoop.remove_signal_handlercCsHt|
t
�std
j|
�
�
�
d|
k
o,tjkn
sDtdj|
tj��
�
dS)z�Internal helper to validate a signal.

        Raise ValueError if the signal number is invalid or uncatchable.
        Raise RuntimeError if there is a problem setting up the handler.
        zsig must be an int, not {!r}rzsig {} out of range(1, {})N)�
isinstance�intr3r@r5�NSIGr8)rr.rrrr4�s




z$_UnixSelectorEventLoop._check_signalcCst||
|||�S)
N)
�_UnixReadPipeTransport)r�pipe�protocol�waiter�extrarrr�_make_read_pipe_transport�sz0_UnixSelectorEventLoop._make_read_pipe_transportcCst||
|||�S)
N)
�_UnixWritePipeTransport)rrOrPrQrRrrr�_make_write_pipe_transport�sz1_UnixSelectorEventLoop._make_write_pipe_transportc	ks�tj
���}
|j�}t||
||||||f||d
�|	��
}|
j|j�|j|�
y|EdH
Wn&tk
r~
}

z
|
}WYdd}
~
XnXd}|dk	r�|j�
|j	�EdH
|�
WdQRX|S)N)rQrR)
r�get_child_watcherZ
create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback�	Exceptionr%Z_wait)rrPrB�shell�stdin�stdout�stderr�bufsizerR�kwargs�watcherrQ�transprC�errrrr�_make_subprocess_transport�s$
















z1_UnixSelectorEventLoop._make_subprocess_transportcCs|j|j
|�
dS)
N)Zcall_soon_threadsafeZ_process_exited)r�pid�
returncoderbrrrrY�s
z._UnixSelectorEventLoop._child_watcher_callback)�ssl�sock�server_hostnameccs
|dkst|t
�st�
|r,|dkr<td
�
�
n|dk	r<td�
�
|dk	r�|dk	rTtd�
�
tjtjtjd�}y |jd�

|j||�EdH
Wq�


|j	�
�Yq�XnB|dkr�td�
�
|j
tjks�tj|j
�
r�tdj|�
�
�
|jd�

|j||
||�EdH\}}||fS)Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with sslz3path and sock can not be specified at the same timer
Fzno path and sock were specifiedz2A UNIX Domain Stream Socket was expected, got {!r})rKr;�AssertionErrorr8r"�AF_UNIX�SOCK_STREAM�setblockingZsock_connectr%�familyr�_is_stream_socket�typer@Z_create_connection_transport)r�protocol_factoryrrgrhri�	transportrPrrr�create_unix_connection�s:

























z-_UnixSelectorEventLoop.create_unix_connection�d)rh�backlogrgc
!Cs�
t|t
�rtd
�
�
|dk	�
r0|dk	r,td�
�
t|�
}tjtjtj�}|dd
kr�y tj	t
j|�
j�
rnt
j|�

WnBt
k
r�


Yn0tk
r�
}
ztjd||�
WYdd}~XnXy|j|�

Wnjtk
�
r
}
z8|j�
|jtjk�
rdj|�
}ttj|�d�n�WYdd}~Xn


|j�
�YnXn>|dk�
rBtd�
�
|jtjk�
s`tj|j�
�
rntdj|�
�
�
tj||g
�}	|j|�

|jd	�

|j|
|||	�
|	S)Nz*ssl argument must be an SSLContext or Nonez3path and sock can not be specified at the same timer
�
z2Unable to check or remove stale UNIX socket %r: %rzAddress {!r} is already in usez-path was not specified, and no sock specifiedz2A UNIX Domain Stream Socket was expected, got {!r}F)r
rv)rK�boolr3r8�_fspathr"rkrl�stat�S_ISSOCK�os�st_mode�remove�FileNotFoundErrorr9r�errorZbindr%r>Z
EADDRINUSEr@rnrrorpZServerZlistenrmZ_start_serving)
rrqrrhrurgrcrC�msgZserverrrr�create_unix_server
sP












 






















z)_UnixSelectorEventLoop.create_unix_server)
N)NN)NN)
N)
N)�__name__�
__module__�__qualname__�__doc__rr#r%r1rEr/r)r4rSrUr
rdrYrsr��
__classcell__rr)
r!rr1s,-
 





%

r�set_blockingc

Cstj
|d
�
dS)NF)r{r�)
�fdrrr�_set_nonblockingB
s
r�c
Cs,tj|tj
�}
|
tjB}
tj|tj|
�
dS)
N)�fcntlZF_GETFLr{�
O_NONBLOCKZF_SETFL)r��flagsrrrr�G
s



cs�eZ
dZdZd �f
dd�	Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	dd�Z
dd�Zdd�Ze
jrhdd�Zd!dd�
Zdd�Zdd�Z�ZS)"rN�
iNcs�t�j
|�

||jd
<|
|_||_|j�|_||_d|_t	j
|j�
j}tj
|�
pbtj|�
pbtj|�
s~d|_d|_d|_td�
�
t|j�

|jj|jj|�
|jj|jj|j|j�
|dk	r�|jjtj|d�
dS)NrOFz)Pipe transport is for pipes/sockets only.)rr�_extra�_loop�_piper7�_fileno�	_protocol�_closingr{�fstatr|ry�S_ISFIFOrz�S_ISCHRr8r��	call_soon�connection_made�_add_reader�_read_readyr	�_set_result_unless_cancelled)r�looprOrPrQrR�mode)
r!rrrQ
s,























z_UnixReadPipeTransport.__init__c
Cs�|jj
g
}
|jdkr |
jd
�

n|jr0|
jd�

|
jd|j�

t|jdd�}|jdk	r�|dk	r�tj	||jt
j�}|r�|
jd�

q�|
jd�

n |jdk	r�|
jd�

n
|
jd
�

dd	j|
�
S)
N�closed�closingzfd=%s�	_selector�polling�idle�openz<%s>�
 )
r!r�r��appendr�r��getattrr�r
�_test_selector_eventrZ
EVENT_READ�join)rr=r r�rrr�__repr__n
s$




















z_UnixReadPipeTransport.__repr__c
Cs�ytj
|j|j�}
WnDttfk
r,


Yn�tk
rX
}
z|j|d
�
WYdd}~Xn^X|
rl|jj	|
�

nJ|j
j�r�tj
d|�
d|_|j
j|j�

|j
j|jj�

|j
j|jd�
dS)Nz"Fatal read error on pipe transportz%r was closed by peerT)r{�readr��max_size�BlockingIOError�InterruptedErrorr9�_fatal_errorr�Z
data_receivedr��	get_debugrr=r��_remove_readerr�Zeof_received�_call_connection_lost)rr0rCrrrr��
s












z"_UnixReadPipeTransport._read_readyc

Cs|jj
|j�

dS)
N)r�r�r�)
rrrr�
pause_reading�
s
z$_UnixReadPipeTransport.pause_readingc

Cs|jj
|j|j�
dS)
N)r�r�r�r�)
rrrr�resume_reading�
s
z%_UnixReadPipeTransport.resume_readingcCs
|
|_dS)
N)
r�)rrPrrr�set_protocol�
s
z#_UnixReadPipeTransport.set_protocolc


Cs|jS)
N)
r�)
rrrr�get_protocol�
s
z#_UnixReadPipeTransport.get_protocolc


Cs|jS)
N)
r�)
rrrr�
is_closing�
s
z!_UnixReadPipeTransport.is_closingc

Cs|js|j
d�

dS)
N)r��_close)
rrrrr%�
s

z_UnixReadPipeTransport.closec

Cs,|jdk	r(t
jd
|t|d�
|jj�
dS)Nzunclosed transport %r)
r$)r�r*r+r,r%)
rrrr�__del__�
s




z_UnixReadPipeTransport.__del__�Fatal error on pipe transportcCsZt|
t
�r4|
jtjkr4|jj�rLtjd
||dd�
n|jj||
||j	d��

|j
|
�

dS)Nz%r: %sT)
�exc_info)�message�	exceptionrrrP)rKr9r>ZEIOr�r�r�debug�call_exception_handlerr�r�)rrCr�rrrr��
s






z#_UnixReadPipeTransport._fatal_errorcCs(d
|_|j
j|j�

|j
j|j|
�
dS)NT)r�r�r�r�r�r�)rrCrrrr��
s


z_UnixReadPipeTransport._closecCs4z|jj
|
�

Wd|jj�
d|_d|_d|_XdS)
N)r��connection_lostr�r%r�)rrCrrrr��
s





z,_UnixReadPipeTransport._call_connection_losti)NN)
r�)r�r�r�r�rr�r�r�r�r�r�r�r%r�PY34r�r�r�r�r�rr)
r!rrNM
s

rNcs�eZ
dZd%�f
dd�	Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zejr|dd�Zdd�Zd&dd �
Zd'd!d"�
Zd#d$�Z�ZS)(rTNc
s�t�j
||
�
||jd
<||_|j�|_||_t�|_d|_	d|_
tj|j�
j
}tj|�
}tj|�
}tj|�
}	|px|px|	s�d|_d|_d|_td�
�
t|j�

|jj|jj|�
|	s�|r�tjjd�
r�|jj|jj|j|j�
|dk	r�|jjtj|d�
dS)NrOr
Fz?Pipe transport is only for pipes, sockets and character devicesZaix)rrr�r�r7r�r��	bytearray�_buffer�
_conn_lostr�r{r�r|ryr�r�rzr8r�r�r�r�r&�platform�
startswithr�r�r	r�)
rr�rOrPrQrRr�Zis_charZis_fifoZ	is_socket)
r!rrr�
s2

























z _UnixWritePipeTransport.__init__c
Cs�|jj
g
}
|jdkr |
jd
�

n|jr0|
jd�

|
jd|j�

t|jdd�}|jdk	r�|dk	r�tj	||jt
j�}|r�|
jd�

n
|
jd�

|j�}|
jd|�

n |jdk	r�|
jd�

n
|
jd
�

d	d
j
|
�
S)Nr�r�zfd=%sr�r�r�z
bufsize=%sr�z<%s>r�)r!r�r�r�r�r�r�r�r
r�rZEVENT_WRITE�get_write_buffer_sizer�)rr=r r�r_rrrr��
s(






















z _UnixWritePipeTransport.__repr__c

Cs
t|j
�
S)
N)�lenr�)
rrrrr�s
z-_UnixWritePipeTransport.get_write_buffer_sizec

Cs6|jj
�rtjd
|�
|jr*|jt��

n|j�
dS)Nz%r was closed by peer)r�r�rr=r�r��BrokenPipeError)
rrrrr�s




z#_UnixWritePipeTransport._read_readycCs0
t|
t
ttf�stt|
�
�
�
t|
t�r.t|
�
}
|
s6dS|jsB|jrj|jtj	krXt
jd
�

|jd7_dS|j�
syt
j|j|
�}WnTttfk
r�


d}Yn:tk
r�
}
z|jd7_|j|d�
dSd}~XnX|t|
�
kr�dS|dk�
rt|
�
|d�}
|jj|j|j�
|j|
7_|j�
dS)Nz=pipe closed by peer or os.write(pipe, data) raised exception.rr
z#Fatal write error on pipe transport)rK�bytesr��
memoryviewrj�reprr�r�rZ!LOG_THRESHOLD_FOR_CONNLOST_WRITESr�warningr�r{�writer�r�r�rZr�r�r�Z_add_writer�_write_readyZ_maybe_pause_protocol)rr0�
nrCrrrr�s4























z_UnixWritePipeTransport.writec
Cs�|jst
d
�
�
ytj|j|j�}
Wnjttfk
r:


Yn�tk
r�
}
z8|jj�
|j	d7_	|j
j|j�

|j|d�
WYdd}~XnfX|
t
|j�
kr�|jj�
|j
j|j�

|j�
|jr�|j
j|j�

|jd�

dS|
dkr�|jd|
�=dS)NzData should not be emptyrz#Fatal write error on pipe transportr
)r�rjr{r�r�r�r�rZr-r�r��_remove_writerr�r�Z_maybe_resume_protocolr�r�r�)rr�rCrrrr�>s(



















z$_UnixWritePipeTransport._write_readyc


Csd
S)NTr)
rrrr�
can_write_eofXs
z%_UnixWritePipeTransport.can_write_eofc

CsB|jr
dS|j
st�
d
|_|js>|jj|j�

|jj|jd�
dS)NT)	r�r�rjr�r�r�r�r�r�)
rrrr�	write_eof[s







z!_UnixWritePipeTransport.write_eofcCs
|
|_dS)
N)
r�)rrPrrrr�ds
z$_UnixWritePipeTransport.set_protocolc


Cs|jS)
N)
r�)
rrrrr�gs
z$_UnixWritePipeTransport.get_protocolc


Cs|jS)
N)
r�)
rrrrr�js
z"_UnixWritePipeTransport.is_closingc

Cs|jdk	r|j
r|j�
dS)
N)r�r�r�)
rrrrr%ms
z_UnixWritePipeTransport.closec

Cs,|jdk	r(t
jd
|t|d�
|jj�
dS)Nzunclosed transport %r)
r$)r�r*r+r,r%)
rrrrr�vs




z_UnixWritePipeTransport.__del__c

Cs|jd�

dS)
N)
r�)
rrrr�abort|s
z_UnixWritePipeTransport.abort�Fatal error on pipe transportcCsPt|
t
j�r*|jj�rBtjd
||dd�
n|jj||
||jd��

|j	|
�

dS)Nz%r: %sT)
r�)r�r�rrrP)
rKrZ_FATAL_ERROR_IGNOREr�r�rr�r�r�r�)rrCr�rrrr�s






z$_UnixWritePipeTransport._fatal_errorcCsFd
|_|j
r|jj|j�

|j
j�
|jj|j�

|jj|j|
�
dS)NT)	r�r�r�r�r�r-r�r�r�)rrCrrrr��s






z_UnixWritePipeTransport._closecCs4z|jj
|
�

Wd|jj�
d|_d|_d|_XdS)
N)r�r�r�r%r�)rrCrrrr��s





z-_UnixWritePipeTransport._call_connection_lost)NN)
r�)
N)r�r�r�rr�r�r�r�r�r�r�r�r�r�r%rr�r�r�r�r�r�r�rr)
r!rrT�
s$%	!	


rT�set_inheritablecCsNtt
d
d�}t
j
|t
j�}|
s4t
j
|t
j||B�
nt
j
|t
j||@�
dS)NZ
FD_CLOEXECr)r�r�ZF_GETFDZF_SETFD)r�ZinheritableZcloexec_flag�oldrrr�_set_inheritable�s



r�c@seZ
dZd
d�ZdS)rWc		Ksvd}|tj
kr*|jj�\}}t|j�d
�
tj|
f
||||d
|d�|��
|_|dk	rr|j�
t	|j
�d|d�|j_dS)NF)r[r\r]r^Zuniversal_newlinesr_�wb)
�	buffering)�
subprocess�PIPEr�r#r�r7�Popen�_procr%r��detachr\)	rrBr[r\r]r^r_r`Zstdin_wrrr�_start�s








z_UnixSubprocessTransport._startN)r�r�r�r�rrrrrW�srWc@s@eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dS)raHAbstract base class for monitoring child processes.

    Objects derived from this class monitor a collection of subprocesses and
    report their termination or interruption by a signal.

    New callbacks are registered with .add_child_handler(). Starting a new
    process must be done within a 'with' block to allow the watcher to suspend
    its activity until the new process if fully registered (this is needed to
    prevent a race condition in some implementations).

    Example:
        with watcher:
            proc = subprocess.Popen("sleep 1")
            watcher.add_child_handler(proc.pid, callback)

    Notes:
        Implementations of this class must be thread-safe.

        Since child watcher objects may catch the SIGCHLD signal and call
        waitpid(-1), there should be only one active object per process.
    c
Gs
t��
d
S)a
Register a new child handler.

        Arrange for callback(pid, returncode, *args) to be called when
        process 'pid' terminates. Specifying another callback for the same
        process replaces the previous handler.

        Note: callback() must be thread-safe.
        N)
�NotImplementedError)rrerArBrrrrX�s	z&AbstractChildWatcher.add_child_handlerc
Cs
t��
d
S)z�Removes the handler for process 'pid'.

        The function returns True if the handler was successfully removed,
        False if there was nothing to remove.N)
r�)rrerrr�remove_child_handler�sz)AbstractChildWatcher.remove_child_handlerc
Cs
t��
d
S)z�Attach the watcher to an event loop.

        If the watcher was previously attached to an event loop, then it is
        first detached before attaching to the new loop.

        Note: loop may be None.
        N)
r�)rr�rrr�attach_loop�sz AbstractChildWatcher.attach_loopc


Cs
t��
d
S)zlClose the watcher.

        This must be called to make sure that any underlying resource is freed.
        N)
r�)
rrrrr%�szAbstractChildWatcher.closec


Cs
t��
d
S)zdEnter the watcher's context and allow starting new processes

        This function must return selfN)
r�)
rrrr�	__enter__szAbstractChildWatcher.__enter__c
Cs
t��
d
S)zExit the watcher's contextN)
r�)r�
a�
b�
crrr�__exit__	szAbstractChildWatcher.__exit__N)
r�r�r�r�rXr�r�r%r�r�rrrrr�s
c@sDeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dS)�BaseChildWatcherc

Csd|_i|_
dS)
N)r��
_callbacks)
rrrrrs

zBaseChildWatcher.__init__c

Cs|jd�

dS)
N)
r�)
rrrrr%s
zBaseChildWatcher.closec
Cs
t��
dS)
N)
r�)r�expected_pidrrr�_do_waitpids
zBaseChildWatcher._do_waitpidc


Cs
t��
dS)
N)
r�)
rrrr�_do_waitpid_alls
z BaseChildWatcher._do_waitpid_allcCs~|
dkst|
t
j�st�
|jdk	r<|
dkr<|jr<tjd
t�
|jdk	rT|jj	t
j�

|
|_|
dk	rz|
jt
j|j
�
|j�
dS)NzCA loop is being detached from a child watcher with pending handlers)rKrZAbstractEventLooprjr�r�r*r+�RuntimeWarningr)r5�SIGCHLDrE�	_sig_chldr�)rr�rrrr�s






zBaseChildWatcher.attach_loopc
CsFy|j�
Wn4t
k
r@
}

z|jjd
|
d��

WYdd}
~
XnXdS)Nz$Unknown exception in SIGCHLD handler)r�r�)r�rZr�r�)rrCrrrr�1s




zBaseChildWatcher._sig_chldcCs2tj
|
�
rtj|
�
Stj|
�
r*tj|
�
S|
SdS)
N)r{�WIFSIGNALED�WTERMSIG�	WIFEXITED�WEXITSTATUS)r�statusrrr�_compute_returncode=s





z$BaseChildWatcher._compute_returncodeN)
r�r�r�rr%r�r�r�r�r�rrrrr�sr�csPeZ
dZd
Z�f
dd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
�ZS)rad
'Safe' child watcher implementation.

    This implementation avoids disrupting other code spawning processes by
    polling explicitly each process in the SIGCHLD handler instead of calling
    os.waitpid(-1).

    This is a safe solution but it has a significant overhead when handling a
    big number of children (O(n) each time SIGCHLD is raised)
    c


s|jj
�
t�j�
dS)
N)r�r-rr%)
r)
r!rrr%Vs


zSafeChildWatcher.closec


Cs|S)
Nr)
rrrrr�Zs
zSafeChildWatcher.__enter__c
CsdS)
Nr)rr�r�r�rrrr�]s
zSafeChildWatcher.__exit__cGs.|jdkrt
d
�
�
||f|j|
<|j|
�

dS)NzICannot add child handler, the child watcher does not have a loop attached)r�r:r�r�)rrerArBrrrrX`s




z"SafeChildWatcher.add_child_handlercCs&y|j|
=d
St
k
r 


dSXdS)NTF)r�rG)rrerrrr�ks





z%SafeChildWatcher.remove_child_handlerc
Cs"xt|j
�
D]}
|j|
�

qWdS)
N)r(r�r�)rrerrrr�rs
z SafeChildWatcher._do_waitpid_allcCs�|
d
kst�
yt
j|
t
j�\}}Wn(tk
rJ


|
}d}tjd|�
Yn0X|d
krXdS|j|�
}|jj	�rztj
d|
|�
y|jj|�
\}}Wn.t
k
r�


|jj	�r�tjd|dd�
YnX|||f|��
dS)Nr
��z8Unknown child process pid %d, will report returncode 255z$process %s exited with returncode %sz'Child watcher got an unexpected pid: %rT)
r�)rjr{�waitpid�WNOHANG�ChildProcessErrorrr�r�r�r�r�r��poprG)rr�rer�rfrArBrrrr�ws,
















zSafeChildWatcher._do_waitpid)r�r�r�r�r%r�r�rXr�r�r�r�rr)
r!rrKs	csTeZ
dZd
Z�f
dd�Z�f
dd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
�ZS)raW
'Fast' child watcher implementation.

    This implementation reaps every terminated processes by calling
    os.waitpid(-1) directly, possibly breaking other code spawning processes
    and waiting for their termination.

    There is no noticeable overhead when handling a big number of children
    (O(1) each time a child terminates).
    c

s$t�j
�
tj�|_i|_d
|_dS)Nr
)rr�	threadingZLock�_lock�_zombies�_forks)
r)
r!rrr�s





zFastChildWatcher.__init__c


s"|jj
�
|jj
�
t�j�
dS)
N)r�r-r�rr%)
r)
r!rrr%�s




zFastChildWatcher.closec


Cs$|j�
|j
d
7_
|SQRXdS)Nr)r�r�)
rrrrr��s

zFastChildWatcher.__enter__c
CsV|j�:
|j
d
8_
|j
s$|jr(dSt|j�
}|jj�
WdQRXtjd|�
dS)Nrz5Caught subprocesses termination from unknown pids: %s)r�r�r�r;r-rr�)rr�r�r�Zcollateral_victimsrrrr��s






zFastChildWatcher.__exit__cGsz|jst
d
�
�
|jdkr td�
�
|j�:
y|jj|
�
}Wn"tk
rZ


||f|j|
<dSXWdQRX||
|f|��
dS)NzMust use the context managerzICannot add child handler, the child watcher does not have a loop attached)	r�rjr�r:r�r�r�rGr�)rrerArBrfrrrrX�s







z"FastChildWatcher.add_child_handlercCs&y|j|
=d
St
k
r 


dSXdS)NTF)r�rG)rrerrrr��s





z%FastChildWatcher.remove_child_handlerc
Cs�x�ytj
dtj�\}
}Wntk
r,


dSX|
dkr:dS|j|�
}|j�v
y|jj|
�
\}}WnBtk
r�


|j	r�||j
|
<|jj�r�t
jd|
|�
wd}YnX|jj�r�t
jd|
|�
WdQRX|dkr�t
jd|
|�
q||
|f|��
qWdS)Nrr
z,unknown process %s exited with returncode %sz$process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %dr2)r{r�r�r�r�r�r�r�rGr�r�r�r�rr�r�)rrer�rfrArBrrrr��s6




















z FastChildWatcher._do_waitpid_all)r�r�r�r�rr%r�r�rXr�r�r�rr)
r!rr�s	
csHeZ
dZd
ZeZ�f
dd�Zdd�Z�f
dd�Zdd	�Z	d
d�Z
�ZS)�_UnixDefaultEventLoopPolicyz:UNIX event loop policy with a watcher for child processes.c

st�j
�
d|_dS)
N)rr�_watcher)
r)
r!rrrs


z$_UnixDefaultEventLoopPolicy.__init__c


CsHtj
�8
|jdkr:t�|_ttj�tj�r:|jj|j	j
�

WdQRXdS)
N)rr�r
rrKr��current_thread�_MainThreadr��_localr�)
rrrr�
_init_watchers






z)_UnixDefaultEventLoopPolicy._init_watchercs6t�j
|
�

|jd
k	r2ttj�tj�r2|jj|
�

d
S)z�Set the event loop.

        As a side effect, if a child watcher was set before, then calling
        .set_event_loop() from the main thread will call .attach_loop(loop) on
        the child watcher.
        N)r�set_event_loopr
rKr�r

r
r�)rr�)
r!rrr
s


z*_UnixDefaultEventLoopPolicy.set_event_loopc

Cs|jd
kr|j
�
|jS)zzGet the watcher for child processes.

        If not yet set, a SafeChildWatcher object is automatically created.
        N)r
r
)
rrrrrV&s

z-_UnixDefaultEventLoopPolicy.get_child_watchercCs4|
d
kst|
t
�st�
|jd
k	r*|jj�
|
|_d
S)z$Set the watcher for child processes.N)rKrrjr
r%)rrarrr�set_child_watcher0s


z-_UnixDefaultEventLoopPolicy.set_child_watcher)r�r�r�r�rZ
_loop_factoryrr
r
rVr
r�rr)
r!rr�s


r�)5r�r>r{r5r"ryr�r&r�r*�rrrrrrr	r
rrr
�logr�__all__r��ImportErrorr�fspathrx�AttributeErrorZBaseSelectorEventLoopr�hasattrr�r�Z
ReadTransportrNZ_FlowControlMixinZWriteTransportrTr�r�ZBaseSubprocessTransportrWrr�rrZBaseDefaultEventLoopPolicyr�rrrrrr�<module>
sn




























O
F=On2