ÿØÿà 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@sT
dg
Zd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlmZmZm	Z	
d
dl
mZmZ
dZ
dZdZej�Zd�Zd	ef
d
��YZefed�Zdef
d��YZd
ef
d��YZeZdef
d��YZdef
d��YZdef
d��YZdef
d��YZdS(tPooli����N(tProcesst	cpu_counttTimeoutError(tFinalizetdebugii
ic

Cs
t|�S(
N(
tmap(
targs((s*/usr/lib/python2.7/multiprocessing/pool.pytmapstar@s
tMaybeEncodingErrorc
Bs)eZ
dZd
�Zd�Zd�ZRS(sVWraps possible unpickleable errors, so they can be
    safely sent through the socket.cCsAt|
�
|_
t|�
|_tt|�j|j
|j�
dS(
N(treprtexctvaluetsuperR	t__init__(tselfRR((s*/usr/lib/python2.7/multiprocessing/pool.pyRKs


c

Csd
|j|j
fS(Ns(Error sending result: '%s'. Reason: '%s'(RR(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyt__str__Ps
	
c

Csd
t|�
S(Ns<MaybeEncodingError: %s>(
tstr(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyt__repr__Ts
(t__name__t
__module__t__doc__RRR(((s*/usr/lib/python2.7/multiprocessing/pool.pyR	Gs		cCs�
|dks6t
|�
ttfkr0|d
ks6t�
|
j}|j}t|d�rt|jj	�
|
j
j	�
n|dk	r�||�
nd
}xI
|dks�|r�
||kr�
y
|�}Wn"ttfk
r�


t
d�

Pn
X|dkr
t
d�

Pn|\}	}
}}}
yt|||
�f}Wntk
rO

}
t|f}n
Xy||	|
|f�

WnMtk
r�

}
t||d�}t
d|�

||	|
t|ff�

n
Xd}}	}}}}
|d7}q�Wt
d|�

dS(Nit_writers)worker got EOFError or IOError -- exitingsworker got sentinel -- exitingi
s0Possible encoding error while sending result: %ssworker exiting after %d tasks(tNonettypetinttlongtAssertionErrortputtgetthasattrRtcloset_readertEOFErrortIOErrorRtTruet	ExceptiontFalseR	(tinqueuetoutqueuetinitializertinitargstmaxtasksRRt	completedttasktjobt
itfuncRtkwdstresultt
etwrapped((s*/usr/lib/python2.7/multiprocessing/pool.pytworkerXsB
6
	
	






!






















cBs
eZ
dZeZddddd
�Zd�Zd�Zd�Zd�Z	did�Z
dd�
Zdd	�
Zdd
�
Z
didd�Zddd�Zed
��
Zed��
Zed��
Zed��
Zd�Zd�Zd�Zd�Zed��
Zed��
ZRS(sH
    Class which supports an async version of the `apply()` builtin
    cCs/|j�
t
j
�|_i|_t|_||_||_||_|
dkr|y
t
�}
Wq|tk
rx


d
}
q|Xn|
d
kr�td�
�
n|dk	r�t
|d�r�td�
�
n|
|_g|_|j�
tjdtjd|f
�|_t|j_t|j_|jj�
tjdtjd|j|j|j|j|jf�|_t|j_t|j_|jj�
tjdtjd|j|j|jf�|_ t|j _t|j _|j j�
t!||j"d|j|j#|j|j|j|j|j |jfdd�|_$dS(	Ni
s&Number of processes must be at least 1t__call__sinitializer must be a callablettargetRtexitpriorityi(%t
_setup_queuestQueuet
_taskqueuet_cachetRUNt_statet_maxtasksperchildt_initializert	_initargsRRtNotImplementedErrort
ValueErrorRt	TypeErrort
_processest_poolt_repopulate_poolt	threadingtThreadRt_handle_workerst_worker_handlerR#tdaemontstartt
_handle_taskst
_quick_putt	_outqueuet
_task_handlert_handle_resultst
_quick_gett_result_handlerRt_terminate_poolt_inqueuet
_terminate(Rt	processesR(R)tmaxtasksperchild((s*/usr/lib/python2.7/multiprocessing/pool.pyR�sX


	
	
	
	
	









	
	

	
	



	
	




	
	








c
Cswt}
xjt
tt|j�
�
�
D]M}|j|}|jdk	r"td
|�

|j�
t	}
|j|=q"q"W|
S(s�Cleanup after any worker processes which have exited due to reaching
        their specified lifetime.  Returns True if any workers were cleaned up.
        scleaning up worker %dN(
R%treversedtrangetlenREtexitcodeRRtjoinR#(RtcleanedR.R4((s*/usr/lib/python2.7/multiprocessing/pool.pyt_join_exited_workers�s
"







c

Cs�x�t|j
t|j�
�
D]�}
|jd
td|j|j|j|j	|j
f�}|jj|�

|jj
dd�|_t|_|j�
td�

qWdS(s�Bring the number of pool processes up to the specified number,
        for use after reaping workers which have exited.
        R6RR
t
PoolWorkersadded workerN(RZRDR[RER
R4RUROR?R@R>tappendtnametreplaceR#RKRLR(RR.t
w((s*/usr/lib/python2.7/multiprocessing/pool.pyRF�s#





	


c


Cs|j�r|j
�
nd
S(sEClean up any exited workers and start replacements for them.
        N(R_RF(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyt_maintain_pool�s
c
CsPd
dlm
}

|
�|_|
�|_|jjj|_|jjj|_	dS(Ni
(
tSimpleQueue(
tqueuesRfRURORtsendRNR trecvRR(RRf((s*/usr/lib/python2.7/multiprocessing/pool.pyR8�s





cCs.|jt
kst�
|j|
||�j�S(
s1
        Equivalent of `apply()` builtin
        (R=R<Rtapply_asyncR(RR/RR0((s*/usr/lib/python2.7/multiprocessing/pool.pytapply�s
cCs.|jt
kst�
|j|
||�j�S(
s/
        Equivalent of `map()` builtin
        (R=R<Rt	map_asyncR(RR/titerablet	chunksize((s*/usr/lib/python2.7/multiprocessing/pool.pyR�s
i
cs�|jt
kst�
|d
krft|j�
�
|jj��
fd�t|�
D�
�
jf�

�
S|d
ksxt�
t	j
�||�}t|j�
�
|jj�
f
d�t|�
D�
�
jf�

d��
D�
SdS(sZ
        Equivalent of `itertools.imap()` -- can be MUCH slower than `Pool.map()`
        i
c
3s0|]&\}
}�
j|
�|f
ifV
qdS(
N(
t_job(t.0R.t
x(R/R1(s*/usr/lib/python2.7/multiprocessing/pool.pys	<genexpr>
s
c
3s0|]&\}
}�j|
t
|f
ifV
qdS(
N(RoR(RpR.Rq(
R1(s*/usr/lib/python2.7/multiprocessing/pool.pys	<genexpr>

s
c
ss"|]}
|
D]}|V
q
qdS(
N((Rptchunktitem((s*/usr/lib/python2.7/multiprocessing/pool.pys	<genexpr>
sN(R=R<RtIMapIteratorR;R:Rt	enumeratet_set_lengthRt
_get_tasks(RR/RmRnttask_batches((R/R1s*/usr/lib/python2.7/multiprocessing/pool.pytimap�s









cs�|jt
kst�
|d
krft|j�
�
|jj��
fd�t|�
D�
�
jf�

�
S|d
ksxt�
t	j
�||�}t|j�
�
|jj�
f
d�t|�
D�
�
jf�

d��
D�
SdS(sK
        Like `imap()` method but ordering of results is arbitrary
        i
c
3s0|]&\}
}�
j|
�|f
ifV
qdS(
N(
Ro(RpR.Rq(R/R1(s*/usr/lib/python2.7/multiprocessing/pool.pys	<genexpr>
s
c
3s0|]&\}
}�j|
t
|f
ifV
qdS(
N(RoR(RpR.Rq(
R1(s*/usr/lib/python2.7/multiprocessing/pool.pys	<genexpr>
s
c
ss"|]}
|
D]}|V
q
qdS(
N((RpRrRs((s*/usr/lib/python2.7/multiprocessing/pool.pys	<genexpr>!
sN(R=R<RtIMapUnorderedIteratorR;R:RRuRvRRw(RR/RmRnRx((R/R1s*/usr/lib/python2.7/multiprocessing/pool.pytimap_unordered
s









cCsV|jt
kst�
t|j|�}|jj|jd
|
||fg
d
f�

|S(s>
        Asynchronous equivalent of `apply()` builtin
        N(	R=R<RtApplyResultR;R:RRoR(RR/RR0tcallbackR1((s*/usr/lib/python2.7/multiprocessing/pool.pyRj#
s

+
cs�|jt
kst�
t|d
�s3t|�
}n|dkr}tt|�
t|j�
d�\}}|r}|d7}q}nt|�
dkr�d}nt	j
|
||�}t|j|t|�
|��|j
j�f
d�t|�
D�
df�

�S(s<
        Asynchronous equivalent of `map()` builtin
        t__len__ii
ic
3s0|]&\}
}�j|
t
|f
ifV
qdS(
N(RoR(RpR.Rq(
R1(s*/usr/lib/python2.7/multiprocessing/pool.pys	<genexpr>=
s
N(R=R<RRtlistRtdivmodR[RERRwt	MapResultR;R:RRu(RR/RmRnR}textraRx((
R1s*/usr/lib/python2.7/multiprocessing/pool.pyRl,
s


(



	



c
Csotj
�}
xB|
jtks6|jrP|
jtkrP|j�
tjd
�

qW|j	j
d�

td�

dS(Ng�������?sworker handler exiting(
RGtcurrent_threadR=R<R;t	TERMINATERettimetsleepR:RRR(tpooltthread((s*/usr/lib/python2.7/multiprocessing/pool.pyRIA
s*



cCs
tj
�}x�
t|jd�D]q
\}}d}d
}	zG
y�x�t|�
D]�\}	}|jrmtd�

Pny|
|�

WqJtk
r�
}

|d \}}y||j	|t
|
f�
Wq�tk
r�


q�XqJXqJW|r�td�

||	d�

nwPWn}tk
r|

}

|r
|d nd\}}||krX
||j	|dt
|
f�
n|r}
td�

||	d�

q}
n
XWdd}}}XqWtd�

y@td�

|jd�

td	�

x|D]}|
d�

q�
WWnt
k
r�



td
�

n
Xtd�

dS(
Ni����s'task handler found thread._state != RUNisdoing set_length()i
istask handler got sentinels/task handler sending sentinel to result handlers(task handler sending sentinel to workerss/task handler got IOError when sending sentinelsstask handler exiting(ii(RGR�titerRRRuR=RR$t_setR%tKeyErrorRR"(t	taskqueueRR'R�tcacheR�ttaskseqt
set_lengthR,R.R2R-tindtext
p((s*/usr/lib/python2.7/multiprocessing/pool.pyRMN
sR




	




















!














cCstj
�}x�y
|
�}Wn"ttfk
r@


td
�

dSX|jrm|jtks_t�
td�

Pn|dkr�td�

Pn|\}}}y||j	||�
Wnt
k
r�


n
Xd}}}qWx�|r�
|jtkr�
y
|
�}Wn"ttfk
r



td
�

dSX|dkr:
td�

q�n|\}}}y||j	||�
Wnt
k
rt



n
Xd}}}q�Wt|d�r�
td�

y5x.td�
D] }|j
j�s�
Pn|
�
q�
WWq�
ttfk
r�



q�
Xntdt|�
|j�
dS(	Ns.result handler got EOFError/IOError -- exitings,result handler found thread._state=TERMINATEsresult handler got sentinels&result handler ignoring extra sentinelR s"ensuring that outqueue is not fulli
s7result handler exiting: len(cache)=%s, thread._state=%s(RGR�R"R!RR=R�RRR�R�RRZR tpollR[(R'RR�R�R,R-R.tobj((s*/usr/lib/python2.7/multiprocessing/pool.pyRQ�
s\






	






































ccsDt|
�
}
x1t
tj|
|��
}|s1dS||fV
qWdS(
N(R�ttuplet	itertoolstislice(R/tittsizeRq((s*/usr/lib/python2.7/multiprocessing/pool.pyRw�
s




c

Cstd
�
�
dS(Ns:pool objects cannot be passed between processes or pickled(
RA(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyt
__reduce__�
s

c

Cs5td
�

|j
tkr1t|_
t|j_
ndS(Nsclosing pool(RR=R<tCLOSERJ(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyR�
s



	
c

Cs-td
�

t
|_t
|j_|j�
dS(Nsterminating pool(RR�R=RJRV(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyt	terminate�
s


	

c
Csntd
�

|j
ttfks%t�
|jj�
|jj�
|jj�
x|j	D]}
|
j�
qVWdS(Nsjoining pool(
RR=R�R�RRJR]RPRSRE(RR�((s*/usr/lib/python2.7/multiprocessing/pool.pyR]�
s










cCsWtd
�

|j
j�
x9|
j�rR|jj�rR|jj�
tjd�

qWdS(Ns7removing tasks from inqueue until task handler finishedi(	Rt_rlocktacquiretis_aliveR R�RiR�R�(R&ttask_handlerR�((s*/usr/lib/python2.7/multiprocessing/pool.pyt_help_stuff_finish�
s







c	
Cs�
td
�

t
|_t
|_td�

|j||t|�
�
|j�sct|�
dksct�
t
|_|jd�

td�

t	j
�|k	r�|jd�

n|r�t|dd�r�td�

x-|D]"}	|	j
dkr�|	j�
q�q�Wntd�

t	j
�|k	r$
|jd�

ntd	�

t	j
�|k	rP
|jd�

n|r�
t|dd�r�
td
�

x;|D]0}	|	j�rz
td|	j�

|	j�
qz
qz
WndS(Nsfinalizing pools&helping task handler/workers to finishisjoining worker handlerg}Ô%�I�TR�sterminating workerssjoining task handlersjoining result handlersjoining pool workersscleaning up worker %d(RR�R=R�R[R�RRRRGR�R]RR\R�tpid(
tclsR�R&R'R�tworker_handlerR�tresult_handlerR�R�((s*/usr/lib/python2.7/multiprocessing/pool.pyRT�
s8
	
	

$	






















N((((RRRR
RRR_RFReR8RkRRyR{RjRltstaticmethodRIRMRQRwR�RR�R]R�tclassmethodRT(((s*/usr/lib/python2.7/multiprocessing/pool.pyR�s0
	
:					
4<							R|cBsDeZ
d�Zd
�Zd�Zdd�
Zdd�
Zd�ZRS(cCsStj
tj��
|_tj�|_|
|_t|_	||_
||
|j<dS(
N(RGt	ConditiontLockt_condtjob_countertnextRoR;R%t_readyt	_callback(RR�R}((s*/usr/lib/python2.7/multiprocessing/pool.pyRs


	
	
	
c


Cs|jS(
N(
R�(
R((s*/usr/lib/python2.7/multiprocessing/pool.pytready&s
c


Cs|jst
�
|jS(
N(R�Rt_success(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyt
successful)s

cCsB|jj
�
z |js,|jj|
�

nWd|jj�
XdS(
N(R�R�R�twaittrelease(Rttimeout((s*/usr/lib/python2.7/multiprocessing/pool.pyR�-s




	
cCs<|j|
�

|j
st�
n|jr/|jS|j�
dS(
N(R�R�RR�t_value(RR�((s*/usr/lib/python2.7/multiprocessing/pool.pyR5s


	
	
	
cCs�|\|_|_
|jr7|jr7|j|j
�

n|jj�
zt|_|jj�
Wd|jj�
X|j	|j
=dS(
N(R�R�R�R�R�R#R�tnotifyR�R;Ro(RR.R�((s*/usr/lib/python2.7/multiprocessing/pool.pyR�>s






	

N(	RRRR�R�RR�RR�(((s*/usr/lib/python2.7/multiprocessing/pool.pyR|s				R�c
BseZ
d�Zd
�ZRS(cCstj
||
|�
t|_dg
||_||_|d
k
r`d
|_t|_|
|j	=n||t
||�
|_dS(Ni(R|RR#R�RR�t
_chunksizet_number_leftR�Rotbool(RR�RntlengthR}((s*/usr/lib/python2.7/multiprocessing/pool.pyRRs

	

	

	
	

cCs
|\}}|r�||j|
|j
|
d
|j
+|jd
8_|jdkr
|jrn|j|j�

n|j|j=|jj�
zt|_	|jj
�
Wd|jj�
Xq
nWt|_
||_|j|j=|jj�
zt|_	|jj
�
Wd|jj�
XdS(Ni
i(R�R�R�R�R;RoR�R�R#R�R�R�R%R�(RR.tsuccess_resulttsuccessR1((s*/usr/lib/python2.7/multiprocessing/pool.pyR�^s*


"


	






	
	
	





	
(RRRR�(((s*/usr/lib/python2.7/multiprocessing/pool.pyR�Ps	RtcBs>eZ
d�Zd
�Zdd�
ZeZd�Zd�ZRS(cCsktj
tj��
|_tj�|_|
|_tj	�|_
d
|_d|_
i|_||
|j<dS(Ni(RGR�R�R�R�R�RoR;tcollectionstdequet_itemst_indexRt_lengtht	_unsorted(RR�((s*/usr/lib/python2.7/multiprocessing/pool.pyRs


	

	
	
	
c


Cs|S(
N((
R((s*/usr/lib/python2.7/multiprocessing/pool.pyt__iter__�s
cCs�|jj
�
z�y|jj�}Wn�tk
r�


|j|jkrNt�
n|jj|
�

y|jj�}Wq�tk
r�


|j|jkr�t�
nt	�
q�Xn
XWd|jj
�
X|\}}|r�|S|�
dS(
N(R�R�R�tpopleftt
IndexErrorR�R�t
StopIterationR�RR�(RR�RsR�R((s*/usr/lib/python2.7/multiprocessing/pool.pyR��s&








	






	



cCs�|jj
�
z�|j|
kr�|jj|�

|jd
7_xJ|j|jkr�|jj|j�
}|jj|�

|jd
7_qAW|jj�
n
||j|
<|j|jkr�|j	|j
=nWd|jj�
XdS(Ni
(R�R�R�R�RaR�tpopR�R�R;RoR�(RR.R�((s*/usr/lib/python2.7/multiprocessing/pool.pyR��s












cCs^|jj
�
z<|
|_|j|jkrH|jj�
|j|j=nWd|jj�
XdS(
N(R�R�R�R�R�R;RoR�(RR�((s*/usr/lib/python2.7/multiprocessing/pool.pyRv�s



	



N(	RRRR�RR�t__next__R�Rv(((s*/usr/lib/python2.7/multiprocessing/pool.pyRt}s	
		Rzc
BseZ
d�ZRS(
cCst|jj
�
zR|jj|�

|jd
7_|jj�
|j|jkr^|j|j=nWd|jj	�
XdS(Ni
(
R�R�R�RaR�R�R�R;RoR�(RR.R�((s*/usr/lib/python2.7/multiprocessing/pool.pyR��s








(RRR�(((s*/usr/lib/python2.7/multiprocessing/pool.pyRz�st
ThreadPoolcBsBeZ
dd
lmZ
dddd�Zd�Zed��
ZRS(i
(
R
cCstj
||
||�
dS(
N(RR(RRWR(R)((s*/usr/lib/python2.7/multiprocessing/pool.pyR�s
c

Cs@tj�|_
tj�|_|j
j|_|jj|_dS(
N(R9RURORRNRRR(
R((s*/usr/lib/python2.7/multiprocessing/pool.pyR8�s



cCsW|jj
�
z5|jj�
|jjdg
|�

|jj�
Wd|jj�
XdS(
N(t	not_emptyR�tqueuetcleartextendRt
notify_allR�(R&R�R�((s*/usr/lib/python2.7/multiprocessing/pool.pyR��s





N((	RRtdummyR
RRR8R�R�(((s*/usr/lib/python2.7/multiprocessing/pool.pyR��s	(t__all__RGR9R�R�R�tmultiprocessingR
RRtmultiprocessing.utilRRR<R�R�tcountR�RR$R	RR4tobjectRR|tAsyncResultR�RtRzR�(((s*/usr/lib/python2.7/multiprocessing/pool.pyt<module>#s,	






	,��.-I