- ;cs dkZdkZdkZdkZ dkZ"dkZ#eidjo:$dZ%dZ&dZ 'dZ (dZ )dZ n/+dk l Z lZlZl Z l Z l Z -y .eWn/ej o0hZnX2d eifd YZ5d a7d ed Z_d edZdd edZdfdYZdefdYZdZedZdkZeidjoKdkZdkZdfdYZdefdYZndS(Nsnti3'i4'i5'iF'iI'iJ'(sEALREADYs EINPROGRESSs EWOULDBLOCKs ECONNRESETsENOTCONNs ESHUTDOWNsExitNowcs23RS(N((((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysExitNow2sif0.0cs789|tjo :t}n;|o<g}g}g}=xe|iD=]T\}}>|i o?|i |n@|i oA|i |nqRWBt i ||||\}}}DtoE|G|G|GHnGx|DG]}Hy]I||}JyK|iWn5Ltj oMtnNO|inXWnPtj o QnXqWSx|DS]}Ty]U||}VyW|iWn5Xtj oYtnZ[|inXWn\tj o ]nXqWndS(N(smapsNones socket_mapsrswsesitemssfdsobjsreadablesappendswritablesselectstimeoutsDEBUGshandle_read_eventsExitNows handle_errorsKeyErrorshandle_write_event(stimeoutsmapsesrsfdswsobj((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyspoll7sL  $        cs_`dk}a|tjo bt}ndt|d}e|ofg}gx|iDg]}\}}hd}i|i oj|i }nk|i ol||iB}nm|on|i||fnqbWo|i||}px|Dp]\}}qyr||}syHt||i @ou|inv||i@ow|inWn5xtj oytnz{|inXWn|tj o }nXqWndS(Nii(spollsmapsNones socket_mapsintstimeoutslsitemssfdsobjsflagssreadablesPOLLINswritablesPOLLOUTsappendsrshandle_read_eventshandle_write_eventsExitNows handle_errorsKeyError(stimeoutsmapsobjslsrsfdsflagsspoll((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyspoll2_s>         f30.0csi|o t}n't}|tjo t}nx|o|||qFWdS(N(suse_pollspoll2spoll_funspollsmapsNones socket_mapstimeout(stimeoutsuse_pollsmapspoll_fun((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysloops     s dispatchercsdZdZdZdZeZeedZdZedZedZ dZ edZ dZ d Z eid jod Zn d Zd ZdZdZdZ dZdZ'dZ-dZ4dZ7ddZ;dZIdZPdZSdZgdZjdZ mdZ!pdZ"sd Z#vd!Z$RS("NicsG|o6|i|||iidd|_ndS(Nii(ssocksselfs set_socketsmapssockets setblockings connected(sselfssocksmap((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys__init__s cs yg}|io|io|idn"|io|idn|io|id|ind|iiti |dt |fSWnPyt |i}Wnd}nXdt ||fSnXdS(Ns listenings connecteds%s:%ds <%s %s at %x>s s no self.addr!s3<__repr__ (self) failed for object at %x (addr=%s)>( sstatussselfs acceptingsaddrsappends connecteds __class__s__name__sstringsjoinsidsreprsar(sselfsstatussar((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys__repr__s   0 cs4|tjo t}n|||i}|dtjo dSnti|dSnXdS(Ni(sselfssocketssendsdatasresultserrorswhys EWOULDBLOCK(sselfsdataswhysresult((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyssend s  csyC|ii|}| o|idSn|SWn_tij oM}!|dtt t gjo"|i#dSn%ti|nXdS(Nsi( sselfssocketsrecvs buffer_sizesdatas handle_closeserrorswhys ECONNRESETsENOTCONNs ESHUTDOWN(sselfs buffer_sizesdataswhy((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysrecvs      cs$'(|i)|iidS(N(sselfs del_channelssocketsclose(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysclose's cs-.t|i|SdS(N(sgetattrsselfssocketsattr(sselfsattr((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys __getattr__-scs$45tiidt|dS(Nslog: %s (ssyssstderrswritesstrsmessage(sselfsmessage((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyslog4ssinfocs478tp |djo9d||fGHndS(Nsinfos%s: %s(s __debug__stypesmessage(sselfsmessagestype((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyslog_info7scs;<|io/?|i o@d|_nA|inFB|i o*C|iDd|_E|inG|idS(Ni(sselfs acceptings connecteds handle_acceptshandle_connects handle_read(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyshandle_read_event;s   cs?IK|i oL|iMd|_nN|idS(Ni(sselfs connectedshandle_connects handle_write(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyshandle_write_eventIs csPQ|idS(N(sselfs handle_expt(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyshandle_expt_eventPscsSTt\\}}}}}}WyXt|}WnYZdt |}nX\|i d||||fcde|i dS(Ns*<__repr__ (self) failed for object at %0x>s:uncaptured python exception, closing channel %s (%s:%s %s)serror( scompact_tracebacksfilesfunslinestsvstbinfosreprsselfs self_reprsidslog_infosclose(sselfstbinfostsfilesvsfuns self_reprsline((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys handle_errorSs! csgh|idddS(Nsunhandled exceptionswarning(sselfslog_info(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys handle_exptgscsjk|idddS(Nsunhandled read eventswarning(sselfslog_info(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys handle_readjscsmn|idddS(Nsunhandled write eventswarning(sselfslog_info(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys handle_writemscspq|idddS(Nsunhandled connect eventswarning(sselfslog_info(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyshandle_connectpscsst|idddS(Nsunhandled accept eventswarning(sselfslog_info(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys handle_acceptsscs'vw|iddx|idS(Nsunhandled close eventswarning(sselfslog_infosclose(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys handle_closevs(%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(((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys dispatchersH                         sdispatcher_with_sendcsDedZdZdZdZdZRS(Ncs&ti||d|_dS(Ns(s dispatchers__init__sselfssocks out_buffer(sselfssock((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys__init__scs?d}ti||id }|i||_dS(Nii(snum_sents dispatcherssendsselfs out_buffer(sselfsnum_sent((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys initiate_sends cs|idS(N(sselfs initiate_send(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys handle_writescs"|i p t|iSdS(N(sselfs connectedslens out_buffer(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyswritablescsR|io|idt|n|i||_|idS(Ns sending %s(sselfsdebugslog_infosreprsdatas out_buffers initiate_send(sselfsdata((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyssends (sNones__init__s initiate_sends handle_writeswritablessend(((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysdispatcher_with_sends    csti\}}}g}xbdoW|i|iii |iii t |i f|i }| oPnq*W~|d\}}}dtitd|dd}|||f|||fSdS(Niis[csti|dS(Ns|(sstringsjoinsx(sx((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysss] [s](ssyssexc_infostsvstbstbinfosappendstb_framesf_codes co_filenamesco_namesstrs tb_linenostb_nextsfilesfunctionslinesstringsjoinsmapsinfo(stbinfosinfosfunctionstsfilesvslinestb((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyscompact_tracebacks  4    cs^|tjo t}nx'|iD]}|iiq0W|idS(N(smapsNones socket_mapsvaluessxssocketsclosesclear(smapsx((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys close_alls   sposixs file_wrappercsAdZdZdZdZdZRS(Ncs||_dS(N(sfdsself(sselfsfd((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys__init__scs$tti|if|SdS(N(sapplysossreadsselfsfdsargs(sselfsargs((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysrecvscs$tti|if|SdS(N(sapplysosswritesselfsfdsargs(sselfsargs((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pyswritescsti|iSdS(N(sossclosesselfsfd(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysclosescs|iSdS(N(sselfsfd(sself((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysfilenos(s__init__srecvswritesclosesfileno(((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys file_wrappers     sfile_dispatchercsdZdZRS(Ncswti|d|_ti|tid}|ti B}ti|ti ||i |dS(Nii( s dispatchers__init__sselfs connectedsfcntlsfdsFCNTLsF_GETFLsflagss O_NONBLOCKsF_SETFLsset_file(sselfsfdsflags((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys__init__s  cs2||_t||_|idS(N(sfdsselfs_filenos file_wrapperssockets add_channel(sselfsfd((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysset_files (s__init__sset_file(((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pysfile_dispatchers (s exceptionssselectssocketsstringssyssossnames EWOULDBLOCKs EINPROGRESSsEALREADYs ECONNRESETsENOTCONNs ESHUTDOWNserrnos socket_maps NameErrors ExceptionsExitNowsDEBUGsNonespollspoll2sloops dispatchersdispatcher_with_sendscompact_tracebacks close_allsfcntlsFCNTLs file_wrappersfile_dispatcher(sfcntlsENOTCONNsstringsdispatcher_with_sendsExitNowssyss close_allsselectscompact_tracebackspolls dispatchers ESHUTDOWNsFCNTLs file_wrapperssockets ECONNRESETsfile_dispatcherspoll2s EINPROGRESSs EWOULDBLOCKs socket_maps exceptionssEALREADYsossloop((sG/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/asyncore.pys?s@           .  (