Ñò
/_[c
@ sŠ d Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k
l Z d Z e f Z
e a e a d a h a d a d a e a d a d a d a d a e a e a e ƒ Z d „ Z d
„ Z! d „ Z" d „ Z# d
„ Z$ d „ Z% d „ Z& d „ Z' d „ Z( d d d „ ƒ YZ) d e i* f d „ ƒ YZ+ d „ Z, e- d j o e, ƒ n d S( s|
B{FastestMirror} is a Yum plugin which sorts each repository's mirrorlist
according to connection speed prior to download.
iÿÿÿÿN( t TYPE_COREs 2.5i t i
i c C s t | d ƒ o | i d ƒ n | i d d d t ƒa | i d d d t ƒa | i d d d d ƒa | i d d d d
ƒa
| i d d d d ƒa | i d d
d d ƒa | i d d d d ƒa | i d d d d ƒa | i d d d d ƒa | i d d d t ƒa d S( sD
This function initiliazes the variables required for running B{fastestmirror}
module. The variables are initiliazed from the main section of the plugin file.
There are no parameteres for this function. It uses global variables to
communicate with other functions.
This function refers:
- L{get_hostfile_age}
@param verbose : Verbosity of output.
@type verbose : Boolean
@param socket_timeout : The default timeout for a socket connection.
@type socket_timeout : Integer
@param hostfilepath : Absolute path to the plugin's cache file.
@type hostfilepath : String
@param maxhostfileage : Maximum age of the plugin's cache file.
@type maxhostfileage : Integer
@param loadcache : Fastest Mirrors to be loaded from plugin's cache or not.
@type loadcache : Boolean
t registerPackageNames yum-plugin-fastestmirrort maint verboset defaultt always_print_best_hostt socket_timeouti t hostfilepatht
timedhostst maxhostfileagei
t
maxthreadst excludet include_onlyt prefers no.prefer.mirrort
downgrade_ftpN( t hasattrR t confBoolt FalseR t TrueR t confIntR t
confStringR R
R t NoneR R
R R ( t conduit( ( s% /usr/lib/yum-plugins/fastestmirror.pyt init_hookH s c C s› t o, t d d j o | i i i d t a n t i i t ƒ oQ | i d d ƒ y t i t ƒ Wq— t j
o } | i d d | ƒ q— Xn d S( s”
This function cleans the plugin cache file if exists. The function is called
when C{yum [options] clean [plugins | all ]} is executed.
i t /i s# Cleaning up list of fastest mirrorss Cleanup failed: %sN(
R t _baset conft cachedirt ost patht existst infot unlinkt Exception( R t e( ( s% /usr/lib/yum-plugins/fastestmirror.pyt
clean_hookp s c C s | i d ƒ d i d ƒ d S( R i t @iÿÿÿÿ( t split( t mirror( ( s% /usr/lib/yum-plugins/fastestmirror.pyt € s c C sL t i i | ƒ p& y t t d ƒ } t SWq9 t SXn t i | t i ƒ S( Nt w( R R R t fileR R R t accesst W_OK( t fnamet hostfile( ( s% /usr/lib/yum-plugins/fastestmirror.pyt _can_write_results‚ s c C s< d } x/ | D]' } | i d ƒ o q
n | d 7} q
W| S( s- Count the number of urls, which aren't ftp. i s ftp:i ( t
startswith( t urlst numt url( ( s% /usr/lib/yum-plugins/fastestmirror.pyt _len_non_ftpΠs c
sˆ t o, t d d j o ˆ i i i d t a n t i i t ƒ o t ƒ t j o
t a
n ˆ i ƒ \ } } ˆ i i i p t
t ƒ o d St o ˆ i d d ƒ n3 t
o ˆ i d d ƒ t ƒ n ˆ i d d ƒ h } ˆ i ƒ } g } x| | i ƒ D]n } | i t j o qn t o t | i ƒ d j o qn t | i ƒ d j o qn | i | i ƒ qWt | ƒ i ƒ } xÌ| i ƒ D]¾} | i t j o q˜n t o5 t | i ƒ d j o t | i d t ƒ| _ q˜n t | i ƒ d j o q˜n t | ƒ | j o# t | i ƒ i ƒ | t | ƒ t o6 ‡ f d † } t | | t | ƒ ƒ | t | ƒ R? t lvl( ( R s% /usr/lib/yum-plugins/fastestmirror.pyt postreposetup_hook• sr #
#''
1
c C sm yS t t ƒ } x6 | i ƒ D]( } | i ƒ \ } } t | ƒ t | | d j o
d | _ n$ | d j o
d | _ n
d
| _ d S( s1
It is initiliazer function for B{L{PollThread}} class. This function
initiliazes the service ports for different webservices.
@param parent : The parent class.
@type parent : Class
@param mirror : The mirror of a repository.
@type mirror : String
i t httpiP t httpsi» Rz i R* s 127.0.0.1iþÿÿÿN( Rs t ThreadRq t parentR' R8 t urlparset port( Rp R• R' t uService( ( s% /usr/lib/yum-plugins/fastestmirror.pyRq à s
c C sl y+| i t j o. t | i } t o d | i | f GHqnÎ | i d d d t f j o
d } n¨ t i t i t i ƒ } t i | i d ƒ } | d j o. t | i | d ƒ | _
| i | | _ n t i ƒ } | i | i | i
f ƒ t i ƒ | } | i
ƒ | i i | i | i | ƒ Wn: t o d | i GHn | i i | i | i d ƒ n Xd
S( sà
The C{threading.Thread.run()} function is being overridden here.
This function pings/polls a mirror and add the details of that
mirror to the C{FastestMirror.results} dictionary.
The response time of any mirror is '99999999999' if any exception
occurs during polling.
This function refers:
- L{FastestMirror._add_result()}
This function is referred by:
- L{FastestMirror._poll_mirrors()}
s %s already timed: %ss 127.0.0.1s ::1R… i t :i s * %s : deadl ÿgí] N( R8 R R R RU t AF_INETt SOCK_STREAMt stringt findt intR— Re t connectRb R• Rˆ R' ( Rp R t sockt uPortt time_before( ( s% /usr/lib/yum-plugins/fastestmirror.pyt runÝ s*
( R R R‘ Rq R£ ( ( ( s% /usr/lib/yum-plugins/fastestmirror.pyR‰ ½ s c C si t a t t i ƒ d j o! d t i d GHt i d ƒ n t i d } d t t | ƒ i ƒ ƒ GHd S( sõ
This is the main function for B{fastestmirror} module.
This function explains the usage of B{fastestmirror} module. Also parses
the command line arguments.
This function refers:
- L{FastestMirror.get_mirrorlist()}
i s+ Usage: %s [mirror2] ... [mirrorN]i iÿÿÿÿs Result: N( R R RJ t syst argvt exitRO RL RM ( Rm ( ( s% /usr/lib/yum-plugins/fastestmirror.pyR s
t __main__( (. R‘ R R¤ Re RU Rœ R– Rg Rs R6 t yum.pluginsR t requires_api_versiont plugin_typeR R R R R R R R
RB R R R R
R R RT t setRE R R$ R8 R/ R4 R_ RF RW RA RL R” R‰ R R ( ( ( s% /usr/lib/yum-plugins/fastestmirror.pyt ( sP (
d ~G