/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/commit.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-2011 Canonical Ltd
 
1
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
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
 
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
 
from __future__ import absolute_import
18
17
 
19
18
# The newly committed revision is going to have a shape corresponding
20
19
# to that of the working tree.  Files that are not in the
50
49
# TODO: Change the parameter 'rev_id' to 'revision_id' to be consistent with
51
50
# the rest of the code; add a deprecation of the old name.
52
51
 
53
 
from . import (
 
52
import os
 
53
import re
 
54
import sys
 
55
import time
 
56
 
 
57
from cStringIO import StringIO
 
58
 
 
59
from bzrlib import (
54
60
    debug,
55
61
    errors,
56
 
    trace,
 
62
    revision,
57
63
    tree,
58
 
    ui,
59
64
    )
60
 
from .branch import Branch
61
 
from .cleanup import OperationWithCleanups
62
 
import breezy.config
63
 
from .errors import (BzrError,
64
 
                     ConflictsInTree,
65
 
                     StrictCommitFailed
66
 
                     )
67
 
from .osutils import (get_user_encoding,
68
 
                      is_inside_any,
69
 
                      minimum_path_selection,
70
 
                      splitpath,
71
 
                      )
72
 
from .trace import mutter, note, is_quiet
73
 
from .urlutils import unescape_for_display
74
 
from .i18n import gettext
75
 
 
76
 
 
77
 
class PointlessCommit(BzrError):
78
 
 
79
 
    _fmt = "No changes to commit"
80
 
 
81
 
 
82
 
class CannotCommitSelectedFileMerge(BzrError):
83
 
 
84
 
    _fmt = 'Selected-file commit of merges is not supported yet:'\
85
 
        ' files %(files_str)s'
86
 
 
87
 
    def __init__(self, files):
88
 
        files_str = ', '.join(files)
89
 
        BzrError.__init__(self, files=files, files_str=files_str)
90
 
 
91
 
 
92
 
def filter_excluded(iter_changes, exclude):
93
 
    """Filter exclude filenames.
94
 
 
95
 
    :param iter_changes: iter_changes function
96
 
    :param exclude: List of paths to exclude
97
 
    :return: iter_changes function
98
 
    """
99
 
    for change in iter_changes:
100
 
        old_path = change[1][0]
101
 
        new_path = change[1][1]
102
 
 
103
 
        new_excluded = (new_path is not None and
104
 
            is_inside_any(exclude, new_path))
105
 
 
106
 
        old_excluded = (old_path is not None and
107
 
            is_inside_any(exclude, old_path))
108
 
 
109
 
        if old_excluded and new_excluded:
110
 
            continue
111
 
 
112
 
        if old_excluded or new_excluded:
113
 
            # TODO(jelmer): Perhaps raise an error here instead?
114
 
            continue
115
 
 
116
 
        yield change
 
65
from bzrlib.branch import Branch
 
66
import bzrlib.config
 
67
from bzrlib.errors import (BzrError, PointlessCommit,
 
68
                           ConflictsInTree,
 
69
                           StrictCommitFailed
 
70
                           )
 
71
from bzrlib.osutils import (kind_marker, isdir,isfile, is_inside_any,
 
72
                            is_inside_or_parent_of_any,
 
73
                            minimum_path_selection,
 
74
                            quotefn, sha_file, split_lines,
 
75
                            splitpath,
 
76
                            )
 
77
from bzrlib.testament import Testament
 
78
from bzrlib.trace import mutter, note, warning, is_quiet
 
79
from bzrlib.xml5 import serializer_v5
 
80
from bzrlib.inventory import InventoryEntry, make_entry
 
81
from bzrlib import symbol_versioning
 
82
from bzrlib.symbol_versioning import (deprecated_passed,
 
83
        deprecated_function,
 
84
        DEPRECATED_PARAMETER)
 
85
from bzrlib.workingtree import WorkingTree
 
86
from bzrlib.urlutils import unescape_for_display
 
87
import bzrlib.ui
117
88
 
118
89
 
119
90
class NullCommitReporter(object):
120
91
    """I report on progress of a commit."""
121
92
 
122
 
    def started(self, revno, revid, location):
 
93
    def started(self, revno, revid, location=None):
 
94
        if location is None:
 
95
            symbol_versioning.warn("As of bzr 1.0 you must pass a location "
 
96
                                   "to started.", DeprecationWarning,
 
97
                                   stacklevel=2)
123
98
        pass
124
99
 
125
100
    def snapshot_change(self, change, path):
128
103
    def completed(self, revno, rev_id):
129
104
        pass
130
105
 
131
 
    def deleted(self, path):
 
106
    def deleted(self, file_id):
 
107
        pass
 
108
 
 
109
    def escaped(self, escape_count, message):
132
110
        pass
133
111
 
134
112
    def missing(self, path):
151
129
        note(format, *args)
152
130
 
153
131
    def snapshot_change(self, change, path):
154
 
        if path == '' and change in (gettext('added'), gettext('modified')):
 
132
        if change == 'unchanged':
 
133
            return
 
134
        if change == 'added' and path == '':
155
135
            return
156
136
        self._note("%s %s", change, path)
157
137
 
158
 
    def started(self, revno, rev_id, location):
159
 
        self._note(
160
 
            gettext('Committing to: %s'),
161
 
            unescape_for_display(location, 'utf-8'))
 
138
    def started(self, revno, rev_id, location=None):
 
139
        if location is not None:
 
140
            location = ' to: ' + unescape_for_display(location, 'utf-8')
 
141
        else:
 
142
            # When started was added, location was only made optional by
 
143
            # accident.  Matt Nordhoff 20071129
 
144
            symbol_versioning.warn("As of bzr 1.0 you must pass a location "
 
145
                                   "to started.", DeprecationWarning,
 
146
                                   stacklevel=2)
 
147
            location = ''
 
148
        self._note('Committing%s', location)
162
149
 
163
150
    def completed(self, revno, rev_id):
164
 
        self._note(gettext('Committed revision %d.'), revno)
165
 
        # self._note goes to the console too; so while we want to log the
166
 
        # rev_id, we can't trivially only log it. (See bug 526425). Long
167
 
        # term we should rearrange the reporting structure, but for now
168
 
        # we just mutter seperately. We mutter the revid and revno together
169
 
        # so that concurrent bzr invocations won't lead to confusion.
170
 
        mutter('Committed revid %s as revno %d.', rev_id, revno)
171
 
 
172
 
    def deleted(self, path):
173
 
        self._note(gettext('deleted %s'), path)
 
151
        self._note('Committed revision %d.', revno)
 
152
 
 
153
    def deleted(self, file_id):
 
154
        self._note('deleted %s', file_id)
 
155
 
 
156
    def escaped(self, escape_count, message):
 
157
        self._note("replaced %d control characters in message", escape_count)
174
158
 
175
159
    def missing(self, path):
176
 
        self._note(gettext('missing %s'), path)
 
160
        self._note('missing %s', path)
177
161
 
178
162
    def renamed(self, change, old_path, new_path):
179
163
        self._note('%s %s => %s', change, old_path, new_path)
196
180
    """
197
181
    def __init__(self,
198
182
                 reporter=None,
199
 
                 config_stack=None):
 
183
                 config=None):
200
184
        """Create a Commit object.
201
185
 
202
186
        :param reporter: the default reporter to use or None to decide later
203
187
        """
204
188
        self.reporter = reporter
205
 
        self.config_stack = config_stack
206
 
 
207
 
    @staticmethod
208
 
    def update_revprops(revprops, branch, authors=None,
209
 
                        local=False, possible_master_transports=None):
210
 
        if revprops is None:
211
 
            revprops = {}
212
 
        if possible_master_transports is None:
213
 
            possible_master_transports = []
214
 
        if (not u'branch-nick' in revprops and
215
 
                branch.repository._format.supports_storing_branch_nick):
216
 
            revprops[u'branch-nick'] = branch._get_nick(
217
 
                local,
218
 
                possible_master_transports)
219
 
        if authors is not None:
220
 
            if u'author' in revprops or u'authors' in revprops:
221
 
                # XXX: maybe we should just accept one of them?
222
 
                raise AssertionError('author property given twice')
223
 
            if authors:
224
 
                for individual in authors:
225
 
                    if '\n' in individual:
226
 
                        raise AssertionError('\\n is not a valid character '
227
 
                                'in an author identity')
228
 
                revprops[u'authors'] = '\n'.join(authors)
229
 
        return revprops
 
189
        self.config = config
230
190
 
231
191
    def commit(self,
232
192
               message=None,
245
205
               config=None,
246
206
               message_callback=None,
247
207
               recursive='down',
248
 
               exclude=None,
249
 
               possible_master_transports=None,
250
 
               lossy=False):
 
208
               exclude=None):
251
209
        """Commit working copy as a new revision.
252
210
 
253
211
        :param message: the commit message (it or message_callback is required)
254
 
        :param message_callback: A callback: message = message_callback(cmt_obj)
255
212
 
256
213
        :param timestamp: if not None, seconds-since-epoch for a
257
214
            postdated/predated commit.
258
215
 
259
 
        :param specific_files: If not None, commit only those files. An empty
260
 
            list means 'commit no files'.
 
216
        :param specific_files: If true, commit only those files.
261
217
 
262
218
        :param rev_id: If set, use this as the new revision id.
263
219
            Useful for test or import commands that need to tightly
279
235
            pending changes of any sort during this commit.
280
236
        :param exclude: None or a list of relative paths to exclude from the
281
237
            commit. Pending changes to excluded files will be ignored by the
282
 
            commit.
283
 
        :param lossy: When committing to a foreign VCS, ignore any
284
 
            data that can not be natively represented.
 
238
            commit. 
285
239
        """
286
 
        operation = OperationWithCleanups(self._commit)
287
 
        self.revprops = revprops or {}
288
 
        # XXX: Can be set on __init__ or passed in - this is a bit ugly.
289
 
        self.config_stack = config or self.config_stack
290
 
        return operation.run(
291
 
               message=message,
292
 
               timestamp=timestamp,
293
 
               timezone=timezone,
294
 
               committer=committer,
295
 
               specific_files=specific_files,
296
 
               rev_id=rev_id,
297
 
               allow_pointless=allow_pointless,
298
 
               strict=strict,
299
 
               verbose=verbose,
300
 
               working_tree=working_tree,
301
 
               local=local,
302
 
               reporter=reporter,
303
 
               message_callback=message_callback,
304
 
               recursive=recursive,
305
 
               exclude=exclude,
306
 
               possible_master_transports=possible_master_transports,
307
 
               lossy=lossy)
308
 
 
309
 
    def _commit(self, operation, message, timestamp, timezone, committer,
310
 
            specific_files, rev_id, allow_pointless, strict, verbose,
311
 
            working_tree, local, reporter, message_callback, recursive,
312
 
            exclude, possible_master_transports, lossy):
313
240
        mutter('preparing to commit')
314
241
 
315
242
        if working_tree is None:
322
249
                    raise errors.RootNotRich()
323
250
        if message_callback is None:
324
251
            if message is not None:
325
 
                if isinstance(message, bytes):
326
 
                    message = message.decode(get_user_encoding())
 
252
                if isinstance(message, str):
 
253
                    message = message.decode(bzrlib.user_encoding)
327
254
                message_callback = lambda x: message
328
255
            else:
329
256
                raise BzrError("The message or message_callback keyword"
330
257
                               " parameter is required for commit().")
331
258
 
332
259
        self.bound_branch = None
 
260
        self.any_entries_changed = False
333
261
        self.any_entries_deleted = False
334
262
        if exclude is not None:
335
263
            self.exclude = sorted(
338
266
            self.exclude = []
339
267
        self.local = local
340
268
        self.master_branch = None
 
269
        self.master_locked = False
341
270
        self.recursive = recursive
342
271
        self.rev_id = None
343
 
        # self.specific_files is None to indicate no filter, or any iterable to
344
 
        # indicate a filter - [] means no files at all, as per iter_changes.
345
272
        if specific_files is not None:
346
273
            self.specific_files = sorted(
347
274
                minimum_path_selection(specific_files))
348
275
        else:
349
276
            self.specific_files = None
350
 
 
 
277
        self.specific_file_ids = None
351
278
        self.allow_pointless = allow_pointless
 
279
        self.revprops = revprops
352
280
        self.message_callback = message_callback
353
281
        self.timestamp = timestamp
354
282
        self.timezone = timezone
355
283
        self.committer = committer
356
284
        self.strict = strict
357
285
        self.verbose = verbose
 
286
        # accumulates an inventory delta to the basis entry, so we can make
 
287
        # just the necessary updates to the workingtree's cached basis.
 
288
        self._basis_delta = []
358
289
 
359
290
        self.work_tree.lock_write()
360
 
        operation.add_cleanup(self.work_tree.unlock)
361
 
        self.parents = self.work_tree.get_parent_ids()
362
 
        self.pb = ui.ui_factory.nested_progress_bar()
363
 
        operation.add_cleanup(self.pb.finished)
 
291
        self.pb = bzrlib.ui.ui_factory.nested_progress_bar()
364
292
        self.basis_revid = self.work_tree.last_revision()
365
293
        self.basis_tree = self.work_tree.basis_tree()
366
294
        self.basis_tree.lock_read()
367
 
        operation.add_cleanup(self.basis_tree.unlock)
368
 
        # Cannot commit with conflicts present.
369
 
        if len(self.work_tree.conflicts()) > 0:
370
 
            raise ConflictsInTree
371
 
 
372
 
        # Setup the bound branch variables as needed.
373
 
        self._check_bound_branch(operation, possible_master_transports)
374
 
 
375
 
        # Check that the working tree is up to date
376
 
        old_revno, old_revid, new_revno = self._check_out_of_date_tree()
377
 
 
378
 
        # Complete configuration setup
379
 
        if reporter is not None:
380
 
            self.reporter = reporter
381
 
        elif self.reporter is None:
382
 
            self.reporter = self._select_reporter()
383
 
        if self.config_stack is None:
384
 
            self.config_stack = self.work_tree.get_config_stack()
385
 
 
386
 
        # Setup the progress bar. As the number of files that need to be
387
 
        # committed in unknown, progress is reported as stages.
388
 
        # We keep track of entries separately though and include that
389
 
        # information in the progress bar during the relevant stages.
390
 
        self.pb_stage_name = ""
391
 
        self.pb_stage_count = 0
392
 
        self.pb_stage_total = 5
393
 
        if self.bound_branch:
394
 
            # 2 extra stages: "Uploading data to master branch" and "Merging
395
 
            # tags to master branch"
396
 
            self.pb_stage_total += 2
397
 
        self.pb.show_pct = False
398
 
        self.pb.show_spinner = False
399
 
        self.pb.show_eta = False
400
 
        self.pb.show_count = True
401
 
        self.pb.show_bar = True
402
 
 
403
 
        # After a merge, a selected file commit is not supported.
404
 
        # See 'bzr help merge' for an explanation as to why.
405
 
        if len(self.parents) > 1 and self.specific_files is not None:
406
 
            raise CannotCommitSelectedFileMerge(self.specific_files)
407
 
        # Excludes are a form of selected file commit.
408
 
        if len(self.parents) > 1 and self.exclude:
409
 
            raise CannotCommitSelectedFileMerge(self.exclude)
410
 
 
411
 
        # Collect the changes
412
 
        self._set_progress_stage("Collecting changes", counter=True)
413
 
        self._lossy = lossy
414
 
        self.builder = self.branch.get_commit_builder(self.parents,
415
 
            self.config_stack, timestamp, timezone, committer, self.revprops,
416
 
            rev_id, lossy=lossy)
417
 
 
418
 
        if self.builder.updates_branch and self.bound_branch:
419
 
            self.builder.abort()
420
 
            raise AssertionError(
421
 
                "bound branches not supported for commit builders "
422
 
                "that update the branch")
423
 
 
424
295
        try:
425
 
            # find the location being committed to
 
296
            # Cannot commit with conflicts present.
 
297
            if len(self.work_tree.conflicts()) > 0:
 
298
                raise ConflictsInTree
 
299
 
 
300
            # Setup the bound branch variables as needed.
 
301
            self._check_bound_branch()
 
302
 
 
303
            # Check that the working tree is up to date
 
304
            old_revno, new_revno = self._check_out_of_date_tree()
 
305
 
 
306
            # Complete configuration setup
 
307
            if reporter is not None:
 
308
                self.reporter = reporter
 
309
            elif self.reporter is None:
 
310
                self.reporter = self._select_reporter()
 
311
            if self.config is None:
 
312
                self.config = self.branch.get_config()
 
313
 
 
314
            # If provided, ensure the specified files are versioned
 
315
            if self.specific_files is not None:
 
316
                # Note: This routine is being called because it raises
 
317
                # PathNotVersionedError as a side effect of finding the IDs. We
 
318
                # later use the ids we found as input to the working tree
 
319
                # inventory iterator, so we only consider those ids rather than
 
320
                # examining the whole tree again.
 
321
                # XXX: Dont we have filter_unversioned to do this more
 
322
                # cheaply?
 
323
                self.specific_file_ids = tree.find_ids_across_trees(
 
324
                    specific_files, [self.basis_tree, self.work_tree])
 
325
 
 
326
            # Setup the progress bar. As the number of files that need to be
 
327
            # committed in unknown, progress is reported as stages.
 
328
            # We keep track of entries separately though and include that
 
329
            # information in the progress bar during the relevant stages.
 
330
            self.pb_stage_name = ""
 
331
            self.pb_stage_count = 0
 
332
            self.pb_stage_total = 5
426
333
            if self.bound_branch:
427
 
                master_location = self.master_branch.base
428
 
            else:
429
 
                master_location = self.branch.base
430
 
 
431
 
            # report the start of the commit
432
 
            self.reporter.started(new_revno, self.rev_id, master_location)
433
 
 
434
 
            self._update_builder_with_changes()
435
 
            self._check_pointless()
436
 
 
437
 
            # TODO: Now the new inventory is known, check for conflicts.
438
 
            # ADHB 2006-08-08: If this is done, populate_new_inv should not add
439
 
            # weave lines, because nothing should be recorded until it is known
440
 
            # that commit will succeed.
441
 
            self._set_progress_stage("Saving data locally")
442
 
            self.builder.finish_inventory()
443
 
 
444
 
            # Prompt the user for a commit message if none provided
445
 
            message = message_callback(self)
446
 
            self.message = message
447
 
 
448
 
            # Add revision data to the local branch
449
 
            self.rev_id = self.builder.commit(self.message)
450
 
 
451
 
        except Exception as e:
452
 
            mutter("aborting commit write group because of exception:")
453
 
            trace.log_exception_quietly()
454
 
            self.builder.abort()
455
 
            raise
456
 
 
457
 
        self._update_branches(old_revno, old_revid, new_revno)
458
 
 
459
 
        # Make the working tree be up to date with the branch. This
460
 
        # includes automatic changes scheduled to be made to the tree, such
461
 
        # as updating its basis and unversioning paths that were missing.
462
 
        self.work_tree.unversion(self.deleted_paths)
463
 
        self._set_progress_stage("Updating the working tree")
464
 
        self.work_tree.update_basis_by_delta(self.rev_id,
465
 
             self.builder.get_basis_delta())
466
 
        self.reporter.completed(new_revno, self.rev_id)
467
 
        self._process_post_hooks(old_revno, new_revno)
468
 
        return self.rev_id
469
 
 
470
 
    def _update_branches(self, old_revno, old_revid, new_revno):
471
 
        """Update the master and local branch to the new revision.
472
 
 
473
 
        This will try to make sure that the master branch is updated
474
 
        before the local branch.
475
 
 
476
 
        :param old_revno: Revision number of master branch before the
477
 
            commit
478
 
        :param old_revid: Tip of master branch before the commit
479
 
        :param new_revno: Revision number of the new commit
480
 
        """
481
 
        if not self.builder.updates_branch:
 
334
                self.pb_stage_total += 1
 
335
            self.pb.show_pct = False
 
336
            self.pb.show_spinner = False
 
337
            self.pb.show_eta = False
 
338
            self.pb.show_count = True
 
339
            self.pb.show_bar = True
 
340
 
 
341
            self.basis_inv = self.basis_tree.inventory
 
342
            self._gather_parents()
 
343
            # After a merge, a selected file commit is not supported.
 
344
            # See 'bzr help merge' for an explanation as to why.
 
345
            if len(self.parents) > 1 and self.specific_files:
 
346
                raise errors.CannotCommitSelectedFileMerge(self.specific_files)
 
347
            # Excludes are a form of selected file commit.
 
348
            if len(self.parents) > 1 and self.exclude:
 
349
                raise errors.CannotCommitSelectedFileMerge(self.exclude)
 
350
 
 
351
            # Collect the changes
 
352
            self._set_progress_stage("Collecting changes",
 
353
                    entries_title="Directory")
 
354
            self.builder = self.branch.get_commit_builder(self.parents,
 
355
                self.config, timestamp, timezone, committer, revprops, rev_id)
 
356
            
 
357
            try:
 
358
                # find the location being committed to
 
359
                if self.bound_branch:
 
360
                    master_location = self.master_branch.base
 
361
                else:
 
362
                    master_location = self.branch.base
 
363
 
 
364
                # report the start of the commit
 
365
                self.reporter.started(new_revno, self.rev_id, master_location)
 
366
 
 
367
                self._update_builder_with_changes()
 
368
                self._report_and_accumulate_deletes()
 
369
                self._check_pointless()
 
370
 
 
371
                # TODO: Now the new inventory is known, check for conflicts.
 
372
                # ADHB 2006-08-08: If this is done, populate_new_inv should not add
 
373
                # weave lines, because nothing should be recorded until it is known
 
374
                # that commit will succeed.
 
375
                self._set_progress_stage("Saving data locally")
 
376
                self.builder.finish_inventory()
 
377
 
 
378
                # Prompt the user for a commit message if none provided
 
379
                message = message_callback(self)
 
380
                self.message = message
 
381
                self._escape_commit_message()
 
382
 
 
383
                # Add revision data to the local branch
 
384
                self.rev_id = self.builder.commit(self.message)
 
385
 
 
386
            except:
 
387
                self.builder.abort()
 
388
                raise
 
389
 
482
390
            self._process_pre_hooks(old_revno, new_revno)
483
391
 
484
392
            # Upload revision data to the master.
485
393
            # this will propagate merged revisions too if needed.
486
394
            if self.bound_branch:
487
 
                self._set_progress_stage("Uploading data to master branch")
 
395
                if not self.master_branch.repository.has_same_location(
 
396
                        self.branch.repository):
 
397
                    self._set_progress_stage("Uploading data to master branch")
 
398
                    self.master_branch.repository.fetch(self.branch.repository,
 
399
                        revision_id=self.rev_id)
 
400
                # now the master has the revision data
488
401
                # 'commit' to the master first so a timeout here causes the
489
402
                # local branch to be out of date
490
 
                (new_revno, self.rev_id) = self.master_branch.import_last_revision_info_and_tags(
491
 
                    self.branch, new_revno, self.rev_id, lossy=self._lossy)
492
 
                if self._lossy:
493
 
                    self.branch.fetch(self.master_branch, self.rev_id)
 
403
                self.master_branch.set_last_revision_info(new_revno,
 
404
                                                          self.rev_id)
494
405
 
495
406
            # and now do the commit locally.
496
407
            self.branch.set_last_revision_info(new_revno, self.rev_id)
497
 
        else:
498
 
            try:
499
 
                self._process_pre_hooks(old_revno, new_revno)
500
 
            except:
501
 
                # The commit builder will already have updated the branch,
502
 
                # revert it.
503
 
                self.branch.set_last_revision_info(old_revno, old_revid)
504
 
                raise
505
408
 
506
 
        # Merge local tags to remote
507
 
        if self.bound_branch:
508
 
            self._set_progress_stage("Merging tags to master branch")
509
 
            tag_updates, tag_conflicts = self.branch.tags.merge_to(
510
 
                self.master_branch.tags)
511
 
            if tag_conflicts:
512
 
                warning_lines = ['    ' + name for name, _, _ in tag_conflicts]
513
 
                note( gettext("Conflicting tags in bound branch:\n{0}".format(
514
 
                    "\n".join(warning_lines))) )
 
409
            # Make the working tree up to date with the branch
 
410
            self._set_progress_stage("Updating the working tree")
 
411
            self.work_tree.update_basis_by_delta(self.rev_id,
 
412
                 self._basis_delta)
 
413
            self.reporter.completed(new_revno, self.rev_id)
 
414
            self._process_post_hooks(old_revno, new_revno)
 
415
        finally:
 
416
            self._cleanup()
 
417
        return self.rev_id
515
418
 
516
419
    def _select_reporter(self):
517
420
        """Select the CommitReporter to use."""
525
428
        # A merge with no effect on files
526
429
        if len(self.parents) > 1:
527
430
            return
528
 
        if self.builder.any_changes():
 
431
        # TODO: we could simplify this by using self._basis_delta.
 
432
 
 
433
        # The initial commit adds a root directory, but this in itself is not
 
434
        # a worthwhile commit.
 
435
        if (self.basis_revid == revision.NULL_REVISION and
 
436
            len(self.builder.new_inventory) == 1):
 
437
            raise PointlessCommit()
 
438
        # If length == 1, then we only have the root entry. Which means
 
439
        # that there is no real difference (only the root could be different)
 
440
        # unless deletes occured, in which case the length is irrelevant.
 
441
        if (self.any_entries_deleted or 
 
442
            (len(self.builder.new_inventory) != 1 and
 
443
             self.any_entries_changed)):
529
444
            return
530
445
        raise PointlessCommit()
531
446
 
532
 
    def _check_bound_branch(self, operation, possible_master_transports=None):
 
447
    def _check_bound_branch(self):
533
448
        """Check to see if the local branch is bound.
534
449
 
535
450
        If it is bound, then most of the commit will actually be
540
455
            raise errors.LocalRequiresBoundBranch()
541
456
 
542
457
        if not self.local:
543
 
            self.master_branch = self.branch.get_master_branch(
544
 
                possible_master_transports)
 
458
            self.master_branch = self.branch.get_master_branch()
545
459
 
546
460
        if not self.master_branch:
547
461
            # make this branch the reference branch for out of date checks.
558
472
        #       commits to the remote branch if they would fit.
559
473
        #       But for now, just require remote to be identical
560
474
        #       to local.
561
 
 
 
475
        
562
476
        # Make sure the local branch is identical to the master
563
477
        master_info = self.master_branch.last_revision_info()
564
478
        local_info = self.branch.last_revision_info()
570
484
        # so grab the lock
571
485
        self.bound_branch = self.branch
572
486
        self.master_branch.lock_write()
573
 
        operation.add_cleanup(self.master_branch.unlock)
 
487
        self.master_locked = True
574
488
 
575
489
    def _check_out_of_date_tree(self):
576
490
        """Check that the working tree is up to date.
577
491
 
578
 
        :return: old_revision_number, old_revision_id, new_revision_number
579
 
            tuple
 
492
        :return: old_revision_number,new_revision_number tuple
580
493
        """
581
494
        try:
582
495
            first_tree_parent = self.work_tree.get_parent_ids()[0]
585
498
            # this is so that we still consider the master branch
586
499
            # - in a checkout scenario the tree may have no
587
500
            # parents but the branch may do.
588
 
            first_tree_parent = breezy.revision.NULL_REVISION
 
501
            first_tree_parent = bzrlib.revision.NULL_REVISION
589
502
        old_revno, master_last = self.master_branch.last_revision_info()
590
503
        if master_last != first_tree_parent:
591
 
            if master_last != breezy.revision.NULL_REVISION:
 
504
            if master_last != bzrlib.revision.NULL_REVISION:
592
505
                raise errors.OutOfDateTree(self.work_tree)
593
506
        if self.branch.repository.has_revision(first_tree_parent):
594
507
            new_revno = old_revno + 1
595
508
        else:
596
509
            # ghost parents never appear in revision history.
597
510
            new_revno = 1
598
 
        return old_revno, master_last, new_revno
 
511
        return old_revno,new_revno
599
512
 
600
513
    def _process_pre_hooks(self, old_revno, new_revno):
601
514
        """Process any registered pre commit hooks."""
607
520
        # Process the post commit hooks, if any
608
521
        self._set_progress_stage("Running post_commit hooks")
609
522
        # old style commit hooks - should be deprecated ? (obsoleted in
610
 
        # 0.15^H^H^H^H 2.5.0)
611
 
        post_commit = self.config_stack.get('post_commit')
612
 
        if post_commit is not None:
613
 
            hooks = post_commit.split(' ')
 
523
        # 0.15)
 
524
        if self.config.post_commit() is not None:
 
525
            hooks = self.config.post_commit().split(' ')
614
526
            # this would be nicer with twisted.python.reflect.namedAny
615
527
            for hook in hooks:
616
528
                result = eval(hook + '(branch, rev_id)',
617
529
                              {'branch':self.branch,
618
 
                               'breezy':breezy,
 
530
                               'bzrlib':bzrlib,
619
531
                               'rev_id':self.rev_id})
620
532
        # process new style post commit hooks
621
533
        self._process_hooks("post_commit", old_revno, new_revno)
623
535
    def _process_hooks(self, hook_name, old_revno, new_revno):
624
536
        if not Branch.hooks[hook_name]:
625
537
            return
626
 
 
 
538
        
627
539
        # new style commit hooks:
628
540
        if not self.bound_branch:
629
541
            hook_master = self.branch
637
549
        if self.parents:
638
550
            old_revid = self.parents[0]
639
551
        else:
640
 
            old_revid = breezy.revision.NULL_REVISION
641
 
 
 
552
            old_revid = bzrlib.revision.NULL_REVISION
 
553
        
642
554
        if hook_name == "pre_commit":
643
555
            future_tree = self.builder.revision_tree()
644
556
            tree_delta = future_tree.changes_from(self.basis_tree,
645
557
                                             include_root=True)
646
 
 
 
558
        
647
559
        for hook in Branch.hooks[hook_name]:
648
560
            # show the running hook in the progress bar. As hooks may
649
561
            # end up doing nothing (e.g. because they are not configured by
663
575
                     old_revno, old_revid, new_revno, self.rev_id,
664
576
                     tree_delta, future_tree)
665
577
 
 
578
    def _cleanup(self):
 
579
        """Cleanup any open locks, progress bars etc."""
 
580
        cleanups = [self._cleanup_bound_branch,
 
581
                    self.basis_tree.unlock,
 
582
                    self.work_tree.unlock,
 
583
                    self.pb.finished]
 
584
        found_exception = None
 
585
        for cleanup in cleanups:
 
586
            try:
 
587
                cleanup()
 
588
            # we want every cleanup to run no matter what.
 
589
            # so we have a catchall here, but we will raise the
 
590
            # last encountered exception up the stack: and
 
591
            # typically this will be useful enough.
 
592
            except Exception, e:
 
593
                found_exception = e
 
594
        if found_exception is not None: 
 
595
            # don't do a plan raise, because the last exception may have been
 
596
            # trashed, e is our sure-to-work exception even though it loses the
 
597
            # full traceback. XXX: RBC 20060421 perhaps we could check the
 
598
            # exc_info and if its the same one do a plain raise otherwise 
 
599
            # 'raise e' as we do now.
 
600
            raise e
 
601
 
 
602
    def _cleanup_bound_branch(self):
 
603
        """Executed at the end of a try/finally to cleanup a bound branch.
 
604
 
 
605
        If the branch wasn't bound, this is a no-op.
 
606
        If it was, it resents self.branch to the local branch, instead
 
607
        of being the master.
 
608
        """
 
609
        if not self.bound_branch:
 
610
            return
 
611
        if self.master_locked:
 
612
            self.master_branch.unlock()
 
613
 
 
614
    def _escape_commit_message(self):
 
615
        """Replace xml-incompatible control characters."""
 
616
        # FIXME: RBC 20060419 this should be done by the revision
 
617
        # serialiser not by commit. Then we can also add an unescaper
 
618
        # in the deserializer and start roundtripping revision messages
 
619
        # precisely. See repository_implementations/test_repository.py
 
620
        
 
621
        # Python strings can include characters that can't be
 
622
        # represented in well-formed XML; escape characters that
 
623
        # aren't listed in the XML specification
 
624
        # (http://www.w3.org/TR/REC-xml/#NT-Char).
 
625
        self.message, escape_count = re.subn(
 
626
            u'[^\x09\x0A\x0D\u0020-\uD7FF\uE000-\uFFFD]+',
 
627
            lambda match: match.group(0).encode('unicode_escape'),
 
628
            self.message)
 
629
        if escape_count:
 
630
            self.reporter.escaped(escape_count, self.message)
 
631
 
 
632
    def _gather_parents(self):
 
633
        """Record the parents of a merge for merge detection."""
 
634
        # TODO: Make sure that this list doesn't contain duplicate 
 
635
        # entries and the order is preserved when doing this.
 
636
        self.parents = self.work_tree.get_parent_ids()
 
637
        self.parent_invs = [self.basis_inv]
 
638
        for revision in self.parents[1:]:
 
639
            if self.branch.repository.has_revision(revision):
 
640
                mutter('commit parent revision {%s}', revision)
 
641
                inventory = self.branch.repository.get_inventory(revision)
 
642
                self.parent_invs.append(inventory)
 
643
            else:
 
644
                mutter('commit parent ghost revision {%s}', revision)
 
645
 
666
646
    def _update_builder_with_changes(self):
667
647
        """Update the commit builder with the data about what has changed.
668
648
        """
669
 
        specific_files = self.specific_files
670
 
        mutter("Selecting files for commit with filter %r", specific_files)
671
 
 
672
 
        self._check_strict()
673
 
        iter_changes = self.work_tree.iter_changes(self.basis_tree,
674
 
            specific_files=specific_files)
675
 
        if self.exclude:
676
 
            iter_changes = filter_excluded(iter_changes, self.exclude)
677
 
        iter_changes = self._filter_iter_changes(iter_changes)
678
 
        for file_id, path, fs_hash in self.builder.record_iter_changes(
679
 
            self.work_tree, self.basis_revid, iter_changes):
680
 
            self.work_tree._observed_sha1(file_id, path, fs_hash)
681
 
 
682
 
    def _filter_iter_changes(self, iter_changes):
683
 
        """Process iter_changes.
684
 
 
685
 
        This method reports on the changes in iter_changes to the user, and 
686
 
        converts 'missing' entries in the iter_changes iterator to 'deleted'
687
 
        entries. 'missing' entries have their
688
 
 
689
 
        :param iter_changes: An iter_changes to process.
690
 
        :return: A generator of changes.
691
 
        """
692
 
        reporter = self.reporter
693
 
        report_changes = reporter.is_verbose()
694
 
        deleted_paths = []
695
 
        for change in iter_changes:
696
 
            if report_changes:
697
 
                old_path = change[1][0]
698
 
                new_path = change[1][1]
699
 
                versioned = change[3][1]
700
 
            kind = change[6][1]
701
 
            versioned = change[3][1]
702
 
            if kind is None and versioned:
703
 
                # 'missing' path
704
 
                if report_changes:
705
 
                    reporter.missing(new_path)
706
 
                deleted_paths.append(change[1][1])
707
 
                # Reset the new path (None) and new versioned flag (False)
708
 
                change = (change[0], (change[1][0], None), change[2],
709
 
                    (change[3][0], False)) + change[4:]
710
 
                new_path = change[1][1]
711
 
                versioned = False
712
 
            elif kind == 'tree-reference':
713
 
                if self.recursive == 'down':
714
 
                    self._commit_nested_tree(change[0], change[1][1])
715
 
            if change[3][0] or change[3][1]:
716
 
                yield change
717
 
                if report_changes:
718
 
                    if new_path is None:
719
 
                        reporter.deleted(old_path)
720
 
                    elif old_path is None:
721
 
                        reporter.snapshot_change(gettext('added'), new_path)
722
 
                    elif old_path != new_path:
723
 
                        reporter.renamed(gettext('renamed'), old_path, new_path)
724
 
                    else:
725
 
                        if (new_path or 
726
 
                            self.work_tree.branch.repository._format.rich_root_data):
727
 
                            # Don't report on changes to '' in non rich root
728
 
                            # repositories.
729
 
                            reporter.snapshot_change(gettext('modified'), new_path)
730
 
            self._next_progress_entry()
731
 
        # Unversion files that were found to be deleted
732
 
        self.deleted_paths = deleted_paths
733
 
 
734
 
    def _check_strict(self):
735
 
        # XXX: when we use iter_changes this would likely be faster if
736
 
        # iter_changes would check for us (even in the presence of
737
 
        # selected_files).
 
649
        # Build the revision inventory.
 
650
        #
 
651
        # This starts by creating a new empty inventory. Depending on
 
652
        # which files are selected for commit, and what is present in the
 
653
        # current tree, the new inventory is populated. inventory entries 
 
654
        # which are candidates for modification have their revision set to
 
655
        # None; inventory entries that are carried over untouched have their
 
656
        # revision set to their prior value.
 
657
        #
 
658
        # ESEPARATIONOFCONCERNS: this function is diffing and using the diff
 
659
        # results to create a new inventory at the same time, which results
 
660
        # in bugs like #46635.  Any reason not to use/enhance Tree.changes_from?
 
661
        # ADHB 11-07-2006
 
662
 
 
663
        exclude = self.exclude
 
664
        specific_files = self.specific_files or []
 
665
        mutter("Selecting files for commit with filter %s", specific_files)
 
666
 
 
667
        # Build the new inventory
 
668
        self._populate_from_inventory()
 
669
 
 
670
        # If specific files are selected, then all un-selected files must be
 
671
        # recorded in their previous state. For more details, see
 
672
        # https://lists.ubuntu.com/archives/bazaar/2007q3/028476.html.
 
673
        if specific_files or exclude:
 
674
            for path, old_ie in self.basis_inv.iter_entries():
 
675
                if old_ie.file_id in self.builder.new_inventory:
 
676
                    # already added - skip.
 
677
                    continue
 
678
                if (is_inside_any(specific_files, path)
 
679
                    and not is_inside_any(exclude, path)):
 
680
                    # was inside the selected path, and not excluded - if not
 
681
                    # present it has been deleted so skip.
 
682
                    continue
 
683
                # From here down it was either not selected, or was excluded:
 
684
                if old_ie.kind == 'directory':
 
685
                    self._next_progress_entry()
 
686
                # We preserve the entry unaltered.
 
687
                ie = old_ie.copy()
 
688
                # Note: specific file commits after a merge are currently
 
689
                # prohibited. This test is for sanity/safety in case it's
 
690
                # required after that changes.
 
691
                if len(self.parents) > 1:
 
692
                    ie.revision = None
 
693
                delta, version_recorded = self.builder.record_entry_contents(
 
694
                    ie, self.parent_invs, path, self.basis_tree, None)
 
695
                if version_recorded:
 
696
                    self.any_entries_changed = True
 
697
                if delta: self._basis_delta.append(delta)
 
698
 
 
699
    def _report_and_accumulate_deletes(self):
 
700
        # XXX: Could the list of deleted paths and ids be instead taken from
 
701
        # _populate_from_inventory?
 
702
        deleted_ids = set(self.basis_inv._byid.keys()) - \
 
703
            set(self.builder.new_inventory._byid.keys())
 
704
        if deleted_ids:
 
705
            self.any_entries_deleted = True
 
706
            deleted = [(self.basis_tree.id2path(file_id), file_id)
 
707
                for file_id in deleted_ids]
 
708
            deleted.sort()
 
709
            # XXX: this is not quite directory-order sorting
 
710
            for path, file_id in deleted:
 
711
                self._basis_delta.append((path, None, file_id, None))
 
712
                self.reporter.deleted(path)
 
713
 
 
714
    def _populate_from_inventory(self):
 
715
        """Populate the CommitBuilder by walking the working tree inventory."""
738
716
        if self.strict:
739
717
            # raise an exception as soon as we find a single unknown.
740
718
            for unknown in self.work_tree.unknowns():
741
719
                raise StrictCommitFailed()
 
720
        
 
721
        specific_files = self.specific_files
 
722
        exclude = self.exclude
 
723
        report_changes = self.reporter.is_verbose()
 
724
        deleted_ids = []
 
725
        # A tree of paths that have been deleted. E.g. if foo/bar has been
 
726
        # deleted, then we have {'foo':{'bar':{}}}
 
727
        deleted_paths = {}
 
728
        # XXX: Note that entries may have the wrong kind because the entry does
 
729
        # not reflect the status on disk.
 
730
        work_inv = self.work_tree.inventory
 
731
        # NB: entries will include entries within the excluded ids/paths
 
732
        # because iter_entries_by_dir has no 'exclude' facility today.
 
733
        entries = work_inv.iter_entries_by_dir(
 
734
            specific_file_ids=self.specific_file_ids, yield_parents=True)
 
735
        for path, existing_ie in entries:
 
736
            file_id = existing_ie.file_id
 
737
            name = existing_ie.name
 
738
            parent_id = existing_ie.parent_id
 
739
            kind = existing_ie.kind
 
740
            if kind == 'directory':
 
741
                self._next_progress_entry()
 
742
            # Skip files that have been deleted from the working tree.
 
743
            # The deleted path ids are also recorded so they can be explicitly
 
744
            # unversioned later.
 
745
            if deleted_paths:
 
746
                path_segments = splitpath(path)
 
747
                deleted_dict = deleted_paths
 
748
                for segment in path_segments:
 
749
                    deleted_dict = deleted_dict.get(segment, None)
 
750
                    if not deleted_dict:
 
751
                        # We either took a path not present in the dict
 
752
                        # (deleted_dict was None), or we've reached an empty
 
753
                        # child dir in the dict, so are now a sub-path.
 
754
                        break
 
755
                else:
 
756
                    deleted_dict = None
 
757
                if deleted_dict is not None:
 
758
                    # the path has a deleted parent, do not add it.
 
759
                    continue
 
760
            if exclude and is_inside_any(exclude, path):
 
761
                # Skip excluded paths. Excluded paths are processed by
 
762
                # _update_builder_with_changes.
 
763
                continue
 
764
            content_summary = self.work_tree.path_content_summary(path)
 
765
            # Note that when a filter of specific files is given, we must only
 
766
            # skip/record deleted files matching that filter.
 
767
            if not specific_files or is_inside_any(specific_files, path):
 
768
                if content_summary[0] == 'missing':
 
769
                    if not deleted_paths:
 
770
                        # path won't have been split yet.
 
771
                        path_segments = splitpath(path)
 
772
                    deleted_dict = deleted_paths
 
773
                    for segment in path_segments:
 
774
                        deleted_dict = deleted_dict.setdefault(segment, {})
 
775
                    self.reporter.missing(path)
 
776
                    deleted_ids.append(file_id)
 
777
                    continue
 
778
            # TODO: have the builder do the nested commit just-in-time IF and
 
779
            # only if needed.
 
780
            if content_summary[0] == 'tree-reference':
 
781
                # enforce repository nested tree policy.
 
782
                if (not self.work_tree.supports_tree_reference() or
 
783
                    # repository does not support it either.
 
784
                    not self.branch.repository._format.supports_tree_reference):
 
785
                    content_summary = ('directory',) + content_summary[1:]
 
786
            kind = content_summary[0]
 
787
            # TODO: specific_files filtering before nested tree processing
 
788
            if kind == 'tree-reference':
 
789
                if self.recursive == 'down':
 
790
                    nested_revision_id = self._commit_nested_tree(
 
791
                        file_id, path)
 
792
                    content_summary = content_summary[:3] + (
 
793
                        nested_revision_id,)
 
794
                else:
 
795
                    content_summary = content_summary[:3] + (
 
796
                        self.work_tree.get_reference_revision(file_id),)
 
797
 
 
798
            # Record an entry for this item
 
799
            # Note: I don't particularly want to have the existing_ie
 
800
            # parameter but the test suite currently (28-Jun-07) breaks
 
801
            # without it thanks to a unicode normalisation issue. :-(
 
802
            definitely_changed = kind != existing_ie.kind
 
803
            self._record_entry(path, file_id, specific_files, kind, name,
 
804
                parent_id, definitely_changed, existing_ie, report_changes,
 
805
                content_summary)
 
806
 
 
807
        # Unversion IDs that were found to be deleted
 
808
        self.work_tree.unversion(deleted_ids)
742
809
 
743
810
    def _commit_nested_tree(self, file_id, path):
744
811
        "Commit a nested tree."
745
 
        sub_tree = self.work_tree.get_nested_tree(path, file_id)
 
812
        sub_tree = self.work_tree.get_nested_tree(file_id, path)
746
813
        # FIXME: be more comprehensive here:
747
814
        # this works when both trees are in --trees repository,
748
815
        # but when both are bound to a different repository,
749
 
        # it fails; a better way of approaching this is to
 
816
        # it fails; a better way of approaching this is to 
750
817
        # finally implement the explicit-caches approach design
751
818
        # a while back - RBC 20070306.
752
819
        if sub_tree.branch.repository.has_same_location(
762
829
                allow_pointless=self.allow_pointless,
763
830
                strict=self.strict, verbose=self.verbose,
764
831
                local=self.local, reporter=self.reporter)
765
 
        except PointlessCommit:
766
 
            return self.work_tree.get_reference_revision(path, file_id)
767
 
 
768
 
    def _set_progress_stage(self, name, counter=False):
 
832
        except errors.PointlessCommit:
 
833
            return self.work_tree.get_reference_revision(file_id)
 
834
 
 
835
    def _record_entry(self, path, file_id, specific_files, kind, name,
 
836
        parent_id, definitely_changed, existing_ie, report_changes,
 
837
        content_summary):
 
838
        "Record the new inventory entry for a path if any."
 
839
        # mutter('check %s {%s}', path, file_id)
 
840
        # mutter('%s selected for commit', path)
 
841
        if definitely_changed or existing_ie is None:
 
842
            ie = make_entry(kind, name, parent_id, file_id)
 
843
        else:
 
844
            ie = existing_ie.copy()
 
845
            ie.revision = None
 
846
        delta, version_recorded = self.builder.record_entry_contents(ie,
 
847
            self.parent_invs, path, self.work_tree, content_summary)
 
848
        if delta:
 
849
            self._basis_delta.append(delta)
 
850
        if version_recorded:
 
851
            self.any_entries_changed = True
 
852
        if report_changes:
 
853
            self._report_change(ie, path)
 
854
        return ie
 
855
 
 
856
    def _report_change(self, ie, path):
 
857
        """Report a change to the user.
 
858
 
 
859
        The change that has occurred is described relative to the basis
 
860
        inventory.
 
861
        """
 
862
        if (self.basis_inv.has_id(ie.file_id)):
 
863
            basis_ie = self.basis_inv[ie.file_id]
 
864
        else:
 
865
            basis_ie = None
 
866
        change = ie.describe_change(basis_ie, ie)
 
867
        if change in (InventoryEntry.RENAMED, 
 
868
            InventoryEntry.MODIFIED_AND_RENAMED):
 
869
            old_path = self.basis_inv.id2path(ie.file_id)
 
870
            self.reporter.renamed(change, old_path, path)
 
871
        else:
 
872
            self.reporter.snapshot_change(change, path)
 
873
 
 
874
    def _set_progress_stage(self, name, entries_title=None):
769
875
        """Set the progress stage and emit an update to the progress bar."""
770
876
        self.pb_stage_name = name
771
877
        self.pb_stage_count += 1
772
 
        if counter:
 
878
        self.pb_entries_title = entries_title
 
879
        if entries_title is not None:
773
880
            self.pb_entries_count = 0
774
 
        else:
775
 
            self.pb_entries_count = None
 
881
            self.pb_entries_total = '?'
776
882
        self._emit_progress()
777
883
 
778
884
    def _next_progress_entry(self):
781
887
        self._emit_progress()
782
888
 
783
889
    def _emit_progress(self):
784
 
        if self.pb_entries_count is not None:
785
 
            text = gettext("{0} [{1}] - Stage").format(self.pb_stage_name,
786
 
                self.pb_entries_count)
 
890
        if self.pb_entries_title:
 
891
            if self.pb_entries_total == '?':
 
892
                text = "%s [%s %d] - Stage" % (self.pb_stage_name,
 
893
                    self.pb_entries_title, self.pb_entries_count)
 
894
            else:
 
895
                text = "%s [%s %d/%s] - Stage" % (self.pb_stage_name,
 
896
                    self.pb_entries_title, self.pb_entries_count,
 
897
                    str(self.pb_entries_total))
787
898
        else:
788
 
            text = gettext("%s - Stage") % (self.pb_stage_name, )
 
899
            text = "%s - Stage" % (self.pb_stage_name)
789
900
        self.pb.update(text, self.pb_stage_count, self.pb_stage_total)
 
901