ÿØÿà 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ÿÙ
�
*t�Wc@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZydd
lZWne	k
r�


dd
l
Zn
XyddlmZ
Wn!e	k
r�


ddl
mZ
n
XddlmZ
ddlmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
dd,d��YZd
d-d��YZdd.d��YZdd/d��YZdd0d��YZdejf
d��YZdej f
d��YZ!dejf
d��YZ"de"f
d��YZ#de"f
d��YZ$dd1d ��YZ%d!d2d"��YZ&d#d3d$��YZ'd%�Z(d&d4d'��YZ)d(d5d)��YZ*d*ef
d+��YZ+d
S(6i����N(
tsha1(
tnew(
tasyncore_25(
t	http_date(
thttp_server(
t	producers(
tfilesys(
tdefault_handler(
tauth_handlertNOT_DONE_YETc
BseZ
RS((t__name__t
__module__(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR	s
tdeferring_chunked_producercBs#eZ
dZdd
�
Zd�ZRS(s'
A producer that implements the 'chunked' transfer coding for HTTP/1.1.
    Here is a sample usage:
            request['Transfer-Encoding'] = 'chunked'
            request.push (
                    producers.chunked_producer (your_producer)
                    )
            request.done()
    cCs|
|_||_
d
|_dS(Ng�������?(tproducertfooterstdelay(tselfR
R((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyt__init__*s
	
	
c
Cs~|jrv|jj
�}
|
tkr(tS|
rBd
t|
�
|
fSd|_|jrodjdg
|j�
dSdSndSdS(Ns%x
%s
s
t
0s

s0

t(R
tmoreR	tlentNoneRtjoin(Rtdata((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR/s
	




	
	
N(R
Rt__doc__RRR(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR stdeferring_composite_producerc
Bs eZ
dZd
�Zd�ZRS(s$combine a fifo of producers into onecCs|
|_d
|_
dS(Ng�������?(RR(RR((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRAs
	
c
CsaxZt|j
�
rX|j
d
}
|
j�}|tkr;tS|rE|S|j
jd
�

qWdSdS(NiR(RRRR	tpop(Rt
pt
d((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyREs







(R
RRRR(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR?s

	tdeferring_globbing_producercBs#eZ
dZdd�
Zd�ZRS(s�
    'glob' the output from a producer into a particular buffer size.
    helps reduce the number of calls to send().  [this appears to
    gain about 30% performance on requests to a single channel]
    i
icCs(|
|_d
|_
||_d|_dS(NRg�������?(R
tbuffertbuffer_sizeR(RR
R ((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRZs
	
	
	
c
CsnxUt|j
�
|jkrW|jj�}
|
tkr:tS|
rS|j
|
|_
qPqW|j
}d
|_
|S(NR(RRR R
RR	(RRt
r((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR`s






	
	
i
(R
RRRR(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRSstdeferring_hooked_producerc
Bs eZ
dZd
�Zd�ZRS(s�
    A producer that will call <function> when it empties,.
    with an argument of the number of bytes produced.  Useful
    for logging/instrumentation purposes.
    cCs(|
|_||_
d
|_d|_dS(Nig�������?(R
tfunctiontbytesR(RR
R#((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRus
	
	
	
c
Csl|jrd|jj
�}
|
tkr(tS|
sJd|_|j|j�

n|jt|
�
|_|
Sd
SdS(NR(R
RR	RR#R$R(Rtresult((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR{s
	




	

(R
RRRR(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR"ns	tdeferring_http_requestc
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(s
 The medusa http_request class uses the default set of producers in
    medusa.producers.  We can't use these because they don't know anything
    about deferred responses, so we override various methods here.  This was
    added to support tail -f like behavior on the logtail handler c
	Os�
tj
tj|j�}|j�}d
}d
}d}|jdkr||dkrsd|krfd}qyd|d<q
d}n�|jdkr
|d	kr�d}q
d|kr
d
|kr�|d
dks�d}q�q�|jr�d|d
<d}d
}q�d}q
n|jdkr
d}ntj	|j
��
}|rB
d	|d<n|rr
tt|j
�
�
}t||g�
}n"|j
jd
|�
t|j
�
}t||j�}|r�
t|�
}n|jj|�

d|j_|r�
|jj�
ndS(
s� I didn't want to override this, but there's no way around
        it in order to support deferreds - CM

        finalize this transaction - send output to the http channelii
s1.0s
keep-alivesContent-Lengths
Keep-Alivet
Connections1.1tclosesTransfer-EncodingtchunkedN(Rt
get_headert
CONNECTIONtheadertlowertversiontuse_chunkedRRtsimple_producertbuild_reply_headerRRtoutgoingtinsertR"tlogRtchanneltpush_with_producertcurrent_requesttclose_when_done(	Rtargtkwt
connectiontclose_ittwrap_in_chunkingtglobbingtoutgoing_headertoutgoing_producer((s3/usr/lib/python2.7/dist-packages/supervisor/http.pytdone�sV






	
	


	




	


	
	








cCs�|jj
r/|jj
d
}|jj
d}nd}d
}|jjjj|d||jtj��
|j|j|
f�
dS(s� We need to override this because UNIX domain sockets return
        an empty string for the addr rather than a (host, port) combination ii
t	localhosts%d - - [%s] "%s" %d %d
N(	R5taddrtservertloggerR4tlog_date_stringttimetrequestt
reply_code(RR$thosttport((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR4�s










c
Cs`i}
id
d6dd6dd6}tj
�}|j�\}}}}|rX||}nx$|r~|ddkr~|d	}q[Wd
|kr�tj|�
}n|r�|d	}n|jj}|jj�|
d<t	|j
�
|
d<|j|
d
<|j|
d<d|j
|
d<|jj|
d<d|
d<d||
d<tjjtjj||
d��
|
d<|rq
||
d<nd|
d<|jjr�
|jjd|
d<n
d|
d<x�|jD]�}	|	jdd	�\}
}|
j�}
|j�}|j|
�
r|r||
|j|
�
<q�
ddj|
jd�
�
j�}
|r�
|
j|
�
r�
||
|
<q�
q�
W|
S(NtCONTENT_LENGTHscontent-lengthtCONTENT_TYPEscontent-typetCONNECTION_TYPER;it
/i
t
%tREQUEST_METHODtSERVER_PORTtSERVER_NAMEtSERVER_SOFTWAREsHTTP/tSERVER_PROTOCOLschannel.creation_timeRtSCRIPT_NAMEt	PATH_INFOtPATH_TRANSLATEDtQUERY_STRINGsCGI/1.1tGATEWAY_INTERFACEtREMOTE_ADDRs	127.0.0.1t
:sHTTP_%st
_t
-(tostgetcwdt	split_uriRtunquoteR5RDtcommandtuppertstrRKtserver_nametSERVER_IDENTR.t
creation_timetpathtnormpathRRCR,tsplitR-tstripthas_keytget(Rtenvt
header2envtworkdirRitparamstquerytfragmentRDR,tkeytvalue((s3/usr/lib/python2.7/dist-packages/supervisor/http.pytcgi_environment�sR







































"


c
Cs
id
d6dd6}
|j�}|j
d�
dksJ|j
d�
d	krSd}nd}|jd
�
r�|d
j�}tj|�
\}}n|dj�}|d}|dks�|
||kr�|}n|d
|}d||f}|ddkr

|d }n|S(s� Functionality that medusa's http request doesn't have; set an
        attribute named 'server_url' on the request based on the Host: header
        t80thttpt443thttpstHTTPStontONtSERVER_PORT_SECUREt
1t	HTTP_HOSTRSRRR\s%s://%si����RO(R}R~N(RwRnRmRlturllibt	splitportR(Rtdefault_porttenvirontprotocolRJthostnameRKt
server_url((s3/usr/lib/python2.7/dist-packages/supervisor/http.pytget_server_url,
s$


	




	




(R
RRRAR4RwR�(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR&�s
	S		5tdeferring_http_channelcBs>eZ
dZd
Zej�Zdd�
Zd�Zd�Z	RS(iicCsp|
dkrt
j
�}
n|jr`|
|j}||jksL|d
krY|
|_tStSntjj|�
S(Ni(	RRGRtlast_writable_checktTruetFalseRthttp_channeltwritable(Rtnowtelapsed((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�R
s

	


	
c
Cs�x�t|j
�
r�|j
j�}
|
d
krT|jsP|j
j�
|j�
nd
St|
t�r�|j
j�
|j|
|_d
S|
j	�}|t
kr�|
j|_d
S|r�|j||_t|_d
S|j
j�
qd
SqWd
S(s Implement deferreds N(
Rt
producer_fifotfirstRt
ac_out_bufferRR(t
isinstanceReRR	RR�(RRR((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyt
refill_buffera
s,


	













	
c
Cs5|jr|jj
�
n|j}
d
|_|
jd�
}x|r[|dr[|d}q=W|sp|j�
dS|d}tj|�
\}}}tj|d�
}
tj|�
\}}d|kr�|r�tj	|�
d|}q�tj	|�
}nt
||||||
�}	|jj�
|j
jj�
|dkrg
|jdt|�
d	�
|	jd
�

dSx�|j
jD]�}
|
j|	�
rt
y|	|_|
j|	�

Wnv


|j
jj�
tj�\\}}}
}}}|j
jd||||
fd	�
y|	jd�

Wq


qXn
XdSqt
W|	jd
�

dS(s� We only override this to use 'deferring_http_request' class
        instead of the normal http_request class; it sucks to need to override
        this Rs
ii
NRPt
?sBad HTTP request: %sterrori�
s'Server Error: %s, %s: file: %s line: %si�
i�
(R7tfound_terminatort	in_bufferRkR8Rt
crack_requesttjoin_headerst
splitqueryRbR&trequest_countert	incrementRDttotal_requestsRtlog_infotreprR�thandlerstmatchthandle_requestt
exceptionstasyncoretcompact_traceback(RR,tlinesRHRcturiR.trpathtrqueryR!t
htfiletfuntlinet
tt
vttbinfo((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��
sX	
	
	









	









	

!
	







N(
R
Rtac_out_buffer_sizeRRGR�RR�R�R�(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�I
s
	 tsupervisor_http_servercBs2eZ
eZdZd�Zd
�Zdd�
ZRS(cCs�d
dlm
}
|s+|jtj�
}n|j|�
}||_
tjj|�

|j	|
�

g|_
|
jd�

|j�
dS(sj Override __init__ to do logger setup earlier so it can
        go to our logger object instead of stdout i����(
REiN(
tsupervisor.medusaREtfile_loggertsyststdouttunresolving_loggerR�t
dispatcherRt
set_socketR�tsetblockingtset_reuse_addr(Rtsockt
logger_objectRE((s3/usr/lib/python2.7/dist-packages/supervisor/http.pytprebind�
s

	

	

c
Cs�d
dlm
}

d
dlm}
|jd�

|
�|_|
�|_|
�|_|
�|_|
�|_	|j
d|tjtj��
|j
|jf�

dS(Ni����(
tcounter(
tVERSION_STRINGis2Medusa (V%s) started at %s
	Hostname: %s
	Port:%s
(tsupervisor.medusa.counterR�tsupervisor.medusa.http_serverR�tlistent
total_clientsR�R�t	bytes_outtbytes_inR�RGtctimeRfRK(RR�R�((s3/usr/lib/python2.7/dist-packages/supervisor/http.pytpostbind�
s










tinfocCsAd
}t|dd�dk	r*|j}n|jj||
�
dS(NRtip(tgetattrRR�RER4(RtmessagettypeR�((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��
s



N(	R
RR�t
channel_classRR�R�R�R�(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��
s


		tsupervisor_af_inet_http_serverc
BseZ
dZd
�ZRS(s+ AF_INET version of supervisor HTTP server cCs
|
|_||_
tjtjtj�}|j||�
|j|
|f�

|jj�\}}|
s�|jd
d�
tj	�}ytj
|�
}
Wq�tjk
r�


td|�
�
q�Xnytj
|
�
d|_Wn-tjk
r




|jdd�
|
|_n
X|j�
dS(NsComputing default hostnametwarnings�Could not determine IP address for hostname %s, please try setting an explicit IP address in the "port" setting of your [inet_http_server] section.  For example, instead of "port = 9001", try "port = 127.0.0.1:9001."isCannot do reverse lookup(R�RKtsockettAF_INETtSOCK_STREAMR�tbindtgetsocknameR�tgethostnamet
gethostbynameR�t
ValueErrort
gethostbyaddrRfR�(RR�RKR�R�RJR�((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRs*
	
	
















(R
RRR(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�s
tsupervisor_af_unix_http_serverc
Bs eZ
dZd
�Zd�ZRS(s+ AF_UNIX version of supervisor HTTP server c
Cs|
|_|
|_
d
|
tj�f}ytj|�

Wntk
rL


n
Xx�
tjtjtj�}z\
|j	|�

tj
||�
ytj||
�
Wn�tk
r(



|j|
�
}|r�tj
tj�
�
nd|
}tjj|�

ytj|
�

Wn


n
X|j�
tjd�

wPn�Xytj|
|d|d�
Wngtk
r�

}	
|	jdtjkr�
d}t||
t|�
tjtj��
df�
�
q�
�n
X|j||�
PWdytj|�

Wntk
r�



n
XXqPWd|_|j �
dS(Ns%s.%dsUnlinking stale socket %s
g333333�?ii
s�Not permitted to chown %s to uid/gid %s; adjust "sockchown" value in config file or on command line to values that the current user (%s) can successfully chowns<unix domain socket>(!R�RKR_tgetpidtunlinktOSErrorR�tAF_UNIXR�R�tchmodtlinkt	checkusedR�terrnot
EADDRINUSER�tstderrtwriteR(RGtsleeptchowntargstEPERMR�R�tpwdtgetpwuidtgeteuidR�RfR�(
Rt
socketnamet	sockchmodt	sockchownR�ttempnameR�tusedtmsgtwhy((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR%sZ
	
	



























	
	







		
cCsmtjtj
tj�}y5|j|
�

|jd
�

|jd�

|j�
Wntjk
rd


tSXt	SdS(NsGET / HTTP/1.0

i
(
R�R�R�tconnecttsendtrecvR(R�R�R�(RR�t
s((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�ls










(R
RRRR�(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�"s
	Gttail_f_producerc
BsGeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(cCsQ|
|_||_
d
|_|j�
|j�}||krM|||_ndS(Ng�������?(RHtfilenameRt_opent_fsizetsz(RRHR�theadR�((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRys
	
	
	



c


Cs|j�
dS(
N(
t_close(
R((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyt__del__�s
c
Cs�|j�
y|j
�}
Wnttfk
r4


d
SX|
|j}|dkr[d|_dS|dkr�|jj|d�
|jj|�
}|
|_|StS(NRis==> File truncated <==
i(	t_followR�R�R�R�R�tseektreadR	(Rtnewsztbytes_addedR$((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�s








	




	

c

CsDt|j
d
�|_tj|jj��
tj|_d|_	dS(Ntrbi(
topenR�R�R_tfstattfilenotstattST_INOtinoR�(
R((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��s

"
c


Cs|jj
�
dS(
N(R�R((
R((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR

�s
c
Csbytj
|j�
t
j}
Wnttfk
r7


dSX|j|
kr^|j�
|j�
ndS(
N(	R_R
R�R

R�R�R
R

R�(RR
((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR
�s





c

Cstj
|jj��
tjS(
N(R_R

R�R
R
tST_SIZE(
R((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��s
(	R
RRR
RR�R

R
R�(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�xs
	
					tlogtail_handlerc
Bs/eZ
dZd
Zd�Zd�Zd�ZRS(sLogtail HTTP Request Handlers/logtailcCs
|
|_dS(
N(
tsupervisord(RR
((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�s
cCs|
jj
|j�
S(
N(R�t
startswithRi(RRH((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��s
cCs�
|
jd
kr |
j
d�

dS|
j�\}}}}d|krVtj|�
}nx$|r||ddkr||d}qYW|jdd�\}}y|jdd�\}}Wntk
r�


|}d}n
Xdd	lm}	
|	|�
\}
}|j	j
j|
�
}|dkr%
|
j
d
�

dS|j
j|�
}|dkrT
|
j
d
�

dSt|jd|d�}
|
dks�
tjj|
�
r�
|
j
d�

dStj|
�
tj}tj|�
|
d
<d|
d<|
jt|
|
d��

|
j�
dS(NtGETi�
RPiROi
R�i����(
tsplit_namespeci�
s
%s_logfilei�
s
Last-Modifieds
text/plainsContent-Typei(RcR�RaRRbRkR�tsupervisor.optionsR
R
tprocess_groupsRnRt	processesR�tconfigR_RitexistsR
tST_MTIMERtbuild_http_datetpushR�RA(RRHRiRrRsRttprocess_name_and_channeltprocess_nameR5R
t
group_nametgrouptprocesstlogfiletmtime((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��sB
























(R
RtIDENTRiRR�R�(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR
�s


		tmainlogtail_handlerc
Bs/eZ
dZd
Zd�Zd�Zd�ZRS(s!Main Logtail HTTP Request Handlers/mainlogtailcCs
|
|_dS(
N(
R
(RR
((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR�s
cCs|
jj
|j�
S(
N(R�R
Ri(RRH((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��s
cCs�|
jd
kr |
j
d�

dS|jjj}|dksNtjj|�
r_|
j
d�

dStj	|�
t	j
}tj|�
|
d<d|
d<|
j
t|
|d��

|
j�
dS(NR
i�
i�
s
Last-Modifieds
text/plainsContent-Typei(RcR�R
toptionsR"
RR_RiR
R
R
RR
R
R�RA(RRHR"
R#
((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR��s









(R
RR$
RiRR�R�(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR%
�s


		c Csg}t|j
�
}x�|jD]�}|d
}|tjkrk|d|d}}t||d|�
}nX|tjkr�|d}	|d}
|d}t|	|
|d|�
}ntd|�
�
d	d
l	m
}
d	dl	m}

d	dlm
}
g}x�|jD]\}}}y||
|�
}Wn3


tj�}|j
j|�

td
|�
�
n
X|j||f�

|j
jd|�

q
W|jd|
|�
f�

||
|�}t|
�
}t|
�
}||
�
}tjjtjjt�
�
}tjj|d�}tj|�
}tj|�
}|d}|d}|r�i
||6}t||�}t||�}t||�}t||�}t||�}n|j
j d|d�

|j!|�

|j!|�

|j!|�

|j!|�

|j!|�

|j||f�

qW|S(NtfamilyRJRKR�R�R�R�sCannot determine socket type %ri����(
tsupervisor_xmlrpc_handler(
tSystemNamespaceRPCInterface(
tsupervisor_ui_handlersCould not make %s rpc interfacesRPC interface %r initializedtsystemtuitusernametpasswords:Server %r running without any HTTP authentication checkingtsection("t
LogWrapperREtserver_configsR�R�R�R�R�R�txmlrpcR(
R)
twebR*
trpcinterface_factoriest	tracebackt
format_exctwarntappendR�R
R%
R_Ritabspathtdirnamet__file__RRt
os_filesystemRtsupervisor_auth_handlertcriticaltinstall_handler( R&
R
tserverstwrapperR
R'
RJRKthsR�R�R�R(
R)
R*
t
subinterfacestnametfactoryRtinstttbt
xmlrpchandlerttailhandlertmaintailhandlert	uihandlertherettemplatedirt
filesystemtdefaulthandlerR-
R.
tusers((s3/usr/lib/python2.7/dist-packages/supervisor/http.pytmake_http_serverssr


























	

















	











R0
c
Bs eZ
dZd
�Zd�ZRS(s\Receives log messages from the Medusa servers and forwards
    them to the Supervisor loggercCs
|
|_dS(
N(
RE(RRE((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRZs
cCsU|
jd
�
r|
d }
nd|
j
�krA|jj|
�

n|jj|
�

dS(s�Medusa servers call this method.  There is no log level so
        we have to sniff the message.  We want "Server Error" messages
        from medusa.http_server logged as errors at least.s

i����R�N(tendswithR-RER�ttrace(RR�((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR4]s




(R
RRRR4(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR0
Ws
	tencrypted_dictionary_authorizerc
BseZ
d�Zd
�ZRS(cCs
|
|_dS(
N(
tdict(RRU
((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRis
cCso|
\}}|jj
|�
rg|j|}|jd
�
rZt|�
j�}|d|kS||kSntSdS(Ns{SHA}i(RU
RmR
Rt	hexdigestR�(Rt	auth_infoR-
R.
tstored_passwordt
password_hash((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyt	authorizels







(R
RRRZ
(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRT
hs
	R=
cBseZ
dd
�
ZRS(tdefaultcCs)tj
||
||�
t|
�
|_dS(
N(RRRT
t
authorizer(RRU
thandlertrealm((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyRys
(R
RR(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyR=
xs
(((((((((((,R_R
RGR�R�R�R�R5
R�tImportErrortgetpassthashlibRtshaR
R�RR�RRRRRtsupervisor.medusa.auth_handlerRR	RRRR"thttp_requestR&R�R�R�R�R�R�R
R%
RQ
R0
RT
R=
(((s3/usr/lib/python2.7/dist-packages/supervisor/http.pyt<module>
sN



















��5V6A	I