FM / yum

/usr/lib/python2.6/site-packages/yum

Name	Size	Mode	Actions
callbacks.py	4666	0755	edit dl rm
callbacks.pyc	5278	0644	edit dl rm
callbacks.pyo	5278	0644	edit dl rm
comps.py	20770	0755	edit dl rm
comps.pyc	17568	0644	edit dl rm
comps.pyo	17568	0644	edit dl rm
config.py	37292	0755	edit dl rm
config.pyc	37470	0644	edit dl rm
config.pyo	37470	0644	edit dl rm
constants.py	4698	0755	edit dl rm
constants.pyc	3575	0644	edit dl rm
constants.pyo	3575	0644	edit dl rm
depsolve.py	65512	0755	edit dl rm
depsolve.pyc	39644	0644	edit dl rm
depsolve.pyo	39586	0644	edit dl rm
Errors.py	3780	0755	edit dl rm
Errors.pyc	8185	0644	edit dl rm
Errors.pyo	8185	0644	edit dl rm
failover.py	3372	0755	edit dl rm
failover.pyc	3591	0644	edit dl rm
failover.pyo	3591	0644	edit dl rm
history.py	62468	0755	edit dl rm
history.pyc	54985	0644	edit dl rm
history.pyo	54769	0644	edit dl rm
i18n.py	20683	0755	edit dl rm
i18n.pyc	16516	0644	edit dl rm
i18n.pyo	16516	0644	edit dl rm
logginglevels.py	7986	0755	edit dl rm
logginglevels.pyc	6620	0644	edit dl rm
logginglevels.pyo	6620	0644	edit dl rm
mdparser.py	6408	0755	edit dl rm
mdparser.pyc	7818	0644	edit dl rm
mdparser.pyo	7818	0644	edit dl rm
metalink.py	9506	0755	edit dl rm
metalink.pyc	9147	0644	edit dl rm
metalink.pyo	9077	0644	edit dl rm
misc.py	36716	0755	edit dl rm
misc.pyc	36926	0644	edit dl rm
misc.pyo	36885	0644	edit dl rm
packages.py	82489	0755	edit dl rm
packages.pyc	79613	0644	edit dl rm
packages.pyo	79572	0644	edit dl rm
packageSack.py	41879	0755	edit dl rm
packageSack.pyc	43372	0644	edit dl rm
packageSack.pyo	43372	0644	edit dl rm
parser.py	7807	0755	edit dl rm
parser.pyc	6545	0644	edit dl rm
parser.pyo	6545	0644	edit dl rm
pgpmsg.py	54420	0755	edit dl rm
pgpmsg.pyc	39598	0644	edit dl rm
pgpmsg.pyo	39598	0644	edit dl rm
pkgtag_db.py	4955	0755	edit dl rm
pkgtag_db.pyc	5211	0644	edit dl rm
pkgtag_db.pyo	5211	0644	edit dl rm
plugins.py	25083	0755	edit dl rm
plugins.pyc	26384	0644	edit dl rm
plugins.pyo	26384	0644	edit dl rm
repoMDObject.py	10084	0755	edit dl rm
repoMDObject.pyc	8617	0644	edit dl rm
repoMDObject.pyo	8617	0644	edit dl rm
repos.py	14302	0755	edit dl rm
repos.pyc	15834	0644	edit dl rm
repos.pyo	15785	0644	edit dl rm
rpmsack.py	68762	0755	edit dl rm
rpmsack.pyc	58447	0644	edit dl rm
rpmsack.pyo	58308	0644	edit dl rm
rpmtrans.py	25004	0755	edit dl rm
rpmtrans.pyc	23500	0644	edit dl rm
rpmtrans.pyo	23443	0644	edit dl rm
sqlitesack.py	71379	0755	edit dl rm
sqlitesack.pyc	55778	0644	edit dl rm
sqlitesack.pyo	55350	0644	edit dl rm
sqlutils.py	6422	0755	edit dl rm
sqlutils.pyc	5789	0644	edit dl rm
sqlutils.pyo	5789	0644	edit dl rm
transactioninfo.py	32007	0755	edit dl rm
transactioninfo.pyc	29718	0644	edit dl rm
transactioninfo.pyo	29718	0644	edit dl rm
update_md.py	24714	0755	edit dl rm
update_md.pyc	21296	0644	edit dl rm
update_md.pyo	21296	0644	edit dl rm
yumRepo.py	75978	0755	edit dl rm
yumRepo.pyc	59618	0644	edit dl rm
yumRepo.pyo	59618	0644	edit dl rm
__init__.py	239205	0755	edit dl rm
__init__.pyc	156538	0644	edit dl rm
__init__.pyo	156365	0644	edit dl rm

Edit: /usr/lib/python2.6/site-packages/yum/repos.py (14302B)

#!/usr/bin/python -tt
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU Library General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
# Copyright 2004 Duke University

import re
import fnmatch
import types
import logging
import misc
import os, urlgrabber

import Errors
from packageSack import MetaSack

from weakref import proxy as weakref

class _wrap_ayum_getKeyForRepo:
    """ This is a wrapper for calling YumBase.getKeyForRepo() because
        otherwise we take a real reference through the bound method and
        that is d00m (this applies to YumBase and RepoStorage, hence why
        we have a seperate class).
        A "better" fix might be to explicitly pass the YumBase instance to
        the callback ... API change! """
    def __init__(self, ayum, ca=False):
        self.ayum = weakref(ayum)
        self.ca = ca
    def __call__(self, repo, callback=None):
        if self.ca:
            return self.ayum.getCAKeyForRepo(repo, callback)
        return self.ayum.getKeyForRepo(repo, callback)

class RepoStorage:
    """This class contains multiple repositories and core configuration data
       about them."""
       
    def __init__(self, ayum):
        self.repos = {} # list of repos by repoid pointing a repo object 
                        # of repo options/misc data
        self.callback = None # progress callback used for populateSack() for importing the xml files
        self.cache = 0
        self.pkgSack = MetaSack()
        self.logger = logging.getLogger("yum.RepoStorage")

self._setup = False

self.ayum = weakref(ayum)
        # callbacks for handling gpg key imports for repomd.xml sig checks
        # need to be set from outside of the repos object to do anything
        # even quasi-useful
        # defaults to what is probably sane-ish
        self.gpg_import_func = _wrap_ayum_getKeyForRepo(ayum)
        self.gpgca_import_func = _wrap_ayum_getKeyForRepo(ayum, ca=True)
        self.confirm_func = None

# This allow listEnabled() to be O(1) most of the time.
        self._cache_enabled_repos = []
        self.quick_enable_disable = {}

def doSetup(self, thisrepo = None):
        
        self.ayum.plugins.run('prereposetup')
        
        if thisrepo is None:
            repos = self.listEnabled()
        else:
            repos = self.findRepos(thisrepo)

if len(repos) < 1:
            self.logger.debug('No Repositories Available to Set Up')

if (hasattr(urlgrabber, 'grabber') and
            hasattr(urlgrabber.grabber, 'pycurl')):
            # Must do basename checking, on cert. files...
            cert_basenames = {}
            for repo in self.listEnabled():
                if repo.sslclientcert:
                    bn = os.path.basename(repo.sslclientcert)
                    other = cert_basenames.setdefault(bn, repo)
                    if repo.sslclientcert != other.sslclientcert:
                        msg = 'sslclientcert basename shared between %s and %s'
                        raise Errors.ConfigError, msg % (repo, other)

for repo in repos:
            repo.setup(self.ayum.conf.cache, self.ayum.mediagrabber,
                   gpg_import_func = self.gpg_import_func, confirm_func=self.confirm_func,
                   gpgca_import_func = self.gpgca_import_func)
            # if we come back from setup NOT enabled then mark as disabled
            # so nothing else touches us
            if not repo.enabled:
                self.disableRepo(repo.id)
            else:
                pkgdir = getattr(self.ayum.conf, 'downloaddir', None)
                if pkgdir:
                    repo.pkgdir = pkgdir

self._setup = True
        self.ayum.plugins.run('postreposetup')
        
    def __str__(self):
        return str(self.repos.keys())

def __del__(self):
        self.close()

def close(self):
        for repo in self.repos.values():
            repo.close()

def add(self, repoobj):
        if repoobj.id in self.repos:
            raise Errors.DuplicateRepoError, 'Repository %s is listed more than once in the configuration' % (repoobj.id)
        self.repos[repoobj.id] = repoobj
        if hasattr(repoobj, 'quick_enable_disable'):
            self.quick_enable_disable.update(repoobj.quick_enable_disable)
            repoobj.quick_enable_disable = self.quick_enable_disable
        else:
            self._cache_enabled_repos = None
        #  At least pulp reuses RepoStorage but doesn't have a "real" YumBase()
        # so we can't guarantee new YumBase() attrs. exist.
        if not hasattr(self.ayum, '_override_sigchecks'):
            repoobj._override_sigchecks = False
        else:
            repoobj._override_sigchecks = self.ayum._override_sigchecks

def delete(self, repoid):
        if repoid in self.repos:
            thisrepo = self.repos[repoid]
            thisrepo.close()
            del self.repos[repoid]
            
    def sort(self):
        repolist = self.repos.values()
        repolist.sort()
        return repolist
        
    def getRepo(self, repoid):
        try:
            return self.repos[repoid]
        except KeyError, e:
            raise Errors.RepoError, \
                'Error getting repository data for %s, repository not found' % (repoid)

def findRepos(self, pattern, name_match=False, ignore_case=False):
        """ Find all repositories matching fnmatch `pattern` on the repo.id,
            can also do case insensitive searches and/or search on the name."""

if pattern in self.repos: # Minor opt. as we do this a lot...
            return [self.repos[pattern]]

result = []
        
        for item in pattern.split(','):
            item = item.strip()
            if ignore_case:
                match = re.compile(fnmatch.translate(item), re.I).match
            else:
                match = re.compile(fnmatch.translate(item)).match
            for name,repo in self.repos.items():
                assert name == repo.id
                if match(name):
                    result.append(repo)
                elif name_match and match(repo.name):
                    result.append(repo)

return result
        
    def disableRepo(self, repoid):
        """disable a repository from use
        
        fnmatch wildcards may be used to disable a group of repositories.
        returns repoid of disabled repos as list
        """
        repos = []
        if misc.re_glob(repoid) or repoid.find(',') != -1:
            for repo in self.findRepos(repoid):
                repos.append(repo.id)
                repo.disable()
        else:
            thisrepo = self.getRepo(repoid)
            repos.append(thisrepo.id)
            thisrepo.disable()
        
        return repos
        
    def enableRepo(self, repoid):
        """enable a repository for use
        
        fnmatch wildcards may be used to enable a group of repositories.
        returns repoid of enables repos as list
        """
        repos = []
        if misc.re_glob(repoid) or repoid.find(',') != -1:
            for repo in self.findRepos(repoid):
                repos.append(repo.id)
                repo.enable()
        else:
            thisrepo = self.getRepo(repoid)
            repos.append(thisrepo.id)
            thisrepo.enable()
        
        return repos
        
    def listEnabled(self):
        """return list of enabled repo objects"""

if (self._cache_enabled_repos is not None and
            not self.quick_enable_disable):
            return self._cache_enabled_repos

returnlist = []
        for repo in self.repos.values():
            if repo.isEnabled():
                returnlist.append(repo)

returnlist.sort()

if self._cache_enabled_repos is not None:
            self._cache_enabled_repos = returnlist
            self.quick_enable_disable.clear()
        return returnlist

def listGroupsEnabled(self):
        """return a list of repo objects that have groups enabled"""
        returnlist = []
        for repo in self.listEnabled():
            if repo.enablegroups:
                returnlist.append(repo)

return returnlist

def setCache(self, cacheval):
        """sets cache value in all repos"""
        self.cache = cacheval
        for repo in self.repos.values():
            repo.cache = cacheval

def setCacheDir(self, cachedir):
        """sets the cachedir value in all repos"""
        
        self._cachedir = cachedir
        for repo in self.repos.values():
            if cachedir != repo.basecachedir:
                repo.old_base_cache_dir = repo.basecachedir
                repo.basecachedir = cachedir

def setProgressBar(self, obj):
        """sets the progress bar for downloading files from repos"""
        
        for repo in self.repos.values():
            repo.setCallback(obj)

def setFailureCallback(self, obj):
        """sets the failure callback for all repos"""
        
        for repo in self.repos.values():
            repo.setFailureObj(obj)

def setMirrorFailureCallback(self, obj):
        """sets the failure callback for all mirrors"""
        
        for repo in self.repos.values():
            repo.setMirrorFailureObj(obj)

def setInterruptCallback(self, callback):
        for repo in self.repos.values():
            repo.setInterruptCallback(callback)

def getPackageSack(self):
        return self.pkgSack

def populateSack(self, which='enabled', mdtype='metadata', callback=None, cacheonly=0):
        """
        This populates the package sack from the repositories, two optional 
        arguments:
            - which='repoid, enabled, all'
            - mdtype='metadata, filelists, otherdata, all'
        """

if not self._setup:
            self.doSetup()

if not callback:
            callback = self.callback
        myrepos = []
        if which == 'enabled':
            myrepos = self.listEnabled()
        elif which == 'all':
            myrepos = self.repos.values()
        else:
            if type(which) == types.ListType:
                for repo in which:
                    if isinstance(repo, Repository):
                        myrepos.append(repo)
                    else:
                        repobj = self.getRepo(repo)
                        myrepos.append(repobj)
            elif type(which) == types.StringType:
                repobj = self.getRepo(which)
                myrepos.append(repobj)

if mdtype == 'all':
            data = ['metadata', 'filelists', 'otherdata']
        else:
            data = [ mdtype ]
         
        for repo in myrepos:
            sack = repo.getPackageSack()
            try:
                sack.populate(repo, mdtype, callback, cacheonly)
            except TypeError, e:
                if not e.args[0].startswith('Parsing'):
                    raise
                if mdtype in ['all', 'metadata'] and repo.skip_if_unavailable:
                    self.disableRepo(repo.id)
                else:
                    raise Errors.RepoError(e.args[0])
            except Errors.RepoError, e:
                if mdtype in ['all', 'metadata'] and repo.skip_if_unavailable:
                    self.disableRepo(repo.id)
                else:
                    raise
            else:
                self.pkgSack.addSack(repo.id, sack)

class Repository:
    """this is an actual repository object"""

def __init__(self, repoid):
        self.id = repoid
        self.quick_enable_disable = {}
        self.disable()
        self._xml2sqlite_local = False

def __cmp__(self, other):
        """ Sort base class repos. by alphanumeric on their id, also
            see __cmp__ in YumRepository(). """
        if self.id > other.id:
            return 1
        elif self.id < other.id:
            return -1
        else:
            return 0

def __str__(self):
        return self.id

def __hash__(self):
        return hash(self.id)
        
    def __del__(self):
        self.close()

def close(self):
        pass

def setAttribute(self, key, value):
        """sets a generic attribute of this repository"""
        setattr(self, key, value)

def getAttribute(self, key):
        return getattr(self, key, None)

def isEnabled(self):
        enabled = self.getAttribute('enabled')
        return enabled is not None and enabled

def enable(self):
        self.setAttribute('enabled', 1)
        self.quick_enable_disable[self.id] = True
                    
    def disable(self):
        self.setAttribute('enabled', 0)
        self.quick_enable_disable[self.id] = False

def getExcludePkgList(self):
        excludeList = self.getAttribute('exclude')
        return excludeList or []

def getIncludePkgList(self):
        includeList = self.getAttribute('includepkgs')
        return includeList or []

# Abstract interface
    def ready(self):
        raise NotImplementedError()

def getGroupLocation(self):
        raise NotImplementedError()
 
    def getPackageSack(self):
        raise NotImplementedError()

def setup(self, cache):
        raise NotImplementedError()
                    
    def setCallback(self, callback):
        raise NotImplementedError()

def setFailureObj(self, obj):
        raise NotImplementedError()

def setMirrorFailureObj(self, obj):
        raise NotImplementedError()

def getPackage(self, package, checkfunc = None, text = None, cache = True):
        raise NotImplementedError()

def getHeader(self, package, checkfunc = None, reget = 'simple', cache = True):
        raise NotImplementedError()

cmd: