← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/status.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2009-01-13 05:14:24 UTC
  • mfrom: (3936.1.3 integration)
  • Revision ID: pqm@pqm.ubuntu.com-20090113051424-nrk3zkfe09h46i9y
(mbp) merge 1.11 and advance to 1.12

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/status.py
1
 
# Copyright (C) 2005, 2006 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
16
16
 
17
17
import sys
18
18
 
19
 
from bzrlib.diff import _raise_if_nonexistent
 
19
from bzrlib import (
 
20
    delta as _mod_delta,
 
21
    log,
 
22
    osutils,
 
23
    tree,
 
24
    tsort,
 
25
    revision as _mod_revision,
 
26
    )
20
27
import bzrlib.errors as errors
21
 
from bzrlib.log import line_log
22
28
from bzrlib.osutils import is_inside_any
23
29
from bzrlib.symbol_versioning import (deprecated_function,
24
 
        zero_eight,
25
30
        )
26
 
from bzrlib.trace import warning
 
31
from bzrlib.trace import mutter, warning
27
32
 
28
33
# TODO: when showing single-line logs, truncate to the width of the terminal
29
34
# if known, but only if really going to the terminal (not into a file)
30
35
 
31
36
 
32
 
@deprecated_function(zero_eight)
33
 
def show_status(branch, show_unchanged=None,
34
 
                specific_files=None,
35
 
                show_ids=False,
36
 
                to_file=None,
37
 
                show_pending=True,
38
 
                revision=None):
39
 
    """Display summary of changes.
40
 
 
41
 
    Please use show_tree_status instead.
42
 
 
43
 
    By default this compares the working tree to a previous revision. 
44
 
    If the revision argument is given, summarizes changes between the 
45
 
    working tree and another, or between two revisions.
46
 
 
47
 
    The result is written out as Unicode and to_file should be able 
48
 
    to encode that.
49
 
 
50
 
    show_unchanged
51
 
        If set, includes unchanged files.
52
 
 
53
 
    specific_files
54
 
        If set, only show the status of files in this list.
55
 
 
56
 
    show_ids
57
 
        If set, includes each file's id.
58
 
 
59
 
    to_file
60
 
        If set, write to this file (default stdout.)
61
 
 
62
 
    show_pending
63
 
        If set, write pending merges.
64
 
 
65
 
    revision
66
 
        If None the compare latest revision with working tree
67
 
        If one revision show compared it with working tree.
68
 
        If two revisions show status between first and second.
69
 
    """
70
 
    show_tree_status(branch.bzrdir.open_workingtree(), show_unchanged, 
71
 
                     specific_files, show_ids, to_file, show_pending, revision)
72
 
 
73
 
 
74
37
def show_tree_status(wt, show_unchanged=None,
75
38
                     specific_files=None,
76
39
                     show_ids=False,
77
40
                     to_file=None,
78
41
                     show_pending=True,
79
42
                     revision=None,
80
 
                     short=False):
 
43
                     short=False,
 
44
                     versioned=False):
81
45
    """Display summary of changes.
82
46
 
83
47
    By default this compares the working tree to a previous revision. 
98
62
    :param show_ids: If set, includes each file's id.
99
63
    :param to_file: If set, write to this file (default stdout.)
100
64
    :param show_pending: If set, write pending merges.
101
 
    :param revision: If None the compare latest revision with working tree
102
 
        If not None it must be a RevisionSpec list.
103
 
        If one revision show compared it with working tree.
104
 
        If two revisions show status between first and second.
105
 
    :param short: If True, gives short SVN-style status lines
 
65
    :param revision: If None, compare latest revision with working tree
 
66
        If not None, it must be a RevisionSpec list.
 
67
        If one revision, compare with working tree.
 
68
        If two revisions, show status between first and second.
 
69
    :param short: If True, gives short SVN-style status lines.
 
70
    :param versioned: If True, only shows versioned files.
106
71
    """
107
72
    if show_unchanged is not None:
108
 
        warn("show_status_trees with show_unchanged has been deprecated "
 
73
        warn("show_tree_status with show_unchanged has been deprecated "
109
74
             "since bzrlib 0.9", DeprecationWarning, stacklevel=2)
110
75
 
111
76
    if to_file is None:
121
86
            old = new.basis_tree()
122
87
        elif len(revision) > 0:
123
88
            try:
124
 
                rev_id = revision[0].in_history(wt.branch).rev_id
125
 
                old = wt.branch.repository.revision_tree(rev_id)
 
89
                old = revision[0].as_tree(wt.branch)
126
90
            except errors.NoSuchRevision, e:
127
91
                raise errors.BzrCommandError(str(e))
128
92
            if (len(revision) > 1) and (revision[1].spec is not None):
129
93
                try:
130
 
                    rev_id = revision[1].in_history(wt.branch).rev_id
131
 
                    new = wt.branch.repository.revision_tree(rev_id)
 
94
                    new = revision[1].as_tree(wt.branch)
132
95
                    new_is_working_tree = False
133
96
                except errors.NoSuchRevision, e:
134
97
                    raise errors.BzrCommandError(str(e))
135
98
            else:
136
99
                new = wt
137
 
        _raise_if_nonexistent(specific_files, old, new)
138
 
        delta = new.changes_from(old, want_unchanged=show_unchanged,
139
 
                              specific_files=specific_files)
140
 
        delta.show(to_file,
141
 
                   show_ids=show_ids,
142
 
                   show_unchanged=show_unchanged,
143
 
                   short_status=short)
144
 
        short_status_letter = '?'
145
 
        if not short:
146
 
            short_status_letter = ''
147
 
        list_paths('unknown', new.unknowns(), specific_files, to_file,
148
 
                   short_status_letter)
149
 
        conflict_title = False
150
 
        # show the new conflicts only for now. XXX: get them from the delta.
151
 
        for conflict in new.conflicts():
152
 
            if not short and conflict_title is False:
153
 
                print >> to_file, "conflicts:"
154
 
                conflict_title = True
 
100
        old.lock_read()
 
101
        new.lock_read()
 
102
        try:
 
103
            _raise_if_nonexistent(specific_files, old, new)
 
104
            want_unversioned = not versioned
155
105
            if short:
156
 
                prefix = 'C '
 
106
                changes = new.iter_changes(old, show_unchanged, specific_files,
 
107
                    require_versioned=False, want_unversioned=want_unversioned)
 
108
                reporter = _mod_delta._ChangeReporter(output_file=to_file,
 
109
                    unversioned_filter=new.is_ignored)
 
110
                _mod_delta.report_changes(changes, reporter)
157
111
            else:
158
 
                prefix = ' '
159
 
            print >> to_file, "%s %s" % (prefix, conflict)
160
 
        if new_is_working_tree and show_pending:
161
 
            show_pending_merges(new, to_file, short)
 
112
                delta = new.changes_from(old, want_unchanged=show_unchanged,
 
113
                                      specific_files=specific_files,
 
114
                                      want_unversioned=want_unversioned)
 
115
                # filter out unknown files. We may want a tree method for
 
116
                # this
 
117
                delta.unversioned = [unversioned for unversioned in
 
118
                    delta.unversioned if not new.is_ignored(unversioned[0])]
 
119
                delta.show(to_file,
 
120
                           show_ids=show_ids,
 
121
                           show_unchanged=show_unchanged,
 
122
                           short_status=False)
 
123
            # show the new conflicts only for now. XXX: get them from the
 
124
            # delta.
 
125
            conflicts = new.conflicts()
 
126
            if specific_files is not None:
 
127
                conflicts = conflicts.select_conflicts(new, specific_files,
 
128
                    ignore_misses=True, recurse=True)[1]
 
129
            if len(conflicts) > 0 and not short:
 
130
                to_file.write("conflicts:\n")
 
131
            for conflict in conflicts:
 
132
                if short:
 
133
                    prefix = 'C  '
 
134
                else:
 
135
                    prefix = ' '
 
136
                to_file.write("%s %s\n" % (prefix, conflict))
 
137
            if (new_is_working_tree and show_pending):
 
138
                show_pending_merges(new, to_file, short)
 
139
        finally:
 
140
            old.unlock()
 
141
            new.unlock()
162
142
    finally:
163
143
        wt.unlock()
164
144
 
 
145
 
 
146
def _get_sorted_revisions(tip_revision, revision_ids, parent_map):
 
147
    """Get an iterator which will return the revisions in merge sorted order.
 
148
 
 
149
    This will build up a list of all nodes, such that only nodes in the list
 
150
    are referenced. It then uses MergeSorter to return them in 'merge-sorted'
 
151
    order.
 
152
 
 
153
    :param revision_ids: A set of revision_ids
 
154
    :param parent_map: The parent information for each node. Revisions which
 
155
        are considered ghosts should not be present in the map.
 
156
    :return: iterator from MergeSorter.iter_topo_order()
 
157
    """
 
158
    # MergeSorter requires that all nodes be present in the graph, so get rid
 
159
    # of any references pointing outside of this graph.
 
160
    parent_graph = {}
 
161
    for revision_id in revision_ids:
 
162
        if revision_id not in parent_map: # ghost
 
163
            parent_graph[revision_id] = []
 
164
        else:
 
165
            # Only include parents which are in this sub-graph
 
166
            parent_graph[revision_id] = [p for p in parent_map[revision_id]
 
167
                                            if p in revision_ids]
 
168
    sorter = tsort.MergeSorter(parent_graph, tip_revision)
 
169
    return sorter.iter_topo_order()
 
170
 
 
171
 
165
172
def show_pending_merges(new, to_file, short=False):
166
173
    """Write out a display of pending merges in a working tree."""
167
174
    parents = new.get_parent_ids()
168
175
    if len(parents) < 2:
169
176
        return
 
177
 
 
178
    # we need one extra space for terminals that wrap on last char
 
179
    term_width = osutils.terminal_width() - 1
 
180
    if short:
 
181
        first_prefix = 'P   '
 
182
        sub_prefix = 'P.   '
 
183
    else:
 
184
        first_prefix = '  '
 
185
        sub_prefix = '    '
 
186
 
170
187
    pending = parents[1:]
171
188
    branch = new.branch
172
189
    last_revision = parents[0]
173
190
    if not short:
174
 
        print >>to_file, 'pending merges:'
175
 
    if last_revision is not None:
176
 
        try:
177
 
            ignore = set(branch.repository.get_ancestry(last_revision))
178
 
        except errors.NoSuchRevision:
179
 
            # the last revision is a ghost : assume everything is new 
180
 
            # except for it
181
 
            ignore = set([None, last_revision])
182
 
    else:
183
 
        ignore = set([None])
184
 
    # TODO: this could be improved using merge_sorted - we'd get the same 
185
 
    # output rather than one level of indent.
 
191
        to_file.write('pending merges:\n')
 
192
    graph = branch.repository.get_graph()
 
193
    other_revisions = [last_revision]
 
194
    log_formatter = log.LineLogFormatter(to_file)
186
195
    for merge in pending:
187
 
        ignore.add(merge)
188
196
        try:
189
 
            from bzrlib.osutils import terminal_width
190
 
            width = terminal_width()
191
 
            m_revision = branch.repository.get_revision(merge)
192
 
            if short:
193
 
                prefix = 'P '
194
 
            else:
195
 
                prefix = ' '
196
 
            print >> to_file, prefix, line_log(m_revision, width - 4)
197
 
            inner_merges = branch.repository.get_ancestry(merge)
198
 
            assert inner_merges[0] is None
199
 
            inner_merges.pop(0)
200
 
            inner_merges.reverse()
201
 
            for mmerge in inner_merges:
202
 
                if mmerge in ignore:
203
 
                    continue
204
 
                mm_revision = branch.repository.get_revision(mmerge)
205
 
                if short:
206
 
                    prefix = 'P. '
207
 
                else:
208
 
                    prefix = '   '
209
 
                print >> to_file, prefix, line_log(mm_revision, width - 5)
210
 
                ignore.add(mmerge)
 
197
            rev = branch.repository.get_revisions([merge])[0]
211
198
        except errors.NoSuchRevision:
212
 
            if short:
213
 
                prefix = 'P '
214
 
            else:
215
 
                prefix = ' '
216
 
            print >> to_file, prefix, merge
217
 
        
218
 
def list_paths(header, paths, specific_files, to_file, short_status_letter=''):
219
 
    done_header = False
220
 
    for path in paths:
221
 
        if specific_files and not is_inside_any(specific_files, path):
 
199
            # If we are missing a revision, just print out the revision id
 
200
            to_file.write(first_prefix + '(ghost) ' + merge + '\n')
 
201
            other_revisions.append(merge)
222
202
            continue
223
 
        if not short_status_letter and not done_header:
224
 
            print >>to_file, '%s:' % header
225
 
            done_header = True
226
 
        print >>to_file, '%s  %s' % (short_status_letter, path)
 
203
 
 
204
        # Log the merge, as it gets a slightly different formatting
 
205
        log_message = log_formatter.log_string(None, rev,
 
206
                        term_width - len(first_prefix))
 
207
        to_file.write(first_prefix + log_message + '\n')
 
208
        # Find all of the revisions in the merge source, which are not in the
 
209
        # last committed revision.
 
210
        merge_extra = graph.find_unique_ancestors(merge, other_revisions)
 
211
        other_revisions.append(merge)
 
212
        merge_extra.discard(_mod_revision.NULL_REVISION)
 
213
 
 
214
        # Get a handle to all of the revisions we will need
 
215
        try:
 
216
            revisions = dict((rev.revision_id, rev) for rev in
 
217
                             branch.repository.get_revisions(merge_extra))
 
218
        except errors.NoSuchRevision:
 
219
            # One of the sub nodes is a ghost, check each one
 
220
            revisions = {}
 
221
            for revision_id in merge_extra:
 
222
                try:
 
223
                    rev = branch.repository.get_revisions([revision_id])[0]
 
224
                except errors.NoSuchRevision:
 
225
                    revisions[revision_id] = None
 
226
                else:
 
227
                    revisions[revision_id] = rev
 
228
 
 
229
        # Display the revisions brought in by this merge.
 
230
        rev_id_iterator = _get_sorted_revisions(merge, merge_extra,
 
231
                            branch.repository.get_parent_map(merge_extra))
 
232
        # Skip the first node
 
233
        num, first, depth, eom = rev_id_iterator.next()
 
234
        if first != merge:
 
235
            raise AssertionError('Somehow we misunderstood how'
 
236
                ' iter_topo_order works %s != %s' % (first, merge))
 
237
        for num, sub_merge, depth, eom in rev_id_iterator:
 
238
            rev = revisions[sub_merge]
 
239
            if rev is None:
 
240
                to_file.write(sub_prefix + '(ghost) ' + sub_merge + '\n')
 
241
                continue
 
242
            log_message = log_formatter.log_string(None,
 
243
                            revisions[sub_merge],
 
244
                            term_width - len(sub_prefix))
 
245
            to_file.write(sub_prefix + log_message + '\n')
 
246
 
 
247
 
 
248
def _raise_if_nonexistent(paths, old_tree, new_tree):
 
249
    """Complain if paths are not in either inventory or tree.
 
250
 
 
251
    It's OK with the files exist in either tree's inventory, or 
 
252
    if they exist in the tree but are not versioned.
 
253
    
 
254
    This can be used by operations such as bzr status that can accept
 
255
    unknown or ignored files.
 
256
    """
 
257
    mutter("check paths: %r", paths)
 
258
    if not paths:
 
259
        return
 
260
    s = old_tree.filter_unversioned_files(paths)
 
261
    s = new_tree.filter_unversioned_files(s)
 
262
    s = [path for path in s if not new_tree.has_filename(path)]
 
263
    if s:
 
264
        raise errors.PathsDoNotExist(sorted(s))
 
265
 
 
266