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
95
101
from bzrlib.filters import filtered_input_file
96
102
from bzrlib.trace import mutter, note
97
103
from bzrlib.transport.local import LocalTransport
104
from bzrlib.progress import DummyProgress, ProgressPhase
98
105
from bzrlib.revision import CURRENT_REVISION
99
106
from bzrlib.rio import RioReader, rio_file, Stanza
100
107
from bzrlib.symbol_versioning import (
371
363
return True, None
373
365
return True, tree
374
t = transport.get_transport(location)
375
iterator = bzrdir.BzrDir.find_bzrdirs(t, evaluate=evaluate,
366
transport = get_transport(location)
367
iterator = bzrdir.BzrDir.find_bzrdirs(transport, evaluate=evaluate,
376
368
list_current=list_current)
377
return [tr for tr in iterator if tr is not None]
369
return [t for t in iterator if t is not None]
379
371
# should be deprecated - this is slow and in any case treating them as a
380
372
# container is (we now know) bad style -- mbp 20070302
465
457
return (file_obj, stat_value)
467
459
def get_file_text(self, file_id, path=None, filtered=True):
468
my_file = self.get_file(file_id, path=path, filtered=filtered)
470
return my_file.read()
460
return self.get_file(file_id, path=path, filtered=filtered).read()
474
462
def get_file_byname(self, filename, filtered=True):
475
463
path = self.abspath(filename)
530
518
# Now we have the parents of this content
531
519
annotator = self.branch.repository.texts.get_annotator()
532
text = self.get_file_text(file_id)
520
text = self.get_file(file_id).read()
533
521
this_key =(file_id, default_revision)
534
522
annotator.add_special_text(this_key, file_parent_keys, text)
535
523
annotations = [(key[-1], line)
921
909
branch.last_revision().
923
911
from bzrlib.merge import Merger, Merge3Merger
924
merger = Merger(self.branch, this_tree=self)
925
# check that there are no local alterations
926
if not force and self.has_changes():
927
raise errors.UncommittedChanges(self)
928
if to_revision is None:
929
to_revision = _mod_revision.ensure_null(branch.last_revision())
930
merger.other_rev_id = to_revision
931
if _mod_revision.is_null(merger.other_rev_id):
932
raise errors.NoCommits(branch)
933
self.branch.fetch(branch, last_revision=merger.other_rev_id)
934
merger.other_basis = merger.other_rev_id
935
merger.other_tree = self.branch.repository.revision_tree(
937
merger.other_branch = branch
938
if from_revision is None:
941
merger.set_base_revision(from_revision, branch)
942
if merger.base_rev_id == merger.other_rev_id:
943
raise errors.PointlessMerge
944
merger.backup_files = False
945
if merge_type is None:
946
merger.merge_type = Merge3Merger
948
merger.merge_type = merge_type
949
merger.set_interesting_files(None)
950
merger.show_base = False
951
merger.reprocess = False
952
conflicts = merger.do_merge()
912
pb = ui.ui_factory.nested_progress_bar()
914
merger = Merger(self.branch, this_tree=self, pb=pb)
915
merger.pp = ProgressPhase("Merge phase", 5, pb)
916
merger.pp.next_phase()
917
# check that there are no local alterations
918
if not force and self.has_changes():
919
raise errors.UncommittedChanges(self)
920
if to_revision is None:
921
to_revision = _mod_revision.ensure_null(branch.last_revision())
922
merger.other_rev_id = to_revision
923
if _mod_revision.is_null(merger.other_rev_id):
924
raise errors.NoCommits(branch)
925
self.branch.fetch(branch, last_revision=merger.other_rev_id)
926
merger.other_basis = merger.other_rev_id
927
merger.other_tree = self.branch.repository.revision_tree(
929
merger.other_branch = branch
930
merger.pp.next_phase()
931
if from_revision is None:
934
merger.set_base_revision(from_revision, branch)
935
if merger.base_rev_id == merger.other_rev_id:
936
raise errors.PointlessMerge
937
merger.backup_files = False
938
if merge_type is None:
939
merger.merge_type = Merge3Merger
941
merger.merge_type = merge_type
942
merger.set_interesting_files(None)
943
merger.show_base = False
944
merger.reprocess = False
945
conflicts = merger.do_merge()
1103
1098
tree_transport = self.bzrdir.root_transport.clone(sub_path)
1104
1099
if tree_transport.base != branch_transport.base:
1105
1100
tree_bzrdir = format.initialize_on_transport(tree_transport)
1106
branch.BranchReferenceFormat().initialize(tree_bzrdir,
1107
target_branch=new_branch)
1101
branch.BranchReferenceFormat().initialize(tree_bzrdir, new_branch)
1109
1103
tree_bzrdir = branch_bzrdir
1110
1104
wt = tree_bzrdir.create_workingtree(_mod_revision.NULL_REVISION)
1148
1142
This does not include files that have been deleted in this
1149
1143
tree. Skips the control directory.
1151
:param include_root: if True, return an entry for the root
1145
:param include_root: if True, do not return an entry for the root
1152
1146
:param from_dir: start from this directory or None for the root
1153
1147
:param recursive: whether to recurse into subdirectories or not
1608
1602
@needs_write_lock
1609
1603
def pull(self, source, overwrite=False, stop_revision=None,
1610
1604
change_reporter=None, possible_transports=None, local=False):
1605
top_pb = ui.ui_factory.nested_progress_bar()
1611
1606
source.lock_read()
1608
pp = ProgressPhase("Pull phase", 2, top_pb)
1613
1610
old_revision_info = self.branch.last_revision_info()
1614
1611
basis_tree = self.basis_tree()
1615
1612
count = self.branch.pull(source, overwrite, stop_revision,
1626
1625
new_basis_tree,
1628
1627
this_tree=self,
1630
1629
change_reporter=change_reporter)
1631
basis_root_id = basis_tree.get_root_id()
1632
new_root_id = new_basis_tree.get_root_id()
1633
if basis_root_id != new_root_id:
1634
self.set_root_id(new_root_id)
1630
if (basis_tree.inventory.root is None and
1631
new_basis_tree.inventory.root is not None):
1632
self.set_root_id(new_basis_tree.get_root_id())
1636
1635
basis_tree.unlock()
1637
1636
# TODO - dedup parents list with things merged by pull ?
1638
1637
# reuse the revisiontree we merged against to set the new
1741
1741
r"""Check whether the filename matches an ignore pattern.
1743
1743
Patterns containing '/' or '\' need to match the whole path;
1744
others match against only the last component. Patterns starting
1745
with '!' are ignore exceptions. Exceptions take precedence
1746
over regular patterns and cause the filename to not be ignored.
1744
others match against only the last component.
1748
1746
If the file is ignored, returns the pattern which caused it to
1749
1747
be ignored, otherwise None. So this can simply be used as a
1750
1748
boolean if desired."""
1751
1749
if getattr(self, '_ignoreglobster', None) is None:
1752
self._ignoreglobster = globbing.ExceptionGlobster(self.get_ignore_list())
1750
self._ignoreglobster = globbing.Globster(self.get_ignore_list())
1753
1751
return self._ignoreglobster.match(filename)
1755
1753
def kind(self, file_id):
1805
1803
raise errors.ObjectNotLocked(self)
1807
1805
def lock_read(self):
1808
"""Lock the tree for reading.
1810
This also locks the branch, and can be unlocked via self.unlock().
1812
:return: A bzrlib.lock.LogicalLockResult.
1806
"""See Branch.lock_read, and WorkingTree.unlock."""
1814
1807
if not self.is_locked():
1815
1808
self._reset_data()
1816
1809
self.branch.lock_read()
1818
self._control_files.lock_read()
1819
return LogicalLockResult(self.unlock)
1811
return self._control_files.lock_read()
1821
1813
self.branch.unlock()
1824
1816
def lock_tree_write(self):
1825
"""See MutableTree.lock_tree_write, and WorkingTree.unlock.
1827
:return: A bzrlib.lock.LogicalLockResult.
1817
"""See MutableTree.lock_tree_write, and WorkingTree.unlock."""
1829
1818
if not self.is_locked():
1830
1819
self._reset_data()
1831
1820
self.branch.lock_read()
1833
self._control_files.lock_write()
1834
return LogicalLockResult(self.unlock)
1822
return self._control_files.lock_write()
1836
1824
self.branch.unlock()
1839
1827
def lock_write(self):
1840
"""See MutableTree.lock_write, and WorkingTree.unlock.
1842
:return: A bzrlib.lock.LogicalLockResult.
1828
"""See MutableTree.lock_write, and WorkingTree.unlock."""
1844
1829
if not self.is_locked():
1845
1830
self._reset_data()
1846
1831
self.branch.lock_write()
1848
self._control_files.lock_write()
1849
return LogicalLockResult(self.unlock)
1833
return self._control_files.lock_write()
1851
1835
self.branch.unlock()
1917
1901
# revision_id is set. We must check for this full string, because a
1918
1902
# root node id can legitimately look like 'revision_id' but cannot
1919
1903
# contain a '"'.
1920
xml = self.branch.repository._get_inventory_xml(new_revision)
1904
xml = self.branch.repository.get_inventory_xml(new_revision)
1921
1905
firstline = xml.split('\n', 1)[0]
1922
1906
if (not 'revision_id="' in firstline or
1923
1907
'format="7"' not in firstline):
1977
1961
def recurse_directory_to_add_files(directory):
1978
1962
# Recurse directory and add all files
1979
1963
# so we can check if they have changed.
1980
for parent_info, file_infos in self.walkdirs(directory):
1964
for parent_info, file_infos in\
1965
self.walkdirs(directory):
1981
1966
for relpath, basename, kind, lstat, fileid, kind in file_infos:
1982
1967
# Is it versioned or ignored?
1983
1968
if self.path2id(relpath) or self.is_ignored(relpath):
2018
2003
# ... but not ignored
2019
2004
has_changed_files = True
2021
elif (content_change and (kind[1] is not None) and
2022
osutils.is_inside_any(files, path[1])):
2023
# Versioned and changed, but not deleted, and still
2024
# in one of the dirs to be deleted.
2006
elif content_change and (kind[1] is not None):
2007
# Versioned and changed, but not deleted
2025
2008
has_changed_files = True
2209
2192
raise NotImplementedError(self.unlock)
2213
def update(self, change_reporter=None, possible_transports=None,
2214
revision=None, old_tip=_marker):
2194
def update(self, change_reporter=None, possible_transports=None):
2215
2195
"""Update a working tree along its branch.
2217
2197
This will update the branch if its bound too, which means we have
2235
2215
- Merge current state -> basis tree of the master w.r.t. the old tree
2237
2217
- Do a 'normal' merge of the old branch basis if it is relevant.
2239
:param revision: The target revision to update to. Must be in the
2241
:param old_tip: If branch.update() has already been run, the value it
2242
returned (old tip of the branch or None). _marker is used
2245
2219
if self.branch.get_bound_location() is not None:
2246
2220
self.lock_write()
2247
update_branch = (old_tip is self._marker)
2221
update_branch = True
2249
2223
self.lock_tree_write()
2250
2224
update_branch = False
2252
2226
if update_branch:
2253
2227
old_tip = self.branch.update(possible_transports)
2255
if old_tip is self._marker:
2257
return self._update_tree(old_tip, change_reporter, revision)
2230
return self._update_tree(old_tip, change_reporter)
2261
2234
@needs_tree_write_lock
2262
def _update_tree(self, old_tip=None, change_reporter=None, revision=None):
2235
def _update_tree(self, old_tip=None, change_reporter=None):
2263
2236
"""Update a tree to the master branch.
2265
2238
:param old_tip: if supplied, the previous tip revision the branch,
2275
2248
# We MUST save it even if an error occurs, because otherwise the users
2276
2249
# local work is unreferenced and will appear to have been lost.
2280
2253
last_rev = self.get_parent_ids()[0]
2281
2254
except IndexError:
2282
2255
last_rev = _mod_revision.NULL_REVISION
2283
if revision is None:
2284
revision = self.branch.last_revision()
2286
old_tip = old_tip or _mod_revision.NULL_REVISION
2288
if not _mod_revision.is_null(old_tip) and old_tip != last_rev:
2289
# the branch we are bound to was updated
2290
# merge those changes in first
2291
base_tree = self.basis_tree()
2292
other_tree = self.branch.repository.revision_tree(old_tip)
2293
nb_conflicts = merge.merge_inner(self.branch, other_tree,
2294
base_tree, this_tree=self,
2295
change_reporter=change_reporter)
2297
self.add_parent_tree((old_tip, other_tree))
2298
trace.note('Rerun update after fixing the conflicts.')
2301
if last_rev != _mod_revision.ensure_null(revision):
2302
# the working tree is up to date with the branch
2303
# we can merge the specified revision from master
2304
to_tree = self.branch.repository.revision_tree(revision)
2305
to_root_id = to_tree.get_root_id()
2256
if last_rev != _mod_revision.ensure_null(self.branch.last_revision()):
2257
# merge tree state up to new branch tip.
2307
2258
basis = self.basis_tree()
2308
2259
basis.lock_read()
2310
if (basis.inventory.root is None
2311
or basis.inventory.root.file_id != to_root_id):
2312
self.set_root_id(to_root_id)
2261
to_tree = self.branch.basis_tree()
2262
if basis.inventory.root is None:
2263
self.set_root_id(to_tree.get_root_id())
2265
result += merge.merge_inner(
2270
change_reporter=change_reporter)
2317
# determine the branch point
2318
graph = self.branch.repository.get_graph()
2319
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2321
base_tree = self.branch.repository.revision_tree(base_rev_id)
2323
nb_conflicts = merge.merge_inner(self.branch, to_tree, base_tree,
2325
change_reporter=change_reporter)
2326
self.set_last_revision(revision)
2327
2273
# TODO - dedup parents list with things merged by pull ?
2328
2274
# reuse the tree we've updated to to set the basis:
2329
parent_trees = [(revision, to_tree)]
2275
parent_trees = [(self.branch.last_revision(), to_tree)]
2330
2276
merges = self.get_parent_ids()[1:]
2331
2277
# Ideally we ask the tree for the trees here, that way the working
2332
2278
# tree can decide whether to give us the entire tree or give us a
2336
2282
for parent in merges:
2337
2283
parent_trees.append(
2338
2284
(parent, self.branch.repository.revision_tree(parent)))
2339
if not _mod_revision.is_null(old_tip):
2285
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2340
2286
parent_trees.append(
2341
2287
(old_tip, self.branch.repository.revision_tree(old_tip)))
2342
2288
self.set_parent_trees(parent_trees)
2343
2289
last_rev = parent_trees[0][0]
2291
# the working tree had the same last-revision as the master
2292
# branch did. We may still have pivot local work from the local
2293
# branch into old_tip:
2294
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2295
self.add_parent_tree_id(old_tip)
2296
if (old_tip is not None and not _mod_revision.is_null(old_tip)
2297
and old_tip != last_rev):
2298
# our last revision was not the prior branch last revision
2299
# and we have converted that last revision to a pending merge.
2300
# base is somewhere between the branch tip now
2301
# and the now pending merge
2303
# Since we just modified the working tree and inventory, flush out
2304
# the current state, before we modify it again.
2305
# TODO: jam 20070214 WorkingTree3 doesn't require this, dirstate
2306
# requires it only because TreeTransform directly munges the
2307
# inventory and calls tree._write_inventory(). Ultimately we
2308
# should be able to remove this extra flush.
2310
graph = self.branch.repository.get_graph()
2311
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2313
base_tree = self.branch.repository.revision_tree(base_rev_id)
2314
other_tree = self.branch.repository.revision_tree(old_tip)
2315
result += merge.merge_inner(
2320
change_reporter=change_reporter)
2346
2323
def _write_hashcache_if_dirty(self):
2347
2324
"""Write out the hashcache if it is dirty."""