ÿØÿà JFIF    ÿÛ „ !.%+&8&+/1555$;@;4?.451 4,$,44444444444414444444444444444444444444444444444444ÿÀ  á á" ÿÄ     ÿÄ ?    !1AQaq"2‘¡±ÁðBRbrÑá#‚’¢²3S CñÿÄ   ÿÄ !    !1QAa‘2ÿÚ   ? 5˜Z¯V¦cø)›t/? z¨±>Õ5€¶‹Á¤·¼z¼Ü¬+ñ®v¤¨_ˆR­BFn©—˜ý®ç̝P8gýt·ÉSTŦˆìät?þé¼íìN/Þa)ì–í6ô… Ï¿øÃj´¿KÇü]ÿ ªô¹-eKànëÕHTx}ýSÜ›ÿ ”7Ø×&µ<¦  ¥ÑO¶[Ù¯ä¨ÞÃÿ PZ-¬;#õ|•oaÿ ©CìÞz3˜öː/¤­ñTûIØ}š^ mÓ%ªxˆ¥ÉŸu=Z+ISe¿45™¼u;ú&WØ÷€æßQ™®{|íx*TC“#ZŠìZ§²‹ 6pv…³¿¡äª*áZÐ%ÒOáˆo"x«OHk w±æ+¬V(kMúŸ5Vö«$ ÁrÏbàb57/luR ¸ÑÛj Òµì`Мq­û žICÀÊ•©4€Âcà¨Ï€O´<èÐ:›ù(Ë^L8þ‘ÍÌ#¸Ð_Ì©ÙK(Öz 4¬û+¸;ü’V’84‘¬ÃŽ:[â‡ÔÌáõp¢~§ªlæ£ö{®G>J¼"°‡7¯ÆÉèßû ‹É‹§ÁòÃýâßî ^ƾÙõ‹×óH#«LP½ïX=xÑÍ$|W?•~• îëÔ©ª‹ {ÝT…Kÿ ”hûâá)J*ö˜–ÔU;iÇ€/ ÆþjóZ\ýwØ=Ìm ºèËL9 ýèÆð/¨’¥öo=nË.%Îì ŽÕ¯È|{Oj²ƒE6e/ßdÄõ²Ìâ1O®ò×TsəԸhOMýíMˆ¿¼H˜l²,7Â¥#MF/Úf°Ö½± ¸–dr‹NýÊ íjqx{œÉ ä-È ¦ øÄër¨q°ð †nцýÑÄÆ’mä…n<0È™;ÁÝá¯ÁZƒ7FÀmì­ É&9ˆîéi¶ùN§Y• ÃZãAâ?•‡©‰ , ó¾IŸŠc1 4â&y­&pŠ­6;M À 0¹qç»p.á …ŸÅáK@%6·y6ƒ‰3?”úºŽ‰éX5ªPT §µ!=Mž«Ú½‹ÅgÂSâÉaþÓoö–¯ÁÔìR>5éÿ üs¶ÆUcÌ kÇR ]ÿ ù¬¼«VŽ;Â|‡~¢¦”ÏŰæ {L™Õ°Óv¹ò¸írޡעCÃ!íVÕ {¶»sŒNPg/ "uÕbkm²“$ďå¿é¹§°½æz¯6 †s¿!s–wÚÝ“™Œ °.ûj>·+™Òa…©Œ&rÝÎtÛë긪Ît’LAVp%c Úý[ÄzJ¾ÇàXXç@˜ó<êL]·T˜¾¥1Ó©V‡g´æ½¦Ý@¹óø!_@´ÞâSÁ —S3™•& ]@JHÚý©ZŽ €×æÔr»Áf!‡yÞ4Mv*èÓã_{‘åóUuљØ«Oïé*®EvÑ Œ÷‡U \"㪒ÍK+À 4“M¡ï:0¥5í!'<@î´”>Ç»&Z–ïCCV˜Ì5Šo&îhè.žû |ÓK©h$s6KìŒëã)¹hI¦GïOåóI;ììü#É$Š0…Ææ¥TØ.5­¾gn´ “ÂÖ\:hœ89G)J@„}œ:’Ò{/Š"¦_Æ×7Æ3VÇŠÊa]ÚŒÙ€Ä–=®uÁßâACZƒ§§£ Qnâ:«,×{tyø¬iÛcœÜÄ€H½ÄÍCk´÷šß .W'b¤Íåh]÷€=,Žv×cÚEÚHXJX¶îo¨FÒtèöŸ>ªª6[J®Fµ£sGÁeqõfe\íjÒÐïÄÐGˆe1Ø‹.Ø”‘Ëuø Y­ˆÜ ŽG|zùªüMpDnQWÄ”%JŠ™)â*p@Örš«ÕT2Ð%ˆG#ª„ ·¤!°ŸOTÂT¸aÚ%4&h™LµšØüÐ.F¿²ÐÞ_Ç‚¾ÅÃaÜ÷09Æ q€öy˜v‡85õN÷]¬äѼóS{°_MެúÔ#°Ç¸0åÞè2ëôPcvÆw9®ií1Ä8F™˜à‰´+‰Ik1òÝ7“Ñ×ÒsÝ\x‚h`ÞÑ`ó"|µEcý£n˜h`}GÞ !±ù²Ápü²ß6 0ïi󜵩SÈÇ7˜-ÕURO˜¦´f$ªž-Í6(œ}<„ éc øs]ŽŽ„*—¾ ìdŽ„)méª\¿êÎIg¾ØÞ~I#C/¼¼´EÁÈŽi8“©õådô·>euä ƒ'Ê×लR1ÉJE1ÐAát`t;ÇР%Ý<‡¥„ÍÆ`×Oyó)õiI€ñQaŸ4Ûù\áàaÃÔ¹HÃu¹*k€¦<„e S‡&õÏ B!ŽhüÞ`yj}mªf×\¿ Ç~æ­9‡û\՞Ǖg²1Žû5V7 !àöšm° c`ܬøÇìµÒ'P"?…´Ö,"§^•õލsÔ)6˜sæéÍR¼ ò|Sl”‹7 nPW Gòú÷½§O¯‡„l¡kSÞŒr½PÊ@æ¢pŽ-mÿ #Ÿ˜Àº¶Áä¦;ïÔæ$1££`“Õ>„—·ž)ßð³ñ#Ï Ô$¶œ‰ÊE‹À;÷º ¯«P:Ñ”8–IÊtpÞ3ª“>ê“þës4ò2OÏÕ­±zô†Õ§‰.÷ä¸;¿˜“'œ›žª}«Œ{ª±Ì 9ÔóÞÕ‡0 $íWV3Üì¬ —@kÝ4@¿r¼±½¬™›?øØæ´'Áé®CË3-g$˜ö‡×auÚi´Žp/êÛ æF›Ú2v‹ã¿¿,nB1̨ƃqÞa5͝@&Æû“él÷ \C²½UÍc ¯k×¢U ÖéQå™—-r wô ÞÏ<Ò=&=ÿ Ôê Òêˈt,i—;LîÜ á¸*ÚÃ1$êL•LÍ <É)ýÐà’ ;F™{ƒ™˜€&'}‚ãÄK`¡ÞT@I;®žZóè‚s’7®°›+§O­Åq©é»²9<Ô J ¼9O’HL»Ùïì¸rk¼Ž_ý‘TŸu[²ßÚŒ·ü÷B%¯E ŸÔX5êO´ Ç•€’I0 ÉJX` ñ¹õ%;µŸD‘«´€àwÒ™U ûئžÖö\×®×´8 ½‡ºÐÆÓ§?Àkmœ=;d5*@-ì0F Rªýš[Ü6âö̃ڸr*KA9· u*µæ£?U¸Âêí†8@¦X4 e-ò„0s{ HâUpU?¼mñRa°®a%Ð'tÉ×’\¾ÊÉ]t›h>·(Ë@R¼¡Ãt h}’O÷au<+nT…Ö…MӐ??Óe95 q>í/;&JSû °¯ÊéÞ øƒ*Ã2½Ài&:nôUl=¾¿5eˆ3”ñc|Ú2V”>„»&eE;«ÚäC p¢Û úy 9š[ŒÌx¼擼A&DåÒ¯ˆ¤ÀÌ;"˜ ÏQä¸åhÊ}Ûq«Û0WžÒ|»€ø®öCm5•\ÇÀ§Pe3£]0ÃàLDÉ‰1øªxjgwT‚÷¿LΨK‹›ùs—xˆÜ±µ kæ¸f‰‰ÜGk/LÛØ6d9ò¶ùA{ƒA3š/¬D¬khÓk‰`˜"㯒r¿±Óã jx‡°e}<Ñø\3y:'À•/h½Í€Ç4~g ?Û(¼]v‘ªlKÎâ~?O‚W%{Ì:“'©úNq¾›úo(X’¥¯ˆ nFê{Ç€ü?º'ë ø‹ì Þ09ŒÌç9Æ —ËC`j@ÓÄ(+a‹un¸#ÂꟋ{K`‘ÑÍÍ'à´»/Û,KW;Þ4²þð ï Nm|~fGÏ(…³Ã)«1ö­Õ ¥‡¨©ƒÃ™ü-s=à=U66Ï«Ýc蓦W¹íž®›nÔ%êÇìŒ<#Ü×84ån®Ð ÒåOC` ñânÑs‡¢ç 1õ%Îhì½Ã½® e:ݼUZo™`  ÅZŸŒÊ«ê1ÏÄo$q¹Þ€©ˆhÐÉä¯ñ[!…Ú˜àJ:x2$Íß&PåT£6ç— ‡Í*4Ýšçjÿ ‰É nófÐ ó(L5C•åÆ\rMÒ@ò }y-W}™üýVù—ú¢=Ù”c®‘< M ž ´Phr ¦©TD ‘ù.$´÷O‡‘V2Æò.=IUŒ=ž‡â¬i™aþÓåÙ?òUø'ØÖ•.~* šTŒ!•-×áºTâ®ä#õü'´ eýlYÅÓeÕKÂrT"CÚ@u!Óxƒ{š3€}1¿(r}%«nËamjÑ%ÑNEò v ˜à  σöK³,*º.àzù¨™Ó ÚçâU¦*¿ 9{%Ö¹ njûdaXöb) kÛÆ±ûÓ\°M7ˆÂ=û›ç¿Ã‚­V»Cg–8ÙêE- j)k$º`Ã-ùEýeBÆÇ]c¡°ñty&Òd0nõ'¡W+ƒ*|–øµFa\GQªEAÔp5\Ǽ·¼Ç8·õ -â§Ú[ ‡ uZeÖ 3}×d'+¹:ð+K†Û®s!Ï$úe€<Û”x)1»a­¡LC]¸µík…ÚàA»AYº{†ªS[¦5HÒ7ù --,ísòDØ€èk ÞÀîÜ ò@â( ËNˆë›4ô½•/¦o‡€Û7 ê•ÆêòðÜy'Án½µ á˜ݦ ndeo…[ì¶Ê,¥R³Ä=À±—–ß;£™´ñSâ*g§”ïaið‘Jå~™ÓÞ ß³Õ¢»8x埒²52>AÊb&-÷\7´éÄù€T˜,w;3{ï˜k…à¹ÄqÀ«œ{€\ ˆ¾[´¨јr &Úé„Ívˆ±8†¿]|¬ņ4I×pÞS1ÈÖz‰#Ìv‡G!YNògñ:màTz¢Ý1ô©^O=~ë|5Bã™ç•¼µõ•bÆ@úÕS¬ÈŒ#¬zünrŸ û” Z²•èðV"ÁHÚý©wÝ €7¼Ìu1hÑa3Éä û f$o¿É ™Ú›ÝçnpÒ3äÌ3†Í§,Äï]$‰/pê †«À¼¸e9­Æê_C]žƒ·ý·frÁN«, E=›Çq -‰öŒ:aÏ¿±í&£Í:-} 84‘ÿ eƒQÑeëSsuiA ³g㟥ú£?ÿ ʼn*”“÷aühe:ÊWa@ÒÞk±eØ] F Ô—r.åä˜ @ö¥ªZoÐýYL·¥S²G/‡ñ <~*ZÆ´è>JlòàÛÆ½ÿ 窘ìGN¢:I®KšJp/`íIÁÀõ#Ä-€ö­šµŒoF4|ÆQØÆ@Ì|£Ô…¢À{9˜è½Üó›€ôYÒÎYsið;ís¤€à²ˆ‚4qÉVŒI$ ‰"° æµ8cXGjœˏ¡Aâý•ËÜ¢ûï e·çLx']á"oÅÎê3¯Ç—¹”ó0nå‚âg{Œñ> S´˜îè°g238‚ãköÝfÚd´6Ò€;ò÷±¢™¼›º ¢Æ'¥Ðx'e¬ç ]bÈÆV¢ó‹kýBO ðÊâ$Ÿ!×T 3Mýמ žìٍàÌü‘8÷€àæØ8æ©6‰©L´«…oãpð„~Çk‰!ñ;‹”ÛžÍ àž±z Ÿôû øŸÝužÏ;ÿ #|u6™Þ¬ÚˆÐõA4¶â|ôl|Ê2ŽÇ¤ÝÅÇY.<#Aí.k§hóF‚”Y; M½Ö4hŸ4&›­¿tès´%FìL¥£Ãk‰ÇT¤haÁ¤ÚxfÉ`ÑìË›>i 3t‚:,–+^÷´–{Û–Nxi"x‘Ûg î¨>¥Õ܁ùZH,2Û“:8xÊ¢Çí9.É-Ìâã-=çjwµS˜dütžçwýGòú®®ûº_ˆýx$–¡ãøO EÚÛÏ÷R„×w+3£Á£öUMyR²¹âŒ°š›¸Ñãò9§Ó_Dl+Ùßc›úšGÅÌc†Ž!Ko=¶.‘Îÿ c²(2®V mª.ÿ ¹B›¹å ù„öŸSV>™ü¯$y:G¢Z×àøúdî¹û­·ýÇ´:•c LÍõi_‹ö+ÎæGÊè>OŠ•äž´§Þ{X}¨1ÚTc›»Qþ•êô°t¿OP?eæ~É{5]•ÙR£r5†nZ\ã@ &îJõ ¾àC°þV>fé¥/ü5ñÊIº_é5 ;e­h<@ Ä&æÃëE%;X,ÒãÆÞ`Oò¦kŸm#˜!ÀyÄ¢| óLšò¥Ä` ¶R=|ÈCâh5ò3DˆïF†ðÒ#ÅìÛœ?¸yhBãœí ZxßÎÄhºRK„`Þödvײ™ÀÈÑÒgŒuY w³%†ƒÓzõ ÖÏp‚dH®¦A´ù§»ÓÇMæ~)ˆð‡û:ù&Ä •vGD´À n ݇¼Ö8Fö óáà£~Ë¥x`oK|Ä?fxiØü%pìR>éò+Û±éÎ>núlFŤ'tq8LZÏvÃ?„¡ß±È⽆¯³íü@x|PöUäèØã¡ð‚ŒAìÏ"vÍwóŸÍ{ ý0.z È•Ö{,N¡£¡ŸKÕÙž>Ýœþ ÍÀ°<×EA!Å‚D™IúOÍ¡>ôG}Â` ÍßkÜL™Ž Þð™ {IøF²¹òQ3&!ÃÂÞz.d&Ï-sH¸,Ôõ˜ŽP€ 77ˆÝ¼ÊëÜw =cÕ Ú,ØÐ5ÎYÐ)ì´öœgŒ[¤ßv㙑8心>h]§µháYš£²ºÑ.{Ï7Sð•?´~×SÃKýJÛ˜ ™Íäiúu<µX¶1õ^kâçIÑ£sZ4h>j*ÔšD:4­¿_ ÷¸ Õxæÿ ¸?Mù _•­ÊÐ ä ÷ý ÑwL œ­ïnTkÛUÍN©ë:¦fV ¶ÜÔÜMªÅâA½–¿R×TXš-%iTÊT•‡Ù‚JôϐZxWÑè‰f‰òG º ×Õû2aZ7OU3[“×AT–ÞŒ…-‘¤”Ì ì&(ˆ¿­•ƒkï’:ðY¦W‘ Å)“†‘˜³Åtcø˜ñTÂwÚÇ4|üLÇªí–v- qˆèU qPE.†â‘˜µ Æ,ÐÅs]8¾„oúÑ i>ÜxxÈó)ƒ ´æÁâØ$À‰vžŸf$Ž |ãw;ÀÁIJ»b` {¦Ó¤Ú$©YÀ‘n@Óïž«9J¼êG m¤ ܯ¹ÌW4€ÐÒÅÛ‡#褕Ÿn-?í|с¥÷Ú¹¬'´ÞÜ9ÓK `hê£SÄSà?7—Wí_´…óB›»:=Ãïq`<8ñÓŒÑlú2d¬ê³£hÖ[l|$vÝro~'R®‰§°ñmY ͧäP |PUª¹·:3Œ[Û{Xÿ ºâ@‚W–Äé u‚ ¯´*=íή.pûÒdt @G‰¬ s¸ ëÉücr ÞæÑ¨Ê@>¤¢Ö±. Þ'¯°ÌME[YéïĵÂCå½ Ué©Áû'Ê9%eÔðNU”ë‘ÌsD3/®+UI˜9h.WC”빓$#:pz:YÓ ¿xž* ³$Í +$kñAŠ‹†¢ Uê>¸)_š¬÷©ßAÂÔb9ÇU ¯¾á•9¯ÏÏ÷O÷¼¼Fähal1‰3Ì[Ïr•´UCksNÐ] R‘¸¥H+§Šé†c©vÖÞ0iÓ76s†î!§=ß ¼~Ô'°Ãmäoäš³ªøi1úÉ)³yV8 CLÄØÁ‘WYïi€H6ÖÑiámø^ÈY´°Ñ7¥Û*—Ñ©L«Qƒï—Ùrÿ ›£Ð*š¸ˆL©ˆ$ˆ ÷¾D§9È®«qbqC)–ˆïv´çñsÑVT­Ø, <àïºÀO«Jý·õ àfPìð .wFšir´þ’2_Y *Æ€x\« ì€9š@ Ž|F⇥ˆkZ@hÖÄ0t¿-<“‹qµ¾*ZL¤Ú)&BJpÓF5=$„at*Zš$’ÑtdûÝRI1 2މ$€$I$#‰SÞ’Hë¬ï;Á$¡t$’`<(ñÇt)$‡Ð.Êf¢X’Kt=Éé$‚ˆªè¢oÝëòI%Rgcª÷ŠyI%¡‰ÿ !ñ)´õ $¤ Ô’IIGÿÙ (iVOdZddlZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZdZejeedee e eeeehZ en #e$riZYnwxYwdZGdd eZeee fZ!d Z"d Z#d Z$d Z%ddZ&ddZ'e'Z(d dZ)GddZ*Gdde*Z+dZ,d!dZ-ej.dkrGddZ/Gdde*Z0dSdS)"aBasic infrastructure for asynchronous socket service clients and servers. There are only two ways to have a program on a single processor do "more than one thing at a time". Multi-threaded programming is the simplest and most popular way to do it, but there is another very different technique, that lets you have nearly all the advantages of multi-threading, without actually using multiple threads. it's really only practical if your program is largely I/O bound. If your program is CPU bound, then pre-emptive scheduled threads are probably what you really need. Network servers are rarely CPU-bound, however. If your operating system supports the select() system call in its I/O library (and nearly all do), then you can use it to juggle multiple communication channels at once; doing other work while your I/O is taking place in the "background." Although this strategy can seem strange and complex, especially at first, it is in many ways easier to understand and control than multi-threaded programming. The module documented here solves many of the difficult problems for you, making the task of building sophisticated high-performance network servers and clients a snap. N) EALREADY EINPROGRESS EWOULDBLOCK ECONNRESETEINVALENOTCONN ESHUTDOWNEISCONNEBADF ECONNABORTEDEPIPEEAGAIN errorcodeznThe {name} module is deprecated and will be removed in Python {remove}. The recommended replacement is asyncio) )removec tj|S#tttf$r |t vrt |cYSd|zcYSwxYw)NzUnknown error %s)osstrerror ValueError OverflowError NameErrorr)errs /usr/lib/python3.11/asyncore.py _strerrorrIse'{3  y 1''' )  S> ! ! !!3&&&&'s-A A  A ceZdZdS)ExitNowN)__name__ __module__ __qualname__rrrQsDr"rc| |dS#t$r|YdSxYwN)handle_read_event_reraised_exceptions handle_errorobjs rreadr*VX     ;c| |dS#t$r|YdSxYwr$)handle_write_eventr&r'r(s rwriter/^sX        r,c| |dS#t$r|YdSxYwr$)handle_expt_eventr&r'r(s r _exceptionr2fr+r,cD |tjzr||tjzr||tjzr||tjtjztj zzr| dSdS#t$rH}|j tvr|n| Yd}~dSYd}~dSd}~wt$r|YdSxYwr$)selectPOLLINr%POLLOUTr.POLLPRIr1POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorerrno _DISCONNECTEDr'r&)r)flagses r readwriterAnsT 6=  $  ! ! # # # 6> ! %  " " $ $ $ 6> ! $  ! ! # # # FNV^3foE F             7- ' '                            sB&B,, D67C99#Dc|t}|rog}g}g}t|D]{\}}|}|}|r|||r|js|||s|r|||g|cxkr |cxkr|krnntj|dStj ||||\}}}|D])}| |}|t|*|D])}| |}|t|*|D]+}| |}|t|*dSdSr$) socket_maplistitemsreadablewritableappend acceptingtimesleepr4getr*r/r2) timeoutmaprwr@fdr)is_ris_ws rpollrUs { " BBCIIKK((  GB<<>>D<<>>D   CM   t      a    1      Jw    F-1a111a  B''"++C{ IIII  B''"++C{ #JJJJ  B''"++C{ sOOOOE""<  r"c.|t}|t|dz}tj}|rt |D]y\}}d}|r|tjtjzz}| r|j s|tj z}|r| ||z||}|D]/\}}| |}|t||.dSdS)Nir)rDintr4rUrErFrGr5r7rHrJr6registerrMrA)rNrOpollsterrRr)r?rPs rpoll2rZs' {gdl##{}}H "CIIKK(( - -GBE||~~ 877||~~ (cm (' -!!"e,,, MM' " " " "IB''"++C{ c5 ! ! ! !!"" " "r">@Fc|t}|rttdrt}nt}||r||||dSdS|r!|dkr||||dz }|r |dkdSdSdSdS)NrUr)rDhasattrr4rZrU)rNuse_pollrOcountpoll_funs rlooprbs {GFF++ } # HWc " " " # # # # # eaii HWc " " "AIE eaiiii    iir"ceZdZdZdZdZdZdZdZe dhZ d#dZ dZ d$dZ d$dZejejfdZd$d Zd Zd Zd Zd ZdZdZdZdZdZdZdZd%dZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(d Z)d!Z*d"Z+dS)& dispatcherFNwarningc| t|_n||_d|_|r|d|||d|_ ||_dS#t$r>}|j ttfvrd|_n| |Yd}~dSd}~wwxYwd|_ dS)NFT)rD_map_fileno setblocking set_socket connected getpeernameaddrr<r=rr del_channelsocket)selfsockrOrs r__init__zdispatcher.__init__s ;"DIIDI     U # # # OOD# & & &!DN  ,,..    96 222&+DNN $$S))) #NNNNN DKKKsA.. B683B11B6c|jjdz|jjzg}|jr|jr|dn|jr|d|jV |d|jzn7#t$r*|t|jYnwxYwdd |t|fzS)N. listeningrkz%s:%dz <%s at %#x> ) __class__rr rJrmrIrk TypeErrorreprjoinid)rpstatuss r__repr__zdispatcher.__repr__s.+C/0KKL > 'di ' MM+ & & & & ^ ' MM+ & & & 9  / g 12222 / / / d49oo..... / 0 0"T((;;;s&B1B87B8c,||j}|||j<dSr$)rgrh)rprOs r add_channelzdispatcher.add_channels ;)C DLr"cB|j}||j}||vr||=d|_dSr$)rhrg)rprOrRs rrnzdispatcher.del_channels0 \ ;)C 99B r"c||f|_tj||}|d||dSNF)family_and_typerorirj)rpfamilytyperqs r create_socketzdispatcher.create_socketsK%t|}VT**  r"cp||_||_||dSr$)rofilenorhrrprqrOs rrjzdispatcher.set_socket#s2 {{}}  r"c |jtjtj|jtjtjdzdS#t $rYdSwxYw)Nr])ro setsockopt SOL_SOCKET SO_REUSEADDR getsockoptr<rps rset_reuse_addrzdispatcher.set_reuse_addr(s  K " "!6#6 &&v'8'-':<<>?@          DD sA A$$ A21A2cdSNTr!rs rrGzdispatcher.readable9tr"cdSrr!rs rrHzdispatcher.writable<rr"ctd|_tjdkr|dkrd}|j|S)NTnt)rJrnamerolisten)rpnums rrzdispatcher.listenCs7 7d??sQwwC{!!#&&&r"cD||_|j|Sr$)rmrobind)rprms rrzdispatcher.bindIs {%%%r"cLd|_d|_|j|}|tt t fvs|tkrtj dkr ||_ dS|dtfvr||_ | dSt|t|)NFTrr)rk connectingro connect_exrrrrrrrmr handle_connect_eventr<r)rpaddressrs rconnectzdispatcher.connectMsk$$W-- ;+6 6 6 &==RW__DI F 1g,  DI  % % ' ' ' ' '#y~.. .r"c |j\}}||fS#t$rYdSt$r'}|jt t tfvrYd}~dSd}~wwxYwr$)roacceptrxr<r=rr r)rpconnrmwhys rrzdispatcher.accept[s ++--JD$:    44   y[,???ttttt  s" A AAAAc |j|}|S#t$rD}|jtkrYd}~dS|jt vr|Yd}~dSd}~wwxYwNr)rosendr<r=rr>r;)rpdataresultrs rrzdispatcher.sendis [%%d++FM   yK''qqqqqm++!!###qqqqq s A,A'"A'&A''A,c |j|}|s|dS|S#t$r.}|jt vr|Yd}~dSd}~wwxYwNr")rorecvr;r<r=r>)rp buffer_sizerrs rrzdispatcher.recvvs ;##K00D !!###s    yM))!!###sssss  s066 A."A)(A))A.cd|_d|_d|_||jJ |jdS#t $r!}|jttfvrYd}~dSd}~wwxYwdSr) rkrJrrnrocloser<r=rr )rprs rrzdispatcher.closes  ; "  !!#####   9Xu$555655555  # "sA A8A33A8cdtjdt|zdS)Nzlog: %s )sysstderrr/str)rpmessages rlogzdispatcher.logs) s7||344444r"infocD||jvrt|d|dSdS)Nz: )ignore_log_typesprint)rprrs rlog_infozdispatcher.log_infos7 t, , , dddGG, - - - - - - ,r"c|jr|dS|js1|jr||dS|dSr$)rJ handle_acceptrkrr handle_readrs rr%zdispatcher.handle_read_events| >       ,))+++                r"c|jtjtj}|dkrt |t ||d|_d|_dS)NrTF) rorrSO_ERRORr<rhandle_connectrkrrprs rrzdispatcher.handle_connect_eventsak$$V%6HH !88#y~~.. . r"c|jrdS|js|jr||dSr$)rJrkrr handle_writers rr.zdispatcher.handle_write_eventsQ >  F~ , ,))+++ r"c|jtjtj}|dkr|dS|dSr)rorrrr; handle_exptrs rr1zdispatcher.handle_expt_events[k$$V%6HH !88                r"c t\}}}} t|}n#dt|z}YnxYw|d|d|d|d|d d|dS)Nz)<__repr__(self) failed for object at %0x>z-uncaptured python exception, closing channel z (:rv)error)compact_tracebackryr{rr;)rpniltvtbinfo self_reprs rr'zdispatcher.handle_errors-//Q6 OT II OCbhhNIII         s%;c2|dddS)Nz!unhandled incoming priority eventrerrs rrzdispatcher.handle_expts 99EEEEEr"c2|dddS)Nzunhandled read eventrerrs rrzdispatcher.handle_reads ,i88888r"c2|dddS)Nzunhandled write eventrerrs rrzdispatcher.handle_writes -y99999r"c2|dddS)Nzunhandled connect eventrerrs rrzdispatcher.handle_connects /;;;;;r"cJ|}| |j|dSdSr$)rhandle_accepted)rppairs rrzdispatcher.handle_accepts3{{}}   D $ ' ' ' '  r"cZ||dddS)Nzunhandled accepted eventre)rr)rprqrms rrzdispatcher.handle_accepteds*  0)<<<<8J    "''' &&& / / /      $    555....            (FFF999:::<<<((( ===r"rdc.eZdZddZdZdZdZdZdS)dispatcher_with_sendNcLt|||d|_dSr)rdrr out_bufferrs rrrzdispatcher_with_send.__init__s%D$,,,r"cd}t||jdd}|j|d|_dS)Nri)rdrr)rpnum_sents r initiate_sendz"dispatcher_with_send.initiate_sends;??4%)@AA/())4r"c.|dSr$)rrs rrz!dispatcher_with_send.handle_write s r"c:|j pt|jSr$)rklenrrs rrHzdispatcher_with_send.writable sN";s4?';';;r"c|jr%|dt|z|j|z|_|dS)Nz sending %s)rrryrr)rprs rrzdispatcher_with_send.sendsO : 5 MM,d3 4 4 4/D0 r"r)rrr rrrrrHrr!r"rrrsd555 <<<r"rcftj\}}}g}|std|rQ||jjj|jjjt|j f|j }|Q~|d\}}}d d|D}|||f|||fS)Nztraceback does not existrvcg|]}d|zS)z [%s|%s|%s]r!).0xs r z%compact_traceback..+s666!\A%666r") rexc_infoAssertionErrorrItb_framef_code co_filenameco_namer tb_linenotb_nextrz)rrtbrfilefunctionliners rrrs|~~HAq" F 97888  K  * K  &       Z  !":D(D 8866v666 7 7D (D !1a --r"c&|t}t|D]Q} |#t$r}|jt krn|sYd}~;d}~wt$r|sYOxYw|dSr$) rDrEvaluesrr<r=r r&clear)rO ignore_allrs r close_allr.s { #**,,      GGIIII   w% #        IIKKKKKsA A: A&&A:posixcBeZdZdZdZdZdZd dZeZeZ dZ dZ dS) file_wrapperc8tj||_dSr$)rduprRrprRs rrrzfile_wrapper.__init__SsfRjjDGGGr"c|jdkrtjd|zt||dS)Nrzunclosed file %r)source)rRwarningswarnResourceWarningrrs r__del__zfile_wrapper.__del__VsDw!|| 047%)++++ JJLLLLLr"c0tj|jg|RSr$)rr*rRrpargss rrzfile_wrapper.recv\s747*T*** *r"c0tj|jg|RSr$)rr/rRrs rrzfile_wrapper.send_s8DG+d+++ +r"Nch|tjkr|tjkr|sdStd)Nrz-Only asyncore specific behaviour implemented.)rorrNotImplementedError)rpleveloptnamebuflens rrzfile_wrapper.getsockoptbsA***6?**+q%'566 6r"cd|jdkrdS|j}d|_tj|dS)Nrr)rRrrr s rrzfile_wrapper.closems1w{{BDG HRLLLLLr"c|jSr$)rRrs rrzfile_wrapper.filenots 7Nr"r$) rrr rrrrrrr*r/rrr!r"rrrNs  ! ! !     + + + , , , 6 6 6 6        r"rceZdZddZdZdS)file_dispatcherNct|d|d|_ |}n#t$rYnwxYw||t j|ddS)NTF)rdrrrkrAttributeErrorset_filer set_blocking)rprRrOs rrrzfile_dispatcher.__init__ys   dC 0 0 0!DN YY[[!     MM"    OB & & & & &s: AAct||_|j|_|dSr$)rrorrhrr s rrzfile_dispatcher.set_files>&r**DK;--//DL        r"r$)rrr rrrr!r"rrrws7 ' ' ' '     r"r)rBN)r[FNNr)1__doc__r4rorrKr rr=rrrrrrr r r r r rr_DEPRECATION_MSG _deprecatedrrr>rDrr ExceptionrKeyboardInterrupt SystemExitr&r*r/r2rArUrZpoll3rbrdrrrrrrr!r"rr)s8*  NX/@@@@ :xL% "## JJJJJ'''     i    !2J?(%%%%N""""4 $aaaaaaaaP :6...(>7g''''''''R*Us A##A-,A-