~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/progress.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2010-01-14 00:01:32 UTC
  • mfrom: (4957.1.1 jam-integration)
  • Revision ID: pqm@pqm.ubuntu.com-20100114000132-3p3rabnonjw3gzqb
(jam) Merge bzr.stable, bringing in bug fixes #175839, #504390

Show diffs side-by-side

added added

removed removed

Lines of Context:
25
25
import sys
26
26
import time
27
27
import os
28
 
import warnings
29
28
 
30
29
 
31
30
from bzrlib import (
32
31
    errors,
33
 
    osutils,
34
 
    trace,
35
 
    ui,
36
32
    )
37
33
from bzrlib.trace import mutter
38
34
from bzrlib.symbol_versioning import (
 
35
    deprecated_function,
39
36
    deprecated_in,
40
37
    deprecated_method,
41
38
    )
42
39
 
43
40
 
44
41
def _supports_progress(f):
45
 
    """Detect if we can use pretty progress bars on the output stream f.
 
42
    """Detect if we can use pretty progress bars on file F.
46
43
 
47
44
    If this returns true we expect that a human may be looking at that
48
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.
49
48
    """
50
49
    isatty = getattr(f, 'isatty', None)
51
50
    if isatty is None:
52
51
        return False
53
52
    if not isatty():
54
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.
55
58
    if os.environ.get('TERM') == 'dumb':
56
59
        # e.g. emacs compile window
57
60
        return False
67
70
    Code updating the task may also set fields as hints about how to display
68
71
    it: show_pct, show_spinner, show_eta, show_count, show_bar.  UIs
69
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.
70
82
    """
71
83
 
72
 
    def __init__(self, parent_task=None, ui_factory=None):
 
84
    def __init__(self, parent_task=None, ui_factory=None, progress_view=None):
73
85
        """Construct a new progress task.
74
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
 
75
94
        Normally you should not call this directly but rather through
76
95
        `ui_factory.nested_progress_bar`.
77
96
        """
80
99
        self.total_cnt = None
81
100
        self.current_cnt = None
82
101
        self.msg = ''
 
102
        # TODO: deprecate passing ui_factory
83
103
        self.ui_factory = ui_factory
 
104
        self.progress_view = progress_view
84
105
        self.show_pct = False
85
106
        self.show_spinner = True
86
107
        self.show_eta = False,
87
108
        self.show_count = True
88
109
        self.show_bar = True
 
110
        self.update_latency = 0.1
 
111
        self.show_transport_activity = True
89
112
 
90
113
    def __repr__(self):
91
114
        return '%s(%r/%r, msg=%r)' % (
99
122
        self.current_cnt = current_cnt
100
123
        if total_cnt:
101
124
            self.total_cnt = total_cnt
102
 
        self.ui_factory._progress_updated(self)
 
125
        if self.progress_view:
 
126
            self.progress_view.show_progress(self)
 
127
        else:
 
128
            self.ui_factory._progress_updated(self)
103
129
 
104
130
    def tick(self):
105
131
        self.update(self.msg)
106
132
 
107
133
    def finished(self):
108
 
        self.ui_factory._progress_finished(self)
 
134
        if self.progress_view:
 
135
            self.progress_view.task_finished(self)
 
136
        else:
 
137
            self.ui_factory._progress_finished(self)
109
138
 
110
139
    def make_sub_task(self):
111
 
        return ProgressTask(self, self.ui_factory)
 
140
        return ProgressTask(self, ui_factory=self.ui_factory,
 
141
            progress_view=self.progress_view)
112
142
 
113
143
    def _overall_completion_fraction(self, child_fraction=0.0):
114
144
        """Return fractional completion of this task and its parents
127
157
                own_fraction = 0.0
128
158
            return self._parent_task._overall_completion_fraction(own_fraction)
129
159
 
 
160
    @deprecated_method(deprecated_in((2, 1, 0)))
130
161
    def note(self, fmt_string, *args):
131
 
        """Record a note without disrupting the progress bar."""
132
 
        # XXX: shouldn't be here; put it in mutter or the ui instead
 
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
        """
133
168
        if args:
134
169
            self.ui_factory.note(fmt_string % args)
135
170
        else:
136
171
            self.ui_factory.note(fmt_string)
137
172
 
138
173
    def clear(self):
139
 
        # XXX: shouldn't be here; put it in mutter or the ui instead
140
 
        self.ui_factory.clear_term()
141
 
 
142
 
 
 
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)))
143
188
def ProgressBar(to_file=None, **kwargs):
144
 
    """Abstract factory"""
 
189
    """Construct a progress bar.
 
190
 
 
191
    Deprecated; ask the ui_factory for a progress task instead.
 
192
    """
145
193
    if to_file is None:
146
194
        to_file = sys.stderr
147
195
    requested_bar_type = os.environ.get('BZR_PROGRESS_BAR')
163
211
        return _progress_bar_types[requested_bar_type](to_file=to_file, **kwargs)
164
212
 
165
213
 
166
 
class ProgressBarStack(object):
167
 
    """A stack of progress bars.
168
 
 
169
 
    This class is deprecated: instead, ask the ui factory for a new progress
170
 
    task and finish it when it's done.
171
 
    """
172
 
 
173
 
    @deprecated_method(deprecated_in((1, 12, 0)))
174
 
    def __init__(self,
175
 
                 to_file=None,
176
 
                 show_pct=False,
177
 
                 show_spinner=True,
178
 
                 show_eta=False,
179
 
                 show_bar=True,
180
 
                 show_count=True,
181
 
                 to_messages_file=None,
182
 
                 klass=None):
183
 
        """Setup the stack with the parameters the progress bars should have."""
184
 
        if to_file is None:
185
 
            to_file = sys.stderr
186
 
        if to_messages_file is None:
187
 
            to_messages_file = sys.stdout
188
 
        self._to_file = to_file
189
 
        self._show_pct = show_pct
190
 
        self._show_spinner = show_spinner
191
 
        self._show_eta = show_eta
192
 
        self._show_bar = show_bar
193
 
        self._show_count = show_count
194
 
        self._to_messages_file = to_messages_file
195
 
        self._stack = []
196
 
        self._klass = klass or ProgressBar
197
 
 
198
 
    def top(self):
199
 
        if len(self._stack) != 0:
200
 
            return self._stack[-1]
201
 
        else:
202
 
            return None
203
 
 
204
 
    def bottom(self):
205
 
        if len(self._stack) != 0:
206
 
            return self._stack[0]
207
 
        else:
208
 
            return None
209
 
 
210
 
    def get_nested(self):
211
 
        """Return a nested progress bar."""
212
 
        if len(self._stack) == 0:
213
 
            func = self._klass
214
 
        else:
215
 
            func = self.top().child_progress
216
 
        new_bar = func(to_file=self._to_file,
217
 
                       show_pct=self._show_pct,
218
 
                       show_spinner=self._show_spinner,
219
 
                       show_eta=self._show_eta,
220
 
                       show_bar=self._show_bar,
221
 
                       show_count=self._show_count,
222
 
                       to_messages_file=self._to_messages_file,
223
 
                       _stack=self)
224
 
        self._stack.append(new_bar)
225
 
        return new_bar
226
 
 
227
 
    def return_pb(self, bar):
228
 
        """Return bar after its been used."""
229
 
        if bar is not self._stack[-1]:
230
 
            warnings.warn("%r is not currently active" % (bar,))
231
 
        else:
232
 
            self._stack.pop()
233
 
 
234
 
 
 
214
# NOTE: This is also deprecated; you should provide a ProgressView instead.
235
215
class _BaseProgressBar(object):
236
216
 
237
217
    def __init__(self,
278
258
        self.to_messages_file.write(fmt_string % args)
279
259
        self.to_messages_file.write('\n')
280
260
 
 
261
    @deprecated_function(deprecated_in((1, 16, 0)))
281
262
    def child_progress(self, **kwargs):
282
263
        return ChildProgress(**kwargs)
283
264
 
309
290
 
310
291
class DotsProgressBar(_BaseProgressBar):
311
292
 
 
293
    @deprecated_function(deprecated_in((1, 16, 0)))
312
294
    def __init__(self, **kwargs):
313
295
        _BaseProgressBar.__init__(self, **kwargs)
314
296
        self.last_msg = None
335
317
        self.tick()
336
318
 
337
319
 
338
 
 
339
 
 
340
320
class TTYProgressBar(_BaseProgressBar):
341
321
    """Progress bar display object.
342
322
 
359
339
    """
360
340
    SPIN_CHARS = r'/-\|'
361
341
 
362
 
 
 
342
    @deprecated_function(deprecated_in((1, 16, 0)))
363
343
    def __init__(self, **kwargs):
364
344
        from bzrlib.osutils import terminal_width
365
345
        _BaseProgressBar.__init__(self, **kwargs)
520
500
 
521
501
 
522
502
 
523
 
 
 
503
# DEPRECATED
524
504
class ChildProgress(_BaseProgressBar):
525
505
    """A progress indicator that pushes its data to the parent"""
526
506
 
 
507
    @deprecated_function(deprecated_in((1, 16, 0)))
527
508
    def __init__(self, _stack, **kwargs):
528
509
        _BaseProgressBar.__init__(self, _stack=_stack, **kwargs)
529
510
        self.parent = _stack.top()
565
546
        self.parent.note(*args, **kwargs)
566
547
 
567
548
 
568
 
class InstrumentedProgress(TTYProgressBar):
569
 
    """TTYProgress variant that tracks outcomes"""
570
 
 
571
 
    def __init__(self, *args, **kwargs):
572
 
        self.always_throttled = True
573
 
        self.never_throttle = False
574
 
        TTYProgressBar.__init__(self, *args, **kwargs)
575
 
 
576
 
    def throttle(self, old_message):
577
 
        if self.never_throttle:
578
 
            result =  False
579
 
        else:
580
 
            result = TTYProgressBar.throttle(self, old_message)
581
 
        if result is False:
582
 
            self.always_throttled = False
583
 
 
584
 
 
585
549
def str_tdelta(delt):
586
550
    if delt is None:
587
551
        return "-:--:--"