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)
39
33
from cStringIO import StringIO
102
95
from bzrlib.filters import filtered_input_file
103
96
from bzrlib.trace import mutter, note
104
97
from bzrlib.transport.local import LocalTransport
105
from bzrlib.progress import DummyProgress, ProgressPhase
106
98
from bzrlib.revision import CURRENT_REVISION
107
99
from bzrlib.rio import RioReader, rio_file, Stanza
108
100
from bzrlib.symbol_versioning import (
281
285
self._control_files.break_lock()
282
286
self.branch.break_lock()
288
def _get_check_refs(self):
289
"""Return the references needed to perform a check of this tree.
291
The default implementation returns no refs, and is only suitable for
292
trees that have no local caching and can commit on ghosts at any time.
294
:seealso: bzrlib.check for details about check_refs.
284
298
def requires_rich_root(self):
285
299
return self._format.requires_rich_root
625
641
def _is_executable_from_path_and_stat_from_basis(self, path, stat_result):
626
642
file_id = self.path2id(path)
644
# For unversioned files on win32, we just assume they are not
627
647
return self._inventory[file_id].executable
629
649
def _is_executable_from_path_and_stat_from_stat(self, path, stat_result):
740
760
kind = _mapper(stat_result.st_mode)
741
761
if kind == 'file':
742
size = stat_result.st_size
743
# try for a stat cache lookup
744
executable = self._is_executable_from_path_and_stat(path, stat_result)
745
return (kind, size, executable, self._sha_from_stat(
762
return self._file_content_summary(path, stat_result)
747
763
elif kind == 'directory':
748
764
# perhaps it looks like a plain directory, but it's really a
757
773
return (kind, None, None, None)
775
def _file_content_summary(self, path, stat_result):
776
size = stat_result.st_size
777
executable = self._is_executable_from_path_and_stat(path, stat_result)
778
# try for a stat cache lookup
779
return ('file', size, executable, self._sha_from_stat(
759
782
def _check_parents_for_ghosts(self, revision_ids, allow_leftmost_as_ghost):
760
783
"""Common ghost checking functionality from set_parent_*.
882
905
@needs_write_lock # because merge pulls data into the branch.
883
906
def merge_from_branch(self, branch, to_revision=None, from_revision=None,
907
merge_type=None, force=False):
885
908
"""Merge from a branch into this working tree.
887
910
:param branch: The branch to merge from.
891
914
branch.last_revision().
893
916
from bzrlib.merge import Merger, Merge3Merger
894
pb = ui.ui_factory.nested_progress_bar()
896
merger = Merger(self.branch, this_tree=self, pb=pb)
897
merger.pp = ProgressPhase("Merge phase", 5, pb)
898
merger.pp.next_phase()
899
# check that there are no
901
merger.check_basis(check_clean=True, require_commits=False)
902
if to_revision is None:
903
to_revision = _mod_revision.ensure_null(branch.last_revision())
904
merger.other_rev_id = to_revision
905
if _mod_revision.is_null(merger.other_rev_id):
906
raise errors.NoCommits(branch)
907
self.branch.fetch(branch, last_revision=merger.other_rev_id)
908
merger.other_basis = merger.other_rev_id
909
merger.other_tree = self.branch.repository.revision_tree(
911
merger.other_branch = branch
912
merger.pp.next_phase()
913
if from_revision is None:
916
merger.set_base_revision(from_revision, branch)
917
if merger.base_rev_id == merger.other_rev_id:
918
raise errors.PointlessMerge
919
merger.backup_files = False
920
if merge_type is None:
921
merger.merge_type = Merge3Merger
923
merger.merge_type = merge_type
924
merger.set_interesting_files(None)
925
merger.show_base = False
926
merger.reprocess = False
927
conflicts = merger.do_merge()
917
merger = Merger(self.branch, this_tree=self)
918
# check that there are no local alterations
919
if not force and self.has_changes():
920
raise errors.UncommittedChanges(self)
921
if to_revision is None:
922
to_revision = _mod_revision.ensure_null(branch.last_revision())
923
merger.other_rev_id = to_revision
924
if _mod_revision.is_null(merger.other_rev_id):
925
raise errors.NoCommits(branch)
926
self.branch.fetch(branch, last_revision=merger.other_rev_id)
927
merger.other_basis = merger.other_rev_id
928
merger.other_tree = self.branch.repository.revision_tree(
930
merger.other_branch = branch
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()
1080
1096
tree_transport = self.bzrdir.root_transport.clone(sub_path)
1081
1097
if tree_transport.base != branch_transport.base:
1082
1098
tree_bzrdir = format.initialize_on_transport(tree_transport)
1083
branch.BranchReferenceFormat().initialize(tree_bzrdir, new_branch)
1099
branch.BranchReferenceFormat().initialize(tree_bzrdir,
1100
target_branch=new_branch)
1085
1102
tree_bzrdir = branch_bzrdir
1086
1103
wt = tree_bzrdir.create_workingtree(_mod_revision.NULL_REVISION)
1124
1141
This does not include files that have been deleted in this
1125
1142
tree. Skips the control directory.
1127
:param include_root: if True, do not return an entry for the root
1144
:param include_root: if True, return an entry for the root
1128
1145
:param from_dir: start from this directory or None for the root
1129
1146
:param recursive: whether to recurse into subdirectories or not
1476
1493
from_tail = splitpath(from_rel)[-1]
1477
1494
from_id = inv.path2id(from_rel)
1478
1495
if from_id is None:
1479
raise errors.BzrRenameFailedError(from_rel,to_rel,
1480
errors.NotVersionedError(path=str(from_rel)))
1481
from_entry = inv[from_id]
1496
# if file is missing in the inventory maybe it's in the basis_tree
1497
basis_tree = self.branch.basis_tree()
1498
from_id = basis_tree.path2id(from_rel)
1500
raise errors.BzrRenameFailedError(from_rel,to_rel,
1501
errors.NotVersionedError(path=str(from_rel)))
1502
# put entry back in the inventory so we can rename it
1503
from_entry = basis_tree.inventory[from_id].copy()
1506
from_entry = inv[from_id]
1482
1507
from_parent_id = from_entry.parent_id
1483
1508
to_dir, to_tail = os.path.split(to_rel)
1484
1509
to_dir_id = inv.path2id(to_dir)
1576
1601
@needs_write_lock
1577
1602
def pull(self, source, overwrite=False, stop_revision=None,
1578
1603
change_reporter=None, possible_transports=None, local=False):
1579
top_pb = ui.ui_factory.nested_progress_bar()
1580
1604
source.lock_read()
1582
pp = ProgressPhase("Pull phase", 2, top_pb)
1584
1606
old_revision_info = self.branch.last_revision_info()
1585
1607
basis_tree = self.basis_tree()
1586
1608
count = self.branch.pull(source, overwrite, stop_revision,
1599
1619
new_basis_tree,
1601
1621
this_tree=self,
1603
1623
change_reporter=change_reporter)
1604
if (basis_tree.inventory.root is None and
1605
new_basis_tree.inventory.root is not None):
1606
self.set_root_id(new_basis_tree.get_root_id())
1624
basis_root_id = basis_tree.get_root_id()
1625
new_root_id = new_basis_tree.get_root_id()
1626
if basis_root_id != new_root_id:
1627
self.set_root_id(new_root_id)
1609
1629
basis_tree.unlock()
1610
1630
# TODO - dedup parents list with things merged by pull ?
1611
1631
# reuse the revisiontree we merged against to set the new
1715
1734
r"""Check whether the filename matches an ignore pattern.
1717
1736
Patterns containing '/' or '\' need to match the whole path;
1718
others match against only the last component.
1737
others match against only the last component. Patterns starting
1738
with '!' are ignore exceptions. Exceptions take precedence
1739
over regular patterns and cause the filename to not be ignored.
1720
1741
If the file is ignored, returns the pattern which caused it to
1721
1742
be ignored, otherwise None. So this can simply be used as a
1722
1743
boolean if desired."""
1723
1744
if getattr(self, '_ignoreglobster', None) is None:
1724
self._ignoreglobster = globbing.Globster(self.get_ignore_list())
1745
self._ignoreglobster = globbing.ExceptionGlobster(self.get_ignore_list())
1725
1746
return self._ignoreglobster.match(filename)
1727
1748
def kind(self, file_id):
1871
1896
# revision_id is set. We must check for this full string, because a
1872
1897
# root node id can legitimately look like 'revision_id' but cannot
1873
1898
# contain a '"'.
1874
xml = self.branch.repository.get_inventory_xml(new_revision)
1899
xml = self.branch.repository._get_inventory_xml(new_revision)
1875
1900
firstline = xml.split('\n', 1)[0]
1876
1901
if (not 'revision_id="' in firstline or
1877
1902
'format="7"' not in firstline):
1878
inv = self.branch.repository.deserialise_inventory(
1903
inv = self.branch.repository._serializer.read_inventory_from_string(
1880
1905
xml = self._create_basis_xml_from_inventory(new_revision, inv)
1881
1906
self._write_basis_inventory(xml)
1882
1907
except (errors.NoSuchRevision, errors.RevisionNotPresent):
1922
1951
new_files=set()
1923
1952
unknown_nested_files=set()
1954
to_file = sys.stdout
1925
1956
def recurse_directory_to_add_files(directory):
1926
1957
# Recurse directory and add all files
1927
1958
# so we can check if they have changed.
1928
for parent_info, file_infos in\
1929
self.walkdirs(directory):
1959
for parent_info, file_infos in self.walkdirs(directory):
1930
1960
for relpath, basename, kind, lstat, fileid, kind in file_infos:
1931
1961
# Is it versioned or ignored?
1932
1962
if self.path2id(relpath) or self.is_ignored(relpath):
1967
1997
# ... but not ignored
1968
1998
has_changed_files = True
1970
elif content_change and (kind[1] is not None):
1971
# Versioned and changed, but not deleted
2000
elif (content_change and (kind[1] is not None) and
2001
osutils.is_inside_any(files, path[1])):
2002
# Versioned and changed, but not deleted, and still
2003
# in one of the dirs to be deleted.
1972
2004
has_changed_files = True
1996
2028
new_status = 'I'
1998
2030
new_status = '?'
1999
textui.show_status(new_status, self.kind(fid), f,
2031
# XXX: Really should be a more abstract reporter interface
2032
kind_ch = osutils.kind_marker(self.kind(fid))
2033
to_file.write(new_status + ' ' + f + kind_ch + '\n')
2001
2034
# Unversion file
2002
2035
inv_delta.append((f, None, fid, None))
2003
2036
message = "removed %s" % (f,)
2155
2188
raise NotImplementedError(self.unlock)
2157
def update(self, change_reporter=None, possible_transports=None):
2192
def update(self, change_reporter=None, possible_transports=None,
2193
revision=None, old_tip=_marker):
2158
2194
"""Update a working tree along its branch.
2160
2196
This will update the branch if its bound too, which means we have
2178
2214
- Merge current state -> basis tree of the master w.r.t. the old tree
2180
2216
- Do a 'normal' merge of the old branch basis if it is relevant.
2218
:param revision: The target revision to update to. Must be in the
2220
:param old_tip: If branch.update() has already been run, the value it
2221
returned (old tip of the branch or None). _marker is used
2182
2224
if self.branch.get_bound_location() is not None:
2183
2225
self.lock_write()
2184
update_branch = True
2226
update_branch = (old_tip is self._marker)
2186
2228
self.lock_tree_write()
2187
2229
update_branch = False
2189
2231
if update_branch:
2190
2232
old_tip = self.branch.update(possible_transports)
2193
return self._update_tree(old_tip, change_reporter)
2234
if old_tip is self._marker:
2236
return self._update_tree(old_tip, change_reporter, revision)
2197
2240
@needs_tree_write_lock
2198
def _update_tree(self, old_tip=None, change_reporter=None):
2241
def _update_tree(self, old_tip=None, change_reporter=None, revision=None):
2199
2242
"""Update a tree to the master branch.
2201
2244
:param old_tip: if supplied, the previous tip revision the branch,
2211
2254
# We MUST save it even if an error occurs, because otherwise the users
2212
2255
# local work is unreferenced and will appear to have been lost.
2216
2259
last_rev = self.get_parent_ids()[0]
2217
2260
except IndexError:
2218
2261
last_rev = _mod_revision.NULL_REVISION
2219
if last_rev != _mod_revision.ensure_null(self.branch.last_revision()):
2220
# merge tree state up to new branch tip.
2262
if revision is None:
2263
revision = self.branch.last_revision()
2265
old_tip = old_tip or _mod_revision.NULL_REVISION
2267
if not _mod_revision.is_null(old_tip) and old_tip != last_rev:
2268
# the branch we are bound to was updated
2269
# merge those changes in first
2270
base_tree = self.basis_tree()
2271
other_tree = self.branch.repository.revision_tree(old_tip)
2272
nb_conflicts = merge.merge_inner(self.branch, other_tree,
2273
base_tree, this_tree=self,
2274
change_reporter=change_reporter)
2276
self.add_parent_tree((old_tip, other_tree))
2277
trace.note('Rerun update after fixing the conflicts.')
2280
if last_rev != _mod_revision.ensure_null(revision):
2281
# the working tree is up to date with the branch
2282
# we can merge the specified revision from master
2283
to_tree = self.branch.repository.revision_tree(revision)
2284
to_root_id = to_tree.get_root_id()
2221
2286
basis = self.basis_tree()
2222
2287
basis.lock_read()
2224
to_tree = self.branch.basis_tree()
2225
if basis.inventory.root is None:
2226
self.set_root_id(to_tree.get_root_id())
2289
if (basis.inventory.root is None
2290
or basis.inventory.root.file_id != to_root_id):
2291
self.set_root_id(to_root_id)
2228
result += merge.merge_inner(
2233
change_reporter=change_reporter)
2296
# determine the branch point
2297
graph = self.branch.repository.get_graph()
2298
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2300
base_tree = self.branch.repository.revision_tree(base_rev_id)
2302
nb_conflicts = merge.merge_inner(self.branch, to_tree, base_tree,
2304
change_reporter=change_reporter)
2305
self.set_last_revision(revision)
2236
2306
# TODO - dedup parents list with things merged by pull ?
2237
2307
# reuse the tree we've updated to to set the basis:
2238
parent_trees = [(self.branch.last_revision(), to_tree)]
2308
parent_trees = [(revision, to_tree)]
2239
2309
merges = self.get_parent_ids()[1:]
2240
2310
# Ideally we ask the tree for the trees here, that way the working
2241
2311
# tree can decide whether to give us the entire tree or give us a
2245
2315
for parent in merges:
2246
2316
parent_trees.append(
2247
2317
(parent, self.branch.repository.revision_tree(parent)))
2248
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2318
if not _mod_revision.is_null(old_tip):
2249
2319
parent_trees.append(
2250
2320
(old_tip, self.branch.repository.revision_tree(old_tip)))
2251
2321
self.set_parent_trees(parent_trees)
2252
2322
last_rev = parent_trees[0][0]
2254
# the working tree had the same last-revision as the master
2255
# branch did. We may still have pivot local work from the local
2256
# branch into old_tip:
2257
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2258
self.add_parent_tree_id(old_tip)
2259
if (old_tip is not None and not _mod_revision.is_null(old_tip)
2260
and old_tip != last_rev):
2261
# our last revision was not the prior branch last revision
2262
# and we have converted that last revision to a pending merge.
2263
# base is somewhere between the branch tip now
2264
# and the now pending merge
2266
# Since we just modified the working tree and inventory, flush out
2267
# the current state, before we modify it again.
2268
# TODO: jam 20070214 WorkingTree3 doesn't require this, dirstate
2269
# requires it only because TreeTransform directly munges the
2270
# inventory and calls tree._write_inventory(). Ultimately we
2271
# should be able to remove this extra flush.
2273
graph = self.branch.repository.get_graph()
2274
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2276
base_tree = self.branch.repository.revision_tree(base_rev_id)
2277
other_tree = self.branch.repository.revision_tree(old_tip)
2278
result += merge.merge_inner(
2283
change_reporter=change_reporter)
2286
2325
def _write_hashcache_if_dirty(self):
2287
2326
"""Write out the hashcache if it is dirty."""
2528
2567
return un_resolved, resolved
2530
2569
@needs_read_lock
2570
def _check(self, references):
2571
"""Check the tree for consistency.
2573
:param references: A dict with keys matching the items returned by
2574
self._get_check_refs(), and values from looking those keys up in
2532
2577
tree_basis = self.basis_tree()
2533
2578
tree_basis.lock_read()
2535
repo_basis = self.branch.repository.revision_tree(
2536
self.last_revision())
2580
repo_basis = references[('trees', self.last_revision())]
2537
2581
if len(list(repo_basis.iter_changes(tree_basis))) > 0:
2538
2582
raise errors.BzrCheckError(
2539
2583
"Mismatched basis inventory content.")
2585
2628
if self._inventory is None:
2586
2629
self.read_working_inventory()
2631
def _get_check_refs(self):
2632
"""Return the references needed to perform a check of this tree."""
2633
return [('trees', self.last_revision())]
2588
2635
def lock_tree_write(self):
2589
2636
"""See WorkingTree.lock_tree_write().
2647
2694
mode=self.bzrdir._get_file_mode())
2697
def _get_check_refs(self):
2698
"""Return the references needed to perform a check of this tree."""
2699
return [('trees', self.last_revision())]
2650
2701
@needs_tree_write_lock
2651
2702
def set_conflicts(self, conflicts):
2652
2703
self._put_rio('conflicts', conflicts.to_stanzas(),
2729
2780
"""Return the format for the working tree object in a_bzrdir."""
2731
2782
transport = a_bzrdir.get_workingtree_transport(None)
2732
format_string = transport.get("format").read()
2783
format_string = transport.get_bytes("format")
2733
2784
return klass._formats[format_string]
2734
2785
except errors.NoSuchFile:
2735
2786
raise errors.NoWorkingTree(base=transport.base)
2999
3050
return self.get_format_string()
3002
__default_format = WorkingTreeFormat4()
3053
__default_format = WorkingTreeFormat6()
3003
3054
WorkingTreeFormat.register_format(__default_format)
3004
WorkingTreeFormat.register_format(WorkingTreeFormat6())
3005
3055
WorkingTreeFormat.register_format(WorkingTreeFormat5())
3056
WorkingTreeFormat.register_format(WorkingTreeFormat4())
3006
3057
WorkingTreeFormat.register_format(WorkingTreeFormat3())
3007
3058
WorkingTreeFormat.set_default_format(__default_format)
3008
3059
# formats which have no format string are not discoverable