- H ?csdZ/1dkZ2dkZ3dkZ4dkZ6dkZ7dklZlZl Z l Z l Z l Z l Z lZ:y ;eWn<ej o=hZnX?deifdYZBdZDdedZqdedZded Zd ded Zd fd YZdefdYZdZedZdkZeidjo?dkZdfdYZdefdYZ ndS(sBasic 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(sEALREADYs EINPROGRESSs EWOULDBLOCKs ECONNRESETsENOTCONNs ESHUTDOWNsEINTRsEISCONNsExitNowcs?@RS(N((((s%/mit/python/lib/python2.2/asyncore.pysExitNow?sif0.0cscDE|tjo Ft}nG|o5Hg}g}g}Ixe|iDI]T\}}J|i oK|i |nL|i oM|i |nqOWNy(Ot i ||||\}}}Wn9Pt ij o'}Q|dtjo RnnXTtoU|G|G|GHnWx|DW]}XyY||}WnZtj o [q9nX]y^|iWn5_tj o`tnab|inXq9Wdx|Dd]}eyf||}Wngtj o hqnXjyk|iWn5ltj omtnno|inXqWndS(Ni(smapsNones socket_mapsrswsesitemssfdsobjsreadablesappendswritablesselectstimeoutserrorserrsEINTRsDEBUGsKeyErrorshandle_read_eventsExitNows handle_errorshandle_write_event(stimeoutsmapseswserrsrsfdsobj((s%/mit/python/lib/python2.2/asyncore.pyspollDsR  (       csqrdk}s|tjo tt}nu|tj owt|d}nx|oyg}zx|iDz]}\}}{d}||i o}|i }n~|i o||iB}n|o|i||fnqvW|i||}x|D]\}}y||}Wntj o qnXyH||i @o|in||i@o|inWn5tj otn|inXqWndS(Nii(spollsmapsNones socket_mapstimeoutsintslsitemssfdsobjsflagssreadablesPOLLINswritablesPOLLOUTsappendsrsKeyErrorshandle_read_eventshandle_write_eventsExitNows handle_error(stimeoutsmapsobjslsrsfdsflagsspoll((s%/mit/python/lib/python2.2/asyncore.pyspoll2qs@         cs*|tjo t}n|tj ot|d}nti}|ox|iD]z\}}d}|i oti }n|io|tiB}n|o|i||nqpWy|i|}WnBtij o0}|dtjo ng}nXx|D]\}}y||}Wntj o qYnXyH|ti @o|in|ti@o|inWn5tj otn|inXqYWndS(Nii(smapsNones socket_mapstimeoutsintsselectspollspollstersitemssfdsobjsflagssreadablesPOLLINswritablesPOLLOUTsregistersrserrorserrsEINTRsKeyErrorshandle_read_eventshandle_write_eventsExitNows handle_error(stimeoutsmapsobjserrspollstersrsfdsflags((s%/mit/python/lib/python2.2/asyncore.pyspoll3sH        f30.0cs|tjo t}n|o-ttdo t}n t}n t }x|o|||qfWdS(Nspoll( smapsNones socket_mapsuse_pollshasattrsselectspoll3spoll_funspoll2spollstimeout(stimeoutsuse_pollsmapspoll_fun((s%/mit/python/lib/python2.2/asyncore.pysloops      s dispatchercsdZdZdZdZeZeedZdZedZedZ dZ edZ  dZ d Z eid jo d Zn #d Z*d Z0dZ4dZ@dZJdZUdZgdZmdZtdZwddZ{dZdZdZdZdZdZ dZ!dZ"d Z#d!Z$RS("Nics|on|i|||iidd|_y|i|_Wnti j o nXn t |_dS(Nii( ssocksselfs set_socketsmapssockets setblockings connecteds getpeernamesaddrserrorsNone(sselfssocksmap((s%/mit/python/lib/python2.2/asyncore.pys__init__s   cs|iid|iig}|io|io|idn"|io|idn|it j oTy|id|iWn/t j o |it |inXnddi |t |fSdS(Ns.s listenings connecteds%s:%ds <%s at %#x>s (sselfs __class__s __module__s__name__sstatuss acceptingsaddrsappends connectedsNones TypeErrorsreprsjoinsid(sselfsstatus((s%/mit/python/lib/python2.2/asyncore.pys__repr__s  "cs4|tjo t}n|||iti |dS(Nii( sselfs connectedssockets connect_exsaddressserrs EINPROGRESSsEALREADYs EWOULDBLOCKsEISCONNsaddrshandle_connectserror(sselfsaddressserr((s%/mit/python/lib/python2.2/asyncore.pysconnect4s    cs{@Ay)B|ii\}}C||fSWnEDtij o3}E|dtjoFnHti|nXdS(Ni(sselfssocketsacceptsconnsaddrserrorswhys EWOULDBLOCK(sselfswhysconnsaddr((s%/mit/python/lib/python2.2/asyncore.pysaccept@scs}JKy L|ii|}M|SWnPNtij o>}O|dtjo PdSnRti|SdSnXdS(Ni(sselfssocketssendsdatasresultserrorswhys EWOULDBLOCK(sselfsdataswhysresult((s%/mit/python/lib/python2.2/asyncore.pyssendJs  csUVyCW|ii|}X| o[|i\dSn^|SWn__tij oM}a|dtt t gjob|icdSneti|nXdS(Nsi( sselfssocketsrecvs buffer_sizesdatas handle_closeserrorswhys ECONNRESETsENOTCONNs ESHUTDOWN(sselfs buffer_sizesdataswhy((s%/mit/python/lib/python2.2/asyncore.pysrecvUs      cs$gh|ii|iidS(N(sselfs del_channelssocketsclose(sself((s%/mit/python/lib/python2.2/asyncore.pysclosegs csmnt|i|SdS(N(sgetattrsselfssocketsattr(sselfsattr((s%/mit/python/lib/python2.2/asyncore.pys __getattr__mscs$tutiidt|dS(Nslog: %s (ssyssstderrswritesstrsmessage(sselfsmessage((s%/mit/python/lib/python2.2/asyncore.pyslogtssinfocs4wxtp |djoyd||fGHndS(Nsinfos%s: %s(s __debug__stypesmessage(sselfsmessagestype((s%/mit/python/lib/python2.2/asyncore.pyslog_infowscs{||io/|i od|_n|inF|i o*|id|_|in|idS(Ni(sselfs acceptings connecteds handle_acceptshandle_connects handle_read(sself((s%/mit/python/lib/python2.2/asyncore.pyshandle_read_event{s   cs?|i o|id|_n|idS(Ni(sselfs connectedshandle_connects handle_write(sself((s%/mit/python/lib/python2.2/asyncore.pyshandle_write_events cs|idS(N(sselfs handle_expt(sself((s%/mit/python/lib/python2.2/asyncore.pyshandle_expt_eventscst\}}}}yt|}Wndt|}nX|i d||||fd|i dS(Ns*<__repr__ (self) failed for object at %0x>s:uncaptured python exception, closing channel %s (%s:%s %s)serror( scompact_tracebacksnilstsvstbinfosreprsselfs self_reprsidslog_infosclose(sselfstbinfosnilsvs self_reprst((s%/mit/python/lib/python2.2/asyncore.pys handle_errors cs|idddS(Nsunhandled exceptionswarning(sselfslog_info(sself((s%/mit/python/lib/python2.2/asyncore.pys handle_exptscs|idddS(Nsunhandled read eventswarning(sselfslog_info(sself((s%/mit/python/lib/python2.2/asyncore.pys handle_readscs|idddS(Nsunhandled write eventswarning(sselfslog_info(sself((s%/mit/python/lib/python2.2/asyncore.pys handle_writescs|idddS(Nsunhandled connect eventswarning(sselfslog_info(sself((s%/mit/python/lib/python2.2/asyncore.pyshandle_connectscs|idddS(Nsunhandled accept eventswarning(sselfslog_info(sself((s%/mit/python/lib/python2.2/asyncore.pys handle_acceptscs'|idd|idS(Nsunhandled close eventswarning(sselfslog_infosclose(sself((s%/mit/python/lib/python2.2/asyncore.pys handle_closes(%sdebugs connecteds acceptingsclosingsNonesaddrs__init__s__repr__s add_channels del_channels create_sockets set_socketsset_reuse_addrsreadablesossnameswritableslistensbindsconnectsacceptssendsrecvscloses __getattr__slogslog_infoshandle_read_eventshandle_write_eventshandle_expt_events handle_errors handle_expts handle_reads handle_writeshandle_connects handle_accepts handle_close(((s%/mit/python/lib/python2.2/asyncore.pys dispatchersH                         sdispatcher_with_sendcsDedZdZdZdZdZRS(Ncs&ti||d|_dS(Ns(s dispatchers__init__sselfssocks out_buffer(sselfssock((s%/mit/python/lib/python2.2/asyncore.pys__init__scs?d}ti||id }|i||_dS(Nii(snum_sents dispatcherssendsselfs out_buffer(sselfsnum_sent((s%/mit/python/lib/python2.2/asyncore.pys initiate_sends cs|idS(N(sselfs initiate_send(sself((s%/mit/python/lib/python2.2/asyncore.pys handle_writescs"|i p t|iSdS(N(sselfs connectedslens out_buffer(sself((s%/mit/python/lib/python2.2/asyncore.pyswritablescsR|io|idt|n|i||_|idS(Ns sending %s(sselfsdebugslog_infosreprsdatas out_buffers initiate_send(sselfsdata((s%/mit/python/lib/python2.2/asyncore.pyssends (sNones__init__s initiate_sends handle_writeswritablessend(((s%/mit/python/lib/python2.2/asyncore.pysdispatcher_with_sends    csti\}}}g}xbdoW|i|iii |iii t |i f|i }| oPnq*W~|d\}}}dditd|d}|||f|||fSdS(Niis[s] [csdi|S(Ns|(sjoinsx(sx((s%/mit/python/lib/python2.2/asyncore.pysss](ssyssexc_infostsvstbstbinfosappendstb_framesf_codes co_filenamesco_namesstrs tb_linenostb_nextsfilesfunctionslinesjoinsmapsinfo(stbinfosinfosfunctionstsfilesvslinestb((s%/mit/python/lib/python2.2/asyncore.pyscompact_tracebacks  4   &cs^|tjo t}nx'|iD]}|iiq0W|idS(N(smapsNones socket_mapsvaluessxssocketsclosesclear(smapsx((s%/mit/python/lib/python2.2/asyncore.pys close_alls   sposixs file_wrappercsSdZ dZdZeZeZdZdZRS(Ncs ||_dS(N(sfdsself(sselfsfd((s%/mit/python/lib/python2.2/asyncore.pys__init__scs$  tti|if|SdS(N(sapplysossreadsselfsfdsargs(sselfsargs((s%/mit/python/lib/python2.2/asyncore.pysrecv scs$tti|if|SdS(N(sapplysosswritesselfsfdsargs(sselfsargs((s%/mit/python/lib/python2.2/asyncore.pyssendscsti|iSdS(N(sossclosesselfsfd(sself((s%/mit/python/lib/python2.2/asyncore.pysclosescs|iSdS(N(sselfsfd(sself((s%/mit/python/lib/python2.2/asyncore.pysfilenos(s__init__srecvssendsreadswritesclosesfileno(((s%/mit/python/lib/python2.2/asyncore.pys file_wrappers      sfile_dispatchercsdZ$dZRS(Ncswti|d|_ti|tid} |ti B}!ti|ti |"|i |dS(Nii( s dispatchers__init__sselfs connectedsfcntlsfdsF_GETFLsflagssoss O_NONBLOCKsF_SETFLsset_file(sselfsfdsflags((s%/mit/python/lib/python2.2/asyncore.pys__init__s  cs2$%||_&t||_'|idS(N(sfdsselfs_filenos file_wrapperssockets add_channel(sselfsfd((s%/mit/python/lib/python2.2/asyncore.pysset_file$s (s__init__sset_file(((s%/mit/python/lib/python2.2/asyncore.pysfile_dispatchers (!s__doc__s exceptionssselectssocketssyssosserrnosEALREADYs EINPROGRESSs EWOULDBLOCKs ECONNRESETsENOTCONNs ESHUTDOWNsEINTRsEISCONNs socket_maps NameErrors ExceptionsExitNowsDEBUGsNonespollspoll2spoll3sloops dispatchersdispatcher_with_sendscompact_tracebacks close_allsnamesfcntls file_wrappersfile_dispatcher(sfcntlsENOTCONNs ESHUTDOWNsdispatcher_with_sendsExitNowssyss close_allscompact_tracebacksEINTRsDEBUGspolls dispatchersselectsEISCONNs file_wrapperssockets ECONNRESETsfile_dispatcherspoll2spoll3s EINPROGRESSs EWOULDBLOCKs socket_maps exceptionssEALREADYsossloop((s%/mit/python/lib/python2.2/asyncore.pys?/s2      :  -"'