Ñò ÆKc@sDddkZddkZddkZddkZddkZddkZddkZddklZddk Z ddk Z ddk Z dei fd„ƒYZ edjo’eiiƒZeieiƒƒeidƒZeiƒiƒZdeiieiidiefZe eiiiƒeƒZei ƒndS( iÿÿÿÿN(tTimert MirrorTestcBs~eZdZdeifd„ƒYZd d„Zd„Zd dd„Z d„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((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyRs      c Cs…d}xx|iiƒ of|iiiƒoSy|iitƒ}|i}|ii d|ƒt i d|dt dt i dt iƒi}x9t o1|iƒ}|pPnti|i|ƒ}qWWn3tij o }dS|ii d|ƒnXtiiƒtid7_|iititi|i|iƒ|o'|iit |dƒ||gƒntii!ƒq WdS( Ns Pinging %s...sping -q -c 2 -W 1 -i 0.5 %stshelltstdouttstderrs Skipping %sii("tNoneRtemptyRtrunningtisSettgettFalsethostnamet report_actiont subprocesstPopentTruetPIPEtSTDOUTRtreadlineR tfindallR tQueuetEmptyRtcompleted_locktacquiret completedtreport_progressttodoRRRtappendtfloattrelease(Rtresulttmirrorthosttcommandotlinete((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pytruns:$    '(ii(ii(t__name__t __module__t__doc__RR2(((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyR s cCsytii|ƒ||_g|_dt_tiƒt_t |ƒt_ ||_ |pti ƒ|_ n ||_ dS(Ni(R R Rt test_filetthreadsRR&tLockR$tlenR(tmirrorstEventR(RR:R6R((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyR7s    cCs |GHdS(sSSubclasses should override this method to receive action message updatesN((Rttext((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyRDsiidcCs#d||d||dfGHdS(sTSubclasses should override this method to receive progress status updatessCompleted %s of %siiN((RtcurrenttmaxRR((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyR'IscCs"|idddd ddƒ}t|iƒ}|djo^|idd|itid |d ƒgƒ|idd|itid |d ƒgƒn|itd „|ƒdddti ti fƒ}x&|D]\}}d |i |fGHqÒW|pdS|dd i }d |GH|SdS(NR>iRigà?RiiicSs|dS(i((tr((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pytVssmirror: %s - time: %ssand the winner is: %s(igà?(ii(gà?i( t run_ping_testR9R:R)trandomtrandinttrun_download_testtmapRR(RR(Rt results_pingtsizeRttthtwinner((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyt run_full_testNs" -1  ic 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( RR:R"tputtrangeRRR7R)tstarttjointsort( RR:R>RRRtmRtiRH((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyRAcs"      c sÇfd†}|djo ˆi}ng}x||D]t}ˆiiƒpPn||ƒ}|djo|i||gƒnˆi|i|ƒdt|ƒ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.csyd|iƒdˆif}ˆid|ƒtiƒ}y0ti|ddƒidƒ}tiƒ|SWndSXdS(Ns%s/%sisDownloading %s...ttimeoutii(t get_repo_urlsR6Rttimeturllib2turlopentread(R-turlRNtdata(R(sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyttest_download_speed€s  iigà?N(gà?i( RR:RRR)R'tindexR9RP( RR:R>RRR[RRQt download_time((RsA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyRDzs    - N(iid(ii(ii(ii(ii(ii( R3R4R5R R RRRRR'RKRARD(((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyR s,   t__main__sdpkg --print-architectures!dists/%s/%s/binary-%s/Packages.gzi(!R R"RUR Rttempfilet aptsourcesttimeitRRVtsocketRBR RR3tdistrot get_distrot get_sourcest SourcesListtostpopentpipeRXtstriptarchtsource_templatetnamet componentsR6t mirror_settvaluestappRK(((sA/usr/lib/python2.6/dist-packages/softwareproperties/MirrorTest.pyts$H