ÿØÿà 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ÿÙ
�
��dc@s�dd
ddgZddl
Z
ddlZddlZddlZddlZddlZddlmZ
ddl	m
Z
mZmZm
Z
mZmZ
ddlmZ
dd	lmZmZmZmZ
dd
lmZmZ
yddlmZ
Wn!ek
r



ddlmZ
n
Xd�Zejeje�
gd
ddfD]Z e!e"ie ���
^qD
Z#de$f
d��YZ%fid�Z&d�Z'de(f
d��YZ)d�Z*d�Z+de$f
d��YZ,de$f
d��YZ-iej.ej/fd6ej0ej1fd6Z2de$f
d��YZ3de4f
d��YZ5de$f
d ��YZ6d!�Z7id"�
Z8e9e9e9e:d#�Z;d$e$f
d%��YZ<d&e$f
d'��YZ=e:d(�
Z>d)e6f
d*��YZ?d+e6f
d,��YZ@d-e@f
d.��YZAd/e6f
d0��YZBd1e6f
d2��YZCd3e6f
d4��YZDe8d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKf�ZEdLeEf
dM��YZFe8dNd7d8d:dOd<d@dPdQdRdSd
ddGdTdUdVdf�ZGi
dWdO6eG_He8dXd<d:d@d;dAf�ZIe8dYdZd[d\d]d^d_d`dadbf	�ZJidcd[6dcda6dWd]6dWd^6eJ_Hd
e3f
dd��YZKeKjdeej�
eKjdfej�
eKjdgejLeB�
eKjdhejMe@�
eKjdiejNe@�
eKjdjejOe@�
eKjdkejPe@�
eKjdlejQeA�
eKjdme
eJ�
eKjdneReF�
eKjdoeSeG�
eKjd&e=eD�
eKjdpe>eI�
eKjd$e<eC�
eKjdWdqe?dreT�

eKjdcdreT�


dS(stBaseManagertSyncManagert	BaseProxytTokeni����N(
t
format_exc(tProcesstcurrent_processtactive_childrentPooltutilt
connection(
tAuthenticationString(texittPopentassert_spawningtForkingPickler(tFinalizetinfo(
t
PicklingErrorc

Cstj|j
|j�ffS(
N(tarrayttypecodettostring(
t
a((s./usr/lib/python2.7/multiprocessing/managers.pytreduce_array@s
titemstkeystvaluescBs8eZ
dZdZd�Zd�Zd�Zd�ZRS(	s4
    Type to uniquely indentify a shared object
    ttypeidtaddresstidcCs!|
|||_|_
|_dS(
N(RRR(tselfRRR((s./usr/lib/python2.7/multiprocessing/managers.pyt__init__Ps
c

Cs|j|j
|jfS(
N(RRR(
R((s./usr/lib/python2.7/multiprocessing/managers.pyt__getstate__Ss
cCs|
\|_|_
|_dS(
N(RRR(Rtstate((s./usr/lib/python2.7/multiprocessing/managers.pyt__setstate__Vs
c

Csd
|j|j
|jfS(Ns#Token(typeid=%r, address=%r, id=%r)(RRR(
R((s./usr/lib/python2.7/multiprocessing/managers.pyt__repr__Ys

(RRR(t__name__t
__module__t__doc__t	__slots__RR R"R#(((s./usr/lib/python2.7/multiprocessing/managers.pyRJs
			cCsN|j|
|||f�

|j
�\}}|d
kr;|St||��
dS(sL
    Send a message to manager using connection `c` and return response
    s#RETURNN(tsendtrecvtconvert_to_error(t
cRt
methodnametargstkwdstkindtresult((s./usr/lib/python2.7/multiprocessing/managers.pytdispatchas




cCs~|d
kr|
S|dkr>t|
�
t
ks4t�
t|
�
S|dkrpt|
�
t
ksbt�
td|
�
Std�
SdS(Ns#ERRORs
#TRACEBACKs#UNSERIALIZABLEsUnserializable message: %s
sUnrecognized message type(ttypetstrtAssertionErrortRemoteErrort
ValueError(R/R0((s./usr/lib/python2.7/multiprocessing/managers.pyR*ks








R5c
BseZ
d�ZRS(
c

Cs)d
ddd
t|j
d�
ddS(Ns

t
-iKi(R3R-(
R((s./usr/lib/python2.7/multiprocessing/managers.pyt__str__xs
(R$R%R8(((s./usr/lib/python2.7/multiprocessing/managers.pyR5ws
c
CsOg}
xBt|�
D]4}t
||�}t|d
�r|
j|�

qqW|
S(s4
    Return a list of names of methods of `obj`
    t__call__(tdirtgetattrthasattrtappend(tobjttemptnametfunc((s./usr/lib/python2.7/multiprocessing/managers.pytall_methodss




c
Cs-gt|�
D]}
|
d
dkr
|
^q
S(sP
    Return a list of names of methods of `obj` which do not start with '_'
    it
_(
RB(R>R@((s./usr/lib/python2.7/multiprocessing/managers.pytpublic_methods�stServerc	Bs�eZ
dZd
dddddddd	g	Zd
�Zd�Zd�Zd
�Zd�Zd�Z	d�Z
ie	d6e
d6ed6Zd�Zd�Z
d�Zd�Zd�Zd�Zd�Zd�Zd�ZRS(sM
    Server class which runs in a process controlled by a manager object
    tshutdowntcreatetaccept_connectiontget_methodst
debug_infotnumber_of_objectstdummytincreftdecrefcCs�t|t
�st�
|
|_t|�
|_t|\}}|d
|dd�|_|jj|_i
ddfd6|_
i|_tj
�|_d|_dS(NRtbacklogit
0i((t
isinstancetbytesR4tregistryRtauthkeytlistener_clienttlistenerRtNonet	id_to_objtid_to_refcountt	threadingtRLocktmutextstop(RRSRRTt
serializertListenertClient((s./usr/lib/python2.7/multiprocessing/managers.pyR�s

	



	

c
Cs�|t�_
z�ylxey|jj�}
Wnttfk
rD


qn
Xtjd
|jd|
f
�}t	|_
|j�
qWWntt
fk
r�


n
XWdd|_|jj�
XdS(s(
        Run the server forever
        ttargetR-Ni�(Rt_manager_serverRVtaccepttOSErrortIOErrorRZtThreadthandle_requesttTruetdaemontstarttKeyboardInterruptt
SystemExitR]tclose(RR+t
t((s./usr/lib/python2.7/multiprocessing/managers.pyt
serve_forever�s








	


	
cCs
d}}}yvt
j|
|j�
t
j|
|j�
|
j�}|\}}}}||jksttd
|�
�
t||�}Wn t	k
r�


dt
�f}	nFXy||
||�
}Wn t	k
r�


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

Wnqt	k
rp

}

y|
jdt
�f�

Wnt	k
r<



n
Xtj
d|	�
tj
d|�
tj
d|
�
n
X|
j�
dS(s)
        Handle a new connection
        s%r unrecognizeds
#TRACEBACKs#RETURNsFailure to send message: %rs ... request was %rs ... exception was %rN(RWR
tdeliver_challengeRTtanswer_challengeR)tpublicR4R;t	ExceptionRR(R	RRm(RR+tfuncnameR0trequesttignoreR-R.RAtmsgt
e((s./usr/lib/python2.7/multiprocessing/managers.pyRg�s4
























cCs�tj
d
tj�j�
|
j}|
j}|j}x�|js�y
d}}|�}|\}}}	}
||\}}}||kr�t
d|t|�
|f�
�
nt||�}
y|
|	|
�}Wnt
k
r�
}
d|f}npX|o
|j|d�}|rP
|j|
||�\}}t||j|�}d||ff}nd|f}Wn�t
k
r�



|dkr�
dt�f}q?y8|j|}|||
|||	|
�}d|f}Wq?t
k
r�



dt�f}q?XnVtk
r


tj
dtj�j�
tjd�

n t
k
r>


dt�f}n
Xy;y||�

Wn&t
k
rx
}
|d	t�f�

n
XWq7t
k
r�
}
tjd
tj�j�
tjd|�
tjd|�
|
j�
tjd
�

q7Xq7WdS(sQ
        Handle requests from the proxies in a particular process/thread
        s$starting server thread to service %rs+method %r of %r object is not in exposed=%rs#ERRORs#PROXYs#RETURNs
#TRACEBACKs$got EOF -- exiting thread serving %ris#UNSERIALIZABLEsexception in thread serving %rs ... message was %rs ... exception was %ri
N(R	tdebugRZtcurrent_threadR@R)R(RXR]RWtAttributeErrorR2R;RstgetRGRRRtfallback_mappingtEOFErrortsysRRRm(RtconnR)R(RXR,R>RutidentR-R.texposedt	gettypeidtfunctiontresRxRwRtridenttrexposedttokent
fallback_funcR0((s./usr/lib/python2.7/multiprocessing/managers.pytserve_client�sl	
	
	
	


	























	









	





c
Cs|S(
N((RR�R�R>((s./usr/lib/python2.7/multiprocessing/managers.pytfallback_getvalue+
s
cCs
t|�
S(
N(
R3(RR�R�R>((s./usr/lib/python2.7/multiprocessing/managers.pytfallback_str.
s
cCs
t|�
S(
N(
trepr(RR�R�R>((s./usr/lib/python2.7/multiprocessing/managers.pyt
fallback_repr1
s
R8R#s	#GETVALUEc
CsdS(
N((RR+((s./usr/lib/python2.7/multiprocessing/managers.pyRL:
s
cCs�|jj
�
z�g}|jj�}|j�
xS|D]K}|d
kr6|jd||j|t|j|d�
d f�

q6q6Wdj|�
SWd|jj	�
XdS(sO
        Return some info --- useful to spot problems with refcounting
        RPs  %s:       refcount=%s
    %siiKs

N(
R\tacquireRXRtsortR=RYR3tjointrelease(RR+R0RR�((s./usr/lib/python2.7/multiprocessing/managers.pyRJ=
s









	


'
cCst|j
�
d
S(s*
        Number of shared objects
        i
(tlenRX(RR+((s./usr/lib/python2.7/multiprocessing/managers.pyRKO
scCs
z�y�tj
d
�

|
jd	�

tjtjkrZtj
d�

tjt_tjt_ntj	d�

x(t
�D]}tj
d�

|j�
qqWx(t
�D]}tj
d�

|j�
q�Wtj	�
tj
d�

Wn


ddl}|j�
n
XWdtd�

XdS(
s'
        Shutdown this process
        s!manager received shutdown messages#RETURNsresetting stdout, stderris&terminating a child process of managersmanager exiting with exitcode 0i����N(s#RETURNN(R	RyR(RWRtstdoutt
__stdout__t
__stderr__tstderrt_run_finalizersRt	terminateR�Rt	tracebackt	print_excR(RR+t
pR�((s./usr/lib/python2.7/multiprocessing/managers.pyRFU
s*




















cOs\
|jj
�
z:
|j|\}}}}|dkrat|�
d
krN|sTt�
|d}	n|||�}	|dkr�t|	�
}n|dk	r�t|�
tks�t�
t	|�
t	|�
}ndt
|	�
}
tjd||
�
|	t
|�
|f|j|
<|
|jkr&
d|j|
<n|j|
|
�
|
t|�
fSWd|jj�
XdS(s>
        Create a new shared object and return its id
        i
is%xs&%r callable returned object with id %rN(R\R�RSRWR�R4RDR2tdicttlistRR	RytsetRXRYRMttupleR�(RR+RR-R.tcallableR�tmethod_to_typeidt	proxytypeR>R�((s./usr/lib/python2.7/multiprocessing/managers.pyRGu
s(











cCst|j
|jd
�
S(sL
        Return the methods of the shared object indicated by token
        i
(R�RXR(RR+R�((s./usr/lib/python2.7/multiprocessing/managers.pyRI�
scCs-|tj
�_|
jd�

|j|
�

dS(s=
        Spawn a new thread to serve this connection
        s#RETURNN(s#RETURNN(RZRzR@R(RWR�(RR+R@((s./usr/lib/python2.7/multiprocessing/managers.pyRH�
s


cCs9|jj
�
z|j|cd
7<Wd|jj�
XdS(Ni
(R\R�RYR�(RR+R�((s./usr/lib/python2.7/multiprocessing/managers.pyRM�
s



cCs�|jj
�
zj|j|d
ks)t�
|j|cd
8<|j|dkrv|j|=|j|=tjd|�
nWd|jj�
XdS(Ni
isdisposing of obj with id %r(R\R�RYR4RXR	RyR�(RR+R�((s./usr/lib/python2.7/multiprocessing/managers.pyRN�
s







(R$R%R&RrRRoRgR�R�R�R�R}RLRJRKRFRGRIRHRMRN(((s./usr/lib/python2.7/multiprocessing/managers.pyRE�s.

			"	J			



				 	&			tStatec
Bs#eZ
dg
Zd
ZdZdZRS(tvalueii
i(R$R%R'tINITIALtSTARTEDtSHUTDOWN(((s./usr/lib/python2.7/multiprocessing/managers.pyR��
s
	


tpicklet	xmlrpclibcBs�eZ
dZiZeZddd
d�Zd�Zd�Z	d�Z
ddd�Zeddd��
Z
d�Zdd	�
Zd
�Zd�Zd�Zd
�Zed��
Zed��
Zedddded��
ZRS(s!
    Base class for managers
    R�cCsq|dkrt
�j}n|
|_t|�
|_t�|_tj|j_	||_
t|\|_|_
dS(
N(RWRRTt_addressRt_authkeyR�t_stateR�R�t_serializerRUt	_Listenert_Client(RRRTR^((s./usr/lib/python2.7/multiprocessing/managers.pyR�
s


	



	
c

Cs%t|�
j
|j|j|jffS(
N(R2tfrom_addressR�R�R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyt
__reduce__�
s

c

Cs:|jj
tjkst�
t|j|j|j|j	�S(
sX
        Return server object with serve_forever() method and address attribute
        (
R�R�R�R�R4REt	_registryR�R�R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyt
get_server�
s

c
CsNt|j
\}
}||jd
|j�

}t|dd�
tj|j_	dS(s>
        Connect manager object to the server process
        RTRLN(
RUR�R�R�R1RWR�R�R�R�(RR_R`R�((s./usr/lib/python2.7/multiprocessing/managers.pytconnect�
s


cCsg
|jj
tjkst�
|
dk	rFt|
d
�rFtd�
�
ntj	dt
�
\}}tdt|�
j
d|j|j|j|j||
|f�|_djd�|jjD�
�
}t|�
jd||j_|jj�
|j�
|j�|_|j�
tj|j_
tj|t|�
jd|j|j|j|j|jfd	d
�|_dS(s@
        Spawn a server process for this manager object
        R9sinitializer must be a callabletduplexRaR-t
:c
ss|]}
t|
�
V
qdS(
N(
R3(t.0t
i((s./usr/lib/python2.7/multiprocessing/managers.pys	<genexpr>
sR7texitpriorityiN( R�R�R�R�R4RWR<t	TypeErrorR
tPipetFalseRR2t_run_serverR�R�R�R�t_processR�t	_identityR$R@RjRmR)R�R	Rt_finalize_managerR�RF(RtinitializertinitargstreadertwriterR�((s./usr/lib/python2.7/multiprocessing/managers.pyRj�
s(















c	Csl|dk	r||�
n|j
|
|||�}|j|j�

|j�
tjd
|j�
|j�
dS(s@
        Create a server, report its address and run it
        smanager serving at %rN(RWt_ServerR(RRmR	RRo(	tclsRSRRTR^R�R�R�tserver((s./usr/lib/python2.7/multiprocessing/managers.pyR�s




cOs�|jj
tjks!td
�
�
|j|jd|j�

}z)t|dd|
f
||�\}}Wd|j
�
Xt|
|j|�|fS(sP
        Create a new shared object; return the token and exposed tuple
        sserver not yet startedRTRGN(R�R�R�R�R4R�R�R�R1RWRmR(RRR-R.R�RR�((s./usr/lib/python2.7/multiprocessing/managers.pyt_create0s!


)
cCs|jj
|
�

d
S(sC
        Join the manager process (if it has been spawned)
        N(R�R�(Rttimeout((s./usr/lib/python2.7/multiprocessing/managers.pyR�<sc
CsA|j|j
d
|j�

}
zt|
dd�SWd|
j�
XdS(sS
        Return some info about the servers shared objects and connections
        RTRJN(R�R�R�R1RWRm(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyt_debug_infoBs

c
CsA|j|j
d
|j�

}
zt|
dd�SWd|
j�
XdS(s5
        Return the number of shared objects
        RTRKN(R�R�R�R1RWRm(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyt_number_of_objectsLs

c


Cs|S(
N((
R((s./usr/lib/python2.7/multiprocessing/managers.pyt	__enter__Vs
c
Cs|j�
dS(
N(
RF(Rtexc_typetexc_valtexc_tb((s./usr/lib/python2.7/multiprocessing/managers.pyt__exit__Ys
cCs
|j�r�t
jd
�

y8||
d|�

}zt|dd�
Wd|j�
XWntk
rd


n
X|jdd�

|j�r�t
jd�

t|d�r�t
jd	�

|j	�
|jdd
�

|j�r�t
jd�

q�q�q�nt
j|_yt
j|
=Wntk
r



n
XdS(sQ
        Shutdown the manager process; will be registered as a finalizer
        s#sending shutdown message to managerRTRFNR�g�������?smanager still aliveR�s'trying to `terminate()` manager processg�������?s#manager still alive after terminate(tis_aliveR	RR1RWRmRsR�R<R�R�R�R�Rt_address_to_localtKeyError(tprocessRRTR!R�R�((s./usr/lib/python2.7/multiprocessing/managers.pyR�\s.
























c


Cs|jS(
N(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyt<lambda>|tc
s$
d
|jkr$|j
j�|_
n�dkr9t�n|pNt�dd�}|pft�dd�}|r�xa|j�D]P\}}t|�
tks�t	d|�
�
t|�
tks|t	d|�
�
q|Wn|||�f|j
�
<|r 
��
fd�}	�
|	_
t|�
|	�
ndS(s9
        Register a typeid with the manager type
        R�t	_exposed_t_method_to_typeid_s%r is not a stringc
	s�tj
d
�
�
|j�
|
|�
\}}�||jd|d|jd|�}|j|jd|j�

}t|dd|j	f
�
|S(Ns)requesting creation of a shared %r objecttmanagerRTR�RN(
R	RyR�R�R�R�RR1RWR(RR-R.R�texptproxyR�(R�R(s./usr/lib/python2.7/multiprocessing/managers.pyR?�s






N(t__dict__R�tcopyRWt	AutoProxyR;RR2R3R4R$tsetattr(
R�RR�R�R�R�t
create_methodtkeyR�R?((R�Rs./usr/lib/python2.7/multiprocessing/managers.pytregister~s 

	


"
)

	
N(((R$R%R&R�RER�RWRR�R�R�RjtclassmethodR�R�R�R�R�R�R�tstaticmethodR�tpropertyRRhR�(((s./usr/lib/python2.7/multiprocessing/managers.pyR�
s*


				$		
	
		 
	
tProcessLocalSetc
BseZ
d�Zd
�ZRS(c

Cstj
|d
��
dS(Nc


Ss
|j�S(
N(
tclear(
R>((s./usr/lib/python2.7/multiprocessing/managers.pyR��R�(R	tregister_after_fork(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR�s
c

Cst|�
d
fS(N((
R2(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
(R$R%RR�(((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
	cBs�eZ
dZiZej�Zddded
�Z	d�Z
d
id�Zd�Zd�Z
ed��
Zd�Zd�Zd	�Zd
�Zd�ZRS(s.
    A base for proxies of shared objects
    cCs;
tj
j�
zPtjj|
jd�}|dkr\tj�t	�f}|tj|
j<nWdtj
j
�
X|d
|_|d|_|
|_
|j
j|_||_||_t|d|_|dk	r�t|�
|_n0|jdk	r
|jj|_nt�j|_|r$
|j�
ntj|tj�
dS(Nii
(Rt_mutexR�R�R|RRWR	tForkAwareLocalR�R�t_tlst_idsett_tokenRt_idt_managerR�RUR�RR�RRTt_increfR�t_after_fork(RR�R^R�RTR�RMt	tls_idset((s./usr/lib/python2.7/multiprocessing/managers.pyR�s,







	

	
	





c
Cs�tj
d
�

t�j}
tj�jdkrH|
dtj�j7}
n|j|jjd|j	�

}t
|dd|
f
�
||j_
dS(Nsmaking connection to managert
MainThreadt
|RTRH(R	RyRR@RZRzR�R�RR�R1RWR�R
(RR@R�((s./usr/lib/python2.7/multiprocessing/managers.pyt_connect�s







c	CsD
y|jj
}Wn@tk
rR


tjd
tj�j�
|j�
|jj
}n
X|j	|j
|
||f�

|j�\}}|dkr�|S|dkr1
|\}}|jj
|jd}	|jj|_|	||jd|jd|jd|�}
|j|jd|j�

}t|d	d|jf
�
|
St||��
d	S(
sW
        Try to call a method of the referrent and return a copy of the result
        s#thread %r does not own a connections#RETURNs#PROXYi����R�RTR�RNN(R�R
R{R	RyRZRzR@R�R(R�R)R�R�RR�RR�R�R�R1RWRR*(RR,R-R.R�R/R0R�R�R�R�((s./usr/lib/python2.7/multiprocessing/managers.pyt_callmethod�s,



	















c

Cs
|jd
�
S(s9
        Get a copy of the value of the referent
        s	#GETVALUE(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyt	_getvaluesc

Cs�|j|j
jd
|j�

}
t|
dd|jf
�
tjd|j
j	�
|j
j|j�

|jor|jj
}tj|tjd|j
|j||j|j
|jfdd�|_dS(NRTRMs	INCREF %rR-R�i
(R�R�RR�R1RWR�R	RyRR�taddR�R�RRt_decrefR�t_close(RR�R!((s./usr/lib/python2.7/multiprocessing/managers.pyR�s






cCs�|j|j
�

|dks.|jtjkr�yEtjd
|j
�
||jd|
�

}t	|dd|j
f
�
Wq�t
k
r�
}
tjd|�
q�Xntjd|j
�
|r�t|d�r�tjdtj
�j�
|jj�
|`ndS(Ns	DECREF %rRTRNs... decref failed %ss%DECREF %r -- manager already shutdownR
s-thread %r has no more proxies so closing conn(tdiscardRRWR�R�R�R	RyRR1RsR<RZRzR@R
Rm(R�RTR!ttlstidsetR�R�Rx((s./usr/lib/python2.7/multiprocessing/managers.pyR�s





	



c
CsBd|_
y|j�
Wn$tk
r=
}

tjd
|
�

n
XdS(Nsincref failed: %s(RWR�R�RsR	R(RRx((s./usr/lib/python2.7/multiprocessing/managers.pyR�7s

	


c
Cs�i}
tj
�r"|j|
d
<nt|dt�r]|j|
d<tt|j|j	|
ffStt
|�
|j|j	|
ffSdS(NRTt_isautoR�(R
tthread_is_spawningR�R;R�R�tRebuildProxyR�R�R�R2(RR.((s./usr/lib/python2.7/multiprocessing/managers.pyR�?s







c
Cs
|j�S(
N(
R�(Rtmemo((s./usr/lib/python2.7/multiprocessing/managers.pyt__deepcopy__Ls
c

Cs*d
t|�
j
|jjdt|�
fS(Ns<%s object, typeid %r at %s>s0x%x(R2R$R�RR(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR#Os

c

Cs8y|jd
�
SWn t
k
r3


t|�
d dSXdS(sV
        Return representation of the referent (or a fall-back if that fails)
        R#i����s; '__str__()' failed>N(R�RsR�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR8Ss



N((R$R%R&R�R	tForkAwareThreadLockR�RWRhRR�R�R�R�R�R�R�R�R
R#R8(((s./usr/lib/python2.7/multiprocessing/managers.pyR�s


%						
		cCs�tt
�d
d�}|r?|j|
jkr?|j|
jdS|jdt�odtt
�dt�}||
|d||�
SdS(s�
    Function used for unpickling proxy objects.

    If possible the shared object is returned, or otherwise a proxy for it.
    RbiRMt_inheritingN(	R;RRWRRXRtpopRhR�(RAR�R^R.R�RM((s./usr/lib/python2.7/multiprocessing/managers.pyR

`s

cBs�e|
�
}
y|||
fSWne
k
r1


n
Xi}x |
D]}d
||f|Uq?We|ef
|�}|
|_||||
f<|S(sB
    Return a proxy type whose methods are given by `exposed`
    sLdef %s(self, *args, **kwds):
        return self._callmethod(%r, args, kwds)(R�R�R2RR�(R@R�t_cachetdictmetht	ProxyType((s./usr/lib/python2.7/multiprocessing/managers.pyt
MakeProxyTypeus






	

c
	Cs�t|
d
}|dkr\||jd|�

}zt|dd|f
�}Wd|j�
Xn|dkr�|dk	r�|j}n|dkr�t�j}ntd|j	|�}|||
d|d|d|�}	t
|	_|	S(s*
    Return an auto-proxy for `token`
    i
RTRINs
AutoProxy[%s]R�RM(RURWRR1RmR�RRTR
RRhR�(
R�R^R�RTR�RMR�R�R

R�((s./usr/lib/python2.7/multiprocessing/managers.pyR��s







	
	
t	Namespacec
BseZ
d�Zd
�ZRS(c
Ks|jj
|
�

dS(
N(R�tupdate(RR.((s./usr/lib/python2.7/multiprocessing/managers.pyR�s
c
Css|jj
�}
g}x=|
D]5\}}|jd
�
s|jd||f�

qqW|j�
dtjd|�S(NRCs%s=%rs
Namespace(%s)s, (R�Rt
startswithR=R�R3R�(RRR?R@R�((s./usr/lib/python2.7/multiprocessing/managers.pyR#�s







(R$R%RR#(((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
	tValuecBs>eZ
ed�
Zd
�Zd�Zd�Zeee�ZRS(cCs|
|_||_
dS(
N(t	_typecodet_value(RRR�tlock((s./usr/lib/python2.7/multiprocessing/managers.pyR�s
	
c


Cs|jS(
N(
R
(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR|�s
cCs
|
|_dS(
N(
R
(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
c

Cs d
t|�
j
|j|jfS(Ns
%s(%r, %r)(R2R$R
R
(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR#�s
(	R$R%RhRR|R�R#R�R�(((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s

			cCstj||
�S(
N(
R(RtsequenceR
((s./usr/lib/python2.7/multiprocessing/managers.pytArray�s
t
IteratorProxycBsDeZ
dZd�Zd�Zd�Zd�Zd	�Zd
�ZRS(t__next__tnextR(tthrowRmc


Cs|S(
N((
R((s./usr/lib/python2.7/multiprocessing/managers.pyt__iter__�s
c
Gs|jd
|
�S(NR
(
R�(RR-((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
c
Gs|jd
|
�S(NR
(
R�(RR-((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
c
Gs|jd
|
�S(NR((
R�(RR-((s./usr/lib/python2.7/multiprocessing/managers.pyR(�s
c
Gs|jd
|
�S(NR
(
R�(RR-((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
c
Gs|jd
|
�S(NRm(
R�(RR-((s./usr/lib/python2.7/multiprocessing/managers.pyRm�s
(R
R
R(R
Rm(	R$R%R�R
R
R
R(R
Rm(((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
					t
AcquirerProxycBs5eZ
dZed�
Zd�Zd�Zd�ZRS(R�R�cCs|jd
|
f
�S(NR�(
R�(Rtblocking((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
c

Cs
|jd
�
S(NR�(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
c

Cs
|jd
�
S(NR�(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
cCs
|jd
�
S(NR�(
R�(RR�R�R�((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
(R�R�(R$R%R�RhR�R�R�R�(((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s


		tConditionProxycBs,eZ
dZd	d�
Zd�Zd�ZRS(
R�R�twaittnotifyt
notify_allcCs|jd
|
f
�S(NR
(
R�(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
c

Cs
|jd
�
S(NR
(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
c

Cs
|jd
�
S(NR
(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
(R�R�R
R
R
N(R$R%R�RWR
R
R
(((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
	t
EventProxycBs5eZ
dZd�Zd�Zd�Zd	d�
ZRS(
tis_setR�R�R
c

Cs
|jd
�
S(NR!
(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR!
�s
c

Cs
|jd
�
S(NR�(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
c

Cs
|jd
�
S(NR�(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR��s
cCs|jd
|
f
�S(NR
(
R�(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyR
�s
(R!
R�R�R
N(R$R%R�R!
R�R�RWR
(((s./usr/lib/python2.7/multiprocessing/managers.pyR 
�s


			tNamespaceProxycBs)eZ
dZd�Zd�Zd�ZRS(t__getattribute__t__setattr__t__delattr__cCsB|
d
dkr tj
||
�Stj
|d�}|d|
f
�S(NiRCR�R#
(tobjectR#
(RR�t
callmethod((s./usr/lib/python2.7/multiprocessing/managers.pyt__getattr__�s



cCsH|
d
dkr#tj
||
|�Stj|d�}|d|
|f�S(NiRCR�R$
(R&
R$
R#
(RR�R�R'
((s./usr/lib/python2.7/multiprocessing/managers.pyR$
s



cCsB|
d
dkr tj
||
�Stj|d�}|d|
f
�S(NiRCR�R%
(R&
R%
R#
(RR�R'
((s./usr/lib/python2.7/multiprocessing/managers.pyR%
s



(R#
R$
R%
(R$R%R�R(
R$
R%
(((s./usr/lib/python2.7/multiprocessing/managers.pyR"
�s

		t
ValueProxycBs/eZ
dZd�Zd�Zeee�ZRS(R|R�c

Cs
|jd
�
S(NR|(
R�(
R((s./usr/lib/python2.7/multiprocessing/managers.pyR|s
cCs|jd
|
f
�S(NR�(
R�(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyR�s
(R|R�(R$R%R�R|R�R�R�(((s./usr/lib/python2.7/multiprocessing/managers.pyR)
s

		t
BaseListProxyt__add__t__contains__t__delitem__t__delslice__t__getitem__t__getslice__t__len__t__mul__t__reversed__t__rmul__t__setitem__t__setslice__R=tcounttextendtindextinsertR
tremovetreverseR�t__imul__t	ListProxyc
BseZ
d�Zd
�ZRS(cCs|jd
|
f
�
|S(NR8
(
R�(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyt__iadd__s

cCs|jd
|
f
�
|S(NR=
(
R�(RR�((s./usr/lib/python2.7/multiprocessing/managers.pyR=
 s

(R$R%R?
R=
(((s./usr/lib/python2.7/multiprocessing/managers.pyR>
s
	t	DictProxyR
R�R�R|thas_keytpopitemt
setdefaultR

tIteratort
ArrayProxyt	PoolProxytapplytapply_asyncRmtimaptimap_unorderedR�tmapt	map_asyncR�tAsyncResultc
BseZ
dZRS(
s(

    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.
    (R$R%R&(((s./usr/lib/python2.7/multiprocessing/managers.pyR
Cs	tQueuet
JoinableQueuetEventtLockR[t	SemaphoretBoundedSemaphoret	ConditionRR�R�R
R�R�(Ut__all__tosRtweakrefRZRRN
R�RtmultiprocessingRRRRR	R
tmultiprocessing.processRtmultiprocessing.forkingRR
RRtmultiprocessing.utilRRtcPickleRtImportErrorR�RR�R@R2R;t
view_typesR&
RR1R*RsR5RBRDRER�R_R`tXmlListenert	XmlClientRURR�R�RR

R
RWRhR�R
R
R
R
R
R
R 
R"
R)
R*
R>
R@
R�RE
RF
R
RP
RQ
R[RR
RS
RT
R�R�R�(((s./usr/lib/python2.7/multiprocessing/managers.pyt<module>$s�





.

"




	4
			
�,


�
�