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

���^\��@sBdd
dddgZddl
Z
ddlZddlZddlZddlZddlZddlZddlmZ
ddl	m
Z

d	d
lmZ
d	dl
mZmZmZ
d	dlmZ
d	d
lmZ
d	dlmZ
d	dlmZ
zd	dlmZ
dZWnek
r�


dZYnXdd�Ze�eje�
dd�dD�
Zedek	�
r.dd�ZeD]Ze�ee�
�
qGdd�de�Zdifdd�
Z dd�Z!Gd d!�d!e"�Z#d"d#�Z$d$d%�Z%Gd&d'�d'e�Z&Gd(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�Z0d/d0�Z1if
d1d2�
Z2dld3d4�
Z3Gd5d6�d6e�Z4Gd7d8�d8e�Z5dmd9d:�
Z6Gd;d<�d<e0�Z7Gd=d>�d>e0�Z8Gd?d@�d@e8�Z9GdAdB�dBe0�Z:GdCdD�dDe0�Z;GdEdF�dFe0�Z<GdGdH�dHe0�Z=e2dIdJ�Z>GdKdL�dLe>�Z?e2dMdN�Z@dOdPi
e@_Ae2dQdR�ZBe2dSdT�ZCdUdUdUdPdPdV�eC_AGdWdS�dSeC�ZDGdXd
�d
e-�ZEeE�dYejF�
eE�dZejF�
eE�d[ejGe:�
eE�d\ejHe8�
eE�d]ejIe8�
eE�d^ejJe8�
eE�d_ejKe8�
eE�d`ejLe9�
eE�daejMe;�
eE�dbejNeD�
eE�dcee?�
eE�ddeOe@�
eE�d8e5e=�
eE�d:e6eB�
eE�d6e4e<�
eEjdPe7dde�
eEjdUddf�
e�r>Gdgdh�dh�ZPGdidj�dje&�ZQGdkd�de-�ZRdS)n�BaseManager�SyncManager�	BaseProxy�Token�SharedMemoryManager�N)
�getpid)
�
format_exc�
)
�
connection)�	reduction�get_spawning_popen�ProcessError)
�pool)
�process)
�util)
�get_context)
�
shared_memoryTFc

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

Cstt|�
f
fSr)
�list�
�objrrr�rebuild_as_list3s
r'c@s4eZ
dZd
ZdZdd�Zdd�Zdd�Zd	d
�ZdS)rz4
    Type to uniquely indentify a shared object
    ��typeid�address�idcCs|
|||_|_
|_dSrr()�selfr)r*r+rrr�__init__Bs
zToken.__init__c

Cs|j|j
|jfSrr(�
r,rrr�__getstate__Es
zToken.__getstate__cCs|
\|_|_
|_dSrr(�r,�staterrr�__setstate__Hs
zToken.__setstate__c

Csd
|jj
|j|j|jfS)Nz %s(typeid=%r, address=%r, id=%r))�	__class__�__name__r)r*r+r.rrr�__repr__Ks

�zToken.__repr__N)	r4�
__module__�__qualname__�__doc__�	__slots__r-r/r2r5rrrrr<s
rcCs8|�|
|||f�

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




rDcCsd|d
kr|
S|dkrRt|
t
�s4td�|
|t|
�
��
�
|dkrHtd|
�
St|
�
Sntd�|�
�
SdS)N�#ERROR)�
#TRACEBACK�#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrGzUnserializable message: %s
zUnrecognized message type {!r})�
isinstance�str�	TypeError�formatr�RemoteError�
ValueError)rBrCrrrr=]s







��

r=c@seZ
dZd
d�ZdS)rLc

Csd
t|j
d�
dS)NzM
---------------------------------------------------------------------------
rzK---------------------------------------------------------------------------)rIr@r.rrr�__str__ms
zRemoteError.__str__N)r4r6r7rNrrrrrLls
rLc
Cs2g}
t|�
D] }t
||�}t|�
r|
�|�

q|
S)
z4
    Return a list of names of methods of `obj`
    )�dirr�callable�append)r&�tempr�funcrrr�all_methodsts





rTc

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�
_rrrrrr �sz"public_methods.<locals>.<listcomp>)
rTr%rrr�public_methodssrVc	@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&e_d'd(�Zd)d*�Zd+d,�Zd-d.�Zd/S)0�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�decrefcCsxt|t
�std
�|t|�
��
�
|
|_t�|�
|_t	|\}}||dd�|_
|j
j|_ddi
|_i|_
i|_t��|_dS)Nz&Authkey {0!r} is type {1!s}, not bytes�)r*Zbacklog�
0�Nr)rH�bytesrJrKr�registryr�AuthenticationString�authkey�listener_client�listenerr*�	id_to_obj�id_to_refcount�id_to_local_proxy_obj�	threading�Lock�mutex)r,rer*rg�
serializer�Listener�Clientrrrr-�s 




��







zServer.__init__c
	Cs�t�
�|_|t��_zVtj|jd�
}
d|
_|
��
z|j��sL|j�d�

q4Wnttfk
rf


YnXW5tjtjkr�t	�
d
�

tjt_tjt_t�
d�

XdS)z(
        Run the server forever
        zresetting stdout, stderrr)
�targetTr	N)rm�Event�
stop_eventr�current_process�_manager_server�sys�stdout�
__stdout__r�debug�
__stderr__�stderr�exit�Thread�accepter�daemon�start�is_set�wait�KeyboardInterrupt�
SystemExit)r,r�rrr�
serve_forever�s 


















zServer.serve_foreverc
CsNz|j�
�}
Wntk
r&


YqYnXtj|j|
f
d
�}d|_|��
qdS)N�rsr@T)riZaccept�OSErrorrmr�handle_requestr�r�)r,r>�
trrrr��s






zServer.acceptercCsL
d
}}}zTt�
|
|j�
t�|
|j�
|
��}|\}}}}||jksTtd|�
�
t||�}Wntk
r~


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


dt	�f}	Yn
Xd|f}	z|
�
|	�

Wnttk
�
r>
}

zTz|
�
dt	�f�

Wntk
�
r


YnXt�d|	�
t�d|�
t�d|
�
W5d
}
~
XYnX|
�
�
d
S)z)
        Handle a new connection
        Nz%r unrecognizedrFr:zFailure to send message: %rz ... request was %r� ... exception was %r)r
Zdeliver_challengergZanswer_challenger<�public�AssertionErrorr�	Exceptionrr;r�info�close)r,r>�funcnamerC�request�ignorer@rArS�msg�
errrr��s4





















zServer.handle_requestc
Cs�t�
d
t��j�
|
j}|
j}|j}|j�	��s�
zBd}}|�}|\}}}	}
z||\}}}Wn^t
k
r�
}

z@z|j|\}}}Wn&t
k
r�
}
z|
�
W5d}~XYnXW5d}
~
XYnX||kr�td|t
|�
|f�
�
t||�}z||	|
�
}Wn,tk
�
r"
}
zd|f}W5d}~XYnPX|�
o4|�|d�}|�
rj|�|
||�\}}t||j|�}d||ff}nd|f}Wn�tk
�
r�


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


dt�f}YnXYnPtk
�r


t�
dt��j�
t�d	�

Yn tk
�r<


dt�f}YnXzDz||�

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

W5d}~XYnXWq$tk
�r�
}
z@t�dt��j�
t�d|�
t�d
|�
|
��
t�d�

W5d}~XYq$Xq$dS)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=%rrE�#PROXYr:rFz$got EOF -- exiting thread serving %rrrGzexception in thread serving %rz ... message was %rr�r	)rr{rm�current_threadrr<r;rjrur��KeyErrorrl�AttributeErrorrrr��getrYrr*r�fallback_mapping�EOFErrorrxr~r�r�)r,�connr<r;rjr?r&r��identr@rA�exposed�	gettypeid�keZ	second_keZfunction�resr�r�r)ZridentZrexposed�tokenZ
fallback_funcrCrrr�serve_client�s�
�








�
(


��














�
�
�



�




$


�


zServer.serve_clientc
Cs|Srr�r,r�r�r&rrr�fallback_getvalue5
s
zServer.fallback_getvaluecCst|�
Sr�
rIr�rrr�fallback_str8
s
zServer.fallback_strcCst|�
Sr)
�reprr�rrr�
fallback_repr;
s
zServer.fallback_repr)rNr5�	#GETVALUEc
CsdSrr�r,r>rrrr^D
s
zServer.dummyc
Cs�|j�t
g}t
|j���
}|��
|D]<}|d
kr&|�d||j|t|j|d�
dd�f�

q&d�|�
W5QR�SQRXdS)zO
        Return some info --- useful to spot problems with refcounting
        rbz  %s:       refcount=%s
    %srN�K�

)	ror$rkr"�sortrQrIrj�join)r,r>rCr"r�rrrr\G
s








��zServer.debug_infocCs
t|j
�
S)
z*
        Number of shared objects
        )�lenrkr�rrrr]W
szServer.number_of_objectscCsLz:zt�d
�

|
�d�

Wn


ddl}|��
YnXW5|j�
�
XdS)z'
        Shutdown this process
        z!manager received shutdown message�r:NrN)ru�setrr{r;�	traceback�	print_exc)r,r>r�rrrrX^
s





zServer.shutdownc	Os�
t|�
d
kr|^}}}}n�|s(t
d�
�
n�d|
krDt
dt|�
d�
�
|
�d�
}t|�
dkr~|^}}}ddl}|jd	tdd
�
nFd|
kr�t
dt|�
d�
�
|
�d�
}|^
}}ddl}|jdtdd
�
t|�
}|j��
|j|\}}}}	|dk�
r|
�
st|�
dk�
rt	d
�
�
|d}
n
|||
�
}
|dk�
r2t
|
�
}|dk	�
rlt|t��
s\t
d�
|t|�
��
�
t|�
t|�
}dt|
�
}t�d||�
|
t|�
|f|j|<||jk�
r�d|j|<W5QRX|�||�
|t|�
fS)z>
        Create a new shared object and return its id
        �z8descriptor 'create' of 'Server' object needs an argumentr)�7create expected at least 2 positional arguments, got %dr	�rNz2Passing 'typeid' as keyword argument is deprecated)
�
stacklevelr>z-Passing 'c' as keyword argument is deprecatedz4Without callable, must have one non-keyword argumentz,Method_to_typeid {0!r}: type {1!s}, not dictz%xz&%r callable returned object with id %r)r�rJ�pop�warnings�warn�DeprecationWarning�tuplerorerMrVrH�dictrKrr$r+rr{r�rjrkr_)r@rAr,r>r)r�rPr��method_to_typeid�	proxytyper&r�rrrrYk
sp






�






�


�




��




�









��


z
Server.createz$($self, c, typeid, /, *args, **kwds)cCst|j
|jd
�
S)zL
        Return the methods of the shared object indicated by token
        r	)r�rjr+)r,r>r�rrrr[�
szServer.get_methodscCs"|t�
�_|
�d
�

|�|
�

dS)z=
        Spawn a new thread to serve this connection
        r�N)rmr�rr;r�)r,r>rrrrrZ�
s



zServer.accept_connectioncCs�|j��
z|j
|d
7<Wnhtk
r�
}
zJ||jkrrd
|j
|<|j||j|<|j|\}}}t�d|�
n|�
W5d}~XYnXW5QRXdS)Nr	z&Server re-enabled tracking & INCREF %r)rorkr�rlrjrr{)r,r>r�r�r&r�r�rrrr_�
s






�
z
Server.increfc	Cs�||jkr$||j
kr$t�d
|�
dS|j�Z
|j|dk
rXtd�||j||j|��
�
|j|d8<|j|dkr�|j|=W5QRX||jkr�d|j|<t�d|�
|j�
|j|=W5QRXdS)NzServer DECREF skipping %rrz+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r	)NrNzdisposing of obj with id %r)rkrlrr{ror�rKrj)r,r>r�rrrr`�
s,


�





��






z
Server.decrefN)r4r6r7r8r�r-r�r�r�r�r�r�r�r�r^r\r]rXrY�__text_signature__r[rZr_r`rrrrrW�s<

�
"Q

�
=rWc
@seZ
dZd
g
ZdZdZdZdS)�State�valuerr	r�N)r4r6r7r9�INITIAL�STARTED�SHUTDOWNrrrrr��
s



r�)�pickleZ	xmlrpclibc@s�eZ
dZd
ZiZeZd"dd�
Zdd�Zdd	�Z	d#dd�
Z
ed$d
d�
�
Zdd�Z
d%dd�
Zdd�Zdd�Zdd�Zdd�Zedd��
Zedd��
Zed&d d!�
�
ZdS)'r
z!
    Base class for managers
    Nr�cCs\|dkrt�
�j}|
|_t�|�
|_t�|_tj|j_	||_
t|\|_|_
|pTt�|_dSr)rrvrg�_addressrf�_authkeyr��_stater�r��_serializerrhZ	_Listener�_Clientr�_ctx)r,r*rgrpZctxrrrr-s









zBaseManager.__init__c

Csf|jj
tjkrP|jj
tjkr&td
�
�
n*|jj
tjkr>td�
�
ntd�|jj
�
�
�
t|j	|j
|j|j�S)zX
        Return server object with serve_forever() method and address attribute
        �Already started server�Manager has shut down�Unknown state {!r})
r�r�r�r�r�r
r�rKrW�	_registryr�r�r�r.rrr�
get_servers






�

�zBaseManager.get_serverc
Cs8t|j
\}
}||j|jd
�}t|dd�
tj|j_dS)z>
        Connect manager object to the server process
        �
rgNr^)	rhr�r�r�rDr�r�r�r�)r,rqrrr�rrr�connects


zBaseManager.connectrc	Cs4
|jj
tjkrP|jj
tjkr&td
�
�
n*|jj
tjkr>td�
�
ntd�|jj
�
�
�
|
dk	rht|
�
sht	d�
�
t
jdd�
\}}|jj
t|�
j|j|j|j|j||
|fd�|_d	�d
d�|jjD�
�
}t|�
jd||j_|j��
|��
|��|_|��
tj|j_
tj|t|�
j|j|j|j|j|jfd
d�|_ dS)z@
        Spawn a server process for this manager object
        r�r�r�Nzinitializer must be a callableF)
Zduplexr��
:c
ss|]}
t|
�
V
qdSrr�)r�
irrr�	<genexpr>Asz$BaseManager.start.<locals>.<genexpr>�
-r�r@Zexitpriority)!r�r�r�r�r�r
r�rKrPrJr
ZPiper�ZProcessr�_run_serverr�r�r�r��_processr�Z	_identityr4rr�r�r<r�Finalize�_finalize_managerr�rX)r,�initializer�initargs�reader�writerr�rrrr�(sH






�



��










��zBaseManager.startc	Cs^t�tj
tj�
|d
k	r ||�
|�|
|||�}|�|j�

|��
t�d|j�
|�	�
d
S)z@
        Create a server, report its address and run it
        Nzmanager serving at %r)
�signal�SIGINT�SIG_IGN�_Serverr;r*r�rr�r�)	�clsrer*rgrpr�r�r��serverrrrr�Ss


zBaseManager._run_servercOsd|jj
tjkstd
�
�
|j|j|jd�}zt	|dd|
f
||�\}}W5|��
Xt
|
|j|�|fS)zP
        Create a new shared object; return the token and exposed tuple
        zserver not yet startedr�NrY)r�r�r�r�r�r�r�r�r�rDr)r,r)r@rAr�r+r�rrr�_createjs




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

|j��s&d
|_d
S)zC
        Join the manager process (if it has been spawned)
        N)r�r��is_alive�r,�timeoutrrrr�vs




zBaseManager.joinc
Cs2|j|j
|jd
�}
zt|
dd�W�S|
��
XdS)zS
        Return some info about the servers shared objects and connections
        r�Nr\�r�r�r�r�rD�r,r�rrr�_debug_infos

zBaseManager._debug_infoc
Cs2|j|j
|jd
�}
zt|
dd�W�S|
��
XdS)z5
        Return the number of shared objects
        r�Nr]r�r�rrr�_number_of_objects�s

zBaseManager._number_of_objectsc

Csj|jj
tjkr|��
|jj
tjkrf|jj
tjkr<td
�
�
n*|jj
tjkrTtd�
�
ntd�|jj
�
�
�
|S)NzUnable to start serverr�r�)	r�r�r�r�r�r�r
r�rKr.rrr�	__enter__�s









�zBaseManager.__enter__cCs|��
dSr)
rX�r,�exc_typeZexc_valZexc_tbrrr�__exit__�s
zBaseManager.__exit__cCs�|��r�t
�d
�

z,||
|d�}zt|dd�
W5|��
XWntk
rR


YnX|jdd�

|��r�t
�d�

t|d�r�t
�d	�

|��
|jd
d�

|��r�t
�d�

t	j
|_ztj
|
=Wntk
r�


YnXdS)zQ
        Shutdown the manager process; will be registered as a finalizer
        z#sending shutdown message to managerr�NrXg�?)
r�zmanager still alive�	terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r�rr�r�rDr�r��hasattrr�r�r�r�r�_address_to_localr�)rr*rgr1r�r�rrrr��s.























zBaseManager._finalize_managerc


Cs|jSr)
r�r.rrrr*�szBaseManager.addressTc
s�d
|jkr|j
��|_
�dkr"t�|p0t�dd�}|p@t�dd�}|r�t|���
D]8\}}t|�
tksrt	d|�
�
t|�
tksRt	d|�
�
qR|||�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`t�
d
�
�
|j�
f
|
�|�
\}}�||j||j|d�}|j|j|jd�}t|dd|jf
�
|S)Nz)requesting creation of a shared %r object��managerrgr�r�r`)	rr{r�r�r�r�r*rDr+)r,r@rAr�Zexp�proxyr��r�r)rrrR�s




�

z"BaseManager.register.<locals>.temp)�__dict__r��copy�	AutoProxyrr$r!rrIr�r4�setattr)
r�r)rPr�r�r��
create_method�keyr�rRrr�r�register�s*




�


�



zBaseManager.register)NNr�N)Nr)Nr)
N)NNNNT)r4r6r7r8r�rWr�r-r�r�r��classmethodr�r�r�r�r�r�r��staticmethodr��propertyr*r
rrrrr
�
s8


�
	
+�
	








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

Cst�
|d
d��
dS)Nc

Ss|��Sr)
�clearr%rrr�<lambda>��z*ProcessLocalSet.__init__.<locals>.<lambda>)r�register_after_forkr.rrrr-�s
zProcessLocalSet.__init__c

Cst|�
d
fSrc)
rr.rrr�
__reduce__�s
zProcessLocalSet.__reduce__N)r4r6r7r-r
rrrrr	
�s
r	
c@s�eZ
dZd
ZiZe��Zddd�
Zdd�Z	d	ifd
d�
Z
dd
�Zdd�Ze
dd��
Zdd�Zdd�Zdd�Zdd�Zdd�ZdS)rz.
    A base for proxies of shared objects
    NTFc		Cs�tj
�8
tj�|
jd�}|dkr:t��t�f}|tj|
j<W5QRX|d
|_|d|_	|
|_
|j
j|_||_
||_t|d|_||_|dk	r�t�|�
|_n"|j
dk	r�|j
j|_nt��j|_|r�|��
t�|tj�
dS)Nrr	)r�_mutexr�r�r*rZForkAwareLocalr	
�_tls�_idset�_tokenr+�_id�_managerr�rhr��_owned_by_managerrrfr�rvrg�_increfr

�_after_fork)	r,r�rpr�rgr�r_�
manager_ownedZ	tls_idsetrrrr-s*















zBaseProxy.__init__c
Csdt�
d
�

t��j}
t��jdkr4|
dt��j7}
|j|jj	|j
d�}t|dd|
f
�
||j_
dS)Nzmaking connection to managerZ
MainThread�
|r�rZ)rr{rrvrrmr�r�r
r*r�rDr
r
)r,rr�rrr�_connect-s








zBaseProxy._connectrcCs�z|jj
}Wn6tk
rB


t�d
t��j�
|��
|jj
}YnX|�	|j
|
||f�

|��\}}|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 connectionr:r������r�r�Nr`)r
r
r�rr{rmr�rr
r;r
r<r
r�r)r
r*r�r�r�rDr+r=)r,r?r@rAr�rBrCr�r�r�r�rrr�_callmethod6s6



�










�


zBaseProxy._callmethodc

Cs
|�d
�
S)z9
        Get a copy of the value of the referent
        r��
r
r.rrr�	_getvalueTszBaseProxy._getvaluec
	Cs�|jrt
�d
|jj�
dS|j|jj|jd�}
t|
dd|j	f
�
t
�d|jj�
|j
�|j	�

|joj|jj
}t
j|tj|j|j||j|j
|jfdd�|_dS)Nz%owned_by_manager skipped INCREF of %rr�r_z	INCREF %r�
r�)r
rr{r
r+r�r*r�rDr
r
�addr
r�r�r�_decrefr
Z_close)r,r�r1rrrr
Zs$








��zBaseProxy._increfc
Cs�|�|j
�

|dks |jtjkr�z2t�d
|j
�
||j|
d�}t|dd|j
f
�
Wq�t	k
r�
}
zt�d|�
W5d}~XYq�Xnt�d|j
�
|s�t
|d�r�t�dt��j
�
|j��
|`dS)Nz	DECREF %rr�r`z... decref failed %sz%DECREF %r -- manager already shutdownr
z-thread %r has no more proxies so closing conn)�discardr+r�r�r�rr{r*rDr�r�rmr�rr
r�)r�rgr1ZtlsZidsetr�r�r�rrrr!
ns




 

�

zBaseProxy._decrefc

CsHd|_z|�
�
Wn0tk
rB
}

zt�d
|
�

W5d}
~
XYnXdS)Nzincref failed: %s)r
r
r�rr�)r,r�rrrr
�s



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

r
r�r�r,rArrrr
�s








�
�zBaseProxy.__reduce__cCs|��Sr)
r
)r,Zmemorrr�__deepcopy__�s
zBaseProxy.__deepcopy__c

Csd
t|�
j
|jjt|�
fS)Nz<%s object, typeid %r at %#x>)rr4r
r)r+r.rrrr5�s

�zBaseProxy.__repr__c

Cs:z|�d
�
WSt
k
r4


t|�
dd�dYSXdS)zV
        Return representation of the referent (or a fall-back if that fails)
        r5Nr
z; '__str__()' failed>)r
r�r�r.rrrrN�s


zBaseProxy.__str__)NNNTF)r4r6r7r8r�rZForkAwareThreadLockr
r-r
r
r
r
r
r!
r
r
r&
r5rNrrrrr�s(


�
)	


cCs�tt
��d
d�}|rT|j|
jkrTt�d|
�
d|d<|
j|jkrT|j|
j|j|
j<|�	dd�optt
��dd�}||
|fd|i
|��
S)	z5
    Function used for unpickling proxy objects.
    rwNz*Rebuild a proxy owned by manager, token=%rTr
r_Z_inheritingF)
rrrvr*rr{r+rlrjr�)rSr�rprAr�r_rrrr$
�s




�

�r$
cCspt|
�
}
z|||
fWSt
k
r*


YnXi}|
D]}td
||f|�
q4t|tf
|�}|
|_||||
f<|S)zB
    Return a proxy type whose methods are given by `exposed`
    zOdef %s(self, /, *args, **kwds):
        return self._callmethod(%r, args, kwds))r�r��execrrr�)rr��_cacheZdicZmeth�	ProxyTyperrr�
MakeProxyType�s 





�
�


r*
c
Cs�t|
d
}|dkrB||j
|d�}zt|dd|f
�}W5|��
X|dkrX|dk	rX|j}|dkrjt��j}td|j	|�}|||
|||d�}	d|	_
|	S)z*
    Return an auto-proxy for `token`
    r	Nr�r[z
AutoProxy[%s])r�rgr_T)rhr*r�rDr�rrvrgr*
r)r#
)
r�rpr�rgr�r_r�r�r)
r�rrrr

�s 










�
r

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

Ks|j�
|
�

dSr)r��updater%
rrrr-�s
zNamespace.__init__c
CsZt|j
���
}
g}|
D]$\}}|�d
�
s|�d||f�

q|��
d|jjd�|�
fS)NrUz%s=%rz%s(%s)z, )	r$r�r!�
startswithrQr�r3r4r�)r,r!rRrr�rrrr5�s







zNamespace.__repr__N)r4r6r7r-r5rrrrr+
�s
r+
c@s8eZ
dZddd�
Zdd�Zdd�Zdd	�Zeee�Zd
S)�ValueTcCs|
|_||_
dSr)�	_typecode�_value)r,rr��lockrrrr-s

zValue.__init__c


Cs|jSr�
r0
r.rrrr�s
z	Value.getcCs
|
|_dSrr2
�r,r�rrrr�
s
z	Value.setc

Csd
t|�
j
|j|jfS)Nz
%s(%r, %r))rr4r/
r0
r.rrrr5s
zValue.__repr__N)
T)	r4r6r7r-r�r�r5r
r�rrrrr.
s


r.
cCst�||
�Sr)
r)r�sequencer1
rrr�Arrays
r5
c@s8eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�ZdS)
�
IteratorProxy)�__next__r;�throwr�c


Cs|Srrr.rrr�__iter__s
zIteratorProxy.__iter__c
Gs|�d
|
�S)Nr7
r
�r,r@rrrr7
s
zIteratorProxy.__next__c
Gs|�d
|
�S)Nr;r
r:
rrrr;s
zIteratorProxy.sendc
Gs|�d
|
�S)Nr8
r
r:
rrrr8
s
zIteratorProxy.throwc
Gs|�d
|
�S)Nr�r
r:
rrrr�!s
zIteratorProxy.closeN)	r4r6r7r�r9
r7
r;r8
r�rrrrr6
s

r6
c@s2eZ
dZd
Zddd�
Zdd�Zdd	�Zd
d�ZdS)
�
AcquirerProxy)�acquire�releaseTNcCs"|dkr|
f
n|
|f}|�d
|�S�Nr<
r
)r,Zblockingr�r@rrrr<
's

zAcquirerProxy.acquirec

Cs
|�d
�
S�Nr=
r
r.rrrr=
*s
zAcquirerProxy.releasec

Cs
|�d
�
Sr>
r
r.rrrr�,s
zAcquirerProxy.__enter__cCs
|�d
�
Sr?
r
r�rrrr�.s
zAcquirerProxy.__exit__)TN)r4r6r7r�r<
r=
r�r�rrrrr;
%s



r;
c@s6eZ
dZd
Zddd�
Zd
dd�
Zdd	�Zdd
d�
ZdS)�ConditionProxy)r<
r=
r��notify�
notify_allNcCs|�d
|
f
�S�Nr�r
r�rrrr�4s
zConditionProxy.waitr	cCs|�d
|
f
�S)NrA
r
)r,�
nrrrrA
6s
zConditionProxy.notifyc

Cs
|�d
�
S)NrB
r
r.rrrrB
8s
zConditionProxy.notify_allcCsd|
�}|r|S|dk	r$t�
�|}nd}d}|s`|dk	rN|t�
�}|d
k
rNq`|�|�

|
�}q,|S)Nr)�time�	monotonicr�)r,Z	predicater�rCZendtimeZwaittimerrr�wait_for:s














zConditionProxy.wait_for)
N)
r	)
N)r4r6r7r�r�rA
rB
rG
rrrrr@
2s




r@
c@s2eZ
dZd
Zdd�Zdd�Zdd�Zdd	d
�
ZdS)�
EventProxy)r�r�r

r�c

Cs
|�d
�
S)Nr�r
r.rrrr�Os
zEventProxy.is_setc

Cs
|�d
�
S�Nr�r
r.rrrr�Qs
zEventProxy.setc

Cs
|�d
�
S)Nr

r
r.rrrr

Ss
zEventProxy.clearNcCs|�d
|
f
�SrC
r
r�rrrr�Us
zEventProxy.wait)
N)r4r6r7r�r�r�r

r�rrrrrH
Ms


rH
c@sNeZ
dZd
Zddd�
Zdd�Zdd�Zed	d
��
Zedd��
Z	ed
d��
Z
dS)�BarrierProxy)�__getattribute__r��abort�resetNcCs|�d
|
f
�SrC
r
r�rrrr�[s
zBarrierProxy.waitc

Cs
|�d
�
S)NrL
r
r.rrrrL
]s
zBarrierProxy.abortc

Cs
|�d
�
S)NrM
r
r.rrrrM
_s
zBarrierProxy.resetc

Cs|�d
d�S)NrK
)
�partiesr
r.rrrrN
aszBarrierProxy.partiesc

Cs|�d
d�S)NrK
)
�	n_waitingr
r.rrrrO
dszBarrierProxy.n_waitingc

Cs|�d
d�S)NrK
)
�brokenr
r.rrrrP
gszBarrierProxy.broken)
N)r4r6r7r�r�rL
rM
r
rN
rO
rP
rrrrrJ
Ys







rJ
c@s(eZ
dZd
Zdd�Zdd�Zdd�ZdS)	�NamespaceProxy)rK
�__setattr__�__delattr__cCs0|
d
dkrt�
||
�St�
|d�}|d|
f
�S)NrrUr
rK
)�objectrK
�r,r
�
callmethodrrr�__getattr__ns



zNamespaceProxy.__getattr__cCs4|
d
dkrt�
||
|�St�|d�}|d|
|f�S)NrrUr
rR
)rT
rR
rK
)r,r
r�rV
rrrrR
ss



zNamespaceProxy.__setattr__cCs0|
d
dkrt�
||
�St�|d�}|d|
f
�S)NrrUr
rS
)rT
rS
rK
rU
rrrrS
xs



zNamespaceProxy.__delattr__N)r4r6r7r�rW
rR
rS
rrrrrQ
ls

rQ
c@s*eZ
dZd
Zdd�Zdd�Zeee�ZdS)�
ValueProxy)r�r�c

Cs
|�d
�
S)Nr�r
r.rrrr��s
zValueProxy.getcCs|�d
|
f
�SrI
r
r3
rrrr��s
zValueProxy.setN)r4r6r7r�r�r�r
r�rrrrrX
s

rX
�
BaseListProxy)�__add__�__contains__�__delitem__�__getitem__�__len__�__mul__�__reversed__�__rmul__�__setitem__rQ�count�extend�index�insertr��remove�reverser��__imul__c@seZ
dZd
d�Zdd�ZdS)�	ListProxycCs|�d
|
f
�
|S)Nrd
r
r3
rrr�__iadd__�s

zListProxy.__iadd__cCs|�d
|
f
�
|S)Nri
r
r3
rrrri
�s

zListProxy.__imul__N)r4r6r7rk
ri
rrrrrj
�s
rj
�	DictProxy)r[
r\
r]
r9
r^
rb
r

r
r�r!r"r��popitem�
setdefaultr,
r#r9
�Iterator�
ArrayProxy)r^
r]
rb
�	PoolProxy)Zapply�apply_asyncr��imap�imap_unorderedr��map�	map_async�starmap�
starmap_asyncr�ZAsyncResult)rr
rv
rx
rs
rt
c@seZ
dZd
d�Zdd�ZdS)rq
c


Cs|Srrr.rrrr��s
zPoolProxy.__enter__cCs|��
dSr)
r�r�rrrr��s
zPoolProxy.__exit__N)r4r6r7r�r�rrrrrq
�s
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)r4r6r7r8rrrrr�s
�QueueZ
JoinableQueuertrn�RLock�	Semaphore�BoundedSemaphore�	Condition�Barrier�Poolr$r�)r�r
)
r
c@sLeZ
dZd
Zgf
dd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dS)�_SharedMemoryTrackerz+Manages one or more shared memory segments.cCs|
|_||_
dSr�Zshared_memory_context_name�
segment_names)r,rr�
rrrr-�s

z_SharedMemoryTracker.__init__cCs(t�
d
|
�dt����

|j�|
�

dS)z6Adds the supplied shared memory block name to tracker.zRegister segment � in pid N)rr{rr�
rQ�r,�segment_namerrr�register_segment�s
z%_SharedMemoryTracker.register_segmentcCsBt�
d
|
�dt����

|j�|
�

t�|
�
}|��
|��
dS)z�Calls unlink() on the shared memory block with the supplied name
            and removes it from the list of blocks being tracked.zDestroy segment r�
N)	rr{rr�
rg
r�SharedMemoryr��unlink)r,r�
Zsegmentrrr�destroy_segment�s





z$_SharedMemoryTracker.destroy_segmentc
Cs"|jd
d
�D]}
|�
|
�

qd
S)z<Calls destroy_segment() on all tracked shared memory blocks.N)r�
r�
r�
rrrr�
�s
z_SharedMemoryTracker.unlinkc

Cs(t�
d
|jj�dt����

|��
dS)NzCall z.__del__ in )rr{r3r4rr�
r.rrr�__del__�s

z_SharedMemoryTracker.__del__c

Cs|j|j
fSrr�
r.rrrr/�s
z!_SharedMemoryTracker.__getstate__cCs|j|
�
dSr)
r-r0rrrr2
s
z!_SharedMemoryTracker.__setstate__N)r4r6r7r8r-r�
r�
r�
r�
r/r2rrrrr�
�s
	r�
c@sReZ
dZejd
ddgZdd�Zdd�Zde_d	d
�Zdd�Z	d
d�Z
dd�ZdS)�SharedMemoryServer�
track_segment�release_segment�
list_segmentsc
OsBtj
|f
|
�|�

td
|j�dt����
|_t�dt����

dS)NZshmm_rUz"SharedMemoryServer started by pid )rWr-r�
r*r�shared_memory_contextrr{)r,r@�kwargsrrrr-
s
�zSharedMemoryServer.__init__cOstt|�
d
kr|d}n4d|
kr(|
d}n"|s6t
d�
�
nt
dt|�
d�
�
ttj|dd�rhtj|
d	<tj||
�
S)
z�Create a new distributed-shared object (not backed by a shared
            memory block) and return its id to be used in a Proxy Object.r�r�r)zDdescriptor 'create' of 'SharedMemoryServer' object needs an argumentr�r	r
Z_shared_memory_proxyr�
)r�rJr�r,rer�
rWrY)r@r�
Ztypeodr)rrrrYs









�


zSharedMemoryServer.createz&($self, c, typeid, /, *args, **kwargs)cCs|j�
�
t�||
�S)
zACall unlink() on all tracked shared memory, terminate the Server.)r�
r�
rWrXr�rrrrX%s

zSharedMemoryServer.shutdowncCs|j�
|�

d
S)z?Adds the supplied shared memory block name to Server's tracker.N)r�
r�
�r,r>r�
rrrr�
*sz SharedMemoryServer.track_segmentcCs|j�
|�

d
S)z�Calls unlink() on the shared memory block with the supplied name
            and removes it from the tracker instance inside the Server.N)r�
r�
r�
rrrr�
.sz"SharedMemoryServer.release_segmentc
Cs|jj
S)
zbReturns a list of names of shared memory blocks that the Server
            is currently tracking.)r�
r�
r�rrrr�
3sz SharedMemoryServer.list_segmentsN)r4r6r7rWr�r-rYr�rXr�
r�
r�
rrrrr�
s
�r�
c@s<eZ
dZd
ZeZdd�Zdd�Zdd�Zdd	�Z	d
d�Z
dS)
ra�
Like SyncManager but uses SharedMemoryServer instead of Server.

        It provides methods for creating and returning SharedMemory instances
        and for creating a list-like object (ShareableList) backed by shared
        memory.  It also provides methods that create and return Proxy Objects
        that support synchronization across processes (i.e. multi-process-safe
        locks and semaphores).
        c
OsNtj
d
krddlm}
|��
tj|f
|
�|�

t�|j	j
�dt����

dS)N�posixr	)
�resource_trackerz created by pid )�osr�r�
Zensure_runningr
r-rr{r3r4r)r,r@r�
r�
rrrr-Es





zSharedMemoryManager.__init__c

Cst�
|jj�d
t����

dS)Nz.__del__ by pid )rr{r3r4rr.rrrr�
Qs

zSharedMemoryManager.__del__c

Csh|jj
tjkrP|jj
tjkr&td
�
�
n*|jj
tjkr>td�
�
ntd�|jj
�
�
�
|�|j	|j
|j|j�S)z@Better than monkeypatching for now; merge into Server ultimatelyz"Already started SharedMemoryServerz!SharedMemoryManager has shut downr�)
r�r�r�r�r�r
r�rKr�r�r�r�r�r.rrrr�Us






�
�zSharedMemoryManager.get_servercCsx|j|j
|jd
��\}tjdd|
d�}zt|dd|jf
�
Wn.tk
rh
}
z|��
|�
W5d}~XYnXW5QRX|S)zoReturns a new SharedMemory instance with the specified size in
            bytes, to be tracked by the manager.r�NT)rY�sizer�
)	r�r�r�rr�
rDr�
BaseExceptionr�
)r,r�
r�Zsmsr�rrrr�
bs





 
z SharedMemoryManager.SharedMemorycCsv|j|j
|jd
��Z}t�|
�
}zt|dd|jjf
�
Wn0tk
rf
}
z|j�	�
|�
W5d}~XYnXW5QRX|S)z�Returns a new ShareableList instance populated with the values
            from the input sequence, to be tracked by the manager.r�Nr�
)
r�r�r�r�
ShareableListrDZshmrr�
r�
)r,r4
r�Zslr�rrrr�
ns







 
z!SharedMemoryManager.ShareableListN)r4r6r7r8r�
r�r-r�
r�r�
r�
rrrrr9s
	
)NNNT)
T)S�__all__rxrmr�rZqueuerE
r�
rr�rr�
r
�contextrrr
rrrrrZ	HAS_SHMEM�ImportErrorrr
Z
view_typesr$r'Z	view_typerT
rrDr=r�rLrTrVrWr�rqrrZXmlListenerZ	XmlClientrhr
r�r	
rr$
r*
r

r+
r.
r5
r6
r;
r@
rH
rJ
rQ
rX
rY
rj
rl
r�rp
Z
BasePoolProxyrq
rry
rtrnrz
r{
r|
r}
r~
r
r�r�
r�
rrrrr�<module>s�
�






















c


�	w
4
�


	
	
�





�








�








%4