ÿØÿà 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�x�@sdd
ddgZddl
Z
ddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
mZ
ddl
mZm
Z

dd	lmZ
ejZy$ddlZdd
lmZmZmZmZ
Wn$ek
r�


ejdkr‚dZYnXdZd
Zej�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�ZEejFe'eD�
dIdJ�ZGdKdL�ZHejFe&eG�
ndMdF�ZDdNdH�ZEejFe'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tj
�|S)
N)�time�	monotonic)
�timeout�r�0/usr/lib/python3.6/multiprocessing/connection.py�
_init_timeout;s
rc

Cstj
�|kS)
N)rr)
�
trrr�_check_timeout>s
rc

CsX|d
krdS|dkr&tj
dtj�d�S|dkrLtj
dtj�tt�
fd	d�Std
�
�
dS)
z?
    Return an arbitrary free address for the given family
    r�	localhostrrz	listener-)�prefix�dirrz\\.\pipe\pyc-%d-%d-�zunrecognized familyN)rr)	�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�socket)
r%rrr�_validate_familySs



r+c

CsJt|�
t
krd
St|�
tkr*|jd�
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




r1c@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�_ConnectionBaseNTcCsB|
j�}
|
d
krt
d�
�
|r,|r,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|j
�
dS)
N)r4�_close)
r7rrr�__del__�s


z_ConnectionBase.__del__c

Cs|jdkrt
d
�
�
dS)Nzhandle is closed)r4�OSError)
r7rrr�
_check_closed�s


z_ConnectionBase._check_closedc

Cs|jst
d
�
�
dS)Nzconnection is write-only)r5r>)
r7rrr�_check_readable�s

z_ConnectionBase._check_readablec

Cs|jst
d
�
�
dS)Nzconnection is read-only)r6r>)
r7rrr�_check_writable�s

z_ConnectionBase._check_writablec

Cs"|jrd
|_
n|j�
td�
�
dS)NFzbad message length)r6r5�closer>)
r7rrr�_bad_message_length�s


z#_ConnectionBase._bad_message_lengthc

Cs
|jd
kS)z True if the connection is closedN)
r4)
r7rrr�closed�sz_ConnectionBase.closedc


Cs|jS)
z"True if the connection is readable)
r5)
r7rrrr9�sz_ConnectionBase.readablec


Cs|jS)
z"True if the connection is writable)
r6)
r7rrrr:�sz_ConnectionBase.writablec


Cs|j�
|j
S)
z+File descriptor or handle of the connection)r?r4)
r7rrr�fileno�s
z_ConnectionBase.filenoc

Cs$|jd
k	r z|j
�
Wd
d
|_Xd
S)zClose the connectionN)r4r<)
r7rrrrB�s


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

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

















z_ConnectionBase.send_bytescCs$|j�
|j
�
|jtj|
�
�

d
S)zSend a (picklable) objectN)r?rArJ�_ForkingPickler�dumps)r7�objrrr�send�s

z_ConnectionBase.sendcCsJ|j�
|j
�
|
d
k	r(|
dkr(td�
�
|j|
�
}|d
krB|j�
|j�S)z7
        Receive bytes data as a bytes object.
        Nrznegative maxlength)r?r@r$�_recv_bytesrC�getvalue)r7Z	maxlengthrKrrr�
recv_bytes�s







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

|j||||||��

|SQRXdS)zq
        Receive bytes data into a writeable bytes-like object.
        Return the number of bytes read.
        rznegative offsetzoffset too largeN)r?r@rFrGrIr$rU�tellr	rV�seek�readinto)r7rKrLrNrGZbytesize�resultrMrrr�recv_bytes_into�s"
















z_ConnectionBase.recv_bytes_intoc
Cs&|j�
|j
�
|j�}
tj|
j��
S)
zReceive a (picklable) object)r?r@rUrQ�loads�	getbuffer)r7rKrrr�recv�s


z_ConnectionBase.recv�cCs|j�
|j
�
|j|
�
S)
z/Whether there is any input available to be read)r?r@�_poll)r7rrrr�poll�s

z_ConnectionBase.pollc


Cs|S)
Nr)
r7rrr�	__enter__
s
z_ConnectionBase.__enter__c
Cs|j�
dS)
N)
rB)r7�exc_type�	exc_value�exc_tbrrr�__exit__
s
z_ConnectionBase.__exit__)TT)rN)
N)
r)
r`)�__name__�
__module__�__qualname__r4r;r=r?r@rArC�propertyrDr9r:rErBrPrTrWr\r_rbrcrgrrrrr2rs(






r2c@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�

dS)
N)
r4)r7Z_CloseHandlerrrr<
s
zPipeConnection._closecCs�tj
|j|
d
d�\}}zHy,|tjkrBtj|jg
dt�}|tksBt�
Wn


|j	�
�YnXWd|j
d
�
\}}X|dks|t�
|t|
�
ks�t�
dS)NT)
�
overlappedFr)�_winapiZ	WriteFiler4�ERROR_IO_PENDING�WaitForMultipleObjects�eventrr�AssertionError�cancel�GetOverlappedResultrI)r7rK�ov�err�waitresZnwrittenrrrrJ
s











zPipeConnection._send_bytesNc	Cs
|jrd
|_t
j�S|
dkr dnt|
d�}y�tj|j|dd�\}}zHy,|tjkrntj|j	g
d
t
�}|tksnt�
Wn


|j
�
�YnXWd|jd�
\}}|dkr�t
j�}|j|j��

|S|tjkr�|j||
�SXWn:tk
�
r
}
z|jtjk�r�t�
n�WYdd}~XnXtd�
�
dS)NF�T)
rmrz.shouldn't get here; expected KeyboardInterrupt)�_got_empty_message�io�BytesIO�minrn�ReadFiler4rorprqrrrrrsrt�writer^ZERROR_MORE_DATA�_get_more_datar>�winerror�ERROR_BROKEN_PIPE�EOFError�RuntimeError)	r7�maxsizeZbsizerurvrwZnread�
f�
errrrU&
s6


























zPipeConnection._recv_bytescCs.|jst
j|j�
d
d
krdStt|g
|
��
S)NrT)ryrn�
PeekNamedPiper4�boolr)r7rrrrraF
s



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

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

|S)NrrT)
rm)r^rzr{r~rnr�r4rrrIrCr}rt)r7rur�rKr��leftrvZrbytesrrrrL
s













zPipeConnection._get_more_data)
N)rhrirj�__doc__ryrn�CloseHandler<rJrUrarrrrrrl
s

 rlc@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�

dS)
N)
r4)r7r<rrrr<c
s
zConnection._closecCs|
|j�

dS)
N)
r4)r7r<rrrr<h
s
cCs<t|
�
}x.||j
|
�}||8}|d
kr(P|
|d�}
q
WdS)Nr)rIr4)r7rKr~�	remainingrOrrr�_sendm
s






zConnection._sendcCsftj
�}|j}|
}xN|d
kr`|||�}t|�
}|d
krL||
krDt�
ntd�
�
|j|�

||8}qW|S)Nrzgot end of file during message)rzr{r4rIr�r>r~)r7rM�readrKr8r��chunkrOrrr�_recvv
s














zConnection._recvcCsDt|
�
}t
jd
|�}|dkr2|j|�

|j|
�

n|j||
�

dS)Nz!ii@)rI�structZpackr�)r7rKrO�headerrrrrJ�
s



zConnection._send_bytesNcCs:|jd
�
}t
jd|j��\
}|
dk	r0||
kr0dS|j|�
S)N�z!i)r�r�ZunpackrV)r7r�rKrMrrrrU�
s






zConnection._recv_bytescCst|g
|
�}t
|�
S)
N)rr�)r7r�
rrrrra�
s

zConnection._poll)
N)rhrirjr�rn�_multiprocessingZclosesocketr<rTZ_writer_Z_readr rBr~r�r�r�rJrUrarrrrr�\
s


	
r�c@sReZ
dZd
Zddd�
Zdd�Zdd	�Zed
d��
Zedd��
Z	d
d�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.
    NrcCsr|p|
rt|
�
pt
}|
pt|�
}
t|�

|d
kr>t|
|�|_nt|
||�|_|dk	rht|t�rht	d�
�
||_
dS)Nrzauthkey should be a byte string)r1�default_familyr&r+�PipeListener�	_listener�SocketListener�
isinstancerH�	TypeError�_authkey)r7r0r%�backlog�authkeyrrrr;�
s





zListener.__init__c
Cs>|jd
krt
d�
�
|jj�}
|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�r>�acceptr��deliver_challenge�answer_challenge)r7�
crrrr��
s





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


zListener.closec


Cs|jj
S)
N)r��_address)
r7rrr�<lambda>�
szListener.<lambda>c


Cs|jj
S)
N)r��_last_accepted)
r7rrrr��
sc


Cs|S)
Nr)
r7rrrrc�
s
zListener.__enter__c
Cs|j�
dS)
N)
rB)r7rdrerfrrrrg�
s
zListener.__exit__)NNrN)rhrirjr�r;r�rBrkr0Z
last_acceptedrcrgrrrrr�
s

	
cCsj|
p
t|�
}
t
|
�

|
d
kr&t|�
}nt|�
}|dk	rJt|t�rJtd�
�
|dk	rft||�
t||�
|S)z=
    Returns a connection to the address of a `Listener`
    rNzauthkey should be a byte string)	r1r+�
PipeClient�SocketClientr�rHr�r�r�)r0r%r�r�rrrr
�
s








Tc
Csj|r>tj
�\}
}|
jd
�

|jd
�

t|
j��
}t|j��
}n$tj�\}}t|dd�}t|dd�}||fS)zL
        Returns pair of connection objects at either end of a pipe
        TF)
r:)
r9)r*Z
socketpair�setblockingr��detachr �pipe)�duplex�s1�s2�c1�c2Zfd1Zfd2rrrr�
s








c

	Cs�td
�
}
|r*t
j}t
jt
jB}tt}}nt
j}t
j}dt}}t
j|
|t
jBt
j	Bt
j
t
jBt
jBd||t
j
t
j�}t
j|
|dt
jt
jt
jt
j�}t
j|t
jdd�
t
j|dd�}|jd�
\}	}
|
dks�t�
t||d�}t||d�}||fS)	zL
        Returns pair of connection objects at either end of a pipe
        rrrNT)
rm)
r:)
r9)r&rn�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�ConnectNamedPipertrrrl)
r�r0Zopenmode�accessZobsizeZibsizeZh1Zh2rm�
_rvr�r�rrrrs4




















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�tjt
t|��
|_yRtjd
kr2|jjtjtjd�
|jjd�

|jj	|
�

|jj
|�

|jj�|_Wn t
k
r�


|jj�
�YnX||_d|_|dkr�tj|tj|
f
dd�|_nd|_dS)N�posixrTrr)�args�exitpriority)r*�getattr�_socketr �nameZ
setsockoptZ
SOL_SOCKETZSO_REUSEADDRr�ZbindZlistenZgetsocknamer�r>rBZ_familyr�r�Finalize�unlink�_unlink)r7r0r%r�rrrr;8s$


















zSocketListener.__init__c
Cs&|jj
�\}
|_|
jd
�

t|
j��
S)NT)r�r�r�r�r�r�)r7�
srrrr�Ps



zSocketListener.acceptc
Cs0z|jj
�
Wd|j}
|
dk	r*d|_|
�
XdS)
N)r�rBr�)r7r�rrrrBUs




zSocketListener.closeN)
r)rhrirjr�r;r�rBrrrrr�4s

r�c
	CsDt|�
}
t
j
tt
|
��
�"}|jd
�

|j|�

t|j��
SQRXdS)zO
    Return a connection object connected to the socket given by `address`
    TN)r1r*r�r�Zconnectr�r�)r0r%r�rrrr�_s






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|_tjd|j�
tj|tj|j|jfdd�|_	dS)NT)
�firstz listener created with address=%rr)r�r�)
r��_new_handle�
_handle_queuer�r�	sub_debugr�r��_finalize_pipe_listenerrB)r7r0r�rrrr;ss





zPipeListener.__init__Fc	CsHtj
tjB}|
r|tjO}tj|j|tjtjBtjBtj	t
t
tjtj�S)
N)
rnr�r�r�r�r�r�r�r�ZPIPE_UNLIMITED_INSTANCESr�r�r�)r7r��flagsrrrr�~s










zPipeListener._new_handlec
Cs�|jj
|j��

|jjd
�
}
ytj|
dd�}Wn0tk
r^
}
z|jtjkrN�WYdd}~Xn\Xz<ytj	|j
g
dt�}Wn 


|j�
tj
|
�

�YnXWd|jd�
\}}|d
ks�t�
Xt|
�
S)NrT)
rmF)r��appendr��poprnr�r>r�Z
ERROR_NO_DATArprqrrsr�rtrrrl)r7r8rur��resr�rvrrrr��s"















zPipeListener.acceptcCs(tj
d
|
�
x|D]}tj|�

qWdS)Nz closing listener with address=%r)rr�rnr�)Zqueuer0r8rrrr��s


z$PipeListener._finalize_pipe_listener)
N)
F)	rhrirjr�r;r�r��staticmethodr�rrrrr�os



r�c
Cs�t�}
x~y6t
j|d
�
t
j|t
jt
jBdt
jt
jt
jt
j�}Wn>t	k
r|
}
z"|j
t
jt
jfksjt
|
�
rl�WYdd}~XqXPqW�t
j|t
jdd�
t|�
S)zU
        Return a connection object connected to the pipe given by `address`
        i�rN)rrnZ
WaitNamedPiper�r�r�r�r�r�r>r�ZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrr�r�rl)r0r�
hr�rrrr��s"











r��s#CHALLENGE#s	#WELCOME#s	#FAILURE#cCstd
dl}t
|
t�st�
tjt�
}|jt|�

|j	|
|d�j
�}|jd�
}||kr^|jt�

n|jt
�

td�
�
dS)Nr�md5�
zdigest received was wrong)�hmacr�rHrrr �urandom�MESSAGE_LENGTHrP�	CHALLENGE�new�digestrW�WELCOME�FAILUREr)�
connectionr�r��messager��responserrrr��s











r�cCs�d
dl}t
|
t�st�
|jd�
}|dtt�
�tks@td|�
�
|tt�
d�}|j|
|d�j�}|j	|�

|jd�
}|t
kr�td�
�
dS)Nrr�zmessage = %rr�zdigest sent was rejected)r�r�rHrrrWrIr�r�r�rPr�r)r�r�r�r�r�r�rrrr��s




 







r�c@s$eZ
dZd
d�Zdd�Zdd�ZdS)�ConnectionWrappercCs:|
|_||_
||_x"dD]}t|
|�}t|||�
qWdS)NrErBrbrWrP)rErBrbrWrP)�_conn�_dumps�_loadsr��setattr)r7�connrRr]�attrrSrrrr;�s







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

dS)
N)r�r�rP)r7rSr�rrrrT�s


zConnectionWrapper.sendc
Cs|jj
�}
|j|
�
S)
N)r�rWr�)r7r�rrrr_�s


zConnectionWrapper.recvN)rhrirjr;rTr_rrrrr��s
r�c

Cstj
|f
dddd
�jd�
S)Nrzutf-8)�	xmlrpclibrR�encode)
rSrrr�
_xml_dumps�s
r�c
Cstj
|jd
�
�
\\
}
}|
S)Nzutf-8)r�r]�decode)r�rS�methodrrr�
_xml_loads�s

r�c@seZ
dZd
d�ZdS)�XmlListenerc
Cs d
dlj
atj|�
}
t|
tt�S)Nr)�
xmlrpc.client�clientr�rr�r�r�r�)r7rSrrrr�s



zXmlListener.acceptN)rhrirjr�rrrrr��s
r�cOsd
dlj
att||
�
tt�S)Nr)r�r�r�r�r
r�r�)r��kwdsrrr�	XmlClients

r�cCs�t|�
}g}x�|r�t
j|d
|
�}|tkr,Pn\t|k
oFtt|�
kn
rV|t8}n2t|k
optt|�
kn
r�|t8}ntd�
�
|j||�

||dd�}d}
qW|S)NFzShould not get hererr)	�listrnrpr
rrIrr�r�)Zhandlesr�
L�readyr�rrr�_exhaustive_waits





 


 





r�c
.sn|
d
krt}
n|
dkrd}
nt
|
dd�
}
t|�
}i�
g}t��t�}�
zH�
x2|D�
](}yt|d�}Wn tk
r�


|�
|j�<YqTXytj|�dd�\}}Wn8t	k
r�
}
zd
|j
}}|tkrʂWYd
d
}~XnX|tjkr�|j
|�

|�
|j<qT|�
rptj�d
d�dk�
rpy|jd	�
\}	}Wn*t	k
�
rT
}
z|j
}WYd
d
}~XnX|�
rpt|d
��
rpd|_�j|�

d}
qTWt�
j�|
�}Wd
x|D]}|j�
�
q�Wx�|D]�}y|jd�
\}	}Wn6t	k
�
r�
}
z|j
}|tk�
r�WYd
d
}~XnX|tjk�
r��
|j}�j|�

|dk�
r�t|d
��
r�d|_�
q�WX�j�
f
dd�|D�
�

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

        Returns list of those objects in object_list which are ready/readable.
        Nri�g�?rET��Fryc
3s|]}
�|
V
qdS)
Nr)�.0r�)
�waithandle_to_objrr�	<genexpr>rszwait.<locals>.<genexpr>c
sg|]}
|
�kr|
�qSrr)r��
o)
�
ready_objectsrr�
<listcomp>sszwait.<locals>.<listcomp>)r�r�)r�intr��setr��AttributeErrorr3rnr}r>r��
_ready_errorsror�rqr'Zgetwindowsversionrtr)ry�addr��keysrsZERROR_OPERATION_ABORTED�update)
�object_listrZov_listZ
ready_handlesr

rErurvr�r�r)r
r�rr'sh
















































�PollSelectorcCs�t��x}x|D]}|j
|tj�
qW|
d
k	r8tj�|
}x@|j|
�
}|rVdd�|D�
S|
d
k	r:|tj�}
|
dkr:|Sq:WWd
QRXd
S)z�
        Wait till an object in object_list is ready/readable.

        Returns list of those objects in object_list which are ready/readable.
        Nc
Ssg|]\}
}|
j�qSr)
Zfileobj)r��keyZeventsrrrr
�szwait.<locals>.<listcomp>r)�
_WaitSelector�register�	selectorsZ
EVENT_READrrZselect)r
rZselectorrSZdeadliner�rrrr�s










c
CsN|j�}
t
j|
t
jt
j��*}d
dlm}
|j|�
}t||j	|j
ffSQRXdS)Nr)
�resource_sharer)rEr*ZfromfdrZSOCK_STREAMrr
Z	DupSocket�rebuild_connectionr9r:)r�r8r�r
�dsrrr�reduce_connection�s






r
cCs|j�}t
|j�|
|�S)
N)r�r�)r
r9r:Zsockrrrr
�s

r
c
CsB|jrt
jnd
|jrt
jnd
B}
tj|j�|
�}t||j|jffS)Nr)	r9rnZFILE_GENERIC_READr:ZFILE_GENERIC_WRITEr
Z	DupHandlerE�rebuild_pipe_connection)r�r��dhrrr�reduce_pipe_connection�s



r
cCs|j�}t
||
|�S)
N)r�rl)r
r9r:r8rrrr
�s

r
c
Cs tj
|j��
}
t|
|j|jffS)
N)r
ZDupFdrEr
r9r:)r��dfrrrr
�s

cCs|j�}t
||
|�S)
N)r�r�)r
r9r:�fdrrrr
�s

)NN)
T)
T)
N)
N)I�__all__rzr r'r*r�rr�	itertoolsr�rrrr	�contextr
ZForkingPicklerrQrnrrr
r�ImportErrorr(r�ZCONNECTION_TIMEOUT�countr#r�Zfamiliesr)rrr&r+r1r2rlr��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
r
r
rrrr�<module>
s�
























PJ8

,+8


	P