~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/progress.py

  • Committer: Mark Hammond
  • Date: 2008-08-10 11:16:39 UTC
  • mto: (3606.5.3 1.6)
  • mto: This revision was merged to the branch mainline in revision 3626.
  • Revision ID: mhammond@skippinet.com.au-20080810111639-9upz1wig1s8lvz62
install all files with 'restartreplace uninsrestartdelete' and close
tbzrcache at uninstall time.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006, 2008, 2009 Canonical Ltd
 
1
# Copyright (C) 2005 Aaron Bentley <aaron.bentley@utoronto.ca>
 
2
# Copyright (C) 2005, 2006 Canonical Ltd
2
3
#
3
4
# This program is free software; you can redistribute it and/or modify
4
5
# it under the terms of the GNU General Public License as published by
12
13
#
13
14
# You should have received a copy of the GNU General Public License
14
15
# 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
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
17
 
17
18
 
18
19
"""Progress indicators.
19
20
 
20
21
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.
 
22
will maintain a ProgressBarStack for you.
 
23
 
 
24
For direct use, the factory ProgressBar will return an auto-detected progress
 
25
bar that should match your terminal type. You can manually create a
 
26
ProgressBarStack too if you need multiple levels of cooperating progress bars.
 
27
Note that bzrlib's internal functions use the ui module, so if you are using
 
28
bzrlib it really is best to use bzrlib.ui.ui_factory.
22
29
"""
23
30
 
 
31
# TODO: Optionally show elapsed time instead/as well as ETA; nicer
 
32
# when the rate is unpredictable
24
33
 
25
34
import sys
26
35
import time
27
36
import os
28
37
 
29
 
 
 
38
from bzrlib.lazy_import import lazy_import
 
39
lazy_import(globals(), """
30
40
from bzrlib import (
31
41
    errors,
32
42
    )
 
43
""")
 
44
 
33
45
from bzrlib.trace import mutter
34
 
from bzrlib.symbol_versioning import (
35
 
    deprecated_function,
36
 
    deprecated_in,
37
 
    deprecated_method,
38
 
    )
39
46
 
40
47
 
41
48
def _supports_progress(f):
42
 
    """Detect if we can use pretty progress bars on file F.
 
49
    """Detect if we can use pretty progress bars on the output stream f.
43
50
 
44
 
    If this returns true we expect that a human may be looking at that
 
51
    If this returns true we expect that a human may be looking at that 
45
52
    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
53
    """
49
54
    isatty = getattr(f, 'isatty', None)
50
55
    if isatty is None:
51
56
        return False
52
57
    if not isatty():
53
58
        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.
58
59
    if os.environ.get('TERM') == 'dumb':
59
60
        # e.g. emacs compile window
60
61
        return False
61
62
    return True
62
63
 
63
64
 
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.
73
 
    
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)))
 
65
_progress_bar_types = {}
 
66
 
 
67
 
188
68
def ProgressBar(to_file=None, **kwargs):
189
 
    """Construct a progress bar.
190
 
 
191
 
    Deprecated; ask the ui_factory for a progress task instead.
192
 
    """
 
69
    """Abstract factory"""
193
70
    if to_file is None:
194
71
        to_file = sys.stderr
195
72
    requested_bar_type = os.environ.get('BZR_PROGRESS_BAR')
210
87
                                                _progress_bar_types.keys())
211
88
        return _progress_bar_types[requested_bar_type](to_file=to_file, **kwargs)
212
89
 
213
 
 
214
 
# NOTE: This is also deprecated; you should provide a ProgressView instead.
 
90
 
 
91
class ProgressBarStack(object):
 
92
    """A stack of progress bars."""
 
93
 
 
94
    def __init__(self,
 
95
                 to_file=None,
 
96
                 show_pct=False,
 
97
                 show_spinner=True,
 
98
                 show_eta=False,
 
99
                 show_bar=True,
 
100
                 show_count=True,
 
101
                 to_messages_file=None,
 
102
                 klass=None):
 
103
        """Setup the stack with the parameters the progress bars should have."""
 
104
        if to_file is None:
 
105
            to_file = sys.stderr
 
106
        if to_messages_file is None:
 
107
            to_messages_file = sys.stdout
 
108
        self._to_file = to_file
 
109
        self._show_pct = show_pct
 
110
        self._show_spinner = show_spinner
 
111
        self._show_eta = show_eta
 
112
        self._show_bar = show_bar
 
113
        self._show_count = show_count
 
114
        self._to_messages_file = to_messages_file
 
115
        self._stack = []
 
116
        self._klass = klass or ProgressBar
 
117
 
 
118
    def top(self):
 
119
        if len(self._stack) != 0:
 
120
            return self._stack[-1]
 
121
        else:
 
122
            return None
 
123
 
 
124
    def bottom(self):
 
125
        if len(self._stack) != 0:
 
126
            return self._stack[0]
 
127
        else:
 
128
            return None
 
129
 
 
130
    def get_nested(self):
 
131
        """Return a nested progress bar."""
 
132
        if len(self._stack) == 0:
 
133
            func = self._klass
 
134
        else:
 
135
            func = self.top().child_progress
 
136
        new_bar = func(to_file=self._to_file,
 
137
                       show_pct=self._show_pct,
 
138
                       show_spinner=self._show_spinner,
 
139
                       show_eta=self._show_eta,
 
140
                       show_bar=self._show_bar,
 
141
                       show_count=self._show_count,
 
142
                       to_messages_file=self._to_messages_file,
 
143
                       _stack=self)
 
144
        self._stack.append(new_bar)
 
145
        return new_bar
 
146
 
 
147
    def return_pb(self, bar):
 
148
        """Return bar after its been used."""
 
149
        if bar is not self._stack[-1]:
 
150
            raise errors.MissingProgressBarFinish()
 
151
        self._stack.pop()
 
152
 
 
153
 
215
154
class _BaseProgressBar(object):
216
155
 
217
156
    def __init__(self,
258
197
        self.to_messages_file.write(fmt_string % args)
259
198
        self.to_messages_file.write('\n')
260
199
 
261
 
    @deprecated_function(deprecated_in((1, 16, 0)))
262
200
    def child_progress(self, **kwargs):
263
201
        return ChildProgress(**kwargs)
264
202
 
268
206
 
269
207
    This can be used as the default argument for methods that
270
208
    take an optional progress indicator."""
271
 
 
272
209
    def tick(self):
273
210
        pass
274
211
 
280
217
 
281
218
    def clear(self):
282
219
        pass
283
 
 
 
220
        
284
221
    def note(self, fmt_string, *args, **kwargs):
285
222
        """See _BaseProgressBar.note()."""
286
223
 
288
225
        return DummyProgress(**kwargs)
289
226
 
290
227
 
 
228
_progress_bar_types['dummy'] = DummyProgress
 
229
_progress_bar_types['none'] = DummyProgress
 
230
 
 
231
 
291
232
class DotsProgressBar(_BaseProgressBar):
292
233
 
293
 
    @deprecated_function(deprecated_in((1, 16, 0)))
294
234
    def __init__(self, **kwargs):
295
235
        _BaseProgressBar.__init__(self, **kwargs)
296
236
        self.last_msg = None
297
237
        self.need_nl = False
298
 
 
 
238
        
299
239
    def tick(self):
300
240
        self.update()
301
 
 
 
241
        
302
242
    def update(self, msg=None, current_cnt=None, total_cnt=None):
303
243
        if msg and msg != self.last_msg:
304
244
            if self.need_nl:
307
247
            self.last_msg = msg
308
248
        self.need_nl = True
309
249
        self.to_file.write('.')
310
 
 
 
250
        
311
251
    def clear(self):
312
252
        if self.need_nl:
313
253
            self.to_file.write('\n')
314
254
        self.need_nl = False
315
 
 
 
255
        
316
256
    def child_update(self, message, current, total):
317
257
        self.tick()
318
258
 
319
259
 
 
260
_progress_bar_types['dots'] = DotsProgressBar
 
261
 
 
262
    
320
263
class TTYProgressBar(_BaseProgressBar):
321
264
    """Progress bar display object.
322
265
 
339
282
    """
340
283
    SPIN_CHARS = r'/-\|'
341
284
 
342
 
    @deprecated_function(deprecated_in((1, 16, 0)))
 
285
 
343
286
    def __init__(self, **kwargs):
344
287
        from bzrlib.osutils import terminal_width
345
288
        _BaseProgressBar.__init__(self, **kwargs)
349
292
        self._max_last_updates = 10
350
293
        self.child_fraction = 0
351
294
        self._have_output = False
352
 
 
 
295
    
353
296
    def throttle(self, old_msg):
354
297
        """Return True if the bar was updated too recently"""
355
298
        # time.time consistently takes 40/4000 ms = 0.01 ms.
369
312
        self.last_updates = self.last_updates[-self._max_last_updates:]
370
313
        self.last_update = now
371
314
        return False
372
 
 
 
315
        
373
316
    def tick(self):
374
317
        self.update(self.last_msg, self.last_cnt, self.last_total,
375
318
                    self.child_fraction)
386
329
        self.tick()
387
330
 
388
331
    def update(self, msg, current_cnt=None, total_cnt=None,
389
 
            child_fraction=0):
390
 
        """Update and redraw progress bar.
391
 
        """
 
332
               child_fraction=0):
 
333
        """Update and redraw progress bar."""
392
334
        if msg is None:
393
335
            msg = self.last_msg
394
336
 
397
339
 
398
340
        if current_cnt < 0:
399
341
            current_cnt = 0
400
 
 
 
342
            
401
343
        if current_cnt > total_cnt:
402
344
            total_cnt = current_cnt
403
 
 
404
 
        ## # optional corner case optimisation
 
345
        
 
346
        ## # optional corner case optimisation 
405
347
        ## # currently does not seem to fire so costs more than saved.
406
348
        ## # trivial optimal case:
407
349
        ## # NB if callers are doing a clear and restore with
414
356
        ##     self.child_fraction == child_fraction):
415
357
        ##     return
416
358
 
417
 
        if msg is None:
418
 
            msg = ''
419
 
 
420
359
        old_msg = self.last_msg
421
360
        # save these for the tick() function
422
361
        self.last_msg = msg
424
363
        self.last_total = total_cnt
425
364
        self.child_fraction = child_fraction
426
365
 
427
 
        # each function call takes 20ms/4000 = 0.005 ms,
 
366
        # each function call takes 20ms/4000 = 0.005 ms, 
428
367
        # but multiple that by 4000 calls -> starts to cost.
429
368
        # so anything to make this function call faster
430
369
        # will improve base 'diff' time by up to 0.1 seconds.
432
371
            return
433
372
 
434
373
        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,
 
374
            eta = get_eta(self.start_time, self.last_cnt + self.child_fraction, 
436
375
                    self.last_total, last_updates = self.last_updates)
437
376
            eta_str = " " + str_tdelta(eta)
438
377
        else:
439
378
            eta_str = ""
440
379
 
441
380
        if self.show_spinner:
442
 
            spin_str = self.SPIN_CHARS[self.spin_pos % 4] + ' '
 
381
            spin_str = self.SPIN_CHARS[self.spin_pos % 4] + ' '            
443
382
        else:
444
383
            spin_str = ''
445
384
 
462
401
            # make both fields the same size
463
402
            t = '%i' % (self.last_total)
464
403
            c = '%*i' % (len(t), self.last_cnt)
465
 
            count_str = ' ' + c + '/' + t
 
404
            count_str = ' ' + c + '/' + t 
466
405
 
467
406
        if self.show_bar:
468
407
            # progress bar, if present, soaks up all remaining space
471
410
 
472
411
            if self.last_total:
473
412
                # number of markers highlighted in bar
474
 
                markers = int(round(float(cols) *
 
413
                markers = int(round(float(cols) * 
475
414
                              (self.last_cnt + self.child_fraction) / self.last_total))
476
415
                bar_str = '[' + ('=' * markers).ljust(cols) + '] '
477
416
            elif False:
479
418
                # so just show an expanded spinning thingy
480
419
                m = self.spin_pos % cols
481
420
                ms = (' ' * m + '*').ljust(cols)
482
 
 
 
421
                
483
422
                bar_str = '[' + ms + '] '
484
423
            else:
485
424
                bar_str = ''
486
425
        else:
487
426
            bar_str = ''
488
427
 
489
 
        m = spin_str + bar_str + self.last_msg + count_str \
490
 
            + pct_str + eta_str
 
428
        m = spin_str + bar_str + self.last_msg + count_str + pct_str + eta_str
491
429
        self.to_file.write('\r%-*.*s' % (self.width - 1, self.width - 1, m))
492
430
        self._have_output = True
493
431
        #self.to_file.flush()
494
 
 
 
432
            
495
433
    def clear(self):
496
434
        if self._have_output:
497
435
            self.to_file.write('\r%s\r' % (' ' * (self.width - 1)))
498
436
        self._have_output = False
499
 
        #self.to_file.flush()
500
 
 
501
 
 
502
 
 
503
 
# DEPRECATED
 
437
        #self.to_file.flush()        
 
438
 
 
439
 
 
440
_progress_bar_types['tty'] = TTYProgressBar
 
441
 
 
442
 
504
443
class ChildProgress(_BaseProgressBar):
505
444
    """A progress indicator that pushes its data to the parent"""
506
445
 
507
 
    @deprecated_function(deprecated_in((1, 16, 0)))
508
446
    def __init__(self, _stack, **kwargs):
509
447
        _BaseProgressBar.__init__(self, _stack=_stack, **kwargs)
510
448
        self.parent = _stack.top()
546
484
        self.parent.note(*args, **kwargs)
547
485
 
548
486
 
 
487
class InstrumentedProgress(TTYProgressBar):
 
488
    """TTYProgress variant that tracks outcomes"""
 
489
 
 
490
    def __init__(self, *args, **kwargs):
 
491
        self.always_throttled = True
 
492
        self.never_throttle = False
 
493
        TTYProgressBar.__init__(self, *args, **kwargs)
 
494
 
 
495
    def throttle(self, old_message):
 
496
        if self.never_throttle:
 
497
            result =  False
 
498
        else:
 
499
            result = TTYProgressBar.throttle(self, old_message)
 
500
        if result is False:
 
501
            self.always_throttled = False
 
502
 
 
503
 
549
504
def str_tdelta(delt):
550
505
    if delt is None:
551
506
        return "-:--:--"
572
527
 
573
528
    if elapsed < 2.0:                   # not enough time to estimate
574
529
        return None
575
 
 
 
530
    
576
531
    total_duration = float(elapsed) * float(total) / float(current)
577
532
 
578
533
    if last_updates and len(last_updates) >= n_recent:
602
557
        else:
603
558
            self.cur_phase += 1
604
559
        self.pb.update(self.message, self.cur_phase, self.total)
605
 
 
606
 
 
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