Gecko [ sachasauda.akalacademy.ac.in ]

Name	Size	Permission
Errors.py	4.26 KB	-rwxr-xr-x
Errors.pyc	9.08 KB	-rw-r--r--
__init__.py	304.1 KB	-rwxr-xr-x
__init__.pyc	199.78 KB	-rw-r--r--
callbacks.py	5.64 KB	-rwxr-xr-x
callbacks.pyc	6.23 KB	-rw-r--r--
comps.py	31.59 KB	-rwxr-xr-x
comps.pyc	26.87 KB	-rw-r--r--
config.py	49.89 KB	-rwxr-xr-x
config.pyc	48.02 KB	-rw-r--r--
constants.py	4.52 KB	-rwxr-xr-x
constants.pyc	3.42 KB	-rw-r--r--
depsolve.py	74.05 KB	-rwxr-xr-x
depsolve.pyc	46.91 KB	-rw-r--r--
drpm.py	12.85 KB	-rwxr-xr-x
drpm.pyc	10.83 KB	-rw-r--r--
failover.py	5 KB	-rwxr-xr-x
failover.pyc	5.24 KB	-rw-r--r--
fssnapshots.py	10.16 KB	-rwxr-xr-x
fssnapshots.pyc	9.75 KB	-rw-r--r--
history.py	61.13 KB	-rwxr-xr-x
history.pyc	53.31 KB	-rw-r--r--
i18n.py	20.44 KB	-rwxr-xr-x
i18n.pyc	16.05 KB	-rw-r--r--
igroups.py	9.31 KB	-rwxr-xr-x
igroups.pyc	10.22 KB	-rw-r--r--
logginglevels.py	7.9 KB	-rwxr-xr-x
logginglevels.pyc	6.51 KB	-rw-r--r--
mdparser.py	6.26 KB	-rwxr-xr-x
mdparser.pyc	7.58 KB	-rw-r--r--
metalink.py	9.19 KB	-rwxr-xr-x
metalink.pyc	8.84 KB	-rw-r--r--
misc.py	39.57 KB	-rwxr-xr-x
misc.pyc	39.58 KB	-rw-r--r--
packageSack.py	40.79 KB	-rwxr-xr-x
packageSack.pyc	41.88 KB	-rw-r--r--
packages.py	84.1 KB	-rwxr-xr-x
packages.pyc	84.51 KB	-rw-r--r--
parser.py	7.97 KB	-rwxr-xr-x
parser.pyc	6.5 KB	-rw-r--r--
pgpmsg.py	53.5 KB	-rwxr-xr-x
pgpmsg.pyc	38.27 KB	-rw-r--r--
pkgtag_db.py	4.86 KB	-rwxr-xr-x
pkgtag_db.pyc	5.06 KB	-rw-r--r--
plugins.py	28.1 KB	-rwxr-xr-x
plugins.pyc	29.1 KB	-rw-r--r--
repoMDObject.py	11.23 KB	-rwxr-xr-x
repoMDObject.pyc	9.17 KB	-rw-r--r--
repos.py	16.53 KB	-rwxr-xr-x
repos.pyc	17.38 KB	-rw-r--r--
rpmsack.py	70.25 KB	-rwxr-xr-x
rpmsack.pyc	58.36 KB	-rw-r--r--
rpmtrans.py	24.84 KB	-rwxr-xr-x
rpmtrans.pyc	22.54 KB	-rw-r--r--
sqlitesack.py	69.76 KB	-rwxr-xr-x
sqlitesack.pyc	53.75 KB	-rw-r--r--
sqlutils.py	6.27 KB	-rwxr-xr-x
sqlutils.pyc	5.6 KB	-rw-r--r--
transactioninfo.py	33.78 KB	-rwxr-xr-x
transactioninfo.pyc	30.29 KB	-rw-r--r--
update_md.py	25.9 KB	-rwxr-xr-x
update_md.pyc	21.72 KB	-rw-r--r--
updateinfo.py	18.29 KB	-rwxr-xr-x
updateinfo.pyc	16.36 KB	-rw-r--r--
yumRepo.py	83.85 KB	-rwxr-xr-x
yumRepo.pyc	64.83 KB	-rw-r--r--

Code Editor : callbacks.py

#!/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.

"""Classes for handling various callbacks."""

# imports

import logging 
from urlgrabber.progress import BaseMeter,format_time,format_number

# ProcessTransaction States

PT_DOWNLOAD        = 10    # Start Download
PT_DOWNLOAD_PKGS   = 11    # Packages to download
PT_GPGCHECK        = 20    # Start Checkin Package Signatures
PT_TEST_TRANS      = 30    # Start Test Transaction
PT_TRANSACTION     = 40    # Start Transaction

PT_MESSAGES = { PT_DOWNLOAD    : "Downloading Packages",
                PT_GPGCHECK    : "Check Package Signatures",
                PT_TEST_TRANS  : "Running Test Transaction",
                PT_TRANSACTION : "Running Transaction"}

class ProcessTransBaseCallback:
    """A class to handle callbacks from
    :func:`YumBase.processTransaction`.
    """
    def __init__(self):
        self.logger = logging.getLogger('yum.verbose.ProcessTrasactionBaseCallback')
        
    def event(self,state,data=None):
        """Handle an event by logging it.

:param state: a number indicating the type of callback
        :param data: data associated with the callback
        """
        if state in PT_MESSAGES.keys():
            self.logger.info(PT_MESSAGES[state])

class ProcessTransNoOutputCallback:
    """A class to handle callbacks from
    :func:`YumBase.processTransaction`, without logging them.
    """
    def __init__(self):
        pass
         
    def event(self,state,data=None):
        """Handle an event.

:param state: a number indicating the type of callback
        :param data: data associated with the callback
        """
        pass
    
class DownloadBaseCallback( BaseMeter ):
    """This is a base class that can be extended to implement a custom
    download progress handler to be used with
    :func:`YumBase.repos.setProgressBar`.
    
    Example::
    
       from yum.callbacks import DownloadBaseCallback
       
       class MyDownloadCallback(  DownloadBaseCallback ):
   
           def updateProgress(self,name,frac,fread,ftime):
               '''
               Update the progressbar
               @param name: filename
               @param frac: Progress fracment (0 -> 1)
               @param fread: formated string containing BytesRead
               @param ftime : formated string containing remaining or elapsed time
               '''
               pct = int( frac*100 )
               print " %s : %s " % (name,pct)
   
   
       if __name__ == '__main__':
           my = YumBase()
           my.doConfigSetup()
           dnlcb = MyDownloadCallback()
           my.repos.setProgressBar( dnlcb )
           for pkg in my.pkgSack:
               print pkg.name
       """
    def __init__(self):
        BaseMeter.__init__( self )
        self.totSize = ""   # Total size to download in a formatted string (Kb, MB etc)
        
    def update( self, amount_read, now=None ):
        """Update the status bar.

:param amount_read: the amount of data, in bytes, that has been read
        :param now: the current time in seconds since the epoch.  If
           *now* is not given, the output of :func:`time.time()` will
           be used.
        """
        BaseMeter.update( self, amount_read, now )

def _do_start( self, now=None ):
        name = self._getName()
        self.updateProgress(name,0.0,"","")
        if not self.size is None:
            self.totSize = format_number( self.size )

def _do_update( self, amount_read, now=None ):
        fread = format_number( amount_read )
        name = self._getName()
        if self.size is None:
            # Elapsed time
            etime = self.re.elapsed_time()
            fetime = format_time( etime )
            frac = 0.0
            self.updateProgress(name,frac,fread,fetime)
        else:
            # Remaining time
            rtime = self.re.remaining_time()
            frtime = format_time( rtime )
            frac = self.re.fraction_read()
            self.updateProgress(name,frac,fread,frtime)

def _do_end( self, amount_read, now=None ):
        total_time = format_time( self.re.elapsed_time() )
        total_size = format_number( amount_read )
        name = self._getName()
        self.updateProgress(name,1.0,total_size,total_time)

def _getName(self):
        '''
        Get the name of the package being downloaded
        '''
        if self.text and type( self.text ) == type( "" ):
            name = self.text
        else:
            name = self.basename
        return name

def updateProgress(self,name,frac,fread,ftime):
        """Update the progressbar.  This method should be overridden
        by subclasses to implement the handler.

:param name: the name of the filed being downloaded
        :param frac: number between 0 and 1 representing the fraction
            fraction of the file that has been downloaded
        :param fread: formatted string containing the number of bytes read
        :param ftime: formatted string containing remaining or elapsed time

"""
        pass

${this.title}

Code Editor : callbacks.py