-í ™º‘;c sádkZ dkZ dkZdkZdkZdeifd„ƒYZ0deifd„ƒYZHdefd„ƒYZ ddk Z fdfd„ƒYZ me d jondk Z pd eijo qeiid ƒrd Zn td Zveeiƒd jo'wd eid GHzeid ƒn{eid djoC|eeide ieidƒfƒZ}eideƒn6~eid djo€e ieidƒdZeidZ‚e ieidƒZƒe ieidƒZ„e ieidƒZ†dkZ‡dkZˆeidƒ‰e ƒZŠx0eeƒDŠ]Z‹e eefeeƒqwWŒeideƒŽei ƒZ!–e i"Z#—eeZ$˜e$eeƒZ%™e&e%ƒe!Z'še$e!Z(œei)i*de!ƒei)i*de$ƒžei)i*de%ƒŸei)i*de'ƒ ei)i*dƒ¡ei)i*de(ƒ£ei+i*e i,e-e.eeeeƒe'e(fƒ¦dƒdƒnndS( Ns test_channelcs\dZdZdZd„Zd„Z#d„Z)d„Z-d„ZRS(Ni@ics9tii||ƒ|idƒd|_dS(Ns s(sasynchats async_chats__init__sselfsconnsset_terminatorsbuffer(sselfsconnsaddr((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys__init__scs3 |i||_!tit|ƒt_dS(N(sselfsbuffersdatas test_channelstotal_inslen(sselfsdata((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pyscollect_incoming_datascs3#%|i}&d|_'|i|dƒdS(Nss (sselfsbuffersdataspush(sselfsdata((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pysfound_terminator#s  cs)+|iƒdS(N(sselfsclose(sself((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys handle_close)scs -.dS(N((sselfsargs((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pyslog-s(sac_in_buffer_sizesac_out_buffer_sizestotal_ins__init__scollect_incoming_datasfound_terminators handle_closeslog(((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys test_channels       s test_servercs01d„Z=d„ZRS(Ncs13t|ƒtdƒjo4ti}n 6ti}8|i|tiƒ9|i |ƒ:|i dƒ;dG|GHdS(Nsisserver started on( stypesaddrssocketsAF_UNIXsfsAF_INETsselfs create_sockets SOCK_STREAMsbindslisten(sselfsaddrsf((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys__init__1s cs,=>|iƒ\}}?t||ƒdS(N(sselfsacceptsconnsaddrs test_channel(sselfsaddrsconn((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys handle_accept=s(s__init__s handle_accept(((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys test_server0s s test_clientcs)HJd„ZYd„Z\d„ZRS(NcsÀJKt|ƒtdƒjoLti}n Nti}Ptii|ƒQ|i |ti ƒR|i dƒSd|_ T|i|ƒU|i|dƒV||_Wd|_dS(Nss i(stypesaddrssocketsAF_UNIXsfsAF_INETsasynchats async_chats__init__sselfs create_sockets SOCK_STREAMsset_terminatorsbuffersconnectspushspacketsnumberscount(sselfsaddrspacketsnumbersf((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys__init__Js   cs YZdS(N((sself((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pyshandle_connectYscsQ\]|id|_^|i|ijo`|iƒnbti|ƒdS(Ni(sselfscountsnumberscloses test_channelsfound_terminator(sself((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pysfound_terminator\s(s__init__shandle_connectsfound_terminator(((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys test_clientHs  stimercsfgd„Zjd„ZRS(Ncsghtiƒ|_dS(N(stimesselfsstart(sself((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys__init__gscsjktiƒ|iSdS(N(stimesselfsstart(sself((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pysendjs(s__init__send(((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pystimerfs s__main__s--polliisˆusage: %s (as a server) [--poll] -s (as a client) [--poll] -c s-siisuse_polls-cisBiiidstotal time: %.2f snumber of transactions: %d stotal bytes sent: %d s#total throughput (bytes/sec): %.2f s5 [note, throughput is this amount in each direction] stransactions/second: %.2f s,s (/ssocketsselectssyssasyncoresasynchats async_chats test_channels dispatchers test_servers test_clientstimestimers__name__sstringsargvsremovesuse_pollslensexitsatoisssloopspacketshostsports num_packetss num_connssprofilessetcheckintervalstsrangesisends total_timestotal_insbytess num_transs total_bytessfloats throughputs trans_per_secsstderrswritesstdoutsjoinsmapsstr(sprofiles total_timesasyncoresstrings trans_per_secs num_transspacketssysshostsportsselectsasynchats test_channelssockets total_bytessisuse_pollsbytesstimers num_packetssss throughputs test_clientstimes test_servers num_connsst((sK/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/test/test_lb.pys?sb        ,       3