/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/progress.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2006-04-13 23:16:57 UTC
  • mfrom: (1662.1.1 bzr.mbp.integration)
  • Revision ID: pqm@pqm.ubuntu.com-20060413231657-bce3d67d3e7a4f2b
(mbp/olaf) push/pull/merge --remember improvements

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006, 2008, 2009 Canonical Ltd
2
 
#
3
 
# This program is free software; you can redistribute it and/or modify
4
 
# it under the terms of the GNU General Public License as published by
5
 
# the Free Software Foundation; either version 2 of the License, or
6
 
# (at your option) any later version.
7
 
#
8
 
# This program is distributed in the hope that it will be useful,
9
 
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
 
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
 
# GNU General Public License for more details.
12
 
#
13
 
# You should have received a copy of the GNU General Public License
14
 
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
 
 
17
 
 
18
 
"""Progress indicators.
19
 
 
20
 
The usual way to use this is via bzrlib.ui.ui_factory.nested_progress_bar which
21
 
will manage a conceptual stack of nested activities.
 
1
# Copyright (C) 2005 Aaron Bentley <aaron.bentley@utoronto.ca>
 
2
# Copyright (C) 2005, 2006 Canonical <canonical.com>
 
3
#
 
4
#    This program is free software; you can redistribute it and/or modify
 
5
#    it under the terms of the GNU General Public License as published by
 
6
#    the Free Software Foundation; either version 2 of the License, or
 
7
#    (at your option) any later version.
 
8
#
 
9
#    This program is distributed in the hope that it will be useful,
 
10
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
 
11
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
12
#    GNU General Public License for more details.
 
13
#
 
14
#    You should have received a copy of the GNU General Public License
 
15
#    along with this program; if not, write to the Free Software
 
16
#    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
17
 
 
18
 
 
19
"""Simple text-mode progress indicator.
 
20
 
 
21
To display an indicator, create a ProgressBar object.  Call it,
 
22
passing Progress objects indicating the current state.  When done,
 
23
call clear().
 
24
 
 
25
Progress is suppressed when output is not sent to a terminal, so as
 
26
not to clutter log files.
22
27
"""
23
28
 
 
29
# TODO: should be a global option e.g. --silent that disables progress
 
30
# indicators, preferably without needing to adjust all code that
 
31
# potentially calls them.
 
32
 
 
33
# TODO: If not on a tty perhaps just print '......' for the benefit of IDEs, etc
 
34
 
 
35
# TODO: Optionally show elapsed time instead/as well as ETA; nicer
 
36
# when the rate is unpredictable
 
37
 
24
38
 
25
39
import sys
26
40
import time
27
41
import os
28
 
 
29
 
 
30
 
from bzrlib import (
31
 
    errors,
32
 
    )
33
 
from bzrlib.trace import mutter
34
 
from bzrlib.symbol_versioning import (
35
 
    deprecated_function,
36
 
    deprecated_in,
37
 
    deprecated_method,
38
 
    )
 
42
from collections import deque
 
43
 
 
44
 
 
45
import bzrlib.errors as errors
 
46
from bzrlib.trace import mutter 
39
47
 
40
48
 
41
49
def _supports_progress(f):
42
 
    """Detect if we can use pretty progress bars on file F.
43
 
 
44
 
    If this returns true we expect that a human may be looking at that
45
 
    output, and that we can repaint a line to update it.
46
 
 
47
 
    This doesn't check the policy for whether we *should* use them.
48
 
    """
49
 
    isatty = getattr(f, 'isatty', None)
50
 
    if isatty is None:
51
 
        return False
52
 
    if not isatty():
53
 
        return False
54
 
    # The following case also handles Win32 - on that platform $TERM is
55
 
    # typically never set, so the case None is treated as a smart terminal,
56
 
    # not dumb.  <https://bugs.launchpad.net/bugs/334808>  win32 files do have
57
 
    # isatty methods that return true.
 
50
    if not hasattr(f, 'isatty'):
 
51
        return False
 
52
    if not f.isatty():
 
53
        return False
58
54
    if os.environ.get('TERM') == 'dumb':
59
55
        # e.g. emacs compile window
60
56
        return False
61
57
    return True
62
58
 
63
59
 
64
 
class ProgressTask(object):
65
 
    """Model component of a progress indicator.
66
 
 
67
 
    Most code that needs to indicate progress should update one of these,
68
 
    and it will in turn update the display, if one is present.
69
 
 
70
 
    Code updating the task may also set fields as hints about how to display
71
 
    it: show_pct, show_spinner, show_eta, show_count, show_bar.  UIs
72
 
    will not necessarily respect all these fields.
 
60
 
 
61
def ProgressBar(to_file=sys.stderr, **kwargs):
 
62
    """Abstract factory"""
 
63
    if _supports_progress(to_file):
 
64
        return TTYProgressBar(to_file=to_file, **kwargs)
 
65
    else:
 
66
        return DotsProgressBar(to_file=to_file, **kwargs)
73
67
    
74
 
    :ivar update_latency: The interval (in seconds) at which the PB should be
75
 
        updated.  Setting this to zero suggests every update should be shown
76
 
        synchronously.
77
 
 
78
 
    :ivar show_transport_activity: If true (default), transport activity
79
 
        will be shown when this task is drawn.  Disable it if you're sure 
80
 
        that only irrelevant or uninteresting transport activity can occur
81
 
        during this task.
82
 
    """
83
 
 
84
 
    def __init__(self, parent_task=None, ui_factory=None, progress_view=None):
85
 
        """Construct a new progress task.
86
 
 
87
 
        :param parent_task: Enclosing ProgressTask or None.
88
 
 
89
 
        :param progress_view: ProgressView to display this ProgressTask.
90
 
 
91
 
        :param ui_factory: The UI factory that will display updates; 
92
 
            deprecated in favor of passing progress_view directly.
93
 
 
94
 
        Normally you should not call this directly but rather through
95
 
        `ui_factory.nested_progress_bar`.
96
 
        """
97
 
        self._parent_task = parent_task
98
 
        self._last_update = 0
99
 
        self.total_cnt = None
100
 
        self.current_cnt = None
101
 
        self.msg = ''
102
 
        # TODO: deprecate passing ui_factory
103
 
        self.ui_factory = ui_factory
104
 
        self.progress_view = progress_view
105
 
        self.show_pct = False
106
 
        self.show_spinner = True
107
 
        self.show_eta = False,
108
 
        self.show_count = True
109
 
        self.show_bar = True
110
 
        self.update_latency = 0.1
111
 
        self.show_transport_activity = True
112
 
 
113
 
    def __repr__(self):
114
 
        return '%s(%r/%r, msg=%r)' % (
115
 
            self.__class__.__name__,
116
 
            self.current_cnt,
117
 
            self.total_cnt,
118
 
            self.msg)
119
 
 
120
 
    def update(self, msg, current_cnt=None, total_cnt=None):
121
 
        self.msg = msg
122
 
        self.current_cnt = current_cnt
123
 
        if total_cnt:
124
 
            self.total_cnt = total_cnt
125
 
        if self.progress_view:
126
 
            self.progress_view.show_progress(self)
127
 
        else:
128
 
            self.ui_factory._progress_updated(self)
129
 
 
130
 
    def tick(self):
131
 
        self.update(self.msg)
132
 
 
133
 
    def finished(self):
134
 
        if self.progress_view:
135
 
            self.progress_view.task_finished(self)
136
 
        else:
137
 
            self.ui_factory._progress_finished(self)
138
 
 
139
 
    def make_sub_task(self):
140
 
        return ProgressTask(self, ui_factory=self.ui_factory,
141
 
            progress_view=self.progress_view)
142
 
 
143
 
    def _overall_completion_fraction(self, child_fraction=0.0):
144
 
        """Return fractional completion of this task and its parents
145
 
 
146
 
        Returns None if no completion can be computed."""
147
 
        if self.current_cnt is not None and self.total_cnt:
148
 
            own_fraction = (float(self.current_cnt) + child_fraction) / self.total_cnt
149
 
        else:
150
 
            # if this task has no estimation, it just passes on directly
151
 
            # whatever the child has measured...
152
 
            own_fraction = child_fraction
153
 
        if self._parent_task is None:
154
 
            return own_fraction
155
 
        else:
156
 
            if own_fraction is None:
157
 
                own_fraction = 0.0
158
 
            return self._parent_task._overall_completion_fraction(own_fraction)
159
 
 
160
 
    @deprecated_method(deprecated_in((2, 1, 0)))
161
 
    def note(self, fmt_string, *args):
162
 
        """Record a note without disrupting the progress bar.
163
 
        
164
 
        Deprecated: use ui_factory.note() instead or bzrlib.trace.  Note that
165
 
        ui_factory.note takes just one string as the argument, not a format
166
 
        string and arguments.
167
 
        """
168
 
        if args:
169
 
            self.ui_factory.note(fmt_string % args)
170
 
        else:
171
 
            self.ui_factory.note(fmt_string)
172
 
 
173
 
    def clear(self):
174
 
        # TODO: deprecate this method; the model object shouldn't be concerned
175
 
        # with whether it's shown or not.  Most callers use this because they
176
 
        # want to write some different non-progress output to the screen, but
177
 
        # they should probably instead use a stream that's synchronized with
178
 
        # the progress output.  It may be there is a model-level use for
179
 
        # saying "this task's not active at the moment" but I don't see it. --
180
 
        # mbp 20090623
181
 
        if self.progress_view:
182
 
            self.progress_view.clear()
183
 
        else:
184
 
            self.ui_factory.clear_term()
185
 
 
186
 
 
187
 
@deprecated_function(deprecated_in((1, 16, 0)))
188
 
def ProgressBar(to_file=None, **kwargs):
189
 
    """Construct a progress bar.
190
 
 
191
 
    Deprecated; ask the ui_factory for a progress task instead.
192
 
    """
193
 
    if to_file is None:
194
 
        to_file = sys.stderr
195
 
    requested_bar_type = os.environ.get('BZR_PROGRESS_BAR')
196
 
    # An value of '' or not set reverts to standard processing
197
 
    if requested_bar_type in (None, ''):
198
 
        if _supports_progress(to_file):
199
 
            return TTYProgressBar(to_file=to_file, **kwargs)
200
 
        else:
201
 
            return DummyProgress(to_file=to_file, **kwargs)
202
 
    else:
203
 
        # Minor sanitation to prevent spurious errors
204
 
        requested_bar_type = requested_bar_type.lower().strip()
205
 
        # TODO: jam 20060710 Arguably we shouldn't raise an exception
206
 
        #       but should instead just disable progress bars if we
207
 
        #       don't recognize the type
208
 
        if requested_bar_type not in _progress_bar_types:
209
 
            raise errors.InvalidProgressBarType(requested_bar_type,
210
 
                                                _progress_bar_types.keys())
211
 
        return _progress_bar_types[requested_bar_type](to_file=to_file, **kwargs)
212
 
 
213
 
 
214
 
# NOTE: This is also deprecated; you should provide a ProgressView instead.
 
68
 
 
69
class ProgressBarStack(object):
 
70
    """A stack of progress bars."""
 
71
 
 
72
    def __init__(self,
 
73
                 to_file=sys.stderr,
 
74
                 show_pct=False,
 
75
                 show_spinner=True,
 
76
                 show_eta=False,
 
77
                 show_bar=True,
 
78
                 show_count=True,
 
79
                 to_messages_file=sys.stdout,
 
80
                 klass=None):
 
81
        """Setup the stack with the parameters the progress bars should have."""
 
82
        self._to_file = to_file
 
83
        self._show_pct = show_pct
 
84
        self._show_spinner = show_spinner
 
85
        self._show_eta = show_eta
 
86
        self._show_bar = show_bar
 
87
        self._show_count = show_count
 
88
        self._to_messages_file = to_messages_file
 
89
        self._stack = []
 
90
        self._klass = klass or TTYProgressBar
 
91
 
 
92
    def top(self):
 
93
        if len(self._stack) != 0:
 
94
            return self._stack[-1]
 
95
        else:
 
96
            return None
 
97
 
 
98
    def bottom(self):
 
99
        if len(self._stack) != 0:
 
100
            return self._stack[0]
 
101
        else:
 
102
            return None
 
103
 
 
104
    def get_nested(self):
 
105
        """Return a nested progress bar."""
 
106
        if len(self._stack) == 0:
 
107
            func = self._klass
 
108
        else:
 
109
            func = self.top().child_progress
 
110
        new_bar = func(to_file=self._to_file,
 
111
                       show_pct=self._show_pct,
 
112
                       show_spinner=self._show_spinner,
 
113
                       show_eta=self._show_eta,
 
114
                       show_bar=self._show_bar,
 
115
                       show_count=self._show_count,
 
116
                       to_messages_file=self._to_messages_file,
 
117
                       _stack=self)
 
118
        self._stack.append(new_bar)
 
119
        return new_bar
 
120
 
 
121
    def return_pb(self, bar):
 
122
        """Return bar after its been used."""
 
123
        if bar is not self._stack[-1]:
 
124
            raise errors.MissingProgressBarFinish()
 
125
        self._stack.pop()
 
126
 
 
127
 
215
128
class _BaseProgressBar(object):
216
129
 
217
130
    def __init__(self,
218
 
                 to_file=None,
 
131
                 to_file=sys.stderr,
219
132
                 show_pct=False,
220
133
                 show_spinner=False,
221
 
                 show_eta=False,
 
134
                 show_eta=True,
222
135
                 show_bar=True,
223
136
                 show_count=True,
224
 
                 to_messages_file=None,
 
137
                 to_messages_file=sys.stdout,
225
138
                 _stack=None):
226
139
        object.__init__(self)
227
 
        if to_file is None:
228
 
            to_file = sys.stderr
229
 
        if to_messages_file is None:
230
 
            to_messages_file = sys.stdout
231
140
        self.to_file = to_file
232
141
        self.to_messages_file = to_messages_file
233
142
        self.last_msg = None
241
150
        self._stack = _stack
242
151
        # seed throttler
243
152
        self.MIN_PAUSE = 0.1 # seconds
244
 
        now = time.time()
 
153
        now = time.clock()
245
154
        # starting now
246
155
        self.start_time = now
247
156
        # next update should not throttle
250
159
    def finished(self):
251
160
        """Return this bar to its progress stack."""
252
161
        self.clear()
 
162
        assert self._stack is not None
253
163
        self._stack.return_pb(self)
254
164
 
255
165
    def note(self, fmt_string, *args, **kwargs):
258
168
        self.to_messages_file.write(fmt_string % args)
259
169
        self.to_messages_file.write('\n')
260
170
 
261
 
    @deprecated_function(deprecated_in((1, 16, 0)))
262
171
    def child_progress(self, **kwargs):
263
172
        return ChildProgress(**kwargs)
264
173
 
268
177
 
269
178
    This can be used as the default argument for methods that
270
179
    take an optional progress indicator."""
271
 
 
272
180
    def tick(self):
273
181
        pass
274
182
 
280
188
 
281
189
    def clear(self):
282
190
        pass
283
 
 
 
191
        
284
192
    def note(self, fmt_string, *args, **kwargs):
285
193
        """See _BaseProgressBar.note()."""
286
194
 
287
195
    def child_progress(self, **kwargs):
288
196
        return DummyProgress(**kwargs)
289
197
 
290
 
 
291
198
class DotsProgressBar(_BaseProgressBar):
292
199
 
293
 
    @deprecated_function(deprecated_in((1, 16, 0)))
294
200
    def __init__(self, **kwargs):
295
201
        _BaseProgressBar.__init__(self, **kwargs)
296
202
        self.last_msg = None
297
203
        self.need_nl = False
298
 
 
 
204
        
299
205
    def tick(self):
300
206
        self.update()
301
 
 
 
207
        
302
208
    def update(self, msg=None, current_cnt=None, total_cnt=None):
303
209
        if msg and msg != self.last_msg:
304
210
            if self.need_nl:
305
211
                self.to_file.write('\n')
 
212
            
306
213
            self.to_file.write(msg + ': ')
307
214
            self.last_msg = msg
308
215
        self.need_nl = True
309
216
        self.to_file.write('.')
310
 
 
 
217
        
311
218
    def clear(self):
312
219
        if self.need_nl:
313
220
            self.to_file.write('\n')
314
 
        self.need_nl = False
315
 
 
 
221
        
316
222
    def child_update(self, message, current, total):
317
223
        self.tick()
318
 
 
319
 
 
 
224
    
320
225
class TTYProgressBar(_BaseProgressBar):
321
226
    """Progress bar display object.
322
227
 
339
244
    """
340
245
    SPIN_CHARS = r'/-\|'
341
246
 
342
 
    @deprecated_function(deprecated_in((1, 16, 0)))
 
247
 
343
248
    def __init__(self, **kwargs):
344
249
        from bzrlib.osutils import terminal_width
345
250
        _BaseProgressBar.__init__(self, **kwargs)
346
251
        self.spin_pos = 0
347
252
        self.width = terminal_width()
348
 
        self.last_updates = []
349
 
        self._max_last_updates = 10
 
253
        self.start_time = None
 
254
        self.last_updates = deque()
350
255
        self.child_fraction = 0
351
 
        self._have_output = False
 
256
    
352
257
 
353
 
    def throttle(self, old_msg):
 
258
    def throttle(self):
354
259
        """Return True if the bar was updated too recently"""
355
260
        # time.time consistently takes 40/4000 ms = 0.01 ms.
356
 
        # time.clock() is faster, but gives us CPU time, not wall-clock time
357
 
        now = time.time()
358
 
        if self.start_time is not None and (now - self.start_time) < 1:
359
 
            return True
360
 
        if old_msg != self.last_msg:
361
 
            return False
 
261
        # but every single update to the pb invokes it.
 
262
        # so we use time.clock which takes 20/4000 ms = 0.005ms
 
263
        # on the downside, time.clock() appears to have approximately
 
264
        # 10ms granularity, so we treat a zero-time change as 'throttled.'
 
265
        
 
266
        now = time.clock()
362
267
        interval = now - self.last_update
363
268
        # if interval > 0
364
269
        if interval < self.MIN_PAUSE:
365
270
            return True
366
271
 
367
272
        self.last_updates.append(now - self.last_update)
368
 
        # Don't let the queue grow without bound
369
 
        self.last_updates = self.last_updates[-self._max_last_updates:]
370
273
        self.last_update = now
371
274
        return False
 
275
        
372
276
 
373
277
    def tick(self):
374
 
        self.update(self.last_msg, self.last_cnt, self.last_total,
 
278
        self.update(self.last_msg, self.last_cnt, self.last_total, 
375
279
                    self.child_fraction)
376
280
 
377
281
    def child_update(self, message, current, total):
381
285
                pass
382
286
            elif self.last_cnt + child_fraction <= self.last_total:
383
287
                self.child_fraction = child_fraction
 
288
            else:
 
289
                mutter('not updating child fraction')
384
290
        if self.last_msg is None:
385
291
            self.last_msg = ''
386
292
        self.tick()
387
293
 
388
 
    def update(self, msg, current_cnt=None, total_cnt=None,
389
 
            child_fraction=0):
390
 
        """Update and redraw progress bar.
391
 
        """
392
 
        if msg is None:
393
 
            msg = self.last_msg
394
294
 
395
 
        if total_cnt is None:
396
 
            total_cnt = self.last_total
 
295
    def update(self, msg, current_cnt=None, total_cnt=None, 
 
296
               child_fraction=0):
 
297
        """Update and redraw progress bar."""
397
298
 
398
299
        if current_cnt < 0:
399
300
            current_cnt = 0
400
 
 
 
301
            
401
302
        if current_cnt > total_cnt:
402
303
            total_cnt = current_cnt
403
 
 
404
 
        ## # optional corner case optimisation
 
304
        
 
305
        ## # optional corner case optimisation 
405
306
        ## # currently does not seem to fire so costs more than saved.
406
307
        ## # trivial optimal case:
407
308
        ## # NB if callers are doing a clear and restore with
414
315
        ##     self.child_fraction == child_fraction):
415
316
        ##     return
416
317
 
417
 
        if msg is None:
418
 
            msg = ''
419
 
 
420
318
        old_msg = self.last_msg
421
319
        # save these for the tick() function
422
320
        self.last_msg = msg
424
322
        self.last_total = total_cnt
425
323
        self.child_fraction = child_fraction
426
324
 
427
 
        # each function call takes 20ms/4000 = 0.005 ms,
 
325
        # each function call takes 20ms/4000 = 0.005 ms, 
428
326
        # but multiple that by 4000 calls -> starts to cost.
429
327
        # so anything to make this function call faster
430
328
        # will improve base 'diff' time by up to 0.1 seconds.
431
 
        if self.throttle(old_msg):
 
329
        if old_msg == self.last_msg and self.throttle():
432
330
            return
433
331
 
434
332
        if self.show_eta and self.start_time and self.last_total:
435
 
            eta = get_eta(self.start_time, self.last_cnt + self.child_fraction,
 
333
            eta = get_eta(self.start_time, self.last_cnt + self.child_fraction, 
436
334
                    self.last_total, last_updates = self.last_updates)
437
335
            eta_str = " " + str_tdelta(eta)
438
336
        else:
439
337
            eta_str = ""
440
338
 
441
339
        if self.show_spinner:
442
 
            spin_str = self.SPIN_CHARS[self.spin_pos % 4] + ' '
 
340
            spin_str = self.SPIN_CHARS[self.spin_pos % 4] + ' '            
443
341
        else:
444
342
            spin_str = ''
445
343
 
462
360
            # make both fields the same size
463
361
            t = '%i' % (self.last_total)
464
362
            c = '%*i' % (len(t), self.last_cnt)
465
 
            count_str = ' ' + c + '/' + t
 
363
            count_str = ' ' + c + '/' + t 
466
364
 
467
365
        if self.show_bar:
468
366
            # progress bar, if present, soaks up all remaining space
471
369
 
472
370
            if self.last_total:
473
371
                # number of markers highlighted in bar
474
 
                markers = int(round(float(cols) *
 
372
                markers = int(round(float(cols) * 
475
373
                              (self.last_cnt + self.child_fraction) / self.last_total))
476
374
                bar_str = '[' + ('=' * markers).ljust(cols) + '] '
477
375
            elif False:
479
377
                # so just show an expanded spinning thingy
480
378
                m = self.spin_pos % cols
481
379
                ms = (' ' * m + '*').ljust(cols)
482
 
 
 
380
                
483
381
                bar_str = '[' + ms + '] '
484
382
            else:
485
383
                bar_str = ''
486
384
        else:
487
385
            bar_str = ''
488
386
 
489
 
        m = spin_str + bar_str + self.last_msg + count_str \
490
 
            + pct_str + eta_str
491
 
        self.to_file.write('\r%-*.*s' % (self.width - 1, self.width - 1, m))
492
 
        self._have_output = True
493
 
        #self.to_file.flush()
494
 
 
495
 
    def clear(self):
496
 
        if self._have_output:
497
 
            self.to_file.write('\r%s\r' % (' ' * (self.width - 1)))
498
 
        self._have_output = False
499
 
        #self.to_file.flush()
500
 
 
501
 
 
502
 
 
503
 
# DEPRECATED
 
387
        m = spin_str + bar_str + self.last_msg + count_str + pct_str + eta_str
 
388
 
 
389
        assert len(m) < self.width
 
390
        self.to_file.write('\r' + m.ljust(self.width - 1))
 
391
        #self.to_file.flush()
 
392
            
 
393
    def clear(self):        
 
394
        self.to_file.write('\r%s\r' % (' ' * (self.width - 1)))
 
395
        #self.to_file.flush()        
 
396
 
 
397
 
504
398
class ChildProgress(_BaseProgressBar):
505
399
    """A progress indicator that pushes its data to the parent"""
506
 
 
507
 
    @deprecated_function(deprecated_in((1, 16, 0)))
508
400
    def __init__(self, _stack, **kwargs):
509
401
        _BaseProgressBar.__init__(self, _stack=_stack, **kwargs)
510
402
        self.parent = _stack.top()
515
407
 
516
408
    def update(self, msg, current_cnt=None, total_cnt=None):
517
409
        self.current = current_cnt
518
 
        if total_cnt is not None:
519
 
            self.total = total_cnt
 
410
        self.total = total_cnt
520
411
        self.message = msg
521
412
        self.child_fraction = 0
522
413
        self.tick()
545
436
    def note(self, *args, **kwargs):
546
437
        self.parent.note(*args, **kwargs)
547
438
 
548
 
 
 
439
 
549
440
def str_tdelta(delt):
550
441
    if delt is None:
551
442
        return "-:--:--"
568
459
    if current > total:
569
460
        return None                     # wtf?
570
461
 
571
 
    elapsed = time.time() - start_time
 
462
    elapsed = time.clock() - start_time
572
463
 
573
464
    if elapsed < 2.0:                   # not enough time to estimate
574
465
        return None
575
 
 
 
466
    
576
467
    total_duration = float(elapsed) * float(total) / float(current)
577
468
 
 
469
    assert total_duration >= elapsed
 
470
 
578
471
    if last_updates and len(last_updates) >= n_recent:
 
472
        while len(last_updates) > n_recent:
 
473
            last_updates.popleft()
579
474
        avg = sum(last_updates) / float(len(last_updates))
580
475
        time_left = avg * (total - current)
581
476
 
601
496
            self.cur_phase = 0
602
497
        else:
603
498
            self.cur_phase += 1
 
499
        assert self.cur_phase < self.total 
604
500
        self.pb.update(self.message, self.cur_phase, self.total)
605
501
 
606
502
 
607
 
_progress_bar_types = {}
608
 
_progress_bar_types['dummy'] = DummyProgress
609
 
_progress_bar_types['none'] = DummyProgress
610
 
_progress_bar_types['tty'] = TTYProgressBar
611
 
_progress_bar_types['dots'] = DotsProgressBar
 
503
def run_tests():
 
504
    import doctest
 
505
    result = doctest.testmod()
 
506
    if result[1] > 0:
 
507
        if result[0] == 0:
 
508
            print "All tests passed"
 
509
    else:
 
510
        print "No tests to run"
 
511
 
 
512
 
 
513
def demo():
 
514
    sleep = time.sleep
 
515
    
 
516
    print 'dumb-terminal test:'
 
517
    pb = DotsProgressBar()
 
518
    for i in range(100):
 
519
        pb.update('Leoparden', i, 99)
 
520
        sleep(0.1)
 
521
    sleep(1.5)
 
522
    pb.clear()
 
523
    sleep(1.5)
 
524
    
 
525
    print 'smart-terminal test:'
 
526
    pb = ProgressBar(show_pct=True, show_bar=True, show_spinner=False)
 
527
    for i in range(100):
 
528
        pb.update('Elephanten', i, 99)
 
529
        sleep(0.1)
 
530
    sleep(2)
 
531
    pb.clear()
 
532
    sleep(1)
 
533
 
 
534
    print 'done!'
 
535
 
 
536
if __name__ == "__main__":
 
537
    demo()