Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
cext	[ DIR ]	drwxr-xr-x
cffi	[ DIR ]	drwxr-xr-x
defaultrc	[ DIR ]	drwxr-xr-x
dirstateutils	[ DIR ]	drwxr-xr-x
helptext	[ DIR ]	drwxr-xr-x
hgweb	[ DIR ]	drwxr-xr-x
interfaces	[ DIR ]	drwxr-xr-x
locale	[ DIR ]	drwxr-xr-x
pure	[ DIR ]	drwxr-xr-x
revlogutils	[ DIR ]	drwxr-xr-x
templates	[ DIR ]	drwxr-xr-x
testing	[ DIR ]	drwxr-xr-x
thirdparty	[ DIR ]	drwxr-xr-x
upgrade_utils	[ DIR ]	drwxr-xr-x
utils	[ DIR ]	drwxr-xr-x
__init__.py	416 B	-rw-r--r--
__modulepolicy__.py	61 B	-rw-r--r--
__version__.py	60 B	-rw-r--r--
ancestor.py	12.51 KB	-rw-r--r--
archival.py	11.59 KB	-rw-r--r--
bookmarks.py	34.74 KB	-rw-r--r--
branchmap.py	31.58 KB	-rw-r--r--
bundle2.py	86.74 KB	-rw-r--r--
bundlecaches.py	13.6 KB	-rw-r--r--
bundlerepo.py	23.29 KB	-rw-r--r--
cacheutil.py	827 B	-rw-r--r--
changegroup.py	65.72 KB	-rw-r--r--
changelog.py	19.72 KB	-rw-r--r--
chgserver.py	26.25 KB	-rw-r--r--
cmdutil.py	131.98 KB	-rw-r--r--
color.py	17.93 KB	-rw-r--r--
commands.py	257.93 KB	-rw-r--r--
commandserver.py	24.59 KB	-rw-r--r--
commit.py	18.52 KB	-rw-r--r--
config.py	8.59 KB	-rw-r--r--
configitems.py	46.49 KB	-rw-r--r--
context.py	100.53 KB	-rw-r--r--
copies.py	46.01 KB	-rw-r--r--
crecord.py	70.99 KB	-rw-r--r--
dagop.py	39.57 KB	-rw-r--r--
dagparser.py	15.13 KB	-rw-r--r--
debugcommands.py	154.84 KB	-rw-r--r--
destutil.py	17.07 KB	-rw-r--r--
diffhelper.py	2.32 KB	-rw-r--r--
diffutil.py	4.52 KB	-rw-r--r--
dirstate.py	51.01 KB	-rw-r--r--
dirstateguard.py	3.09 KB	-rw-r--r--
dirstatemap.py	23.77 KB	-rw-r--r--
discovery.py	22 KB	-rw-r--r--
dispatch.py	46.19 KB	-rw-r--r--
dummycert.pem	2.19 KB	-rw-r--r--
encoding.py	22.89 KB	-rw-r--r--
error.py	17.88 KB	-rw-r--r--
exchange.py	94.65 KB	-rw-r--r--
extensions.py	30.6 KB	-rw-r--r--
exthelper.py	11.83 KB	-rw-r--r--
fancyopts.py	11.3 KB	-rw-r--r--
filelog.py	8.58 KB	-rw-r--r--
filemerge.py	39.67 KB	-rw-r--r--
fileset.py	18.66 KB	-rw-r--r--
filesetlang.py	10.34 KB	-rw-r--r--
formatter.py	26.34 KB	-rw-r--r--
graphmod.py	16.76 KB	-rw-r--r--
grep.py	7.26 KB	-rw-r--r--
hbisect.py	10.89 KB	-rw-r--r--
help.py	36.74 KB	-rw-r--r--
hg.py	51.95 KB	-rw-r--r--
hook.py	11.53 KB	-rw-r--r--
httpconnection.py	4.27 KB	-rw-r--r--
httppeer.py	20.71 KB	-rw-r--r--
i18n.py	4.05 KB	-rw-r--r--
keepalive.py	27.1 KB	-rw-r--r--
linelog.py	14.94 KB	-rw-r--r--
localrepo.py	140.97 KB	-rw-r--r--
lock.py	11.89 KB	-rw-r--r--
logcmdutil.py	42.53 KB	-rw-r--r--
logexchange.py	4.98 KB	-rw-r--r--
loggingutil.py	3.93 KB	-rw-r--r--
lsprof.py	4.25 KB	-rw-r--r--
lsprofcalltree.py	2.74 KB	-rw-r--r--
mail.py	17.09 KB	-rw-r--r--
manifest.py	75.45 KB	-rw-r--r--
match.py	52.06 KB	-rw-r--r--
mdiff.py	17.37 KB	-rw-r--r--
merge.py	90.09 KB	-rw-r--r--
mergestate.py	31.37 KB	-rw-r--r--
mergeutil.py	502 B	-rw-r--r--
metadata.py	32.33 KB	-rw-r--r--
minifileset.py	3.54 KB	-rw-r--r--
minirst.py	29.13 KB	-rw-r--r--
namespaces.py	8.19 KB	-rw-r--r--
narrowspec.py	11.57 KB	-rw-r--r--
node.py	2.07 KB	-rw-r--r--
obsolete.py	36.76 KB	-rw-r--r--
obsutil.py	35.84 KB	-rw-r--r--
parser.py	25.68 KB	-rw-r--r--
patch.py	102 KB	-rw-r--r--
pathutil.py	12.21 KB	-rw-r--r--
phases.py	32.54 KB	-rw-r--r--
policy.py	4.74 KB	-rw-r--r--
posix.py	23.05 KB	-rw-r--r--
profiling.py	8.64 KB	-rw-r--r--
progress.py	10.92 KB	-rw-r--r--
pushkey.py	1.67 KB	-rw-r--r--
pvec.py	6.01 KB	-rw-r--r--
pycompat.py	16.33 KB	-rw-r--r--
rcutil.py	3.57 KB	-rw-r--r--
registrar.py	17.78 KB	-rw-r--r--
repair.py	18.46 KB	-rw-r--r--
repocache.py	4.49 KB	-rw-r--r--
repoview.py	16.89 KB	-rw-r--r--
requirements.py	4.64 KB	-rw-r--r--
revlog.py	117.08 KB	-rw-r--r--
revset.py	87.27 KB	-rw-r--r--
revsetlang.py	28.47 KB	-rw-r--r--
rewriteutil.py	8.47 KB	-rw-r--r--
scmposix.py	2.57 KB	-rw-r--r--
scmutil.py	75.72 KB	-rw-r--r--
scmwindows.py	3.37 KB	-rw-r--r--
server.py	7.05 KB	-rw-r--r--
setdiscovery.py	18 KB	-rw-r--r--
shelve.py	38.04 KB	-rw-r--r--
similar.py	3.97 KB	-rw-r--r--
simplemerge.py	16.86 KB	-rw-r--r--
smartset.py	33.65 KB	-rw-r--r--
sparse.py	26.37 KB	-rw-r--r--
sshpeer.py	22.56 KB	-rw-r--r--
sslutil.py	35.54 KB	-rw-r--r--
stack.py	762 B	-rw-r--r--
state.py	11.99 KB	-rw-r--r--
statichttprepo.py	7.92 KB	-rw-r--r--
statprof.py	32.16 KB	-rw-r--r--
store.py	25.27 KB	-rw-r--r--
streamclone.py	30.73 KB	-rw-r--r--
strip.py	8.72 KB	-rw-r--r--
subrepo.py	70.89 KB	-rw-r--r--
subrepoutil.py	17.42 KB	-rw-r--r--
tagmerge.py	11.29 KB	-rw-r--r--
tags.py	29.67 KB	-rw-r--r--
templatefilters.py	15.11 KB	-rw-r--r--
templatefuncs.py	30.14 KB	-rw-r--r--
templatekw.py	34.12 KB	-rw-r--r--
templater.py	37.7 KB	-rw-r--r--
templateutil.py	35.66 KB	-rw-r--r--
transaction.py	25.97 KB	-rw-r--r--
treediscovery.py	5.92 KB	-rw-r--r--
txnutil.py	1.02 KB	-rw-r--r--
ui.py	80.23 KB	-rw-r--r--
unionrepo.py	9.72 KB	-rw-r--r--
upgrade.py	14.59 KB	-rw-r--r--
url.py	24.56 KB	-rw-r--r--
urllibcompat.py	5.94 KB	-rw-r--r--
util.py	95.18 KB	-rw-r--r--
verify.py	21.8 KB	-rw-r--r--
vfs.py	24.93 KB	-rw-r--r--
win32.py	22.04 KB	-rw-r--r--
windows.py	21.77 KB	-rw-r--r--
wireprotoframing.py	64.95 KB	-rw-r--r--
wireprotoserver.py	17.38 KB	-rw-r--r--
wireprototypes.py	13.07 KB	-rw-r--r--
wireprotov1peer.py	21.51 KB	-rw-r--r--
wireprotov1server.py	26.33 KB	-rw-r--r--
worker.py	15.47 KB	-rw-r--r--
zstd.cpython-310-x86_64-linux-...	570.78 KB	-rw-r--r--

Code Editor : progress.py

# progress.py progress bars related code
#
# Copyright (C) 2010 Augie Fackler <durin42@gmail.com>
#
# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from __future__ import absolute_import

import errno
import threading
import time

from .i18n import _
from . import encoding

def spacejoin(*args):
    return b' '.join(s for s in args if s)

def shouldprint(ui):
    return not (ui.quiet or ui.plain(b'progress')) and (
        ui._isatty(ui.ferr) or ui.configbool(b'progress', b'assume-tty')
    )

def fmtremaining(seconds):
    """format a number of remaining seconds in human readable way

This will properly display seconds, minutes, hours, days if needed"""
    if seconds < 60:
        # i18n: format XX seconds as "XXs"
        return _(b"%02ds") % seconds
    minutes = seconds // 60
    if minutes < 60:
        seconds -= minutes * 60
        # i18n: format X minutes and YY seconds as "XmYYs"
        return _(b"%dm%02ds") % (minutes, seconds)
    # we're going to ignore seconds in this case
    minutes += 1
    hours = minutes // 60
    minutes -= hours * 60
    if hours < 30:
        # i18n: format X hours and YY minutes as "XhYYm"
        return _(b"%dh%02dm") % (hours, minutes)
    # we're going to ignore minutes in this case
    hours += 1
    days = hours // 24
    hours -= days * 24
    if days < 15:
        # i18n: format X days and YY hours as "XdYYh"
        return _(b"%dd%02dh") % (days, hours)
    # we're going to ignore hours in this case
    days += 1
    weeks = days // 7
    days -= weeks * 7
    if weeks < 55:
        # i18n: format X weeks and YY days as "XwYYd"
        return _(b"%dw%02dd") % (weeks, days)
    # we're going to ignore days and treat a year as 52 weeks
    weeks += 1
    years = weeks // 52
    weeks -= years * 52
    # i18n: format X years and YY weeks as "XyYYw"
    return _(b"%dy%02dw") % (years, weeks)

# file_write() and file_flush() of Python 2 do not restart on EINTR if
# the file is attached to a "slow" device (e.g. a terminal) and raise
# IOError. We cannot know how many bytes would be written by file_write(),
# but a progress text is known to be short enough to be written by a
# single write() syscall, so we can just retry file_write() with the whole
# text. (issue5532)
#
# This should be a short-term workaround. We'll need to fix every occurrence
# of write() to a terminal or pipe.
def _eintrretry(func, *args):
    while True:
        try:
            return func(*args)
        except IOError as err:
            if err.errno == errno.EINTR:
                continue
            raise

class progbar(object):
    def __init__(self, ui):
        self.ui = ui
        self._refreshlock = threading.Lock()
        self.resetstate()

def resetstate(self):
        self.topics = []
        self.topicstates = {}
        self.starttimes = {}
        self.startvals = {}
        self.printed = False
        self.lastprint = time.time() + float(
            self.ui.config(b'progress', b'delay')
        )
        self.curtopic = None
        self.lasttopic = None
        self.indetcount = 0
        self.refresh = float(self.ui.config(b'progress', b'refresh'))
        self.changedelay = max(
            3 * self.refresh, float(self.ui.config(b'progress', b'changedelay'))
        )
        self.order = self.ui.configlist(b'progress', b'format')
        self.estimateinterval = self.ui.configwith(
            float, b'progress', b'estimateinterval'
        )

def show(self, now, topic, pos, item, unit, total):
        if not shouldprint(self.ui):
            return
        termwidth = self.width()
        self.printed = True
        head = b''
        needprogress = False
        tail = b''
        for indicator in self.order:
            add = b''
            if indicator == b'topic':
                add = topic
            elif indicator == b'number':
                if total:
                    add = b'%*d/%d' % (len(str(total)), pos, total)
                else:
                    add = b'%d' % pos
            elif indicator.startswith(b'item') and item:
                slice = b'end'
                if b'-' in indicator:
                    wid = int(indicator.split(b'-')[1])
                elif b'+' in indicator:
                    slice = b'beginning'
                    wid = int(indicator.split(b'+')[1])
                else:
                    wid = 20
                if slice == b'end':
                    add = encoding.trim(item, wid, leftside=True)
                else:
                    add = encoding.trim(item, wid)
                add += (wid - encoding.colwidth(add)) * b' '
            elif indicator == b'bar':
                add = b''
                needprogress = True
            elif indicator == b'unit' and unit:
                add = unit
            elif indicator == b'estimate':
                add = self.estimate(topic, pos, total, now)
            elif indicator == b'speed':
                add = self.speed(topic, pos, unit, now)
            if not needprogress:
                head = spacejoin(head, add)
            else:
                tail = spacejoin(tail, add)
        if needprogress:
            used = 0
            if head:
                used += encoding.colwidth(head) + 1
            if tail:
                used += encoding.colwidth(tail) + 1
            progwidth = termwidth - used - 3
            if total and pos <= total:
                amt = pos * progwidth // total
                bar = b'=' * (amt - 1)
                if amt > 0:
                    bar += b'>'
                bar += b' ' * (progwidth - amt)
            else:
                progwidth -= 3
                self.indetcount += 1
                # mod the count by twice the width so we can make the
                # cursor bounce between the right and left sides
                amt = self.indetcount % (2 * progwidth)
                amt -= progwidth
                bar = (
                    b' ' * int(progwidth - abs(amt))
                    + b'<=>'
                    + b' ' * int(abs(amt))
                )
            prog = b''.join((b'[', bar, b']'))
            out = spacejoin(head, prog, tail)
        else:
            out = spacejoin(head, tail)
        self._writeerr(b'\r' + encoding.trim(out, termwidth))
        self.lasttopic = topic
        self._flusherr()

def clear(self):
        if not self.printed or not self.lastprint or not shouldprint(self.ui):
            return
        self._writeerr(b'\r%s\r' % (b' ' * self.width()))
        self._flusherr()
        if self.printed:
            # force immediate re-paint of progress bar
            self.lastprint = 0

def complete(self):
        if not shouldprint(self.ui):
            return
        if self.ui.configbool(b'progress', b'clear-complete'):
            self.clear()
        else:
            self._writeerr(b'\n')
        self._flusherr()

def _flusherr(self):
        _eintrretry(self.ui.ferr.flush)

def _writeerr(self, msg):
        _eintrretry(self.ui.ferr.write, msg)

def width(self):
        tw = self.ui.termwidth()
        return min(int(self.ui.config(b'progress', b'width', default=tw)), tw)

def estimate(self, topic, pos, total, now):
        if total is None:
            return b''
        initialpos = self.startvals[topic]
        target = total - initialpos
        delta = pos - initialpos
        if delta > 0:
            elapsed = now - self.starttimes[topic]
            seconds = (elapsed * (target - delta)) // delta + 1
            return fmtremaining(seconds)
        return b''

def speed(self, topic, pos, unit, now):
        initialpos = self.startvals[topic]
        delta = pos - initialpos
        elapsed = now - self.starttimes[topic]
        if elapsed > 0:
            return _(b'%d %s/sec') % (delta / elapsed, unit)
        return b''

def _oktoprint(self, now):
        '''Check if conditions are met to print - e.g. changedelay elapsed'''
        if (
            self.lasttopic is None  # first time we printed
            # not a topic change
            or self.curtopic == self.lasttopic
            # it's been long enough we should print anyway
            or now - self.lastprint >= self.changedelay
        ):
            return True
        else:
            return False

def _calibrateestimate(self, topic, now, pos):
        """Adjust starttimes and startvals for topic so ETA works better

If progress is non-linear (ex. get much slower in the last minute),
        it's more friendly to only use a recent time span for ETA and speed
        calculation.

[======================================>       ]
                                             ^^^^^^^
                           estimateinterval, only use this for estimation
        """
        interval = self.estimateinterval
        if interval <= 0:
            return
        elapsed = now - self.starttimes[topic]
        if elapsed > interval:
            delta = pos - self.startvals[topic]
            newdelta = delta * interval / elapsed
            # If a stall happens temporarily, ETA could change dramatically
            # frequently. This is to avoid such dramatical change and make ETA
            # smoother.
            if newdelta < 0.1:
                return
            self.startvals[topic] = pos - newdelta
            self.starttimes[topic] = now - interval

def progress(self, topic, pos, item=b'', unit=b'', total=None):
        if pos is None:
            self.closetopic(topic)
            return
        now = time.time()
        with self._refreshlock:
            if topic not in self.topics:
                self.starttimes[topic] = now
                self.startvals[topic] = pos
                self.topics.append(topic)
            self.topicstates[topic] = pos, item, unit, total
            self.curtopic = topic
            self._calibrateestimate(topic, now, pos)
            if now - self.lastprint >= self.refresh and self.topics:
                if self._oktoprint(now):
                    self.lastprint = now
                    self.show(now, topic, *self.topicstates[topic])

def closetopic(self, topic):
        with self._refreshlock:
            self.starttimes.pop(topic, None)
            self.startvals.pop(topic, None)
            self.topicstates.pop(topic, None)
            # reset the progress bar if this is the outermost topic
            if self.topics and self.topics[0] == topic and self.printed:
                self.complete()
                self.resetstate()
            # truncate the list of topics assuming all topics within
            # this one are also closed
            if topic in self.topics:
                self.topics = self.topics[: self.topics.index(topic)]
                # reset the last topic to the one we just unwound to,
                # so that higher-level topics will be stickier than
                # lower-level topics
                if self.topics:
                    self.lasttopic = self.topics[-1]
                else:
                    self.lasttopic = None

${this.title}

Code Editor : progress.py