ÿØÿà 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�l�@s�
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZddlmZ
ddlm	Z	
ddlm
Z

ddlmZ
ddlmZ
dd	lm
Z

dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
ddddgZd
ZdZdZdZdZdZGdd�de
j�ZGdd�de
j�ZGdd�de�ZGdd�de�ZGdd �d e �Z!Gd!d"�d"ej"�Z#Gd#d�dej$�Z%Gd$d�d�Z&Gd%d&�d&e	j'�Z(e#Z)Gd'd(�d(ej*�Z+e+Z,dS))z.Selector and proactor event loops for Windows.�N�
)
�events)
�base_subprocess)
�futures)
�proactor_events)
�selector_events)
�tasks)
�
windows_utils)
�_overlapped)
�	coroutine)
�logger�SelectorEventLoop�ProactorEventLoop�IocpProactor�DefaultEventLoopPolicyl��i�i�g����MbP?g�������?cs^eZ
dZd
Zdd�
�f
dd�
Z�f
dd�Zdd	�Z�f
d
d�Z�f
dd
�Z�f
dd�Z	�Z
S)�_OverlappedFuturez�Subclass of Future which represents an overlapped operation.

    Cancelling it will immediately cancel the overlapped operation.
    N)
�loopc
s&t�j
|d
�

|jr|jd=|
|_dS)N)
rr�����)�super�__init__�_source_traceback�_ov)�self�ovr)
�	__class__��,/usr/lib/python3.6/asyncio/windows_events.pyr-s



z_OverlappedFuture.__init__c
s@t�j
�}
|jdk	r<|jjr d
nd}|
jdd||jjf�
|
S)N�pendingZ	completedrzoverlapped=<%s, %#x>)r�
_repr_inforr�insert�address)r�info�state)
rrrr3s







z_OverlappedFuture._repr_infoc
Csr|jdkrdSy|jj
�
WnJtk
rf
}

z.d
|
|d�}|jrJ|j|d<|jj|�

WYdd}
~
XnXd|_dS)Nz&Cancelling an overlapped future failed)�message�	exception�future�source_traceback)r�cancel�OSErrorr�_loop�call_exception_handler)r�exc�contextrrr�_cancel_overlapped:s











z$_OverlappedFuture._cancel_overlappedc


s|j�
t
�j�S)
N)r-rr')
r)
rrrr'Js

z_OverlappedFuture.cancelcst�j
|
�

|j�
dS)
N)r�
set_exceptionr-)rr$)
rrrr.Ns

z_OverlappedFuture.set_exceptioncst�j
|
�

d|_dS)
N)r�
set_resultr)r�result)
rrrr/Rs

z_OverlappedFuture.set_result)�__name__�
__module__�__qualname__�__doc__rrr-r'r.r/�
__classcell__rr)
rrr'srcsneZ
dZd
Zdd�
�f
dd�
Zdd�Z�f
dd	�Zd
d�Zdd
�Z�f
dd�Z	�f
dd�Z
�f
dd�Z�ZS)�_BaseWaitHandleFuturez2Subclass of Future which represents a wait handle.N)
rc
s8t�j
|d
�

|jr|jd=|
|_||_||_d|_dS)N)
rrTr)rrrr�_handle�_wait_handle�_registered)rr�handle�wait_handler)
rrrrZs




z_BaseWaitHandleFuture.__init__c

Cstj
|jd
�tjkS)Nr
)�_winapiZWaitForSingleObjectr7Z
WAIT_OBJECT_0)
rrrr�_pollhs
z_BaseWaitHandleFuture._pollc
s\t�j
�}
|
jd
|j�

|jdk	r>|j�r0dnd}|
j|�

|jdk	rX|
jd|j�

|
S)Nz
handle=%#xZsignaledZwaitingzwait_handle=%#x)rr�appendr7r=r8)rr!r")
rrrrms











z _BaseWaitHandleFuture._repr_infocCs
d|_dS)
N)
r)r�futrrr�_unregister_wait_cbwsz)_BaseWaitHandleFuture._unregister_wait_cbc
Cs�|js
dSd
|_|j
}
d|_
ytj|
�

WnZtk
r�
}
z>|jtjkrtd||d�}|jrd|j|d<|jj	|�

dSWYdd}~XnX|j
d�

dS)NFz$Failed to unregister the wait handle)r#r$r%r&)r9r8r
ZUnregisterWaitr(�winerror�ERROR_IO_PENDINGrr)r*r@)rr;r+r,rrr�_unregister_wait|s"













z&_BaseWaitHandleFuture._unregister_waitc


s|j�
t
�j�S)
N)rCrr')
r)
rrrr'�s

z_BaseWaitHandleFuture.cancelcs|j�
t
�j|
�

dS)
N)rCrr.)rr$)
rrrr.�s

z#_BaseWaitHandleFuture.set_exceptioncs|j�
t
�j|
�

dS)
N)rCrr/)rr0)
rrrr/�s

z _BaseWaitHandleFuture.set_result)
r1r2r3r4rr=rr@rCr'r.r/r5rr)
rrr6Ws

r6csFeZ
dZd
Zdd�
�f
dd�
Zdd�Z�f
dd	�Z�f
d
d�Z�ZS)�_WaitCancelFuturezoSubclass of Future which represents a wait for the cancellation of a
    _WaitHandleFuture using an event.
    N)
rc
st�j
|
|||d
�
d|_dS)N)
r)rr�_done_callback)rr�eventr;r)
rrrr�s
z_WaitCancelFuture.__init__c

Cstd
�
�
dS)Nz'_WaitCancelFuture must not be cancelled)
�RuntimeError)
rrrrr'�s
z_WaitCancelFuture.cancelcs$t�j
|
�

|jdk	r |j|�

dS)
N)rr/rE)rr0)
rrrr/�s



z_WaitCancelFuture.set_resultcs$t�j
|
�

|jdk	r |j|�

dS)
N)rr.rE)rr$)
rrrr.�s



z_WaitCancelFuture.set_exception)	r1r2r3r4rr'r/r.r5rr)
rrrD�s
rDcs6eZ
dZd
d�
�f
dd�
Z�f
dd�Zdd�Z�ZS)	�_WaitHandleFutureN)
rc
s<t�j
|
|||d
�
||_d|_tjdddd�|_d|_dS)N)
rTF)rr�	_proactorZ_unregister_proactorr
ZCreateEvent�_event�
_event_fut)rrr:r;�proactorr)
rrrr�s





z_WaitHandleFuture.__init__csF|jdk	r"t
j|j�

d|_d|_|jj|j�

d|_t�j|
�

dS)
N)	rJr<�CloseHandlerKrI�_unregisterrrr@)rr?)
rrrr@�s




	
z%_WaitHandleFuture._unregister_wait_cbc
Cs�|js
dSd
|_|j
}
d|_
ytj|
|j�
WnZtk
r�
}
z>|jtjkrxd||d�}|jrh|j|d<|j	j
|�

dSWYdd}~XnX|jj|j|j
�|_dS)NFz$Failed to unregister the wait handle)r#r$r%r&)r9r8r
ZUnregisterWaitExrJr(rArBrr)r*rI�_wait_cancelr@rK)rr;r+r,rrrrC�s$















z"_WaitHandleFuture._unregister_wait)r1r2r3rr@rCr5rr)
rrrH�s
rHc@s<eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�ZeZ	dS)
�
PipeServerzXClass representing a pipe server.

    This is much like a bound, listening socket.
    cCs,|
|_t
j�|_d|_d|_|jd
�
|_dS)NT)�_address�weakref�WeakSet�_free_instances�_pipe�_accept_pipe_future�_server_pipe_handle)rr rrrr�s





zPipeServer.__init__c
Cs|j|j
d
�
}
|_|
S)NF)rUrW)r�tmprrr�_get_unconnected_pipe�s
z PipeServer._get_unconnected_pipec	Csr|j�rdSt
jt
jB}|
r&|t
jO}t
j|j|t
jt
jBt
j	Bt
j
tjtjt
j
t
j�}tj|�
}|jj|�

|S)
N)�closedr<ZPIPE_ACCESS_DUPLEXZFILE_FLAG_OVERLAPPEDZFILE_FLAG_FIRST_PIPE_INSTANCEZCreateNamedPiperQZPIPE_TYPE_MESSAGEZPIPE_READMODE_MESSAGEZ	PIPE_WAITZPIPE_UNLIMITED_INSTANCESr	ZBUFSIZEZNMPWAIT_WAIT_FOREVER�NULL�
PipeHandlerT�add)r�first�flags�
h�piperrrrW
s
















zPipeServer._server_pipe_handlec

Cs
|jdkS)
N)
rQ)
rrrrrZ
s
zPipeServer.closedc
CsV|jdk	r|jj
�
d|_|jdk	rRx|jD]}
|
j�
q,Wd|_d|_|jj�
dS)
N)rVr'rQrT�closerU�clear)rrarrrrb
s










zPipeServer.closeN)
r1r2r3r4rrYrWrZrb�__del__rrrrrP�s

rPc@seZ
dZd
Zdd�ZdS)�_WindowsSelectorEventLoopz'Windows version of selector event loop.c


Cstj
�S)
N)r	�
socketpair)
rrrr�_socketpair+
s
z%_WindowsSelectorEventLoop._socketpairN)r1r2r3r4rgrrrrre(
s
recsPeZ
dZd
Zd
�f
dd�	Zdd�Zedd��
Zed	d
��
Zeddd�
�
Z	�Z
S)rz2Windows version of proactor event loop using IOCP.Ncs|
dkrt�}
t
�j|
�

dS)
N)rrr)rrL)
rrrr2
s


zProactorEventLoop.__init__c


Cstj
�S)
N)r	rf)
rrrrrg7
s
zProactorEventLoop._socketpairccs8|jj
|�
}|EdH}|
�}|j||d
|i
d�}||fS)N�addr)
�extra)rI�connect_pipe�_make_duplex_pipe_transport)r�protocol_factoryr �
fra�protocol�transrrr�create_pipe_connection:
s





z(ProactorEventLoop.create_pipe_connectioncs.t��
�d��
���fd
d�	�
�j
�
�

�g
S)Nc
s
d}
yj|rL|j�}
�j
j|
�

�j�r2|
j�
dS��}�j|
|d
�i
d�
�j�}
|
dkr`dS�jj|
�
}Wn�t	k
r�
}
zH|
r�|
j
�d	kr��jd||
d��

|
j�
n�jr�t
jd|
dd�
WYdd}~Xn2tjk
r�


|
r�|
j�
YnX|�_|j�
�

dS)
Nrh)
rirzPipe accept failed)r#r$razAccept pipe failed on pipe %rT)
�exc_infor)r0rT�discardrZrbrkrYrI�accept_piper(�filenor*Z_debugrZwarningr�CancelledErrorrV�add_done_callback)rmrarnr+)r �loop_accept_piperlr�serverrrrwG
s<
























z>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_pipe)
N)rPZ	call_soon)rrlr r)r rwrlrrxr�start_serving_pipeC
s(

z$ProactorEventLoop.start_serving_pipec	ks�|j�}
t
||
||||||f|
|d
�|	��
}y|
EdH
Wn&tk
r`
}
z
|}
WYdd}~XnXd}
|
dk	r�|j�
|j�EdH
|
�
|S)N)�waiterri)�
create_future�_WindowsSubprocessTransport�	ExceptionrbZ_wait)rrn�args�shell�stdin�stdout�stderr�bufsizeri�kwargsrzZtranspr+�errrrr�_make_subprocess_transportr
s











z,ProactorEventLoop._make_subprocess_transport)
N)
N)r1r2r3r4rrgrrpryr�r5rr)
rrr/
s
	/c@s�eZ
dZd
Zd1dd�
Zdd�Zdd�Zd2d
d�
Zdd
�Zd3dd�
Z	d4dd�
Z
dd�Zdd�Zdd�Z
edd��
Zd5dd�
Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd6d)d*�
Zd+d,�Zd-d.�Zd/d0�Zd	S)7rz#Proactor implementation using IOCP.���cCsDd|_g|_
tjtjtd
|
�|_i|_tj	�|_
g|_tj	�|_dS)Nr
)
r)�_resultsr
�CreateIoCompletionPort�INVALID_HANDLE_VALUEr[�_iocp�_cacherRrSr9�
_unregistered�_stopped_serving)rZconcurrencyrrrr�
s








zIocpProactor.__init__c

Csd
|jj
t|j�
t|j�
fS)Nz<%s overlapped#=%s result#=%s>)rr1�lenr�r�)
rrrr�__repr__�
s


zIocpProactor.__repr__cCs
|
|_dS)
N)
r))rrrrr�set_loop�
s
zIocpProactor.set_loopNcCs |js|j
|
�

|j}g|_|S)
N)r�r=)r�timeoutrXrrr�select�
s






zIocpProactor.selectcCs|jj
�}|j|
�

|S)
N)r)r{r/)r�valuer?rrr�_result�
s




zIocpProactor._resultr
cCsz|j|
�

t
jt�
}y4t|
tj�r6|j|
j�||�
n|j|
j�|�
Wnt	k
rb


|j
d
�
SXdd�}|j||
|�S)N�cSsJy|j�St
k
rD
}
z |jtjkr2t|j��
n�WYdd}~XnXdS)
N)�	getresultr(rAr
�ERROR_NETNAME_DELETED�ConnectionResetErrorr~)ro�keyrr+rrr�finish_recv�
s




z&IocpProactor.recv.<locals>.finish_recv)�_register_with_iocpr
�
Overlappedr[�
isinstance�socketZWSARecvrtZReadFile�BrokenPipeErrorr��	_register)r�conn�nbytesr_rr�rrr�recv�
s








	zIocpProactor.recvcCsZ|j|
�

t
jt�
}t|
tj�r4|j|
j�||�
n|j|
j�|�
d
d�}|j	||
|�S)NcSsJy|j�St
k
rD
}
z |jtjkr2t|j��
n�WYdd}~XnXdS)
N)r�r(rAr
r�r�r~)ror�rr+rrr�finish_send�
s




z&IocpProactor.send.<locals>.finish_send)
r�r
r�r[r�r�ZWSASendrtZ	WriteFiler�)rr��bufr_rr�rrr�send�
s





	zIocpProactor.sendcsz|j�
�

|j
�
j�
�tjt�
}|j�
j��j��
��
fd
d�}tdd��
}|j	|�
|�}||��}t
j||jd�
|S)NcsD|j�
t
jd
�
j��}�jtjtj|�
�j	�
j
��

��j�fS)Nz@P)r��structZpackrt�
setsockoptr��
SOL_SOCKETr
ZSO_UPDATE_ACCEPT_CONTEXT�
settimeoutZ
gettimeoutZgetpeername)ror�rr�)r��listenerrr�
finish_accept�
s





z*IocpProactor.accept.<locals>.finish_acceptcss4y|EdH
Wn tj
k
r.


|
j�
�YnXdS)
N)rrurb)r%r�rrr�accept_coro�
s




z(IocpProactor.accept.<locals>.accept_coro)
r)
r��_get_accept_socket�familyr
r�r[ZAcceptExrtrr�rZ
ensure_futurer))rr�rr�r�r%�coror)r�r�r�accept�
s





		



zIocpProactor.acceptcs�|j��

yt
j�j��j�
WnBtk
rb
}
z&|jtjkr@��j	�d
dkrR�WYdd}~XnXt
j
t�
}|j�j�|�
�f
dd�}|j
|�|�S)Nrr
cs|j�
�j
tjtjd
�
�S)Nr
)r�r�r�r�r
ZSO_UPDATE_CONNECT_CONTEXT)ror�r)
r�rr�finish_connect
s



z,IocpProactor.connect.<locals>.finish_connect)r�r
Z	BindLocalrtr�r(rA�errnoZ	WSAEINVALZgetsocknamer�r[Z	ConnectExr�)rr�r �
err�r)
r�r�connect�
s









zIocpProactor.connectcsJ|j��

t
jt�
}|j�j��
}|r0|j��
S�f
d
d�}|j|�|�S)Nc
s|j�
�S)
N)
r�)ror�r)
rarr�finish_accept_pipes

z4IocpProactor.accept_pipe.<locals>.finish_accept_pipe)r�r
r�r[ZConnectNamedPipertr�r�)rrarZ	connectedr�r)
rarrs
s





zIocpProactor.accept_pipeccszt}xjyt
j|
�
}PWn0tk
rF
}
z|jt
jkr6�WYdd}~XnXt|d
t�}tj	||j
d�EdH
qWtj|�
S)N�)
r)
�CONNECT_PIPE_INIT_DELAYr
ZConnectPiper(rAZERROR_PIPE_BUSY�min�CONNECT_PIPE_MAX_DELAYrZsleepr)r	r\)rr Zdelayr:r+rrrrjs







zIocpProactor.connect_pipecCs|j|
|d
�S)z�Wait for a handle.

        Return a Future object. The result of the future is True if the wait
        completed, or False if the wait did not complete (on timeout).
        F)
�_wait_for_handle)rr:r�rrr�wait_for_handle/szIocpProactor.wait_for_handlecCs|j|
dd
�}||_
|S)NT)r�rE)rrFZ
done_callbackr?rrrrO7s

zIocpProactor._wait_cancelcs�|dkrtj
}ntj|d
�
}tjt�
}tj|
|j|j	|�}|rTt
||
||jd��nt||
|||jd���j
rv�j
d=�f
dd�}�|d|f|j|j	<�S)Ng@�@)
rrc
s�j�S)
N)
r=)ror�r)
rmrr�finish_wait_for_handleRsz=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handler
r)r<�INFINITE�math�ceilr
r�r[ZRegisterWaitWithQueuer�r rDr)rHrr�)rr:r�Z
_is_cancel�msrr;r�r)
rmrr�>s











	
zIocpProactor._wait_for_handlecCs0|
|jkr,|jj
|
�

tj|
j�|jd
d
�
dS)Nr
)r9r]r
r�rtr�)r�objrrrr�^s


z IocpProactor._register_with_iocpcCs�t|
|j
d
�}|jr|jd=|
jsjy|dd|
�}Wn,tk
r^
}
z|j|�

WYdd}~XnX|j|�

||
||f|j|
j<|S)N)
rrr)	rr)rrr(r.r/r�r )rrr��callbackrmr�r�rrrr�hs








zIocpProactor._registercCs|jj
|
�

d
S)a

Unregister an overlapped object.

        Call this method when its future has been cancelled. The event can
        already be signalled (pending in the proactor event queue). It is also
        safe if the event is never signalled (because it was cancelled).
        N)r�r>)rrrrrrN�szIocpProactor._unregistercCstj|
�
}|j
d
�

|S)Nr
)r�r�)rr��
srrrr��s




zIocpProactor._get_accept_socketcCs�
|
dkrt}n0|
d
kr t
d�
�
ntj|
d�
}|tkr>t
d�
�
�
xtj|j|�}|dkrZPd
}|\}}}}y|jj|�
\}}	}
}WnVt	k
r�


|j
j�r�|j
jdd||||fd��

|d
tj
fkr�tj|�

wBYnX|
|jkr�|j�
qB|j�sBy||||	�}Wn:tk
�
r@
}

z|j|
�

|jj|�

WYdd}
~
XqBX|j|�

|jj|�

qBWx |jD]}	|jj|	jd�
�
qdW|jj�
dS)Nr
znegative timeoutg@�@ztimeout too bigz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r#�status)r��
ValueErrorr�r�r
ZGetQueuedCompletionStatusr�r��pop�KeyErrorr)Z	get_debugr*r�r<rMr�r'Zdoner(r.r�r>r/r�r rc)rr�r�r�r�Ztransferredr�r rmrr�r�r�r�rrrr=�sJ


































zIocpProactor._pollcCs|jj
|
�

dS)
N)r�r])rr�rrr�
_stop_serving�szIocpProactor._stop_servingc
Cs�x�t|j
j��
D]�\}
\}}}}|j�r*qt|t�r6qy|j�
Wqtk
r�
}
z8|jdk	r�d
||d�}|j	rz|j	|d<|jj
|�

WYdd}~XqXqWx|j
r�|jd�
s�tj
d�

q�Wg|_|jdk	r�tj|j�

d|_dS)NzCancelling a future failed)r#r$r%r&rz"taking long time to close proactor)�listr��itemsZ	cancelledr�rDr'r(r)rr*r=r�debugr�r�r<rM)rr r?rr�r�r+r,rrrrb�s, 











"






zIocpProactor.closec


Cs|j�
dS)
N)
rb)
rrrrrd�s
zIocpProactor.__del__)
r�)
N)
r
)
r
)
N)
N)r1r2r3r4rr�r�r�r�r�r�r�r�rsrrjr�rOr�r�r�rNr�r=r�rbrdrrrrr�
s.






 
	
7 c@seZ
dZd
d�ZdS)r|c
sPtj
|
f
|||||d
�|��
�_�f
dd�}�jjjt�jj�
�
}	|	j|�

dS)N)rr�r�r�r�c
s�jj
�}
�j|
�

dS)
N)�_procZpollZ_process_exited)rm�
returncode)
rrrr��s


z4_WindowsSubprocessTransport._start.<locals>.callback)	r	�Popenr�r)rIr��intr7rv)
rr~rr�r�r�r�r�r�rmr)
rr�_start�s



z"_WindowsSubprocessTransport._startN)r1r2r3r�rrrrr|�sr|c
@seZ
dZeZd
S)�_WindowsDefaultEventLoopPolicyN)r1r2r3r
Z
_loop_factoryrrrrr�s
r�)-r4r<r�r�r�r�rR�rrrrrrr	r
Z
coroutinesr�logr�__all__r[r�ZERROR_CONNECTION_REFUSEDZERROR_CONNECTION_ABORTEDr�r�ZFuturerr6rDrH�objectrPZBaseSelectorEventLoopreZBaseProactorEventLooprrZBaseSubprocessTransportr|r
ZBaseDefaultEventLoopPolicyr�rrrrr�<module>
sL

















0J4;]k