~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/progress.py

  • Committer: John Arbash Meinel
  • Author(s): Mark Hammond
  • Date: 2008-09-09 17:02:21 UTC
  • mto: This revision was merged to the branch mainline in revision 3697.
  • Revision ID: john@arbash-meinel.com-20080909170221-svim3jw2mrz0amp3
An updated transparent icon for bzr.

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
 
    )
38
46
 
39
47
 
40
48
def _supports_progress(f):
41
 
    """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.
42
50
 
43
 
    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 
44
52
    output, and that we can repaint a line to update it.
45
 
 
46
 
    This doesn't check the policy for whether we *should* use them.
47
53
    """
48
54
    isatty = getattr(f, 'isatty', None)
49
55
    if isatty is None:
50
56
        return False
51
57
    if not isatty():
52
58
        return False
53
 
    # The following case also handles Win32 - on that platform $TERM is
54
 
    # typically never set, so the case None is treated as a smart terminal,
55
 
    # not dumb.  <https://bugs.launchpad.net/bugs/334808>  win32 files do have
56
 
    # isatty methods that return true.
57
59
    if os.environ.get('TERM') == 'dumb':
58
60
        # e.g. emacs compile window
59
61
        return False
60
62
    return True
61
63
 
62
64
 
63
 
class ProgressTask(object):
64
 
    """Model component of a progress indicator.
65
 
 
66
 
    Most code that needs to indicate progress should update one of these,
67
 
    and it will in turn update the display, if one is present.
68
 
 
69
 
    Code updating the task may also set fields as hints about how to display
70
 
    it: show_pct, show_spinner, show_eta, show_count, show_bar.  UIs
71
 
    will not necessarily respect all these fields.
72
 
    
73
 
    :ivar update_latency: The interval (in seconds) at which the PB should be
74
 
        updated.  Setting this to zero suggests every update should be shown
75
 
        synchronously.
76
 
 
77
 
    :ivar show_transport_activity: If true (default), transport activity
78
 
        will be shown when this task is drawn.  Disable it if you're sure 
79
 
        that only irrelevant or uninteresting transport activity can occur
80
 
        during this task.
81
 
    """
82
 
 
83
 
    def __init__(self, parent_task=None, ui_factory=None, progress_view=None):
84
 
        """Construct a new progress task.
85
 
 
86
 
        :param parent_task: Enclosing ProgressTask or None.
87
 
 
88
 
        :param progress_view: ProgressView to display this ProgressTask.
89
 
 
90
 
        :param ui_factory: The UI factory that will display updates; 
91
 
            deprecated in favor of passing progress_view directly.
92
 
 
93
 
        Normally you should not call this directly but rather through
94
 
        `ui_factory.nested_progress_bar`.
95
 
        """
96
 
        self._parent_task = parent_task
97
 
        self._last_update = 0
98
 
        self.total_cnt = None
99
 
        self.current_cnt = None
100
 
        self.msg = ''
101
 
        # TODO: deprecate passing ui_factory
102
 
        self.ui_factory = ui_factory
103
 
        self.progress_view = progress_view
104
 
        self.show_pct = False
105
 
        self.show_spinner = True
106
 
        self.show_eta = False,
107
 
        self.show_count = True
108
 
        self.show_bar = True
109
 
        self.update_latency = 0.1
110
 
        self.show_transport_activity = True
111
 
 
112
 
    def __repr__(self):
113
 
        return '%s(%r/%r, msg=%r)' % (
114
 
            self.__class__.__name__,
115
 
            self.current_cnt,
116
 
            self.total_cnt,
117
 
            self.msg)
118
 
 
119
 
    def update(self, msg, current_cnt=None, total_cnt=None):
120
 
        self.msg = msg
121
 
        self.current_cnt = current_cnt
122
 
        if total_cnt:
123
 
            self.total_cnt = total_cnt
124
 
        if self.progress_view:
125
 
            self.progress_view.show_progress(self)
126
 
        else:
127
 
            self.ui_factory._progress_updated(self)
128
 
 
129
 
    def tick(self):
130
 
        self.update(self.msg)
131
 
 
132
 
    def finished(self):
133
 
        if self.progress_view:
134
 
            self.progress_view.task_finished(self)
135
 
        else:
136
 
            self.ui_factory._progress_finished(self)
137
 
 
138
 
    def make_sub_task(self):
139
 
        return ProgressTask(self, ui_factory=self.ui_factory,
140
 
            progress_view=self.progress_view)
141
 
 
142
 
    def _overall_completion_fraction(self, child_fraction=0.0):
143
 
        """Return fractional completion of this task and its parents
144
 
 
145
 
        Returns None if no completion can be computed."""
146
 
        if self.current_cnt is not None and self.total_cnt:
147
 
            own_fraction = (float(self.current_cnt) + child_fraction) / self.total_cnt
148
 
        else:
149
 
            # if this task has no estimation, it just passes on directly
150
 
            # whatever the child has measured...
151
 
            own_fraction = child_fraction
152
 
        if self._parent_task is None:
153
 
            return own_fraction
154
 
        else:
155
 
            if own_fraction is None:
156
 
                own_fraction = 0.0
157
 
            return self._parent_task._overall_completion_fraction(own_fraction)
158
 
 
159
 
    def note(self, fmt_string, *args):
160
 
        """Record a note without disrupting the progress bar."""
161
 
        # XXX: shouldn't be here; put it in mutter or the ui instead
162
 
        if args:
163
 
            self.ui_factory.note(fmt_string % args)
164
 
        else:
165
 
            self.ui_factory.note(fmt_string)
166
 
 
167
 
    def clear(self):
168
 
        # XXX: shouldn't be here; put it in mutter or the ui instead
169
 
        if self.progress_view:
170
 
            self.progress_view.clear()
171
 
        else:
172
 
            self.ui_factory.clear_term()
173
 
 
174
 
 
175
 
@deprecated_function(deprecated_in((1, 16, 0)))
 
65
_progress_bar_types = {}
 
66
 
 
67
 
176
68
def ProgressBar(to_file=None, **kwargs):
177
 
    """Construct a progress bar.
178
 
 
179
 
    Deprecated; ask the ui_factory for a progress task instead.
180
 
    """
 
69
    """Abstract factory"""
181
70
    if to_file is None:
182
71
        to_file = sys.stderr
183
72
    requested_bar_type = os.environ.get('BZR_PROGRESS_BAR')
198
87
                                                _progress_bar_types.keys())
199
88
        return _progress_bar_types[requested_bar_type](to_file=to_file, **kwargs)
200
89
 
201
 
 
202
 
# 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
 
203
154
class _BaseProgressBar(object):
204
155
 
205
156
    def __init__(self,
246
197
        self.to_messages_file.write(fmt_string % args)
247
198
        self.to_messages_file.write('\n')
248
199
 
249
 
    @deprecated_function(deprecated_in((1, 16, 0)))
250
200
    def child_progress(self, **kwargs):
251
201
        return ChildProgress(**kwargs)
252
202
 
256
206
 
257
207
    This can be used as the default argument for methods that
258
208
    take an optional progress indicator."""
259
 
 
260
209
    def tick(self):
261
210
        pass
262
211
 
268
217
 
269
218
    def clear(self):
270
219
        pass
271
 
 
 
220
        
272
221
    def note(self, fmt_string, *args, **kwargs):
273
222
        """See _BaseProgressBar.note()."""
274
223
 
276
225
        return DummyProgress(**kwargs)
277
226
 
278
227
 
 
228
_progress_bar_types['dummy'] = DummyProgress
 
229
_progress_bar_types['none'] = DummyProgress
 
230
 
 
231
 
279
232
class DotsProgressBar(_BaseProgressBar):
280
233
 
281
 
    @deprecated_function(deprecated_in((1, 16, 0)))
282
234
    def __init__(self, **kwargs):
283
235
        _BaseProgressBar.__init__(self, **kwargs)
284
236
        self.last_msg = None
285
237
        self.need_nl = False
286
 
 
 
238
        
287
239
    def tick(self):
288
240
        self.update()
289
 
 
 
241
        
290
242
    def update(self, msg=None, current_cnt=None, total_cnt=None):
291
243
        if msg and msg != self.last_msg:
292
244
            if self.need_nl:
295
247
            self.last_msg = msg
296
248
        self.need_nl = True
297
249
        self.to_file.write('.')
298
 
 
 
250
        
299
251
    def clear(self):
300
252
        if self.need_nl:
301
253
            self.to_file.write('\n')
302
254
        self.need_nl = False
303
 
 
 
255
        
304
256
    def child_update(self, message, current, total):
305
257
        self.tick()
306
258
 
307
259
 
 
260
_progress_bar_types['dots'] = DotsProgressBar
 
261
 
 
262
    
308
263
class TTYProgressBar(_BaseProgressBar):
309
264
    """Progress bar display object.
310
265
 
327
282
    """
328
283
    SPIN_CHARS = r'/-\|'
329
284
 
330
 
    @deprecated_function(deprecated_in((1, 16, 0)))
 
285
 
331
286
    def __init__(self, **kwargs):
332
287
        from bzrlib.osutils import terminal_width
333
288
        _BaseProgressBar.__init__(self, **kwargs)
337
292
        self._max_last_updates = 10
338
293
        self.child_fraction = 0
339
294
        self._have_output = False
340
 
 
 
295
    
341
296
    def throttle(self, old_msg):
342
297
        """Return True if the bar was updated too recently"""
343
298
        # time.time consistently takes 40/4000 ms = 0.01 ms.
357
312
        self.last_updates = self.last_updates[-self._max_last_updates:]
358
313
        self.last_update = now
359
314
        return False
360
 
 
 
315
        
361
316
    def tick(self):
362
317
        self.update(self.last_msg, self.last_cnt, self.last_total,
363
318
                    self.child_fraction)
374
329
        self.tick()
375
330
 
376
331
    def update(self, msg, current_cnt=None, total_cnt=None,
377
 
            child_fraction=0):
378
 
        """Update and redraw progress bar.
379
 
        """
 
332
               child_fraction=0):
 
333
        """Update and redraw progress bar."""
380
334
        if msg is None:
381
335
            msg = self.last_msg
382
336
 
385
339
 
386
340
        if current_cnt < 0:
387
341
            current_cnt = 0
388
 
 
 
342
            
389
343
        if current_cnt > total_cnt:
390
344
            total_cnt = current_cnt
391
 
 
392
 
        ## # optional corner case optimisation
 
345
        
 
346
        ## # optional corner case optimisation 
393
347
        ## # currently does not seem to fire so costs more than saved.
394
348
        ## # trivial optimal case:
395
349
        ## # NB if callers are doing a clear and restore with
402
356
        ##     self.child_fraction == child_fraction):
403
357
        ##     return
404
358
 
405
 
        if msg is None:
406
 
            msg = ''
407
 
 
408
359
        old_msg = self.last_msg
409
360
        # save these for the tick() function
410
361
        self.last_msg = msg
412
363
        self.last_total = total_cnt
413
364
        self.child_fraction = child_fraction
414
365
 
415
 
        # each function call takes 20ms/4000 = 0.005 ms,
 
366
        # each function call takes 20ms/4000 = 0.005 ms, 
416
367
        # but multiple that by 4000 calls -> starts to cost.
417
368
        # so anything to make this function call faster
418
369
        # will improve base 'diff' time by up to 0.1 seconds.
420
371
            return
421
372
 
422
373
        if self.show_eta and self.start_time and self.last_total:
423
 
            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, 
424
375
                    self.last_total, last_updates = self.last_updates)
425
376
            eta_str = " " + str_tdelta(eta)
426
377
        else:
427
378
            eta_str = ""
428
379
 
429
380
        if self.show_spinner:
430
 
            spin_str = self.SPIN_CHARS[self.spin_pos % 4] + ' '
 
381
            spin_str = self.SPIN_CHARS[self.spin_pos % 4] + ' '            
431
382
        else:
432
383
            spin_str = ''
433
384
 
450
401
            # make both fields the same size
451
402
            t = '%i' % (self.last_total)
452
403
            c = '%*i' % (len(t), self.last_cnt)
453
 
            count_str = ' ' + c + '/' + t
 
404
            count_str = ' ' + c + '/' + t 
454
405
 
455
406
        if self.show_bar:
456
407
            # progress bar, if present, soaks up all remaining space
459
410
 
460
411
            if self.last_total:
461
412
                # number of markers highlighted in bar
462
 
                markers = int(round(float(cols) *
 
413
                markers = int(round(float(cols) * 
463
414
                              (self.last_cnt + self.child_fraction) / self.last_total))
464
415
                bar_str = '[' + ('=' * markers).ljust(cols) + '] '
465
416
            elif False:
467
418
                # so just show an expanded spinning thingy
468
419
                m = self.spin_pos % cols
469
420
                ms = (' ' * m + '*').ljust(cols)
470
 
 
 
421
                
471
422
                bar_str = '[' + ms + '] '
472
423
            else:
473
424
                bar_str = ''
474
425
        else:
475
426
            bar_str = ''
476
427
 
477
 
        m = spin_str + bar_str + self.last_msg + count_str \
478
 
            + pct_str + eta_str
 
428
        m = spin_str + bar_str + self.last_msg + count_str + pct_str + eta_str
479
429
        self.to_file.write('\r%-*.*s' % (self.width - 1, self.width - 1, m))
480
430
        self._have_output = True
481
431
        #self.to_file.flush()
482
 
 
 
432
            
483
433
    def clear(self):
484
434
        if self._have_output:
485
435
            self.to_file.write('\r%s\r' % (' ' * (self.width - 1)))
486
436
        self._have_output = False
487
 
        #self.to_file.flush()
488
 
 
489
 
 
490
 
 
491
 
# DEPRECATED
 
437
        #self.to_file.flush()        
 
438
 
 
439
 
 
440
_progress_bar_types['tty'] = TTYProgressBar
 
441
 
 
442
 
492
443
class ChildProgress(_BaseProgressBar):
493
444
    """A progress indicator that pushes its data to the parent"""
494
445
 
495
 
    @deprecated_function(deprecated_in((1, 16, 0)))
496
446
    def __init__(self, _stack, **kwargs):
497
447
        _BaseProgressBar.__init__(self, _stack=_stack, **kwargs)
498
448
        self.parent = _stack.top()
534
484
        self.parent.note(*args, **kwargs)
535
485
 
536
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
 
537
504
def str_tdelta(delt):
538
505
    if delt is None:
539
506
        return "-:--:--"
560
527
 
561
528
    if elapsed < 2.0:                   # not enough time to estimate
562
529
        return None
563
 
 
 
530
    
564
531
    total_duration = float(elapsed) * float(total) / float(current)
565
532
 
566
533
    if last_updates and len(last_updates) >= n_recent:
590
557
        else:
591
558
            self.cur_phase += 1
592
559
        self.pb.update(self.message, self.cur_phase, self.total)
593
 
 
594
 
 
595
 
_progress_bar_types = {}
596
 
_progress_bar_types['dummy'] = DummyProgress
597
 
_progress_bar_types['none'] = DummyProgress
598
 
_progress_bar_types['tty'] = TTYProgressBar
599
 
_progress_bar_types['dots'] = DotsProgressBar