ÿØÿà 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ÿÙ
U

���^{�@sdd
ddgZddl
Z
ddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
mZ
ddl
mZm
Z

dd	lmZ
ejZz$ddlZdd
lmZmZmZmZ
Wn$ek
r�


ejdkr‚dZYnXdZd
Ze��ZdZdg
Zeed�r�dZedg
7Zejdk�
rdZedg
7Zef
dd�
Z dd�Z!dd�Z"dd�Z#dd�Z$Gdd�d�Z%e�
rhGdd�de%�Z&Gdd �d e%�Z'Gd!d
�d
e(�Z)dOd"d�
Z*ejdk�
r�dPd$d�
Z+n
dQd%d�
Z+Gd&d'�d'e(�Z,d(d)�Z-ejdk�
r�Gd*d+�d+e(�Z.d,d-�Z/d.Z0d/Z1d0Z2d1Z3d2d3�Z4d4d5�Z5Gd6d7�d7e(�Z6d8d9�Z7d:d;�Z8Gd<d=�d=e)�Z9d>d?�Z:ejdk�rtd@dA�Z;ej<ej=hZ>dRdBd�
Z?n,ddl@Z@ee@dC��r�e@jAZBne@jCZBdSdDd�
Z?ejdk�r�dEdF�ZDdGdH�ZEe�Fe'eD�
dIdJ�ZGdKdL�ZHe�Fe&eG�
ndMdF�ZDdNdH�ZEe�Fe'eD�
dS)T�Client�Listener�Pipe�wait�N�
)
�util)�AuthenticationError�BufferTooShort)
�	reduction)�
WAIT_OBJECT_0�WAIT_ABANDONED_0�WAIT_TIMEOUT�INFINITE�win32i g4@�AF_INET�AF_UNIX�AF_PIPEc

Cst�
�|S�
N��time�	monotonic)
�timeout�r�0/usr/lib/python3.8/multiprocessing/connection.py�
_init_timeout;s
rc

Cst�
�|kSrr)
�
trrr�_check_timeout>s
rc

CsX|d
krdS|dkr&tj
dt��d�S|dkrLtj
dt��tt�
fdd�Std	�
�
d
S)z?
    Return an arbitrary free address for the given family
    r)Z	localhostrrz	listener-)�prefix�dirrz\\.\pipe\pyc-%d-%d-�zunrecognized familyN)	�tempfileZmktemprZget_temp_dir�os�getpid�next�
_mmap_counter�
ValueError�
�familyrrr�arbitrary_addressEs





�
�r(c

CsJtj
d
kr|dkrtd|�
�
tj
d
krF|dkrFtt|�sFtd|�
�
dS)zD
    Checks if the family is valid for the current environment.
    rrzFamily %s is not recognized.rN)�sys�platformr%�hasattr�socketr&rrr�_validate_familySs



r-c

CsJt|�
t
krd
St|�
tkr*|�d�
r*dSt|�
tkr:dStd|�
�
dS)z]
    Return the types of the address

    This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'
    rz\\rrzaddress type of %r unrecognizedN)�type�tuple�str�
startswithr%)
�addressrrr�address_type_s




r3c@s�eZ
dZd
Zd+dd�
Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	e
dd��
Ze
dd��
Ze
dd��
Z
dd�Zdd�Zd,dd�
Zdd�Zd-dd�
Zd.d d!�
Zd"d#�Zd/d%d&�
Zd'd(�Zd)d*�Zd
S)0�_ConnectionBaseNTcCs>|
��}
|
d
krt
d�
�
|s(|s(t
d�
�
|
|_||_||_dS)Nrzinvalid handlez6at least one of `readable` and `writable` must be True)�	__index__r%�_handle�	_readable�	_writable)�self�handle�readable�writablerrr�__init__us





�

z_ConnectionBase.__init__c

Cs|jdk	r|�
�
dSr�r6�_close�
r9rrr�__del__�s


z_ConnectionBase.__del__c

Cs|jdkrt
d
�
�
dS)Nzhandle is closed)r6�OSErrorr@rrr�
_check_closed�s


z_ConnectionBase._check_closedc

Cs|jst
d
�
�
dS)Nzconnection is write-only)r7rBr@rrr�_check_readable�s

z_ConnectionBase._check_readablec

Cs|jst
d
�
�
dS)Nzconnection is read-only)r8rBr@rrr�_check_writable�s

z_ConnectionBase._check_writablec

Cs"|jrd
|_
n|��
td�
�
dS)NFzbad message length)r8r7�closerBr@rrr�_bad_message_length�s


z#_ConnectionBase._bad_message_lengthc

Cs
|jd
kS)z True if the connection is closedN�
r6r@rrr�closed�sz_ConnectionBase.closedc


Cs|jS)
z"True if the connection is readable)
r7r@rrrr;�sz_ConnectionBase.readablec


Cs|jS)
z"True if the connection is writable)
r8r@rrrr<�sz_ConnectionBase.writablec

Cs|��
|j
S)
z+File descriptor or handle of the connection)rCr6r@rrr�fileno�s
z_ConnectionBase.filenoc

Cs$|jd
k	r z|�
�
W5d
|_Xd
S)zClose the connectionNr>r@rrrrF�s


z_ConnectionBase.closercCs�|��
|�
�
t|
�
}|jd
kr.tt|�
�
}t|�
}|dkrFtd�
�
||krVtd�
�
|dkrh||}n&|dkrztd�
�
n|||kr�td�
�
|�||||��

dS)z,Send the bytes data from a bytes-like objectrrzoffset is negativezbuffer length < offsetNzsize is negativezbuffer length < offset + size)rCrE�
memoryview�itemsize�bytes�lenr%�_send_bytes)r9�buf�offset�size�
m�
nrrr�
send_bytes�s"

















z_ConnectionBase.send_bytescCs$|��
|�
�
|�t�|
�
�

d
S)zSend a (picklable) objectN)rCrErO�_ForkingPickler�dumps�r9�objrrr�send�s

z_ConnectionBase.sendcCsJ|��
|�
�
|
d
k	r(|
dkr(td�
�
|�|
�
}|d
krB|��
|��S)z7
        Receive bytes data as a bytes object.
        Nrznegative maxlength)rCrDr%�_recv_bytesrG�getvalue)r9Z	maxlengthrPrrr�
recv_bytes�s







z_ConnectionBase.recv_bytesc
Cs�|��
|�
�
t|
�
��}|j}|t|�
}|d
kr>td�
�
n||krNtd�
�
|��}|��}|||krvt|�	��
�
|�
d
�

|�||||||��

|W5QR�SQRXdS)zq
        Receive bytes data into a writeable bytes-like object.
        Return the number of bytes read.
        rznegative offsetzoffset too largeN)rCrDrKrLrNr%r[�tellr	r\�seek�readinto)r9rPrQrSrLZbytesize�resultrRrrr�recv_bytes_into�s$
















�z_ConnectionBase.recv_bytes_intoc
Cs&|��
|�
�
|��}
t�|
���
S)
zReceive a (picklable) object)rCrDr[rV�loads�	getbuffer)r9rPrrr�recv�s


z_ConnectionBase.recv�cCs|��
|�
�
|�|
�
S)
z/Whether there is any input available to be read)rCrD�_poll�r9rrrr�poll�s

z_ConnectionBase.pollc


Cs|Srrr@rrr�	__enter__
s
z_ConnectionBase.__enter__cCs|��
dSr�
rF�r9�exc_type�	exc_valueZexc_tbrrr�__exit__
s
z_ConnectionBase.__exit__)TT)rN)
N)
r)
rf)�__name__�
__module__�__qualname__r6r=rArCrDrErG�propertyrIr;r<rJrFrUrZr]rbrerirjrorrrrr4rs.












r4c@sDeZ
dZd
ZdZejf
dd�
Zdd�Zddd	�
Z	d
d�Z
dd
�ZdS)�PipeConnectionz�
        Connection class based on a Windows named pipe.
        Overlapped I/O is used, so the handles must have been created
        with FILE_FLAG_OVERLAPPED.
        FcCs|
|j�

dSrrH)r9Z_CloseHandlerrrr?
s
zPipeConnection._closec	Cs�tj
|j|
d
d�\}}zHz,|tjkrBt�|jg
dt�}|tksBt	�
Wn


|�
�
�YnXW5|�d
�
\}}X|dks|t	�
|t|
�
ks�t	�
dS)NT�
�
overlappedFr)�_winapiZ	WriteFiler6�GetOverlappedResult�ERROR_IO_PENDING�WaitForMultipleObjects�eventrr�AssertionError�cancelrN)r9rP�ov�errZnwritten�waitresrrrrO
s





�




zPipeConnection._send_bytesNc	Cs2
|jrd
|_t
��S|
dkr dnt|
d�}z�tj|j|dd�\}}dzHz,|tjkrpt�
|jg
d
t�}|tkspt�
Wn


|��
�YnXW5|�d�
\}}|dkr�t
��}|�|�	��

|�

WS|tj
kr�|�||
��

WSX
Wn:tk
�
r$
}
z|jtjk�
rt�
n�W5d}~XYnXtd�
�
dS)NF�Trurz.shouldn't get here; expected KeyboardInterrupt)�_got_empty_message�io�BytesIO�minrw�ReadFiler6rx�writerdZERROR_MORE_DATA�_get_more_dataryrzr{rrr|r}rB�winerror�ERROR_BROKEN_PIPE�EOFError�RuntimeError)	r9�maxsizeZbsizer~rZnread�
fr��
errrr[&
s>






�




�













zPipeConnection._recv_bytescCs.|jst
�|j�
d
d
krdStt|g
|
��
S)NrT)r�rw�
PeekNamedPiper6�boolrrhrrrrgF
s


�
zPipeConnection._pollcCs�|
��}t
��}|�|�

t�|j�
d
}|dks6t�
|dk	rVt|�
||krV|�	�
tj
|j|dd�\}
}|
�d�
\}}|dks�t�
||ks�t�
|�|
���

|S)NrrTru)rdr�r�r�rwr�r6r|rNrGr�rx)r9r~r�rPr��leftrZrbytesrrrr�L
s













zPipeConnection._get_more_data)
N)rprqrr�__doc__r�rw�CloseHandler?rOr[rgr�rrrrrt
s

 rtc@s|eZ
dZd
Zer,ejf
dd�
ZejZ	ej
Znej
f
dd�
ZejZ	ejZe	f
dd�
Zef
dd�
Zd	d
�Zddd
�
Zdd�ZdS)�
Connectionzo
    Connection class based on an arbitrary file descriptor (Unix only), or
    a socket handle (Windows).
    cCs|
|j�

dSrrH�r9r?rrrr?c
s
zConnection._closecCs|
|j�

dSrrHr�rrrr?h
s
cCs8t|
�
}||j
|
�}||8}|d
kr&q4|
|d�}
qdS�Nr)rNr6)r9rPr��	remainingrTrrr�_sendm
s




zConnection._sendcCsbt�
�}|j}|
}|d
kr^|||�}t|�
}|d
krJ||
krBt�
ntd�
�
|�|�

||8}q|S)Nrzgot end of file during message)r�r�r6rNr�rBr�)r9rR�readrPr:r��chunkrTrrr�_recvv
s














zConnection._recvcCs�t|
�
}|d
krHt
�dd�}t
�d|�}|�|�

|�|�

|�|
�

n8t
�d|�}|dkrr|�|�

|�|
�

n|�||
�

dS)Ni����!i������!Qi@)rN�structZpackr�)r9rPrTZ
pre_header�headerrrrrO�
s











zConnection._send_bytesNcCs^|�d
�
}t
�d|���\
}|dkr@|�d�
}t
�d|���\
}|
dk	rT||
krTdS|�|�
S)N�r�r��r�)r�r�Zunpackr\)r9r�rPrRrrrr[�
s









zConnection._recv_bytescCst|g
|
�}t
|�
Sr)rr�)r9r�
rrrrrg�
s

zConnection._poll)
N)rprqrrr�rw�_multiprocessingZclosesocketr?rZZ_writereZ_readr!rFr�r�r�r�rOr[rgrrrrr�\
s



	

r�c@sReZ
dZd
Zddd�
Zdd�Zdd	�Zed
d��
Zedd
��
Z	dd�Z
dd�ZdS)rz�
    Returns a listener object.

    This is a wrapper for a bound socket which is 'listening' for
    connections, or for a Windows named pipe.
    NrcCsp|p|
rt|
�
pt
}|
pt|�
}
t|�

|d
kr>t|
|�|_nt|
||�|_|dk	rft|t�sft	d�
�
||_
dS)Nr�authkey should be a byte string)r3�default_familyr(r-�PipeListener�	_listener�SocketListener�
isinstancerM�	TypeError�_authkey)r9r2r'�backlog�authkeyrrrr=�
s

�


zListener.__init__c
Cs>|jd
krt
d�
�
|j��}
|jr:t|
|j�
t|
|j�
|
S)zz
        Accept a connection on the bound socket or named pipe of `self`.

        Returns a `Connection` object.
        Nzlistener is closed)r�rB�acceptr��deliver_challenge�answer_challenge)r9�
crrrr��
s







zListener.acceptc
Cs |j}
|
d
k	rd
|_|
�
�
d
S)zA
        Close the bound socket or named pipe of `self`.
        N)r�rF)r9ZlistenerrrrrF�
s


zListener.closec


Cs|jj
Sr)r��_addressr@rrrr2�
szListener.addressc


Cs|jj
Sr)r��_last_acceptedr@rrr�
last_accepted�
szListener.last_acceptedc


Cs|Srrr@rrrrj�
s
zListener.__enter__cCs|��
dSrrkrlrrrro�
s
zListener.__exit__)NNrN)rprqrrr�r=r�rFrsr2r�rjrorrrrr�
s

	



cCsh|
p
t|�
}
t
|
�

|
d
kr&t|�
}nt|�
}|dk	rHt|t�sHtd�
�
|dk	rdt||�
t||�
|S)z=
    Returns a connection to the address of a `Listener`
    rNr�)	r3r-�
PipeClient�SocketClientr�rMr�r�r�)r2r'r�r�rrrr
�
s








Tc
Csj|r>t�
�\}
}|
�d
�

|�d
�

t|
���
}t|���
}n$t��\}}t|dd�}t|dd�}||fS)�L
        Returns pair of connection objects at either end of a pipe
        TF�
r<�
r;)r,Z
socketpair�setblockingr��detachr!�pipe)�duplex�s1�s2�c1�c2Zfd1Zfd2rrrrs








c


Cs�td
�
}
|r*t
j}t
jt
jB}tt}}nt
j}t
j}dt}}t
�|
|t
jBt
j	Bt
j
t
jBt
jBd||t
j
t
j�}t
�|
|dt
jt
jt
jt
j�}t
�|t
jdd�
t
j|dd�}|�d�
\}	}
|
dks�t�
t||d�}t||d�}||fS)	r�rrrNTrur�r�)r(rw�PIPE_ACCESS_DUPLEX�GENERIC_READ�
GENERIC_WRITE�BUFSIZEZPIPE_ACCESS_INBOUND�CreateNamedPipe�FILE_FLAG_OVERLAPPED�FILE_FLAG_FIRST_PIPE_INSTANCE�PIPE_TYPE_MESSAGE�PIPE_READMODE_MESSAGE�	PIPE_WAIT�NMPWAIT_WAIT_FOREVER�NULL�
CreateFile�
OPEN_EXISTING�SetNamedPipeHandleState�ConnectNamedPiperxr|rt)
r�r2Zopenmode�accessZobsizeZibsizeZh1Zh2rv�
_rr�r�rrrrsV








�

��	

�
�


c@s*eZ
dZd
Zd
dd�
Zdd�Zdd�Zd	S)r�zO
    Representation of a socket which is bound to an address and listening
    rcCs�t�t
t|��
|_zRtjd
kr2|j�tjtjd�
|j�d�

|j�	|
�

|j�
|�

|j��|_Wn t
k
r�


|j��
�YnX||_d|_|dkr�tj|tj|
f
dd�|_nd|_dS)N�posixrTrr��argsZexitpriority)r,�getattr�_socketr!�nameZ
setsockoptZ
SOL_SOCKETZSO_REUSEADDRr�ZbindZlistenZgetsocknamer�rBrFZ_familyr�r�Finalize�unlink�_unlink)r9r2r'r�rrrr=Gs0





�










�
zSocketListener.__init__c
Cs&|j�
�\}
|_|
�d
�

t|
���
S)NT)r�r�r�r�r�r��r9�
srrrr�_s



zSocketListener.acceptc
Cs0z|j
��
W5|j}
|
dk	r*d|_|
�
XdSr)r�r�rF)r9r�rrrrFds




zSocketListener.closeN)
r)rprqrrr�r=r�rFrrrrr�Cs

r�c

CsPt|�
}
t
�
tt
|
��
�.}|�d
�

|�|�

t|���
W5QR�SQRXdS)zO
    Return a connection object connected to the socket given by `address`
    TN)r3r,r�r�Zconnectr�r�)r2r'r�rrrr�ns






r�c@s8eZ
dZd
Zddd�
Zd
dd�
Zdd	�Zed
d��
ZdS)r�z0
        Representation of a named pipe
        NcCsL|
|_|j
d
d�
g
|_d|_t�d|j�
tj|tj|j|jfdd�|_	dS)NT)
�firstz listener created with address=%rrr�)
r��_new_handle�
_handle_queuer�r�	sub_debugr�r��_finalize_pipe_listenerrF)r9r2r�rrrr=�s






�zPipeListener.__init__Fc
CsHtj
tjB}|
r|tjO}t�|j|tjtjBtjBtj	t
t
tjtj�Sr)
rwr�r�r�r�r�r�r�r�ZPIPE_UNLIMITED_INSTANCESr�r�r�)r9r��flagsrrrr��s








�
�zPipeListener._new_handlec

Cs�|j�
|���

|j�d
�
}
ztj|
dd�}Wn0tk
r^
}
z|jtjkrN�W5d}~XYn\Xz<zt�|jg
dt
�}Wn 


|��
t�|
�

�YnXW5|�	d�
\}}|d
ks�t
�
Xt|
�
S)NrTruF)r��appendr��poprwr�rBr�Z
ERROR_NO_DATArxr|rzr{rr}r�rt)r9r:r~r�r�r�resrrrr��s(








�





zPipeListener.acceptcCs$t�
d
|
�
|D]}t�|�

qdS)Nz closing listener with address=%r)rr�rwr�)Zqueuer2r:rrrr��s

z$PipeListener._finalize_pipe_listener)
N)
F)	rprqrrr�r=r�r��staticmethodr�rrrrr�~s



r�c

Cs�t�}
z6t
�|d
�
t
�|t
jt
jBdt
jt
jt
jt
j�}Wq�t	k
rz
}
z |j
t
jt
jfksht
|
�
rj�W5d}~XYqXq�q�t
�|t
jdd�
t|�
S)zU
        Return a connection object connected to the pipe given by `address`
        ��rN)rrwZ
WaitNamedPiper�r�r�r�r�r�rBr�ZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrr�r�rt)r2r�
hr�rrrr��s8





�

�
�
�r��s#CHALLENGE#s	#WELCOME#s	#FAILURE#cCs�d
dl}t
|
t�s$td�t|
�
�
�
�
t�t�
}|�	t
|�

|�|
|d���}|�
d�
}||krl|�	t�

n|�	t�

td�
�
dS)Nr� Authkey must be bytes, not {0!s}�md5�
zdigest received was wrong)�hmacr�rMr%�formatr.r!�urandom�MESSAGE_LENGTHrU�	CHALLENGE�new�digestr]�WELCOME�FAILUREr�Z
connectionr�r��messager�Zresponserrrr��s




�








r�cCs�d
dl}t
|
t�s$td�t|
�
�
�
�
|�d�
}|dtt�
�tksNt	d|�
�
|tt�
d�}|�
|
|d���}|�|�

|�d�
}|t
kr�td�
�
dS)Nrr�r�zmessage = %rr�zdigest sent was rejected)r�r�rMr%r�r.r]rNr�r|r�r�rUr�rr�rrrr��s




�

 







r�c@s$eZ
dZd
d�Zdd�Zdd�ZdS)�ConnectionWrappercCs6|
|_||_
||_d
D]}t|
|�}t|||�
qdS)N)rJrFrir]rU)�_conn�_dumps�_loadsr��setattr)r9�connrWrc�attrrYrrrr=�s






zConnectionWrapper.__init__cCs|�|
�
}|j
�|�

dSr)r�r�rU)r9rYr�rrrrZs


zConnectionWrapper.sendc
Cs|j�
�}
|�|
�
Sr)r�r]r�r�rrrres


zConnectionWrapper.recvN)rprqrrr=rZrerrrrr��s
r�c

Cst�
|f
dddd
��d�
S)Nr�utf-8)�	xmlrpclibrW�encode)
rYrrr�
_xml_dumpss
r
c
Cst�
|�d
�
�
\\
}
}|
S)Nr
)r
rc�decode)r�rY�methodrrr�
_xml_loadss

r	
c@seZ
dZd
d�ZdS)�XmlListenerc
Cs"d
dlm
a
t�|�
}
t|
tt�Sr�)�
xmlrpc.client�clientr
rr�r�r
r	
rXrrrr�s


zXmlListener.acceptN)rprqrrr�rrrrr

s
r

cOsd
dlm
a
tt||
�
tt�Sr�)r
r
r
r�r
r
r	
)r��kwdsrrr�	XmlClients
r
cCs�t|�
}g}|r�t
�|d
|
�}|tkr*q�n\t|k
rFtt|�
krTn
n
|t8}n2t|k
rptt|�
kr~n
n
|t8}ntd�
�
|�||�

||dd�}d}
q|S)NFzShould not get hererr)	�listrwrzr
rrNrr�r�)Zhandlesr�
L�readyr�rrr�_exhaustive_wait$s





 


 





r
c
s^|
d
krt}
n|
dkrd}
nt
|
dd�
}
t|�
}i�
g}t��t�}�
z@|D�
]&}zt|d�}	Wn tk
r�


|�
|��<YqPXzt	�|	�dd�\}}Wn8tk
r�
}
zd
|j}}|tkrƂW5d
}~XYnX|t	jkr�|�|�

|�
|j<qP|�
rjt��d
d�d	k�
rjz|�d
�
\}}Wn*tk
�
rP
}
z
|j}W5d
}~XYnX|�
sjt
|d��
rjd|_��|�

d}
qPt�
��|
�}W5|D]}|��
�
q�|D]�}z|�d�
\}}Wn6tk
�
r�
}
z|j}|tk�
r��W5d
}~XYnX|t	j
k�
r��
|j}��|�

|dk�
r�t
|d��
r�d|_�
q�X���
f
dd�|D�
�

�f
d
d�|D�
S)��
        Wait till an object in object_list is ready/readable.

        Returns list of those objects in object_list which are ready/readable.
        Nrr�g�?Tr�rJ�)�r
Fc
3s|]}
�|
V
qdSrr)�.0r�)
�waithandle_to_objrr�	<genexpr>�szwait.<locals>.<genexpr>c
sg|]}
|
�kr|
�qSrr)r
�
o)
�
ready_objectsrr�
<listcomp>�s�wait.<locals>.<listcomp>)r�intr
�setr}rxrBr��
_ready_errorsrwZERROR_OPERATION_ABORTEDr{�addr+r�r��AttributeErrorr5r�ryr�r)Zgetwindowsversionr
�keys�update)
�object_listrZov_listZ
ready_handlesr~r�rr�r
rJr)r
r
rr:sh















































�PollSelectorc
Cs�t���}|D]}|�
|tj�
q|
d
k	r4t��|
}|�|
�
}|r\dd�|D�
W5QR�S|
d
k	r4|t��}
|
dkr4|W5QR�Sq4W5QRXd
S)r
Nc
Ssg|]\}
}|
j�qSr)
Zfileobj)r
�keyZeventsrrrr
�sr
r)�
_WaitSelector�register�	selectorsZ
EVENT_READrrZselect)r$
rZselectorrYZdeadliner
rrrr�s








c

CsZ|��}
t
�|
t
jt
j��6}d
dlm}
|�|�
}t||j	|j
ffW5QR�SQRXdS)Nr)
�resource_sharer)rJr,ZfromfdrZSOCK_STREAMrr*
Z	DupSocket�rebuild_connectionr;r<)r

r:r�r*
�dsrrr�reduce_connection�s






r-
cCs|��}t
|��|
|�Sr�r�r�)r,
r;r<Zsockrrrr+
�s

r+
c
CsB|jrt
jnd
|jrt
jnd
B}
t�|��|
�}t||j|jffSr�)	r;rwZFILE_GENERIC_READr<ZFILE_GENERIC_WRITEr
Z	DupHandlerJ�rebuild_pipe_connection)r

r��dhrrr�reduce_pipe_connection�s


�
r1
cCs|��}t
||
|�Sr)r�rt)r0
r;r<r:rrrr/
�s

r/
c
Cs t�
|���
}
t|
|j|jffSr)r
ZDupFdrJr+
r;r<)r

�dfrrrr-
�s

cCs|��}t
||
|�Srr.
)r2
r;r<�fdrrrr+
�s

)NN)
T)
T)
N)
N)I�__all__r�r!r)r,r�rr �	itertoolsr�rrrr	�contextr
ZForkingPicklerrVrwrrr
r�ImportErrorr*r�ZCONNECTION_TIMEOUT�countr$r�Zfamiliesr+rrr(r-r3r4rtr��objectrr
rr�r�r�r�r�r�r�r�r�r�r�r
r	
r

r
r
r�ZERROR_NETNAME_DELETEDr
rr)
r%
r'
ZSelectSelectorr-
r+
r(
r1
r/
rrrr�<module>
s�
























PT=

,+8

	P