ÿØÿà 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�dd
ddgZddl
Z
ddlZddlZddlZddlZddlmZ
ddlm	Z	
dd	l
mZmZ
dd
lm
Z

ddlmZ
ddlmZ
dd
lmZ
dd�Zejeje�
dd�d�D�
Zedek	r�dd�ZxeD]Zejee�
q�WGdd�de�Zfifdd�
Zdd�ZGdd�de�Zdd�Zd d!�ZGd"d#�d#e�ZGd$d%�d%e�Z e	j!e	j"fe	j#e	j$fd&�Z%Gd'd�de�Z&Gd(d)�d)e'�Z(Gd*d�de�Z)d+d,�Z*if
d-d.�
Z+d�d0d1�
Z,Gd2d3�d3e�Z-Gd4d5�d5e�Z.d�d6d7�
Z/Gd8d9�d9e)�Z0Gd:d;�d;e)�Z1Gd<d=�d=e1�Z2Gd>d?�d?e)�Z3Gd@dA�dAe)�Z4GdBdC�dCe)�Z5GdDdE�dEe)�Z6e+dFd��Z7GdZd[�d[e7�Z8e+d\d��Z9d]dei
e9_:e+dfd��Z;e+dgd��Z<dsdsdsdededt�e<_:Gdudg�dge<�Z=Gdvd
�d
e&�Z>e>jdwej?�
e>jdxej?�
e>jdyej@e3�
e>jdzejAe1�
e>jd{ejBe1�
e>jd|ejCe1�
e>jd}ejDe1�
e>jd~ejEe2�
e>jdejFe4�
e>jd�e
jGe=�
e>jd�ee8�
e>jd�eHe9�
e>jd5e.e6�
e>jd7e/e;�
e>jd3e-e5�
e>jdee0d�d��
e>jdsd�d��
dS)��BaseManager�SyncManager�	BaseProxy�Token�N)
�
format_exc�
)
�
connection)�	reduction�get_spawning_popen)
�pool)
�process)
�util)
�get_contextc

Cstj|j
|j�ffS)
N)�array�typecode�tobytes)
�
a�r�./usr/lib/python3.6/multiprocessing/managers.py�reduce_array$s
rc
Csg|]}
tt
i|
���
�qSr)�type�getattr)�.0�namerrr�
<listcomp>(sr�items�keys�valuesc

Cstt|�
f
fS)
N)
�list)
�objrrr�rebuild_as_list*s
r c@s4eZ
dZd
ZdZdd�Zdd�Zd	d
�Zdd�Zd
S)rz4
    Type to uniquely indentify a shared object
    �typeid�address�idcCs|
|||_|_
|_dS)
N)r!r"r#)�selfr!r"r#rrr�__init__9s
zToken.__init__c

Cs|j|j
|jfS)
N)r!r"r#)
r$rrr�__getstate__<s
zToken.__getstate__cCs|
\|_|_
|_dS)
N)r!r"r#)r$�staterrr�__setstate__?s
zToken.__setstate__c

Csd
|jj
|j|j|jfS)Nz %s(typeid=%r, address=%r, id=%r))�	__class__�__name__r!r"r#)
r$rrr�__repr__Bs

zToken.__repr__N)r!r"r#)	r*�
__module__�__qualname__�__doc__�	__slots__r%r&r(r+rrrrr3s
cCs8|j|
|||f�

|j
�\}}|d
kr*|St||��
dS)zL
    Send a message to manager using connection `c` and return response
    z#RETURNN)�send�recv�convert_to_error)�
cr#�
methodname�args�kwds�kind�resultrrr�dispatchJs




r9cCs\|d
kr|
S|dkr,t|
�
t
ks$t�
t|
�
S|dkrPt|
�
t
ksDt�
td|
�
Std�
SdS)Nz#ERRORz
#TRACEBACKz#UNSERIALIZABLEzUnserializable message: %s
zUnrecognized message type)r�str�AssertionError�RemoteError�
ValueError)r7r8rrrr2Ts







r2c@seZ
dZd
d�ZdS)r<c

Cs&d
ddd
t|j
d�
ddS)N�

�
-�Kr)r:r5)
r$rrr�__str__as
zRemoteError.__str__N)r*r,r-rArrrrr<`s
r<c
Cs6g}
x,t|�
D] }t
||�}t|�
r|
j|�

qW|
S)
z4
    Return a list of names of methods of `obj`
    )�dirr�callable�append)r�tempr�funcrrr�all_methodshs





rGc

Csd
d�t|�
D�
S)zP
    Return a list of names of methods of `obj` which do not start with '_'
    c
Ssg|]}
|
dd
kr|
�qS)r�
_r)rrrrrrwsz"public_methods.<locals>.<listcomp>)
rG)
rrrr�public_methodsssrIc	@s�eZ
dZd
Zdddddddd	d
g	Zdd�Zd
d�Zdd�Zdd�Zdd�Z	dd�Z
dd�Zdd�Zeee
d�Z
dd�Zdd�Zd d!�Zd"d#�Zd$d%�Zd&d'�Zd(d)�Zd*d+�Zd,d-�Zd.S)/�ServerzM
    Server class which runs in a process controlled by a manager object
    �shutdown�create�accept_connection�get_methods�
debug_info�number_of_objects�dummy�incref�decrefcCslt|t
�st�
|
|_tj|�
|_t|\}}||d
d�|_|jj	|_	ddffi
|_
i|_i|_t
j�|_dS)N�)r"Zbacklog�
0)�
isinstance�bytesr;�registryr�AuthenticationString�authkey�listener_client�listenerr"�	id_to_obj�id_to_refcount�id_to_local_proxy_obj�	threading�Lock�mutex)r$rXr"rZ�
serializer�Listener�Clientrrrr%�s








zServer.__init__c
Cs�tj
�|_|tj�_zZtj|jd
�
}
d|
_|
j	�
y x|jj
�sN|jjd�

q6WWntt
fk
rj


YnXWdtjtjkr�tjd�

tjt_tjt_tjd�

XdS)z(
        Run the server forever
        )
�targetTrNzresetting stdout, stderrr)r`�Event�
stop_eventr�current_process�_manager_server�Thread�accepter�daemon�start�is_set�wait�KeyboardInterrupt�
SystemExit�sys�stdout�
__stdout__r
�debug�
__stderr__�stderr�exit)r$rlrrr�
serve_forever�s 

















zServer.serve_foreverc
CsPxJy|jj
�}
Wntk
r&


wYnXtj|j|
f
d
�}d|_|j�
qWdS)N)rfr5T)r\Zaccept�OSErrorr`rk�handle_requestrmrn)r$r3�
trrrrl�s







zServer.accepterc'CsL
d
}}}yTtj
|
|j�
tj|
|j�
|
j�}|\}}}}||jksTtd|�
�
t||�}Wntk
r~


dt	�f}	Yn>Xy||
f
|�|�
}Wntk
r�


dt	�f}	Yn
Xd|f}	y|
j
|	�

Wnttk
�
r>
}

zVy|
j
dt	�f�

Wntk
�
r


YnXtjd|	�
tjd|�
tjd|
�
WYd
d
}
~
XnX|
j
�
d
S)z)
        Handle a new connection
        Nz%r unrecognizedz
#TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)rZdeliver_challengerZZanswer_challenger1�publicr;r�	Exceptionrr0r
�info�close)r$r3�funcnamer8�request�ignorer5r6rF�msg�
errrr|�s4





















zServer.handle_requestcDCs�tj
d
tj�j�
|
j}|
j}|j}�x�|jj	��s�
yBd}}|�}|\}}}	}
y||\}}}Wn^t
k
r�
}

zBy|j|\}}}Wn&t
k
r�
}
z
|
�
WYdd}~XnXWYdd}
~
XnX||kr�td|t
|�
|f�
�
t||�}y||	|
�
}Wn,tk
�
r&
}
zd|f}WYdd}~XnPX|�
o8|j|d�}|�
rn|j|
||�\}}t||j|�}d||ff}nd|f}Wn�tk
�
r�


|dk�
r�dt�f}nNy,|j|}|||
||f|	�|
�
}d|f}Wn tk
�
r�


dt�f}YnXYnPtk
�r"


tj
dtj�j�
tjd	�

Yn tk
�r@


dt�f}YnXyDy||�

Wn2tk
�r�
}
z|d
t�f�

WYdd}~XnXWq(tk
�r�
}
zBtjdtj�j�
tjd|�
tjd
|�
|
j�
tjd�

WYdd}~Xq(Xq(WdS)zQ
        Handle requests from the proxies in a particular process/thread
        z$starting server thread to service %rNz+method %r of %r object is not in exposed=%rz#ERRORz#PROXYz#RETURNz
#TRACEBACKz$got EOF -- exiting thread serving %rrz#UNSERIALIZABLEzexception in thread serving %rz ... message was %rz ... exception was %rr)r
rvr`�current_threadrr1r0r]rhro�KeyErrorr_�AttributeErrorrrr�getrLrr"r�fallback_mapping�EOFErrorrsryr�r�)r$�connr1r0r]r4rr��identr5r6�exposed�	gettypeid�keZ	second_keZfunctionZresr�r�r!ZridentZrexposed�tokenZ
fallback_funcr8rrr�serve_client�sx











(



























$






zServer.serve_clientc
Cs|S)
Nr)r$r�r�rrrr�fallback_getvalue&
s
zServer.fallback_getvaluecCst|�
S)
N)
r:)r$r�r�rrrr�fallback_str)
s
zServer.fallback_strcCst|�
S)
N)
�repr)r$r�r�rrrr�
fallback_repr,
s
zServer.fallback_repr)rAr+z	#GETVALUEc
CsdS)
Nr)r$r3rrrrQ5
s
zServer.dummycCs||j�l
g}t
|jj��
}|j�
xD|D]<}|d
kr(|jd||j|t|j|d�
dd�f�

q(Wdj|�
SQRXdS)zO
        Return some info --- useful to spot problems with refcounting
        rUz  %s:       refcount=%s
    %srNr@r>)	rbrr^r�sortrDr:r]�join)r$r3r8rr�rrrrO8
s









$
zServer.debug_infocCs
t|j
�
S)
z*
        Number of shared objects
        )�lenr^)r$r3rrrrPG
szServer.number_of_objectscCsLz:ytj
d
�

|
jd�

Wn


ddl}|j�
YnXWd|jj�
XdS)z'
        Shutdown this process
        z!manager received shutdown message�#RETURNNr)r�N)r
rvr0�	traceback�	print_excrh�set)r$r3r�rrrrKN
s





zServer.shutdowncOs�|j��
|j
|\}}}}|d
krBt|�
dkr4|s8t�
|d}	n
|||�
}	|d
kr\t|	�
}|d
k	r�t|�
tkstt�
t|�
t|�
}dt|	�
}
t	j
d||
�
|	t|�
|f|j|
<|
|j
kr�d|j
|
<Wd
QRX|j|
|
�
|
t|�
fS)z>
        Create a new shared object and return its id
        Nrrz%xz&%r callable returned object with id %r)rbrXr�r;rIr�dictrr#r
rvr�r]r^rR�tuple)r$r3r!r5r6rCr��method_to_typeid�	proxytyperr�rrrrL[
s$











z
Server.createcCst|j
|jd
�
S)zL
        Return the methods of the shared object indicated by token
        r)r�r]r#)r$r3r�rrrrNz
szServer.get_methodscCs"|tj
�_|
jd�

|j|
�

dS)z=
        Spawn a new thread to serve this connection
        �#RETURNN)r�N)r`r�rr0r�)r$r3rrrrrM�
s



zServer.accept_connectioncCs�|j��
y|j
|d
7<Wnhtk
r�
}
zL||jkrrd
|j
|<|j||j|<|j|\}}}tjd|�
n|�
WYdd}~XnXWdQRXdS)Nrz&Server re-enabled tracking & INCREF %r)rbr^r�r_r]r
rv)r$r3r�r�rr�r�rrrrR�
s








z
Server.increfcCs�||jkr$||j
kr$tjd
|�
dS|j�@
|j|dks>t�
|j|d8<|j|dkrf|j|=WdQRX||jkr�dfdf|j|<tjd|�
|j�
|j|=WdQRXdS)NzServer DECREF skipping %rrrzdisposing of obj with id %r)r^r_r
rvrbr;r])r$r3r�rrrrS�
s













z
Server.decrefN)r*r,r-r.r~r%rzrlr|r�r�r�r�r�rQrOrPrKrLrNrMrRrSrrrrrJ}s.


"Q


rJc
@seZ
dZd
g
ZdZdZdZdS)�State�valuerr�N)r*r,r-r/�INITIAL�STARTED�SHUTDOWNrrrrr��
s



r�)�pickleZ	xmlrpclibc@s�eZ
dZd
ZiZeZd!dd�
Zdd�Zdd	�Z	dffd
d�
Z
edffdd
�
�
Zdd�Z
d"dd�
Zdd�Zdd�Zdd�Zdd�Zedd��
Zedd��
Zed#dd �
�
ZdS)$r
z!
    Base class for managers
    Nr�cCs\|dkrtj
�j}|
|_tj|�
|_t�|_tj|j_	||_
t|\|_|_
|pTt�|_dS)
N)rrirZ�_addressrY�_authkeyr��_stater�r��_serializerr[Z	_Listener�_Clientr�_ctx)r$r"rZrcZctxrrrr%�
s









zBaseManager.__init__c

Cs(|jj
tjkst�
t|j|j|j|j	�S)
zX
        Return server object with serve_forever() method and address attribute
        )
r�r�r�r�r;rJ�	_registryr�r�r�)
r$rrr�
get_server�
s


zBaseManager.get_serverc
Cs8t|j
\}
}||j|jd
�}t|dd�
tj|j_dS)z>
        Connect manager object to the server process
        )
rZNrQ)	r[r�r�r�r9r�r�r�r�)r$rdrer�rrr�connect�
s


zBaseManager.connectc	Cs�|jj
tjkst�
|
d
k	r,t|
�
r,td�
�
tjdd�
\}}|j	j
t|�
j|j
|j|j|j||
|fd�|_djdd�|jjD�
�
}t|�
jd	||j_|jj�
|j�
|j�|_|j�
tj|j_
tj|t|�
j|j|j|j|j|jfd
d�|_d
S)z@
        Spawn a server process for this manager object
        Nzinitializer must be a callableF)
Zduplex)rfr5�
:c
ss|]}
t|
�
V
qdS)
N)
r:)r�
irrr�	<genexpr>�
sz$BaseManager.start.<locals>.<genexpr>r?r)r5�exitpriority)r�r�r�r�r;rC�	TypeErrorrZPiper�ZProcessr�_run_serverr�r�r�r��_processr�Z	_identityr*rrnr�r1r�r
�Finalize�_finalize_managerr�rK)r$�initializer�initargs�reader�writerr�rrrrn�
s(

















zBaseManager.startc	CsN|d
k	r||�
|j|
|||�}|j
|j�

|j�
tjd|j�
|j�
d
S)z@
        Create a server, report its address and run it
        Nzmanager serving at %r)�_Serverr0r"r�r
r�rz)	�clsrXr"rZrcr�r�r��serverrrrr�s


zBaseManager._run_servercOsd|jj
tjkstd
�
�
|j|j|jd�}zt|dd|
f
||�\}}Wd|j	�
Xt
|
|j|�|fS)zP
        Create a new shared object; return the token and exposed tuple
        zserver not yet started)
rZNrL)r�r�r�r�r;r�r�r�r9r�r)r$r!r5r6r�r#r�rrr�_create%s




zBaseManager._createcCs*|jd
k	r&|jj
|
�

|jj�s&d
|_d
S)zC
        Join the manager process (if it has been spawned)
        N)r�r��is_alive)r$�timeoutrrrr�1s




zBaseManager.joinc

Cs.|j|j
|jd
�}
zt|
dd�S|
j�
XdS)zS
        Return some info about the servers shared objects and connections
        )
rZNrO)r�r�r�r9r�)r$r�rrr�_debug_info:s

zBaseManager._debug_infoc

Cs.|j|j
|jd
�}
zt|
dd�S|
j�
XdS)z5
        Return the number of shared objects
        )
rZNrP)r�r�r�r9r�)r$r�rrr�_number_of_objectsDs

zBaseManager._number_of_objectsc

Cs,|jj
tjkr|j�
|jj
tjks(t�
|S)
N)r�r�r�r�rnr�r;)
r$rrr�	__enter__Ns



zBaseManager.__enter__c
Cs|j�
dS)
N)
rK)r$�exc_type�exc_val�exc_tbrrr�__exit__Ts
zBaseManager.__exit__cCs�|j�r�t
jd
�

y,||
|d�}zt|dd�
Wd|j�
XWntk
rR


YnX|jdd�

|j�r�t
jd�

t|d�r�t
jd	�

|j�
|jd
d�

|j�r�t
jd�

t	j
|_ytj
|
=Wntk
r�


YnXdS)zQ
        Shutdown the manager process; will be registered as a finalizer
        z#sending shutdown message to manager)
rZNrKg�?)
r�zmanager still alive�	terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r�r
r�r9r�rr��hasattrr�r�r�r�r�_address_to_localr�)rr"rZr'r�r�rrrr�Ws.























zBaseManager._finalize_managerc


Cs|jS)
N)
r�)
r$rrr�<lambda>wszBaseManager.<lambda>Tc
s�d
|jkr|j
j�|_
�dkr"t�|p0t�dd�}|p@t�dd�}|r�xHt|j��
D]8\}}t|�
tkstt	d|�
�
t|�
tksTt	d|�
�
qTW|||�f|j
�
<|rƇ�
fdd�}	�
|	_
t|�
|	�
dS)z9
        Register a typeid with the manager type
        r�N�	_exposed_�_method_to_typeid_z%r is not a stringc
s`tj
d
�
�
|j�
f
|
�|�
\}}�||j||j|d�}|j|j|jd�}t|dd|jf
�
|S)Nz)requesting creation of a shared %r object)�managerrZr�)
rZrS)	r
rvr�r�r�r�r"r9r#)r$r5r6r�Zexp�proxyr�)r�r!rrrE�s






z"BaseManager.register.<locals>.temp)�__dict__r��copy�	AutoProxyrrrrr:r;r*�setattr)
r�r!rCr�r�r��
create_method�keyr�rEr)r�r!r�registerys 









zBaseManager.register)NNr�N)
N)NNNNT)r*r,r-r.r�rJr�r%r�r�rn�classmethodr�r�r�r�r�r�r��staticmethodr��propertyr"r�rrrrr
�
s*



	$
	

 

c@seZ
dZd
d�Zdd�ZdS)�ProcessLocalSetc

Cstj
|d
d��
dS)Nc


Ss|j�S)
N)
�clear)
rrrrr��sz*ProcessLocalSet.__init__.<locals>.<lambda>)r
�register_after_fork)
r$rrrr%�s
zProcessLocalSet.__init__c

Cst|�
ffS)
N)
r)
r$rrr�
__reduce__�s
zProcessLocalSet.__reduce__N)r*r,r-r%r�rrrrr��s
r�c@s�eZ
dZd
ZiZej�Zddd�
Zdd�Z	fifd	d
�
Z
dd�Zd
d�Ze
dd��
Zdd�Zdd�Zdd�Zdd�Zdd�ZdS)rz.
    A base for proxies of shared objects
    NTFc	
Cs�tj
�8
tjj|
jd�}|dkr:tj�t�f}|tj|
j<WdQRX|d
|_|d|_	|
|_
|j
j|_||_
||_t|d|_||_|dk	r�tj|�
|_n"|j
dk	r�|j
j|_ntj�j|_|r�|j�
tj|tj�
dS)Nrr)r�_mutexr�r�r"r
ZForkAwareLocalr��_tls�_idset�_tokenr#�_id�_managerr�r[r��_owned_by_managerrrYr�rirZ�_increfr��_after_fork)	r$r�rcr�rZr�rR�
manager_ownedZ	tls_idsetrrrr%�s*















zBaseProxy.__init__c
Csdtj
d
�

tj�j}
tj�jdkr4|
dtj�j7}
|j|jj	|j
d�}t|dd|
f
�
||j_
dS)Nzmaking connection to managerZ
MainThread�
|)
rZrM)r
rvrrirr`r�r�r�r"r�r9r�r)r$rr�rrr�_connect�s








zBaseProxy._connectcCs�y|jj
}Wn6tk
rB


tjd
tj�j�
|j�
|jj
}YnX|j	|j
|
||f�

|j�\}}|dkrp|S|dkr�|\}}|jj
|jd	}	|jj|_|	||j|j|j|d�}
|j|j|jd�}t|dd|jf
�
|
St||��
dS)
zW
        Try to call a method of the referrent and return a copy of the result
        z#thread %r does not own a connectionz#RETURNz#PROXYr)r�rZr�)
rZNrS�����)r�rr�r
rvr`r�rr�r0r�r1r�r�r!r�r"r�r�r�r9r#r2)r$r4r5r6r�r7r8r�r�r�r�rrr�_callmethod�s,



















zBaseProxy._callmethodc

Cs
|jd
�
S)z9
        Get a copy of the value of the referent
        z	#GETVALUE)
r�)
r$rrr�	_getvalueszBaseProxy._getvaluec
	Cs�|jrt
jd
|jj�
dS|j|jj|jd�}
t|
dd|j	f
�
t
jd|jj�
|j
j|j	�

|joj|jj
}t
j|tj|j|j||j|j
|jfdd�|_dS)Nz%owned_by_manager skipped INCREF of %r)
rZrRz	INCREF %r�
)r5r�)r�r
rvr�r#r�r"r�r9r�r��addr�r�r�r�_decrefr�Z_close)r$r�r'rrrr�s









zBaseProxy._increfcCs�|j|j
�

|dks |jtjkr�y2tjd
|j
�
||j|
d�}t|dd|j
f
�
Wq�t	k
r�
}
ztjd|�
WYdd}~Xq�Xntjd|j
�
|r�t
|d�r�tjdtj�j
�
|jj�
|`dS)Nz	DECREF %r)
rZrSz... decref failed %sz%DECREF %r -- manager already shutdownrz-thread %r has no more proxies so closing conn)�discardr#r�r�r�r
rvr"r9rr�r`r�rrr�)r�rZr'ZtlsZidsetr�r�r�rrrr� s




 




zBaseProxy._decrefc
CsHd|_y|j
�
Wn0tk
rB
}

ztjd
|
�

WYdd}
~
XnXdS)Nzincref failed: %s)r�r�rr
r�)r$r�rrrr�9s




zBaseProxy._after_forkc
Cs^i}
t�dk	r|j
|
d
<t|dd�rB|j|
d<tt|j|j|
ffStt|�
|j|j|
ffSdS)NrZ�_isautoFr�)	r
r�rr��RebuildProxyr�r�r�r)r$r6rrrr�As









zBaseProxy.__reduce__c
Cs|j�S)
N)
r�)r$�memorrr�__deepcopy__Ns
zBaseProxy.__deepcopy__c

Csd
t|�
j
|jjt|�
fS)Nz<%s object, typeid %r at %#x>)rr*r�r!r#)
r$rrrr+Qs

zBaseProxy.__repr__c

Cs4y
|jd
�
St
k
r.


t|�
dd�dSXdS)zV
        Return representation of the referent (or a fall-back if that fails)
        r+Nrz; '__str__()' failed>r�)r�rr�)
r$rrrrAUs



zBaseProxy.__str__)NNNTF)r*r,r-r.r�r
ZForkAwareThreadLockr�r%r�r�r�r�r�r�r�r�r�r+rArrrrr�s



(	
cCs�tt
j�d
d�}|rT|j|
jkrTtjd|
�
d|d<|
j|jkrT|j|
j|j|
j<|j	dd�optt
j�dd�}||
|fd|i
|��
S)	z5
    Function used for unpickling proxy objects.
    rjNz*Rebuild a proxy owned by manager, token=%rTr�rRZ_inheritingF)
rrrir"r
rvr#r_r]�pop)rFr�rcr6r�rRrrrr�bs




r�c
Csrt|
�
}
y|||
fSt
k
r(


YnXi}x|
D]}td
||f|�
q4Wt|tf
|�}|
|_||||
f<|S)zB
    Return a proxy type whose methods are given by `exposed`
    zLdef %s(self, *args, **kwds):
        return self._callmethod(%r, args, kwds))r�r��execrrr�)rr��_cacheZdic�meth�	ProxyTyperrr�
MakeProxyTypews









r
Tc
Cs�t|
d
}|dkrB||j
|d�}zt|dd|f
�}Wd|j�
X|dkrX|dk	rX|j}|dkrjtj�j}td|j	|�}|||
|||d�}	d|	_
|	S)z*
    Return an auto-proxy for `token`
    rN)
rZrNz
AutoProxy[%s])r�rZrRT)r[r"r9r�r�rrirZr
r!r�)
r�rcr�rZr�rRr�r�r�r�rrrr��s












r�c@seZ
dZd
d�Zdd�ZdS)�	Namespacec
Ks|jj
|
�

dS)
N)r��update)r$r6rrrr%�s
zNamespace.__init__c
Cs^t|j
j��
}
g}x,|
D]$\}}|jd
�
s|jd||f�

qW|j�
d|jjdj|�
fS)NrHz%s=%rz%s(%s)z, )	rr�r�
startswithrDr�r)r*r�)r$rrErr�rrrr+�s







zNamespace.__repr__N)r*r,r-r%r+rrrrr

�s
r

c@s8eZ
dZddd�
Zdd�Zdd�Zdd	�Zeee�Zd
S)�ValueTcCs|
|_||_
dS)
N)�	_typecode�_value)r$rr��lockrrrr%�s

zValue.__init__c


Cs|jS)
N)
r
)
r$rrrr��s
z	Value.getcCs
|
|_dS)
N)
r
)r$r�rrrr��s
z	Value.setc

Csd
t|�
j
|j|jfS)Nz
%s(%r, %r))rr*r
r
)
r$rrrr+�s
zValue.__repr__N)
T)	r*r,r-r%r�r�r+r�r�rrrrr
�s


r
cCstj||
�S)
N)
r)rZsequencer
rrr�Array�s
r
c@s8eZ
dZdZdd�Zdd�Zd	d
�Zdd�Zd
d�ZdS)�
IteratorProxy�__next__r0�throwr�c


Cs|S)
Nr)
r$rrr�__iter__�s
zIteratorProxy.__iter__c
Gs|jd
|
�S)Nr

)
r�)r$r5rrrr

�s
zIteratorProxy.__next__c
Gs|jd
|
�S)Nr0)
r�)r$r5rrrr0�s
zIteratorProxy.sendc
Gs|jd
|
�S)Nr
)
r�)r$r5rrrr
�s
zIteratorProxy.throwc
Gs|jd
|
�S)Nr�)
r�)r$r5rrrr��s
zIteratorProxy.closeN)r

r0r
r�)	r*r,r-r�r
r

r0r
r�rrrrr	
�s

r	
c@s2eZ
dZd
Zddd�
Zdd�Zd	d
�Zdd�ZdS)�
AcquirerProxy�acquire�releaseTNcCs"|dkr|
f
n|
|f}|jd
|�S)Nr
)
r�)r$Zblockingr�r5rrrr
�s

zAcquirerProxy.acquirec

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
�s
zAcquirerProxy.releasec

Cs
|jd
�
S)Nr
)
r�)
r$rrrr��s
zAcquirerProxy.__enter__cCs
|jd
�
S)Nr
)
r�)r$r�r�r�rrrr��s
zAcquirerProxy.__exit__)r
r
)TN)r*r,r-r�r
r
r�r�rrrrr

�s



r

c@s4eZ
dZdZddd�
Zd	d
�Zdd�Zdd
d�
ZdS)�ConditionProxyr
r
rp�notify�
notify_allNcCs|jd
|
f
�S)Nrp)
r�)r$r�rrrrp�s
zConditionProxy.waitc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
�s
zConditionProxy.notifyc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
�s
zConditionProxy.notify_allcCsh|
�}|r|S|dk	r$tj
�|}nd}d}x6|sb|dk	rP|tj
�}|d
k
rPP|j|�

|
�}q.W|S)Nr)�timeZ	monotonicrp)r$Z	predicater�r8ZendtimeZwaittimerrr�wait_for�s















zConditionProxy.wait_for)r
r
rpr
r
)
N)
N)r*r,r-r�rpr
r
r
rrrrr
�s



r
c@s2eZ
dZdZdd�Zdd�Zd	d
�Zddd
�
ZdS)�
EventProxyror�r�rpc

Cs
|jd
�
S)Nro)
r�)
r$rrrro
s
zEventProxy.is_setc

Cs
|jd
�
S)Nr�)
r�)
r$rrrr�s
zEventProxy.setc

Cs
|jd
�
S)Nr�)
r�)
r$rrrr�s
zEventProxy.clearNcCs|jd
|
f
�S)Nrp)
r�)r$r�rrrrps
zEventProxy.wait)ror�r�rp)
N)r*r,r-r�ror�r�rprrrrr
�s


r
c@sNeZ
dZdZddd�
Zdd	�Zd
d�Zedd
��
Zedd��
Z	edd��
Z
dS)�BarrierProxy�__getattribute__rp�abort�resetNcCs|jd
|
f
�S)Nrp)
r�)r$r�rrrrp
s
zBarrierProxy.waitc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
s
zBarrierProxy.abortc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
s
zBarrierProxy.resetc

Cs|jd
d�S)Nr
�parties)
r
)
r�)
r$rrrr
szBarrierProxy.partiesc

Cs|jd
d�S)Nr
�	n_waiting)
r
)
r�)
r$rrrr
szBarrierProxy.n_waitingc

Cs|jd
d�S)Nr
�broken)
r
)
r�)
r$rrrr
szBarrierProxy.broken)r
rpr
r
)
N)r*r,r-r�rpr
r
r�r
r
r
rrrrr
s


r
c@s(eZ
dZdZdd�Zdd�Zdd	�Zd
S)�NamespaceProxyr
�__setattr__�__delattr__cCs0|
d
dkrtj
||
�Stj
|d�}|d|
f
�S)NrrHr�r
)�objectr
)r$r��
callmethodrrr�__getattr__ s



zNamespaceProxy.__getattr__cCs4|
d
dkrtj
||
|�Stj|d�}|d|
|f�S)NrrHr�r
)r 
r
r
)r$r�r�r!
rrrr
%s



zNamespaceProxy.__setattr__cCs0|
d
dkrtj
||
�Stj|d�}|d|
f
�S)NrrHr�r
)r 
r
r
)r$r�r!
rrrr
*s



zNamespaceProxy.__delattr__N)r
r
r
)r*r,r-r�r"
r
r
rrrrr
s

r
c@s*eZ
dZdZdd�Zdd�Zeee�ZdS)	�
ValueProxyr�r�c

Cs
|jd
�
S)Nr�)
r�)
r$rrrr�3s
zValueProxy.getcCs|jd
|
f
�S)Nr�)
r�)r$r�rrrr�5s
zValueProxy.setN)r�r�)r*r,r-r�r�r�r�r�rrrrr#
1s

r#
�
BaseListProxy�__add__�__contains__�__delitem__�__getitem__�__len__�__mul__�__reversed__�__rmul__�__setitem__rD�count�extend�index�insertr��remove�reverser��__imul__c@seZ
dZd
d�Zdd�ZdS)�	ListProxycCs|jd
|
f
�
|S)Nr/
)
r�)r$r�rrr�__iadd__As

zListProxy.__iadd__cCs|jd
|
f
�
|S)Nr4
)
r�)r$r�rrrr4
Ds

zListProxy.__imul__N)r*r,r-r6
r4
rrrrr5
@s
r5
�	DictProxyr
r�r�r��has_key�popitem�
setdefaultr
�Iterator�
ArrayProxy�	PoolProxy�apply�apply_asyncr��imap�imap_unorderedr��map�	map_async�starmap�
starmap_asyncr�ZAsyncResult)r?
rC
rE
r@
rA
c@seZ
dZd
d�Zdd�ZdS)r=
c


Cs|S)
Nr)
r$rrrr�ds
zPoolProxy.__enter__c
Cs|j�
dS)
N)
r�)r$r�r�r�rrrr�fs
zPoolProxy.__exit__N)r*r,r-r�r�rrrrr=
cs
c
@seZ
dZd
ZdS)ra(

    Subclass of `BaseManager` which supports a number of shared object types.

    The types registered are those intended for the synchronization
    of threads, plus `dict`, `list` and `Namespace`.

    The `multiprocessing.Manager()` function creates started instances of
    this class.
    N)r*r,r-r.rrrrrms	�QueueZ
JoinableQueuergra�RLock�	Semaphore�BoundedSemaphore�	Condition�Barrier�Poolrr�F)r�r�)
r�)rrr)NNNT)
T)r%
r&
r'
r(
r)
r*
r+
r,
r-
rDr.
r/
r0
r1
r�r2
r3
r�r4
)r&
r'
r(
r
r)
r-
r�r�r�r8
rrr�r9
r:
r
r)r)
r(
r-
)r>
r?
r�r@
rA
r�rB
rC
rD
rE
r�)I�__all__rsr`rZqueuer
r�r�r�contextr	r
rrr
rrr�Z
view_typesrr Z	view_typer 
rr9r2rr<rGrIrJr�rdreZXmlListenerZ	XmlClientr[r
r�r�rr�r
r�r

r
r
r	
r

r
r
r
r
r#
r$
r5
r7
r�r<
Z
BasePoolProxyr=
rrF
rgrarG
rH
rI
rJ
rK
rL
r�rrrr�<module>s�














;

]
4