łň ˆ Fc@sQddkZddkZddkZddkZddkZddkZddkZddklZddk Z ddk Z ddk Z e i dƒdei fd„ƒYZedjo’eiiƒZeieiƒƒeidƒZeiƒiƒZdeiieiid iefZeeiiiƒeƒZei ƒndS( i˙˙˙˙N(tTimerit MirrorTestcBs~eZdZdeifd„ƒYZd d„Zd„Zd„Z d dd„Z d d ddd „Z d d ddd „Z RS(s@Determines the best mirrors by perfoming ping and download test.t PingWorkercBs&eZdZddd„Zd„ZRS(s˘Use the command line command ping to determine the server's response time. Using multiple threads allows to run several test simultaneously.iicCs\||_||_||_||_||_||_tidƒ|_t i i |ƒdS(Ns^rtt .* = [\.\d]+/([\.\d]+)/.*( tborderstmodtparenttidtjobstresultstretcompilet match_resultt threadingtThreadt__init__(tselfRRRRRR((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyRs      cCsId}x<titijo(|iiiƒoy"|iit dƒ}|i }Wn q nX|ii d|ƒt i d|dƒ}x9t o1|iƒ}|pPnti|i|ƒ}q‹Wtiiƒtid7_|iititi|i|iƒ|o'|iit|dƒ||gƒntiiƒq WdS(Nis Pinging %s...sping -q -c 2 -W 1 -i 0.5 %stri(tNoneRt completedttodoRtrunningtisSetRtgettTruethostnamet report_actiontostpopentreadlineR tfindallR tcompleted_locktacquiretreport_progressRRRtappendtfloattrelease(Rtresulttmirrorthosttcommandotline((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pytruns6      '(ii(ii(t__name__t __module__t__doc__RR)(((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyRs cCsytii|ƒ||_g|_dt_tiƒt_t |ƒt_ ||_ |pti ƒ|_ n ||_ dS(Ni(R R Rt test_filetthreadsRRtLockRtlenRtmirrorstEventR(RR1R-R((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyR6s    cCsT|iddƒ}|itd„|ƒƒ}x |D]\}}|iG|GHq4WdS(sRun a test of the mirror test.tmaxi cSs|dS(i((R((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pytFsN(t run_ping_testtrun_download_testtmapR(Rt results_pingRttth((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyt run_full_testCs  cCs |GHdS(s_Should be used by all sub test to collect action status messages in a central place.N((Rttext((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyRJsiidcCs#d||d||dfGHdS(sZShould be used by all sub test to collect progress messages in a central place.sCompleted %s of %siiN((RtcurrentR3RR((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyR Osic CsĚ|djo |i}ntiƒ}x|D]}|i|ƒq-Wg}xLtdƒD]>}ti||||||ƒ} |ii| ƒ| i ƒqWWx|iD]} | i ƒqŁW|i ƒ|d|!S(sőPerforms ping tests of the given mirrors and returns the best results (specified by max). Mod and borders could be used to tweak the reported result if the download test is only a part of a whole series of tests.iiN( RR1tQueuetputtrangeRRR.R!tstarttjointsort( RR1R3RRRtmRtiR9((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyR5Ts"      c sż‡fd†}|djo ˆi}ng}xx|D]p}ˆiiƒpPn||ƒ}|djo|i||gƒnˆi|i|ƒt|ƒd|ƒq6W|iƒ|d|!S(sůPerforms download tests of the given mirrors and returns the best results (specified by max). Mod and borders could be used to tweak the reported result if the download test is only a part of a whole series of tests.csvd|iƒdˆif}ˆid|ƒtiƒ}y*ti|ƒidƒ}tiƒ|SWn dSnXdS(Ns%s/%sisDownloading %s...i(t get_repo_urlsR-Rttimeturllibturlopentread(R%turlRAtdata(R(sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyttest_download_speedqs  igŕ?iN(gŕ?i( RR1RRR!R tindexR0RC( RR1R3RRRMRRDt download_time((RsB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyR6ks    ) N(iid(ii(ii(ii(ii(ii( R*R+R,R R RRRR;RR R5R6(((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyR s(   t__main__sdpkg --print-architectures!dists/%s/%s/binary-%s/Packages.gzi(!R R>RGR Rttempfilet aptsourcesttimeitRRHtsockettrandomtsetdefaulttimeoutR RR*tdistrot get_distrot get_sourcest SourcesListRtpipeRJtstriptarchtsource_templatetnamet componentsR-t mirror_settvaluestappR;(((sB/var/lib/python-support/python2.5/softwareproperties/MirrorTest.pyss&H     }