29
29
WorkingTree.open(dir).
32
# TODO: Give the workingtree sole responsibility for the working inventory;
33
# remove the variable and references to it from the branch. This may require
34
# updating the commit code so as to update the inventory within the working
35
# copy, and making sure there's only one WorkingTree for any directory on disk.
36
# At the moment they may alias the inventory and have old copies of it in
37
# memory. (Now done? -- mbp 20060309)
33
39
from cStringIO import StringIO
96
102
from bzrlib.filters import filtered_input_file
97
103
from bzrlib.trace import mutter, note
98
104
from bzrlib.transport.local import LocalTransport
105
from bzrlib.progress import DummyProgress, ProgressPhase
99
106
from bzrlib.revision import CURRENT_REVISION
100
107
from bzrlib.rio import RioReader, rio_file, Stanza
101
108
from bzrlib.symbol_versioning import (
463
458
return (file_obj, stat_value)
465
460
def get_file_text(self, file_id, path=None, filtered=True):
466
my_file = self.get_file(file_id, path=path, filtered=filtered)
468
return my_file.read()
461
return self.get_file(file_id, path=path, filtered=filtered).read()
472
463
def get_file_byname(self, filename, filtered=True):
473
464
path = self.abspath(filename)
528
519
# Now we have the parents of this content
529
520
annotator = self.branch.repository.texts.get_annotator()
530
text = self.get_file_text(file_id)
521
text = self.get_file(file_id).read()
531
522
this_key =(file_id, default_revision)
532
523
annotator.add_special_text(this_key, file_parent_keys, text)
533
524
annotations = [(key[-1], line)
646
637
def _is_executable_from_path_and_stat_from_basis(self, path, stat_result):
647
638
file_id = self.path2id(path)
649
# For unversioned files on win32, we just assume they are not
652
639
return self._inventory[file_id].executable
654
641
def _is_executable_from_path_and_stat_from_stat(self, path, stat_result):
910
897
@needs_write_lock # because merge pulls data into the branch.
911
898
def merge_from_branch(self, branch, to_revision=None, from_revision=None,
912
merge_type=None, force=False):
913
900
"""Merge from a branch into this working tree.
915
902
:param branch: The branch to merge from.
919
906
branch.last_revision().
921
908
from bzrlib.merge import Merger, Merge3Merger
922
merger = Merger(self.branch, this_tree=self)
923
# check that there are no local alterations
924
if not force and self.has_changes():
925
raise errors.UncommittedChanges(self)
926
if to_revision is None:
927
to_revision = _mod_revision.ensure_null(branch.last_revision())
928
merger.other_rev_id = to_revision
929
if _mod_revision.is_null(merger.other_rev_id):
930
raise errors.NoCommits(branch)
931
self.branch.fetch(branch, last_revision=merger.other_rev_id)
932
merger.other_basis = merger.other_rev_id
933
merger.other_tree = self.branch.repository.revision_tree(
935
merger.other_branch = branch
936
if from_revision is None:
939
merger.set_base_revision(from_revision, branch)
940
if merger.base_rev_id == merger.other_rev_id:
941
raise errors.PointlessMerge
942
merger.backup_files = False
943
if merge_type is None:
944
merger.merge_type = Merge3Merger
946
merger.merge_type = merge_type
947
merger.set_interesting_files(None)
948
merger.show_base = False
949
merger.reprocess = False
950
conflicts = merger.do_merge()
909
pb = ui.ui_factory.nested_progress_bar()
911
merger = Merger(self.branch, this_tree=self, pb=pb)
912
merger.pp = ProgressPhase("Merge phase", 5, pb)
913
merger.pp.next_phase()
914
# check that there are no
916
merger.check_basis(check_clean=True, require_commits=False)
917
if to_revision is None:
918
to_revision = _mod_revision.ensure_null(branch.last_revision())
919
merger.other_rev_id = to_revision
920
if _mod_revision.is_null(merger.other_rev_id):
921
raise errors.NoCommits(branch)
922
self.branch.fetch(branch, last_revision=merger.other_rev_id)
923
merger.other_basis = merger.other_rev_id
924
merger.other_tree = self.branch.repository.revision_tree(
926
merger.other_branch = branch
927
merger.pp.next_phase()
928
if from_revision is None:
931
merger.set_base_revision(from_revision, branch)
932
if merger.base_rev_id == merger.other_rev_id:
933
raise errors.PointlessMerge
934
merger.backup_files = False
935
if merge_type is None:
936
merger.merge_type = Merge3Merger
938
merger.merge_type = merge_type
939
merger.set_interesting_files(None)
940
merger.show_base = False
941
merger.reprocess = False
942
conflicts = merger.do_merge()
1101
1095
tree_transport = self.bzrdir.root_transport.clone(sub_path)
1102
1096
if tree_transport.base != branch_transport.base:
1103
1097
tree_bzrdir = format.initialize_on_transport(tree_transport)
1104
branch.BranchReferenceFormat().initialize(tree_bzrdir,
1105
target_branch=new_branch)
1098
branch.BranchReferenceFormat().initialize(tree_bzrdir, new_branch)
1107
1100
tree_bzrdir = branch_bzrdir
1108
1101
wt = tree_bzrdir.create_workingtree(_mod_revision.NULL_REVISION)
1146
1139
This does not include files that have been deleted in this
1147
1140
tree. Skips the control directory.
1149
:param include_root: if True, return an entry for the root
1142
:param include_root: if True, do not return an entry for the root
1150
1143
:param from_dir: start from this directory or None for the root
1151
1144
:param recursive: whether to recurse into subdirectories or not
1606
1599
@needs_write_lock
1607
1600
def pull(self, source, overwrite=False, stop_revision=None,
1608
1601
change_reporter=None, possible_transports=None, local=False):
1602
top_pb = ui.ui_factory.nested_progress_bar()
1609
1603
source.lock_read()
1605
pp = ProgressPhase("Pull phase", 2, top_pb)
1611
1607
old_revision_info = self.branch.last_revision_info()
1612
1608
basis_tree = self.basis_tree()
1613
1609
count = self.branch.pull(source, overwrite, stop_revision,
1624
1622
new_basis_tree,
1626
1624
this_tree=self,
1628
1626
change_reporter=change_reporter)
1629
basis_root_id = basis_tree.get_root_id()
1630
new_root_id = new_basis_tree.get_root_id()
1631
if basis_root_id != new_root_id:
1632
self.set_root_id(new_root_id)
1627
if (basis_tree.inventory.root is None and
1628
new_basis_tree.inventory.root is not None):
1629
self.set_root_id(new_basis_tree.get_root_id())
1634
1632
basis_tree.unlock()
1635
1633
# TODO - dedup parents list with things merged by pull ?
1636
1634
# reuse the revisiontree we merged against to set the new
1739
1738
r"""Check whether the filename matches an ignore pattern.
1741
1740
Patterns containing '/' or '\' need to match the whole path;
1742
others match against only the last component. Patterns starting
1743
with '!' are ignore exceptions. Exceptions take precedence
1744
over regular patterns and cause the filename to not be ignored.
1741
others match against only the last component.
1746
1743
If the file is ignored, returns the pattern which caused it to
1747
1744
be ignored, otherwise None. So this can simply be used as a
1748
1745
boolean if desired."""
1749
1746
if getattr(self, '_ignoreglobster', None) is None:
1750
self._ignoreglobster = globbing.ExceptionGlobster(self.get_ignore_list())
1747
self._ignoreglobster = globbing.Globster(self.get_ignore_list())
1751
1748
return self._ignoreglobster.match(filename)
1753
1750
def kind(self, file_id):
1803
1800
raise errors.ObjectNotLocked(self)
1805
1802
def lock_read(self):
1806
"""Lock the tree for reading.
1808
This also locks the branch, and can be unlocked via self.unlock().
1810
:return: A bzrlib.lock.LogicalLockResult.
1803
"""See Branch.lock_read, and WorkingTree.unlock."""
1812
1804
if not self.is_locked():
1813
1805
self._reset_data()
1814
1806
self.branch.lock_read()
1816
self._control_files.lock_read()
1817
return LogicalLockResult(self.unlock)
1808
return self._control_files.lock_read()
1819
1810
self.branch.unlock()
1822
1813
def lock_tree_write(self):
1823
"""See MutableTree.lock_tree_write, and WorkingTree.unlock.
1825
:return: A bzrlib.lock.LogicalLockResult.
1814
"""See MutableTree.lock_tree_write, and WorkingTree.unlock."""
1827
1815
if not self.is_locked():
1828
1816
self._reset_data()
1829
1817
self.branch.lock_read()
1831
self._control_files.lock_write()
1832
return LogicalLockResult(self.unlock)
1819
return self._control_files.lock_write()
1834
1821
self.branch.unlock()
1837
1824
def lock_write(self):
1838
"""See MutableTree.lock_write, and WorkingTree.unlock.
1840
:return: A bzrlib.lock.LogicalLockResult.
1825
"""See MutableTree.lock_write, and WorkingTree.unlock."""
1842
1826
if not self.is_locked():
1843
1827
self._reset_data()
1844
1828
self.branch.lock_write()
1846
self._control_files.lock_write()
1847
return LogicalLockResult(self.unlock)
1830
return self._control_files.lock_write()
1849
1832
self.branch.unlock()
1915
1894
# revision_id is set. We must check for this full string, because a
1916
1895
# root node id can legitimately look like 'revision_id' but cannot
1917
1896
# contain a '"'.
1918
xml = self.branch.repository._get_inventory_xml(new_revision)
1897
xml = self.branch.repository.get_inventory_xml(new_revision)
1919
1898
firstline = xml.split('\n', 1)[0]
1920
1899
if (not 'revision_id="' in firstline or
1921
1900
'format="7"' not in firstline):
1970
1945
new_files=set()
1971
1946
unknown_nested_files=set()
1973
to_file = sys.stdout
1975
1948
def recurse_directory_to_add_files(directory):
1976
1949
# Recurse directory and add all files
1977
1950
# so we can check if they have changed.
1978
for parent_info, file_infos in self.walkdirs(directory):
1951
for parent_info, file_infos in\
1952
self.walkdirs(directory):
1979
1953
for relpath, basename, kind, lstat, fileid, kind in file_infos:
1980
1954
# Is it versioned or ignored?
1981
1955
if self.path2id(relpath) or self.is_ignored(relpath):
2016
1990
# ... but not ignored
2017
1991
has_changed_files = True
2019
elif (content_change and (kind[1] is not None) and
2020
osutils.is_inside_any(files, path[1])):
2021
# Versioned and changed, but not deleted, and still
2022
# in one of the dirs to be deleted.
1993
elif content_change and (kind[1] is not None):
1994
# Versioned and changed, but not deleted
2023
1995
has_changed_files = True
2047
2019
new_status = 'I'
2049
2021
new_status = '?'
2050
# XXX: Really should be a more abstract reporter interface
2051
kind_ch = osutils.kind_marker(self.kind(fid))
2052
to_file.write(new_status + ' ' + f + kind_ch + '\n')
2022
textui.show_status(new_status, self.kind(fid), f,
2053
2024
# Unversion file
2054
2025
inv_delta.append((f, None, fid, None))
2055
2026
message = "removed %s" % (f,)
2207
2178
raise NotImplementedError(self.unlock)
2211
def update(self, change_reporter=None, possible_transports=None,
2212
revision=None, old_tip=_marker):
2180
def update(self, change_reporter=None, possible_transports=None):
2213
2181
"""Update a working tree along its branch.
2215
2183
This will update the branch if its bound too, which means we have
2233
2201
- Merge current state -> basis tree of the master w.r.t. the old tree
2235
2203
- Do a 'normal' merge of the old branch basis if it is relevant.
2237
:param revision: The target revision to update to. Must be in the
2239
:param old_tip: If branch.update() has already been run, the value it
2240
returned (old tip of the branch or None). _marker is used
2243
2205
if self.branch.get_bound_location() is not None:
2244
2206
self.lock_write()
2245
update_branch = (old_tip is self._marker)
2207
update_branch = True
2247
2209
self.lock_tree_write()
2248
2210
update_branch = False
2250
2212
if update_branch:
2251
2213
old_tip = self.branch.update(possible_transports)
2253
if old_tip is self._marker:
2255
return self._update_tree(old_tip, change_reporter, revision)
2216
return self._update_tree(old_tip, change_reporter)
2259
2220
@needs_tree_write_lock
2260
def _update_tree(self, old_tip=None, change_reporter=None, revision=None):
2221
def _update_tree(self, old_tip=None, change_reporter=None):
2261
2222
"""Update a tree to the master branch.
2263
2224
:param old_tip: if supplied, the previous tip revision the branch,
2273
2234
# We MUST save it even if an error occurs, because otherwise the users
2274
2235
# local work is unreferenced and will appear to have been lost.
2278
2239
last_rev = self.get_parent_ids()[0]
2279
2240
except IndexError:
2280
2241
last_rev = _mod_revision.NULL_REVISION
2281
if revision is None:
2282
revision = self.branch.last_revision()
2284
old_tip = old_tip or _mod_revision.NULL_REVISION
2286
if not _mod_revision.is_null(old_tip) and old_tip != last_rev:
2287
# the branch we are bound to was updated
2288
# merge those changes in first
2289
base_tree = self.basis_tree()
2290
other_tree = self.branch.repository.revision_tree(old_tip)
2291
nb_conflicts = merge.merge_inner(self.branch, other_tree,
2292
base_tree, this_tree=self,
2293
change_reporter=change_reporter)
2295
self.add_parent_tree((old_tip, other_tree))
2296
trace.note('Rerun update after fixing the conflicts.')
2299
if last_rev != _mod_revision.ensure_null(revision):
2300
# the working tree is up to date with the branch
2301
# we can merge the specified revision from master
2302
to_tree = self.branch.repository.revision_tree(revision)
2303
to_root_id = to_tree.get_root_id()
2242
if last_rev != _mod_revision.ensure_null(self.branch.last_revision()):
2243
# merge tree state up to new branch tip.
2305
2244
basis = self.basis_tree()
2306
2245
basis.lock_read()
2308
if (basis.inventory.root is None
2309
or basis.inventory.root.file_id != to_root_id):
2310
self.set_root_id(to_root_id)
2247
to_tree = self.branch.basis_tree()
2248
if basis.inventory.root is None:
2249
self.set_root_id(to_tree.get_root_id())
2251
result += merge.merge_inner(
2256
change_reporter=change_reporter)
2315
# determine the branch point
2316
graph = self.branch.repository.get_graph()
2317
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2319
base_tree = self.branch.repository.revision_tree(base_rev_id)
2321
nb_conflicts = merge.merge_inner(self.branch, to_tree, base_tree,
2323
change_reporter=change_reporter)
2324
self.set_last_revision(revision)
2325
2259
# TODO - dedup parents list with things merged by pull ?
2326
2260
# reuse the tree we've updated to to set the basis:
2327
parent_trees = [(revision, to_tree)]
2261
parent_trees = [(self.branch.last_revision(), to_tree)]
2328
2262
merges = self.get_parent_ids()[1:]
2329
2263
# Ideally we ask the tree for the trees here, that way the working
2330
2264
# tree can decide whether to give us the entire tree or give us a
2334
2268
for parent in merges:
2335
2269
parent_trees.append(
2336
2270
(parent, self.branch.repository.revision_tree(parent)))
2337
if not _mod_revision.is_null(old_tip):
2271
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2338
2272
parent_trees.append(
2339
2273
(old_tip, self.branch.repository.revision_tree(old_tip)))
2340
2274
self.set_parent_trees(parent_trees)
2341
2275
last_rev = parent_trees[0][0]
2277
# the working tree had the same last-revision as the master
2278
# branch did. We may still have pivot local work from the local
2279
# branch into old_tip:
2280
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2281
self.add_parent_tree_id(old_tip)
2282
if (old_tip is not None and not _mod_revision.is_null(old_tip)
2283
and old_tip != last_rev):
2284
# our last revision was not the prior branch last revision
2285
# and we have converted that last revision to a pending merge.
2286
# base is somewhere between the branch tip now
2287
# and the now pending merge
2289
# Since we just modified the working tree and inventory, flush out
2290
# the current state, before we modify it again.
2291
# TODO: jam 20070214 WorkingTree3 doesn't require this, dirstate
2292
# requires it only because TreeTransform directly munges the
2293
# inventory and calls tree._write_inventory(). Ultimately we
2294
# should be able to remove this extra flush.
2296
graph = self.branch.repository.get_graph()
2297
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2299
base_tree = self.branch.repository.revision_tree(base_rev_id)
2300
other_tree = self.branch.repository.revision_tree(old_tip)
2301
result += merge.merge_inner(
2306
change_reporter=change_reporter)
2344
2309
def _write_hashcache_if_dirty(self):
2345
2310
"""Write out the hashcache if it is dirty."""
2803
2765
"""Return the format for the working tree object in a_bzrdir."""
2805
2767
transport = a_bzrdir.get_workingtree_transport(None)
2806
format_string = transport.get_bytes("format")
2768
format_string = transport.get("format").read()
2807
2769
return klass._formats[format_string]
2808
2770
except errors.NoSuchFile:
2809
2771
raise errors.NoWorkingTree(base=transport.base)